publishingengine.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 PUBLISHING_ENG_H
#define PUBLISHING_ENG_H

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

class PublishingEngine : public QTimer {
  Q_OBJECT
public:
  PublishingEngine(Controller* aController,
                   Model& aModel ) ;
  ~PublishingEngine() ;
signals:
  void error(QTcpSocket::SocketError socketError);
public slots:
  void nodeConnectionAttemptStatus(Connection::ConnectionState aStatus,
                                   const Hash aHashOfAttemptedNode );
  void run();
private:
  void emptyNodeCandidateList() ; 
  void askConnectionsForNodesOnPublishList() ; 
  enum StageOfPublish {
    InitialStage,
    AwaitingConnection 
  } ;
  void sendPublishItemToAlreadyConnectedNodes() ; 
  void publishToNode(const Hash& aNode) ; 
  void checkForSuccessfullyConnectedNodes() ; 
  void checkForUnSuccessfullyConnectedNodes() ; 
public:
  bool iNeedsToRun ;
private: // data
  Controller* iController ; 
  Model &iModel ; 
  PublishItem iWorkItem ; 
  QList<Node *> iNodeCandidatesToTryPush ; 
  QList<Hash> iNodesSuccessfullyConnected ; 
  QList<Hash> iNodesFailurefullyConnected ; 
  StageOfPublish iStageOfPublish ;
  bool iNowRunning ;
} ;
#endif