on method

EventEmitterListener on({ required String event_name, required FutureOr onUpdate(UpdateTelegramClient updateTelegramClient), required FutureOr onError(Object error, StackTrace stackTrace), })

return original data json

Implementation

EventEmitterListener on({
  required String event_name,
  required FutureOr<dynamic> Function(
    UpdateTelegramClient updateTelegramClient,
  ) onUpdate,
  required FutureOr<dynamic> Function(Object error, StackTrace stackTrace)
      onError,
}) {
  return event_emitter.on(
    eventName: event_name,
    onCallback: (listener, update) async {
      try {
        if (update is UpdateTelegramClientTelegramBotApi) {
          await onUpdate(
            UpdateTelegramClient(
              uri: update.uri,
              rawData: update.body,
              query: update.query,
              client_option: {},
              tg: this,
              telegramClientData: TelegramClientData(
                tdlib_client_id: 0,
                telegram_bot_api_token_bot: "",
                telegramClientType: TelegramClientType.telegam_bot_api,
              ),
            ),
          );
        }

        if (update is TdlibIsolateReceiveData) {
          final TdlibClient? tdlibClient = tdlib.clients[update.clientId];

          final UpdateTelegramClientTdlib updateTd =
              UpdateTelegramClientTdlib(
            update: update.updateData,
            client_id: update.clientId,
            client_option: () {
              try {
                if (tdlibClient != null) {
                  return tdlibClient.client_option;
                }
              } catch (e) {}
              return {};
            }(),
          );
          await onUpdate(
            UpdateTelegramClient(
              rawData: updateTd.raw,
              uri: Uri.base,
              query: {},
              tg: this,
              client_option: updateTd.client_option,
              telegramClientData: TelegramClientData(
                tdlib_client_id: updateTd.client_id,
                telegram_bot_api_token_bot: "",
                telegramClientType: TelegramClientType.tdlib,
                client_user_name: () {
                  try {
                    if (tdlibClient != null) {
                      if (tdlibClient.client_option["client_username"]
                          is String) {
                        return tdlibClient.client_option["client_username"];
                      }
                    }
                  } catch (e) {}

                  return "";
                }(),
                client_tg_user_id: () {
                  try {
                    if (tdlibClient != null) {
                      return tdlibClient.client_tg_user_id;
                    }
                  } catch (e) {}
                  return 0;
                }(),
                is_bot: () {
                  try {
                    if (tdlibClient != null) {
                      return tdlibClient.is_bot;
                    }
                  } catch (e) {}
                  return false;
                }(),
              ),
            ),
          );
        }
      } catch (e, stack) {
        try {
          await onError(e, stack);
        } catch (e) {}
      }
    },
  );
}