dbretrievalengine.h

Go to the documentation of this file.

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

  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 DB_RECORD_RETRIEVAL_ENG_H
#define DB_RECORD_RETRIEVAL_ENG_H

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

class DbRecordRetrievalEngine : public QTimer {
    Q_OBJECT
public:
    DbRecordRetrievalEngine(Controller* aController,
                            Model& aModel ) ;
    ~DbRecordRetrievalEngine() ;
    void startRetrieving( CaDbRecord::SearchTerms aSearchTerms ) ;

public slots:
    void stopRetrieving( ) ;

    void notifyOfContentReceived(const Hash& aHashOfContent,
                                 const ProtocolItemType aTypeOfReceivedContent );

    void nodeConnectionAttemptStatus(Connection::ConnectionState aStatus,
                                     const Hash aHashOfAttemptedNode );
    void run();
private: // methods
    void sendQueryToNode(const CaDbRecord::SearchTerms& aSearchTerms, 
                         const Hash& aNodeFingerPrint) ; 
private: // data
    Controller* iController ; 
    Model &iModel ; 
    bool iNowRunning ; 
    QList<Hash> iNodeCandidatesToTryQuery ;
    QList<Hash> iNodesSuccessfullyConnected ;
    QList<Hash> iNodesFailurefullyConnected ;
    typedef struct DlQueueItemStruct {
        CaDbRecord::SearchTerms iTerms ; 
        QList<Hash> iListOfNodes ; 
        QDateTime iTimeOfLastRefresh ; 
    } DlQueueItem ; 
    QList<DlQueueItem> iSearchTerms ;
} ;
#endif