mailboxServer.h

Go to the documentation of this file.

/* Copyright 2014 - 2015 CyberTech Labs Ltd.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License. */

#pragma once

#include <QtCore/QObject>
#include <QtCore/QMultiHash>
#include <QtCore/QReadWriteLock>
#include <QtCore/QQueue>
#include <QtNetwork/QHostAddress>

#include "trikServer.h"

namespace trikNetwork {

class MailboxServer : public TrikServer
{
    Q_OBJECT

public:
    MailboxServer(int port);

    bool isConnected();

    int hullNumber() const;

    QHostAddress serverIp();

    QHostAddress myIp() const;

    void renewIp();

    Q_INVOKABLE void start();

    Q_INVOKABLE void setHullNumber(int hullNumber);

    Q_INVOKABLE void connect(const QString &ip, int port);

    Q_INVOKABLE void connect(const QString &ip);

    Q_INVOKABLE void send(int hullNumber, const QString &message);

    Q_INVOKABLE void send(const QString &message);

    Q_INVOKABLE bool hasMessages();

    Q_INVOKABLE QString receive();

signals:
    void newMessage(int senderHullNumber, const QString &message);

private slots:
    void onNewConnection(const QHostAddress &ip, int clientPort, int serverPort, int hullNumber);
    void onConnectionInfo(const QHostAddress &ip, int port, int hullNumber);
    void onNewData(const QHostAddress &ip, int port, const QByteArray &data);

private:
    Connection *connect(const QHostAddress &ip, int port);

    Connection *connectionFactory();

    void connectConnection(Connection * connection);

    static QHostAddress determineMyIp();

    Connection *prepareConnection(const QHostAddress &ip);

    void loadSettings();
    void saveSettings();

    void forEveryConnection(std::function<void(Connection *)> method, int hullNumber = -1);

    int mHullNumber;
    QHostAddress mMyIp;
    QHostAddress mSavedIp;
    const int mMyPort;
    QHostAddress mServerIp;
    int mServerPort{};

    struct Endpoint {
        QHostAddress ip;
        int port;
    };

    inline uint qHash(const Endpoint &key)
    {
        return ::qHash(key.ip.toString()) ^ key.port;
    }

    friend bool operator ==(const MailboxServer::Endpoint &left, const MailboxServer::Endpoint &right);
    friend inline QDebug operator <<(QDebug dbg, const Endpoint &endpoint);

    QMultiHash<int, Endpoint> mKnownRobots;

    QQueue<QByteArray> mMessagesQueue;
    QReadWriteLock mMessagesQueueLock;
    QReadWriteLock mKnownRobotsLock;

    QReadWriteLock mAuxiliaryInformationLock;
};

inline bool operator ==(const MailboxServer::Endpoint &left, const MailboxServer::Endpoint &right)
{
    return left.ip == right.ip && left.port == right.port;
}

inline QDebug operator <<(QDebug dbg, const MailboxServer::Endpoint &endpoint)
{
    dbg.nospace() << endpoint.ip << ":" << endpoint.port;
    return dbg.space();
}

}