retrievalengine.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 RETRIEVAL_ENG_H
#define RETRIEVAL_ENG_H

#include <QHostAddress>
#include <QPair>
#include "connection.h" // for ConnectionObserver
#include "../controller.h"
#include "../datamodel/model.h"

class RetrievalEngine : public QTimer {
  Q_OBJECT
public:
  RetrievalEngine(Controller* aController,
          Model& aModel ) ;
  ~RetrievalEngine() ;
  void startRetrieving(  NetworkRequestExecutor::NetworkRequestQueueItem aObject,
             bool aIsPriorityWork) ; 
  void notifyOfContentReceived(const Hash& aHashOfContent,
                   const ProtocolItemType aTypeOfReceivdContent );
signals:
  void error(QTcpSocket::SocketError socketError);
  void notifyOfContentNotReceived(const Hash& aHashOfContent,
                  const ProtocolItemType aTypeOfNotReceivdContent );
public slots:
  void nodeConnectionAttemptStatus(Connection::ConnectionState aStatus,
                                   const Hash aHashOfAttemptedNode );
  void run();
private:
  void emptyNodeCandidateList() ; 
  void askConnectionsForNodesOnConnectList() ; 
  void sendQueryItemToAlreadyConnectedNodes() ; 
  void sendQueryToNode(const Hash& aNode) ; 
  void checkForSuccessfullyConnectedNodes() ; 
  void checkForUnSuccessfullyConnectedNodes() ; 
public:
  bool iNeedsToRun ;
private: // data
  Controller* iController ; 
  Model &iModel ; 
  NetworkRequestExecutor::NetworkRequestQueueItem iObjectBeingRetrieved ; 
  QList<Hash> iNodeCandidatesToTryQuery ; 
  QList<Hash> iNodesSuccessfullyConnected ; 
  QList<Hash> iNodesFailurefullyConnected ; 
  bool iNowRunning ;
  QList<NetworkRequestExecutor::NetworkRequestQueueItem> iDownloadQueue ; 
} ;
#endif