sendMessageRaw method

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

method SendMessageRaw

Implementation

FutureOr<Map> sendMessageRaw({
  required Map parameters,
  required TelegramClientCallApiInvoke callApiInvoke,
  required TelegramClientData telegramClientData,
}) async {
  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)) {
    var 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;
    }
  }
  Map request_parameters = {
    "@type": "sendMessage",
    "chat_id": parameters["chat_id"],
    "options": <String, dynamic>{
      "@type": "messageSendOptions",
    },
    "input_message_content": <String, dynamic>{
      "@type": "",
    },
  };

  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];
    }
  }
  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"] =
        (parameters["message_thread_id"]);
  }

  if (parameters.containsKey("message_id")) {
    request_parameters["message_id"] =
        TgUtils.messageApiToTdlib(parameters["message_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"] = {
      "@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"] = {
      "@type": "inputMessageReplyToStory",
      "story_sender_chat_id": request_parameters["chat_id"],
      "story_id": parameters["reply_to_story_id"],
    };
  }
  Map? formatted_text = {
    "@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;
    }
  }

  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
  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"] = {
          "@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"] = {
        "@type": "contact",
        "latitude": parameters["latitude"],
        "longitude": parameters["longitude"],
      };
      List<String> contact_parameters = [
        "phone_number",
        "first_name",
        "last_name",
        "vcard",
        "user_id",
      ];
      for (var contact_parameter in contact_parameters) {
        if (parameters.containsKey(contact_parameter)) {
          request_parameters["input_message_content"]["contact"]
              [contact_parameter] = parameters[contact_parameter];
        }
      }
    }
    if (RegExp(r"^(sendVenue)$", caseSensitive: false)
        .hashData(parameters["@type"])) {
      request_parameters["input_message_content"]["@type"] =
          "inputMessageVenue";
      request_parameters["input_message_content"]["venue"] = {
        "@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"] = {
        "@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) {
    Map? reply_markup = TgUtils.replyMarkupTgApiToTdlib(
        replyMarkup: parameters["reply_markup"]);
    if (reply_markup != null) {
      request_parameters["reply_markup"] = reply_markup;
    }
  }

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

  if (message_send["@type"] == "message") {
    if (message_send["sending_state"] is Map == false) {
      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") {
      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);
    }
  }
  Completer<Map> completer = Completer<Map>();

  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();

  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(listen);
  if (result["@type"] is String) {
    if (result["@type"] == "error") {
      throw result;
    }
    result.remove("@type");
    if (result["message"] is Map) {
      Map json_message = await message_Message(
        message: result["message"],
        is_lite: false,
        telegramClientData: telegramClientData,
        isUseCache: false,
        durationCacheExpire: null,
      );

      return (json_message);
    }
  }
  throw result;
}