netrequestexecutor.h

Go to the documentation of this file.

/*    -*-C++-*- -*-coding: utf-8-unix;-*-
    Classified Ads is Copyright (c) Antti Järvinen 2013.

    This file is part of Classified Ads.

    Classified Ads is free software; you can redistribute it and/or
    modify it under the terms of the GNU Lesser General Public
    License as published by the Free Software Foundation; either
    version 2.1 of the License, or (at your option) any later version.

    Classified Ads is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public
    License along with Classified Ads; if not, write to the Free Software
    Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/

#ifndef CLASSIFIED_NETREQEXEC_H
#define CLASSIFIED_NETREQEXEC_H

#include <QTimer>
#include "../net/protocol.h"
#include <time.h> // for time_t
#include "../net/connection.h"

class MController ;
class Model ;
extern Hash KNullHash ;

class NetworkRequestExecutor : public QTimer {
    Q_OBJECT
public:
    enum NetworkRequestState {
        NewRequest, 
        Processing, 
        NodeIsInWishList, 
        RequestBeingSentAround, 
        ReadyToSend 
    };
    struct NetworkRequestQueueItem {
        ProtocolItemType iRequestType ;
        Hash iDestinationNode ;
        Hash iRequestedItem ;
        quint32 iTimeStampOfItem ;
        quint32 iTimeStampOfLastActivity ;
        NetworkRequestState iState ;
        int iMaxNumberOfItems ;
        QList<quint32> iBangPath ;
        QList<Hash> iWishListForNodesAround ;
    } ;
    NetworkRequestExecutor(MController *aController,
                           Model& aModel) ;
    ~NetworkRequestExecutor() ;
private:
    void processNodeGreeting(NetworkRequestQueueItem& aEntry) ;
    void processRequestForNodesAroundHash(NetworkRequestQueueItem& entry) ;
    void processRequestForContentPublish(NetworkRequestQueueItem& entry) ;
    void processRequestForPrivateMessagePublish(NetworkRequestQueueItem& aEntry) ;
    void processRequestForBinaryBlob(NetworkRequestQueueItem& aEntry) ;
    void processRequestForClassifiedAd(NetworkRequestQueueItem& aEntry) ;
    void processRequestForProfilePoll(NetworkRequestQueueItem& aEntry) ;
    void processRequestForUserProfile(NetworkRequestQueueItem& aEntry) ;
    void processRequestForUserProfileComment(NetworkRequestQueueItem& aEntry) ;
    void doSendRequestToNode(NetworkRequestQueueItem& aEntry,
                             const Hash& aNodeToSend = KNullHash ) ;
    void sendRequestToNodesAroundHash(NetworkRequestQueueItem& aEntry,
                                      bool aUseContentHashNotDestination = false) ;

    void processBinaryBlob(NetworkRequestQueueItem& aEntry) ;
    void processPrivateMessage(NetworkRequestQueueItem& aEntry) ;
    void  processUserProfileCommentsForProfile(NetworkRequestQueueItem& entry) ;
    void processUserProfileComment(NetworkRequestQueueItem& aEntry) ;
    void processPrivateMessagesForProfile(NetworkRequestQueueItem& aEntry) ;
    void processUserProfile(NetworkRequestQueueItem& aEntry) ;

    void processClassifiedAd(NetworkRequestQueueItem& aEntry) ;

    void processAdsClassified(NetworkRequestQueueItem& aEntry) ;

public slots:
    void run() ;
    void nodeConnectionAttemptStatus(Connection::ConnectionState aStatus,
                                     const Hash aHashOfAttemptedNode );
private:
    MController *iController  ;
    Model& iModel ;
    bool iNowRunning ;
    time_t iLastTimeOfNodeConnectedNodeStatusUpdate ;
} ;
#endif