sendMessageRaw method

FutureOr<Map> sendMessageRaw({
  1. required Map parameters,
  2. required TelegramClientCallApiInvoke callApiInvoke,
  3. required TelegramClientData telegramClientData,
})

method SendMessageRaw

Implementation

FutureOr<Map> sendMessageRaw({
  required Map parameters,
  required TelegramClientCallApiInvoke callApiInvoke,
  required TelegramClientData telegramClientData,
}) async {
  final dynamic target_chat_id = TgUtils.parse_all_chat_id(
    parameters: parameters,
  );
  if (target_chat_id is String &&
      RegExp(
        r"^((@)[a-z0-9_]+)$",
        caseSensitive: false,
      ).hashData(target_chat_id)) {
    final Map search_public_chat = await callApiInvoke(
      parameters: {
        "@type": "searchPublicChat",
        "username": (target_chat_id).replaceAll(
          RegExp(r"@", caseSensitive: false),
          "",
        ),
      },
      is_invoke_no_relevance: true,
    );
    if (search_public_chat["@type"] == "chat") {
      parameters["chat_id"] = search_public_chat["id"];
    } else {
      return search_public_chat;
    }
  }
  final Map request_parameters = <dynamic, dynamic>{
    "@type": "sendMessage",
    "chat_id": parameters["chat_id"],
    "options": <String, dynamic>{"@type": "messageSendOptions"},
    "input_message_content": <String, dynamic>{"@type": ""},
  };

  final List<String> options_parameters = [
    "protect_content",
    "disable_notification",
  ];
  for (var option_parameter in options_parameters) {
    if (parameters[option_parameter] is bool) {
      request_parameters["options"][option_parameter] =
          parameters[option_parameter];
    }
  }
  final List<String> input_message_content_parameters = [
    "has_spoiler",
    "disable_web_page_preview",
  ];
  for (var option_parameter in input_message_content_parameters) {
    if (parameters[option_parameter] is bool) {
      request_parameters["input_message_content"][option_parameter] =
          parameters[option_parameter];
    }
  }

  if (parameters.containsKey("message_thread_id")) {
    request_parameters["message_thread_id"] = TgUtils.messageApiToTdlib(
      parameters["message_thread_id"],
    );
  }
  if (parameters.containsKey("message_tdlib_thread_id")) {
    request_parameters["message_thread_id"] =
        parameters["message_tdlib_thread_id"];
  }

  if (parameters.containsKey("message_id")) {
    request_parameters["message_id"] = TgUtils.messageApiToTdlib(
      parameters["message_id"],
    );
  }

  if (parameters.containsKey("message_tdlib_id")) {
    request_parameters["message_id"] = parameters["message_tdlib_id"];
  }

  if (parameters.containsKey("inline_message_id")) {
    request_parameters["inline_message_id"] = parameters["inline_message_id"];
  }
  if (parameters["reply_to_message_id"] is int) {
    request_parameters["reply_to"] = <dynamic, dynamic>{
      "@type": "inputMessageReplyToMessage",
      "chat_id": request_parameters["chat_id"],
      "message_id": TgUtils.messageApiToTdlib(
        parameters["reply_to_message_id"],
      ),
    };
  } else if (parameters["reply_to_story_id"] is int) {
    request_parameters["reply_to"] = <dynamic, dynamic>{
      "@type": "inputMessageReplyToStory",
      "story_sender_chat_id": request_parameters["chat_id"],
      "story_id": parameters["reply_to_story_id"],
    };
  }
  Map? formatted_text = <dynamic, dynamic>{"@type": "formattedText"};

  if (RegExp(
    r"^(sendMessage|editMessageText)$",
    caseSensitive: false,
  ).hashData(parameters["@type"])) {
    formatted_text["text"] = parameters["text"];
  } else {
    if (parameters["caption"] is String) {
      formatted_text["text"] = parameters["caption"];
      if ((formatted_text["text"] as String).isEmpty) {
        formatted_text = null;
      }
    } else {
      formatted_text = null;
    }
  }

  final String parse_mode = () {
    if (parameters["parse_mode"] is String) {
      return parameters["parse_mode"];
    }
    return "";
  }();
  if (formatted_text != null) {
    if (parse_mode == "html") {
      formatted_text = tdlib.td_execute({
        "@type": 'parseTextEntities',
        "parse_mode": {"@type": "textParseModeHTML"},
        "text": formatted_text["text"],
      });
    } else if (parse_mode == "markdown") {
      formatted_text = tdlib.td_execute({
        "@type": 'parseTextEntities',
        "parse_mode": {"@type": "textParseModeMarkdown"},
        "text": formatted_text["text"],
      });
    }
  }

  if (formatted_text != null) {
    if (formatted_text["@type"] == "error") {
      return formatted_text;
    }
  }

  //  editInlineMessageCaption
  //  editInlineMessageLiveLocation
  //  editInlineMessageMedia
  //  editInlineMessageReplyMarkup
  //  editInlineMessageText
  //  editMessageCaption
  //  editMessageLiveLocation
  //  editMessageMedia
  //  editMessageReplyMarkup
  //  editMessageSchedulingState
  //  editMessageText
  final String add_inline = () {
    if (parameters["inline_message_id"] is String &&
        (parameters["inline_message_id"] as String).isNotEmpty) {
      return "Inline";
    }
    return "";
  }();

  if (RegExp(
    r"^(editMessageCaption)$",
    caseSensitive: false,
  ).hashData(parameters["@type"])) {
    request_parameters["@type"] = "edit${add_inline}MessageCaption";
  }
  if (RegExp(
    r"^(editMessageMedia)$",
    caseSensitive: false,
  ).hashData(parameters["@type"])) {
    request_parameters["@type"] = "edit${add_inline}MessageMedia";
  }
  if (RegExp(
    r"^(editMessageReplyMarkup)$",
    caseSensitive: false,
  ).hashData(parameters["@type"])) {
    request_parameters["@type"] = "edit${add_inline}MessageReplyMarkup";
  }
  if (RegExp(
    r"^(editMessageText)$",
    caseSensitive: false,
  ).hashData(parameters["@type"])) {
    request_parameters["@type"] = "edit${add_inline}MessageText";
  }

  if (RegExp(
    r"^(sendMessage|editMessageText)$",
    caseSensitive: false,
  ).hashData(parameters["@type"])) {
    request_parameters["input_message_content"]["@type"] = "inputMessageText";

    if (parameters["clear_draft"] is bool) {
      request_parameters["input_message_content"]["clear_draft"] =
          parameters["clear_draft"];
    }
    if (formatted_text != null) {
      request_parameters["input_message_content"]["text"] = formatted_text;
    }
  } else {
    if (RegExp(
      r"^(forwardMessage|copyMessage)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageForwarded";
      request_parameters["input_message_content"]["from_chat_id"] =
          parameters["from_chat_id"];
      request_parameters["input_message_content"]["message_id"] =
          TgUtils.messageApiToTdlib(parameters["message_id"]);
      if (parameters["in_game_share"] is bool) {
        request_parameters["input_message_content"]["in_game_share"] =
            parameters["in_game_share"];
      }
      if (RegExp(
        r"^(copyMessage)$",
        caseSensitive: false,
      ).hashData(parameters["@type"])) {
        request_parameters["input_message_content"]
            ["copy_options"] = <dynamic, dynamic>{
          "@type": "messageCopyOptions",
          "send_copy": true,
        };
        if (formatted_text != null) {
          request_parameters["input_message_content"]["copy_options"]
              ["replace_caption"] = true;
          request_parameters["input_message_content"]["copy_options"]
              ["new_caption"] = formatted_text;
        }
      }
    } else {
      if (formatted_text != null) {
        if (RegExp(
          r"^(editMessageCaption)$",
          caseSensitive: false,
        ).hashData(parameters["@type"])) {
          request_parameters["caption"] = formatted_text;
        } else {
          request_parameters["input_message_content"]["caption"] =
              formatted_text;
        }
      }
    }
    if (RegExp(
      r"^(sendAudio)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageAudio";
      request_parameters["input_message_content"]["audio"] =
          (await TgUtils.typeFile(
        content: parameters["audio"],
        directory_temp: directory_temp,
      ));
    }
    if (RegExp(
      r"^(sendPhoto)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessagePhoto";
      request_parameters["input_message_content"]["photo"] =
          (await TgUtils.typeFile(
        content: parameters["photo"],
        directory_temp: directory_temp,
      ));
    }
    if (RegExp(
      r"^(sendAnimation)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageAnimation";
      request_parameters["input_message_content"]["animation"] =
          (await TgUtils.typeFile(
        content: parameters["animation"],
        directory_temp: directory_temp,
      ));
    }
    if (RegExp(
      r"^(sendDocument)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageDocument";
      request_parameters["input_message_content"]["document"] =
          (await TgUtils.typeFile(
        content: parameters["document"],
        directory_temp: directory_temp,
      ));
    }
    if (RegExp(
      r"^(sendContact)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageContact";
      request_parameters["input_message_content"]
          ["contact"] = <dynamic, dynamic>{"@type": "contact"};
      final List<String> contact_parameters = [
        "phone_number",
        "first_name",
        "last_name",
        "vcard",
        "user_id",
      ];
      for (final contact_parameter in contact_parameters) {
        if (parameters.containsKey(contact_parameter)) {
          request_parameters["input_message_content"]["contact"]
              [contact_parameter] = parameters[contact_parameter];
        }
      }
    }
    if (RegExp(
      r"^(sendPoll)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessagePoll";
      if (parameters["question"] is String) {
        final Map<dynamic, dynamic> result_poll_question = <dynamic, dynamic>{
          "@type": "formattedText",
          "text": parameters["question"],
        };
        request_parameters["input_message_content"]["question"] =
            result_poll_question;
      }
      if (parameters["options"] is List) {
        final poll_options = (parameters["options"] as List);
        final result_poll_options = <Map>[];
        for (final poll_option in poll_options) {
          if (poll_option is Map) {
            final Map<dynamic, dynamic> result_poll_option =
                <dynamic, dynamic>{};
            if (poll_option["text"] is String) {
              result_poll_option["@type"] = "formattedText";
              result_poll_option["text"] = poll_option["text"];
            }
            if (result_poll_option.isEmpty) {
              continue;
            }
            result_poll_options.add(poll_option);
          }
        }
        request_parameters["input_message_content"]["options"] =
            result_poll_options;
      }

      if (parameters.containsKey("is_anonymous")) {
        request_parameters["input_message_content"]["is_anonymous"] =
            parameters["is_anonymous"];
      }
      if (parameters.containsKey("type")) {
        request_parameters["input_message_content"]["type"] = {
          "@type":
              "pollType${parameters["type"].toString().trim().toLowerCase().toUpperCaseFirstData()}",
        };
      }
      if (parameters.containsKey("open_period")) {
        request_parameters["input_message_content"]["open_period"] =
            parameters["open_period"];
      }
      if (parameters.containsKey("close_date")) {
        request_parameters["input_message_content"]["close_date"] =
            parameters["close_date"];
      }
      if (parameters.containsKey("is_closed")) {
        request_parameters["input_message_content"]["is_closed"] =
            parameters["is_closed"];
      }
    }
    if (RegExp(
      r"^(sendVenue)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageVenue";
      request_parameters["input_message_content"]
          ["venue"] = <dynamic, dynamic>{
        "@type": "location",
        "latitude": parameters["latitude"],
        "longitude": parameters["longitude"],
      };
      if (parameters.containsKey("horizontal_accuracy")) {
        request_parameters["input_message_content"]["location"]
            ["horizontal_accuracy"] = parameters["horizontal_accuracy"];
      }
      if (parameters.containsKey("live_period")) {
        request_parameters["input_message_content"]["live_period"] =
            parameters["live_period"];
      }
      if (parameters.containsKey("heading")) {
        request_parameters["input_message_content"]["heading"] =
            parameters["heading"];
      }
      if (parameters.containsKey("proximity_alert_radius")) {
        request_parameters["input_message_content"]
            ["proximity_alert_radius"] = parameters["proximity_alert_radius"];
      }
    }
    if (RegExp(
      r"^(sendLocation)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageLocation";
      request_parameters["input_message_content"]
          ["location"] = <dynamic, dynamic>{
        "@type": "location",
        "latitude": parameters["latitude"],
        "longitude": parameters["longitude"],
      };
      if (parameters.containsKey("horizontal_accuracy")) {
        request_parameters["input_message_content"]["location"]
            ["horizontal_accuracy"] = parameters["horizontal_accuracy"];
      }
      if (parameters.containsKey("live_period")) {
        request_parameters["input_message_content"]["live_period"] =
            parameters["live_period"];
      }
      if (parameters.containsKey("heading")) {
        request_parameters["input_message_content"]["heading"] =
            parameters["heading"];
      }
      if (parameters.containsKey("proximity_alert_radius")) {
        request_parameters["input_message_content"]
            ["proximity_alert_radius"] = parameters["proximity_alert_radius"];
      }
    }
    if (RegExp(
      r"^(sendDice)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageDice";
      request_parameters["input_message_content"]["emoji"] =
          parameters["emoji"];

      if (parameters["clear_draft"] is bool) {
        request_parameters["input_message_content"]["clear_draft"] =
            parameters["clear_draft"];
      }
    }
    if (RegExp(
      r"^(sendSticker)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageSticker";
      request_parameters["input_message_content"]["sticker"] =
          (await TgUtils.typeFile(
        content: parameters["sticker"],
        directory_temp: directory_temp,
      ));
    }
    if (RegExp(
      r"^(sendVideo)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageVideo";
      request_parameters["input_message_content"]["video"] =
          (await TgUtils.typeFile(
        content: parameters["video"],
        directory_temp: directory_temp,
      ));
    }

    if (RegExp(
      r"^(sendVoice)$",
      caseSensitive: false,
    ).hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageVoiceNote";
      request_parameters["input_message_content"]["voice_note"] =
          (await TgUtils.typeFile(
        content: parameters["voice"],
        directory_temp: directory_temp,
      ));
    }
  }
  if (parameters["reply_markup"] is Map) {
    final Map? reply_markup = TgUtils.replyMarkupTgApiToTdlib(
      replyMarkup: parameters["reply_markup"],
    );
    if (reply_markup != null) {
      request_parameters["reply_markup"] = reply_markup;
    }
  }

  final Map message_send = await callApiInvoke(
    parameters: request_parameters,
  );

  if (message_send["@type"] == "message") {
    if (message_send["sending_state"] is Map == false) {
      final Map json_message = await message_Message(
        message: message_send,
        is_skip_reply_message: true,
        is_lite: false,
        telegramClientData: telegramClientData,
        isUseCache: false,
        durationCacheExpire: null,
      );

      return (json_message);
    }
  }
  if (message_send["@type"] == "error") {
    return message_send;
  }
  if (parameters["is_void"] == true) {
    if (message_send["@type"] == "message") {
      final Map json_message = await message_Message(
        message: message_send,
        is_skip_reply_message: true,
        is_lite: false,
        telegramClientData: telegramClientData,
        isUseCache: false,
        durationCacheExpire: null,
      );

      return (json_message);
    }
  }
  final Completer<Map> completer = Completer<Map>();

  final EventEmitterListener listen = on(
    event_name: event_update,
    onUpdate: (UpdateTelegramClient updateTelegramClient) async {
      if (updateTelegramClient.telegramClientData.telegramClientType ==
          TelegramClientType.tdlib) {
        if (updateTelegramClient.telegramClientData.tdlib_client_id !=
            telegramClientData.tdlib_client_id) {
          return;
        }
        Map updateOrigin = updateTelegramClient.rawData;
        if (![
          "updateMessageSendSucceeded",
          "updateMessageSendFailed",
        ].contains(updateOrigin["@type"])) {
          return;
        }

        if (updateOrigin["message"] is Map &&
            updateOrigin["message"]["chat_id"] == message_send["chat_id"] &&
            updateOrigin["old_message_id"] == message_send["id"]) {
          if (updateOrigin["error"] is Map) {
            completer.complete(updateOrigin["error"]);
            // result = updateOrigin["error"];
          } else {
            completer.complete(updateOrigin);
            // result = updateOrigin;
          }
        }
      }
    },
    onError: (Object error, StackTrace stackTrace) {},
  );

  // tdlib.task_increase();

  final Map result = await completer.future.timeout(
    tdlib.invoke_time_out,
    onTimeout: () {
      return {
        "@type": "error",
        "message": "time_out_limit",
        "invoke_request": request_parameters,
      };
    },
  );
  event_emitter.off(listener: listen);
  if (result["@type"] is String) {
    if (result["@type"] == "error") {
      throw result;
    }
    result.remove("@type");
    if (result["message"] is Map) {
      final Map json_message = await message_Message(
        message: result["message"],
        is_lite: false,
        telegramClientData: telegramClientData,
        isUseCache: false,
        durationCacheExpire: null,
      );

      return (json_message);
    }
  }
  throw result;
}