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 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 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<MNodeModelProtocolInterface::HostConnectQueueItem> iAddressesInOrderToConnect ;
    QUdpSocket* iBroadCastSocket ;
    time_t iTimeOfLastBroadCast ;
    time_t iTimeOfLastMsgPoll ;
    quint32 iTimeOfLastMsgPollForProfile ;
    QList<QHostAddress> iAddressBlacklist ;
    Hash iProfileToPollPrivateMessages ;
    QList<Hash> iPrivateMessagePollWishList ;
} ;
#endif