ClientActor.h

Go to the documentation of this file.

//
// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2024
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
#pragma once


#include "td/telegram/td_api.h"
#include "td/telegram/td_api.hpp"
#include "td/telegram/TdCallback.h"

#include "td/actor/actor.h"

#include "td/utils/common.h"

#include <memory>

namespace td {

class NetQueryStats;
class Td;

class ClientActor final : public Actor {
 public:
  struct Options {
    std::shared_ptr<NetQueryStats> net_query_stats;

    Options() {
    }
  };

  explicit ClientActor(unique_ptr<TdCallback> callback, Options options = {});

  void request(uint64 id, td_api::object_ptr<td_api::Function> request);

  static td_api::object_ptr<td_api::Object> execute(td_api::object_ptr<td_api::Function> request);

  ~ClientActor() final;

  ClientActor(ClientActor &&other) noexcept;

  ClientActor &operator=(ClientActor &&other) noexcept;

  ClientActor(const ClientActor &) = delete;

  ClientActor &operator=(const ClientActor &) = delete;

 private:
  void start_up() final;

  ActorOwn<Td> td_;
  unique_ptr<TdCallback> callback_;
  Options options_;
};

std::shared_ptr<NetQueryStats> create_net_query_stats();

void dump_pending_network_queries(NetQueryStats &stats);

uint64 get_pending_network_query_count(NetQueryStats &stats);

}  // namespace td