Function ensureBotReady

parsehub/parsehub.ts:122–197

(msg: Api.Message)

  if (!text) return [];
  const matches = text.match(/(?:https?:\/\/|www\.)\S+/gi) || [];
  const sanitized = matches.map((raw) => {
    const cleaned = raw.replace(
      /[)\]\}\u3002\uff1a\uff01\uff1f\u3001\uff0c>]+$/u,
      "",
    );
    return cleaned.startsWith("http") ? cleaned : `https://${cleaned}`;
  });
  return Array.from(new Set(sanitized.map((link) => link.trim()))).filter(
    Boolean,
  );
}

async function ensureBotReady(msg: Api.Message) {
  const client = msg.client;
  if (!client) return;

  try {
    await client.invoke(new Api.contacts.Unblock({ id: BOT_USERNAME }));
  } catch {}

  try {
    const inputPeer = await client.getInputEntity(BOT_USERNAME);
    await client.invoke(
      new Api.account.UpdateNotifySettings({
        peer: new Api.InputNotifyPeer({ peer: inputPeer }),
        settings: new Api.InputPeerNotifySettings({
          silent: true,
          muteUntil: 2147483647,
        }),
      }),
    );
  } catch {}

  if (hasStartedBot) {
    return;
  }

  try {
    const history = await safeGetMessages(client, BOT_USERNAME, { limit: 1 });
    if (history.length > 0) {
      hasStartedBot = true;
      return;
    }
  } catch {}

  try {
    if (!initState.initialized) {
      firstRunPreStartLastId = await getLatestBotMessageId(client);
      shouldIgnoreNextBotMessage = true;
    }
    await client.invoke(
      new Api.messages.StartBot({
        bot: BOT_USERNAME,
        peer: BOT_USERNAME,
        startParam: "",
      }),
    );
    hasStartedBot = true;