ArnServer.hpp

Go to the documentation of this file.

// Copyright (C) 2010-2022 Michael Wiklund.
// All rights reserved.
// Contact: arnlib@wiklunden.se
//
// This file is part of the ArnLib - Active Registry Network.
// Parts of ArnLib depend on Qt and/or other libraries that have their own
// licenses. Usage of these other libraries is subject to their respective
// license agreements.
//
// GNU Lesser General Public License Usage
// This file may be used under the terms of the GNU Lesser General Public
// License version 2.1 as published by the Free Software Foundation and
// appearing in the file LICENSE_LGPL.txt included in the packaging of this
// file. In addition, as a special exception, you may use the rights described
// in the Nokia Qt LGPL Exception version 1.1, included in the file
// LGPL_EXCEPTION.txt in this package.
//
// GNU General Public License Usage
// Alternatively, this file may be used under the terms of the GNU General Public
// License version 3.0 as published by the Free Software Foundation and appearing
// in the file LICENSE_GPL.txt included in the packaging of this file.
//
// Other Usage
// Alternatively, this file may be used in accordance with the terms and conditions
// contained in a signed written agreement between you and Michael Wiklund.
//
// This program 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.
//

#ifndef ARNSERVER_HPP
#define ARNSERVER_HPP

#include "ArnLib_global.hpp"
#include "Arn.hpp"
#include "MQFlags.hpp"
#include "XStringMap.hpp"
#include <QObject>
#include <QHostAddress>
#include <QMap>
#include <QStringList>

class ArnServerPrivate;
class ArnSync;
class ArnSyncLogin;
class ArnItemNetEar;
class ArnServer;
class QTcpServer;
class QTcpSocket;


class ArnServerSession : public QObject
{
    Q_OBJECT
public:
    ArnServerSession( QTcpSocket* socket, ArnServer* arnServer);

    QTcpSocket*  socket()  const;
    Arn::XStringMap  remoteWhoIAm()  const;
    QString  loginUserName()  const;
    Arn::Allow  getAllow()  const;
    void  sendMessage( int type, const QByteArray& data = QByteArray());
    bool  getTraffic( quint64& in, quint64& out)  const;

signals:
    void  infoReceived( int type);
    void  loginCompleted();
    void  messageReceived( int type, const QByteArray& data);

private slots:
    void  shutdown();
    void  doDestroyArnTree( const QString& path, bool isGlobal);
    void  onCommandDelete( const QString& path);
    void  doSyncStateChanged( int state);

private:
    QTcpSocket*  _socket;
    ArnServer*  _arnServer;
    ArnSync*  _arnNetSync;
    ArnItemNetEar*  _arnNetEar;
};



class ARNLIBSHARED_EXPORT ArnServer : public QObject
{
    Q_OBJECT
    Q_DECLARE_PRIVATE(ArnServer)

public:
    struct Type {
        enum E {
            NetSync
        };
        MQ_DECLARE_ENUM( Type)
    };


    ArnServer( Type serverType, QObject *parent = arnNullptr);

    ~ArnServer();


    void  start( int port = -1, QHostAddress listenAddr = QHostAddress::Any);


    int  port();


    QHostAddress  listenAddress();


    void  addAccess( const QString& userName, const QString& password, Arn::Allow allow);


    bool  isDemandLogin()  const;


    void  setDemandLogin( bool isDemandLogin);


    void  setNoLoginNets( const QStringList& noLoginNets);


    QStringList  noLoginNets()  const;


    bool  isDemandLoginNet( const QHostAddress& remoteAddr)  const;


    void  addFreePath( const QString& path);


    QStringList  freePaths()  const;


    void  setWhoIAm( const Arn::XStringMap& whoIAmXsm);

    ArnSyncLogin*  arnLogin()  const;
    ArnServerSession*  getSession()  const;
    QByteArray  whoIAm()  const;

signals:
    void  newSession();

protected:
    ArnServer( ArnServerPrivate& dd, QObject* parent);
    ArnServerPrivate* const  d_ptr;

private slots:
    void tcpConnection();

private:
};

#endif // ARNSERVER_HPP