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 General Public License as published by
    the Free Software Foundation, either version 3 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 General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with Classified Ads.  If not, see <http://www.gnu.org/licenses/>.
*/

#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