networkconnectorengine.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 NETWORK_CONNECTOR_ENG_H
#define NETWORK_CONNECTOR_ENG_H

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

class ProtocolMessageParser ;

class NetworkConnectorEngine : public QThread {
  Q_OBJECT
public:
  NetworkConnectorEngine(Controller *aController,
                         Model *aModel,
                         Connection::ConnectionObserver &aObserver) ;
  ~NetworkConnectorEngine() ;
  void run();
public slots:
  void threadIsDeleted() ;
  void blackListNetworkAddr(QHostAddress aAddr) ;
  void nodeConnectionAttemptStatus(Connection::ConnectionState aStatus,
                                   const Hash aHashOfAttemptedNode );
signals:
  void error(QTcpSocket::SocketError socketError);
private:
  void spawnNewConnection(const QHostAddress& aAddr,
                          const int aPort,
                          const Hash& aHashOfNodeToConnect) ;
  void updateListOfNodesToConnect() ;
  bool pruneConnectionProspectList(QList<Node *>* aListToPrune) const ;
  void sendBroadCast() ; 
  bool tryServeWishListItem() ; 
  void createConnectionsToNodesStoringPrivateMessages() ;
  void sendPrivateMessagesPoll(const Hash& aNodeFingerPrint) ;
private: // methods:
  bool performDNSLookup(QHostAddress* aAddressToBeSet,
            const QString& aFromDnsName,
            bool aDoWeHaveIpv6) ; 
public:
  bool iNeedsToRun ;
private: // data
  Controller *iController ;
  Model *iModel ;
  Connection::ConnectionObserver &iConnectionObserver ;
  QList<QPair<QHostAddress,int> > iAddressesInOrderToConnect ;
  QUdpSocket* iBroadCastSocket ; 
  time_t iTimeOfLastBroadCast ;
  time_t iTimeOfLastMsgPoll ; 
  quint32 iTimeOfLastMsgPollForProfile ;
  QList<QHostAddress> iAddressBlacklist ; 
  Hash iProfileToPollPrivateMessages ;
  QList<Hash> iPrivateMessagePollWishList ; 
} ;
#endif