/*
    SPDX-FileCopyrightText: 2005 Joris Guisson <joris.guisson@gmail.com>

    SPDX-License-Identifier: GPL-2.0-or-later
*/
#ifndef DHTRPCSERVER_H
#define DHTRPCSERVER_H

#include <QList>
#include <QObject>
#include <dht/rpcserverinterface.h>
#include <net/address.h>
#include <net/socket.h>
#include <util/constants.h>
#include <util/ptrmap.h>

#include <memory>

namespace dht
{
class Key;
class DHT;

/*!
 * \headerfile dht/rpcserver.h
 * \author Joris Guisson
 *
 * \brief Handles incoming and outgoing RPC messages.
 */
class RPCServer : public QObject, public RPCServerInterface
{
    Q_OBJECT
public:
    RPCServer(DHT *dh_table, bt::Uint16 port, QObject *parent = nullptr);
    ~RPCServer() override;

    //! Start the server
    void start();

    //! Stop the server
    void stop();

    /*!
     * Do a RPC call.
     * \param msg The message to send
     * \return The call object
     */
    RPCCall *doCall(std::unique_ptr<RPCMsg> msg) override;

    /*!
     * Send a message, this only sends the message, it does not keep any call
     * information. This should be used for replies.
     * \param msg The message to send
     */
    void sendMsg(const RPCMsg &msg);

    /*!
     * Ping a node, we don't care about the MTID.
     * \param our_id The ID of our node
     * \param addr The address
     */
    void ping(const dht::Key &our_id, const net::Address &addr);

    //! Get the number of active calls
    [[nodiscard]] bt::Uint32 getNumActiveRPCCalls() const;

private Q_SLOTS:
    void callTimeout(dht::RPCCall *call);

private:
    class Private;
    std::unique_ptr<Private> d;
};

}

#endif
