1 files changed, 163 insertions, 0 deletions

diff --git a/client.cpp b/client.cpp
new file mode 100644
index 0000000..a64973e
--- /dev/null
+++ b/client.cpp
@@ -0,0 +1,163 @@
+#include "td/telegram/Client.h"
+#include "td/telegram/td_api.h"
+#include <cstdio>
+#include <cstdlib>
+#include <iostream>
+
+using namespace td::td_api;
+
+class AutoReactClient {
+private:
+  td::ClientManager manager;
+  int client_id;
+  bool is_authorized;
+
+  int user_id;
+  string emoji;
+
+public:
+  AutoReactClient(int user_id, string emoji) {
+    td::ClientManager manager;
+
+    this->manager = std::move(manager);
+    this->client_id = this->manager.create_client_id();
+    this->is_authorized = false;
+
+    this->manager.send(
+        client_id, 1,
+        td::td_api::make_object<td::td_api::getOption>("version"));
+
+    this->user_id = user_id;
+    this->emoji = emoji;
+  }
+
+  void authorize() {
+    std::cout << "Client authorization" << std::endl;
+
+    while (!this->is_authorized) {
+      auto response = this->manager.receive(10);
+
+      if (response.object == NULL || (response.request_id != 0 &&
+                                      response.object->get_id() != error::ID)) {
+        continue;
+      }
+
+      switch (response.object->get_id()) {
+      case (updateAuthorizationState::ID):
+        on_auth_state(
+            move_object_as<updateAuthorizationState>(response.object));
+        break;
+      case (error::ID):
+        on_auth_error(move_object_as<error>(response.object));
+        break;
+      default:
+        continue;
+      }
+    }
+  }
+
+  void loop() {
+    while (this->is_authorized) {
+      auto response = this->manager.receive(10);
+
+      if (response.object == NULL || (response.request_id != 0 &&
+                                      response.object->get_id() != error::ID)) {
+        continue;
+      }
+
+      feed_update(std::move(response.object));
+    }
+  }
+
+private:
+  void on_auth_error(object_ptr<error> err) {
+    std::cout << "Error while authorizing: " << err->message_ << std::endl;
+    std::exit(1);
+  }
+
+  void on_auth_state(object_ptr<updateAuthorizationState> update) {
+    switch (update->authorization_state_->get_id()) {
+    case (authorizationStateWaitTdlibParameters::ID):
+      set_td_lib_params();
+      break;
+    case (authorizationStateWaitPhoneNumber::ID):
+      input_phone_number();
+      break;
+    case (authorizationStateWaitCode::ID):
+      input_auth_code();
+      break;
+    case (authorizationStateWaitPassword::ID):
+      input_password();
+      break;
+    case (authorizationStateReady::ID):
+      this->is_authorized = true;
+      break;
+    default:
+      std::cout << "Unhandled auth state: "
+                << to_string(update->authorization_state_) << std::endl;
+      break;
+    }
+  }
+
+  void set_td_lib_params() {
+    auto request = make_object<setTdlibParameters>();
+    request->database_directory_ = "tdlib/db";
+    request->files_directory_ = "tdlib/files";
+    request->api_id_ = 2092395;
+    request->api_hash_ = "38e26914cf0fda6356fda8f9d28f3bb9";
+    request->system_language_code_ = "en";
+    request->device_model_ = "auto reaction client";
+    request->system_version_ = "1.0.0";
+    request->application_version_ = "1.0.0";
+    this->manager.send(this->client_id, 1, std::move(request));
+  }
+
+  void input_phone_number() {
+    auto request = make_object<setAuthenticationPhoneNumber>();
+    std::cout << "Enter the phone number: ";
+    std::cin >> request->phone_number_;
+    this->manager.send(this->client_id, 1, std::move(request));
+  }
+
+  void input_auth_code() {
+    auto request = make_object<checkAuthenticationCode>();
+    std::cout << "Enter auth code: ";
+    std::cin >> request->code_;
+    this->manager.send(this->client_id, 1, std::move(request));
+  }
+
+  void input_password() {
+    auto request = make_object<checkAuthenticationPassword>();
+    std::cout << "Enter password: ";
+    std::cin >> request->password_;
+    this->manager.send(this->client_id, 1, std::move(request));
+  }
+
+  void feed_update(object_ptr<Object> object) {
+    switch (object->get_id()) {
+    case (error::ID):
+      on_error(move_object_as<error>(object));
+      break;
+    case (updateNewMessage::ID):
+      on_new_message(move_object_as<updateNewMessage>(object));
+      break;
+    default:
+      break;
+    }
+  }
+
+  void on_error(object_ptr<error> err) {}
+
+  void on_new_message(object_ptr<updateNewMessage> update) {
+    if (update->message_->sender_id_->get_id() == messageSenderUser::ID &&
+        move_object_as<messageSenderUser>(update->message_->sender_id_)
+                ->user_id_ == this->user_id) {
+      auto request = make_object<addMessageReaction>();
+      request->chat_id_ = update->message_->chat_id_;
+      request->message_id_ = update->message_->id_;
+      request->reaction_type_ = make_object<reactionTypeEmoji>(this->emoji);
+      request->is_big_ = true;
+      this->manager.send(this->client_id, 1, std::move(request));
+    }
+  }
+};