webhook.test.js

const test = require("node:test");
const assert = require("node:assert/strict");
const { loadMaxBotContext } = require("./helpers/gas");

function response(status, text) {
  return {
    getResponseCode: () => status,
    getContentText: () => text,
  };
}

function runtime(options) {
  const context = loadMaxBotContext(() => response(200, "{}"));
  return { context, bot: context.create("token", options) };
}

test("handleWebhook сверяет query secret с секретом экземпляра до JSON parse", () => {
  const { bot } = runtime();

  assert.throws(
    () => bot.handleWebhook({ parameter: { secret: "anything" }, postData: { contents: "not json" } }),
    (error) => !(error instanceof SyntaxError) && /secret/i.test(error.message)
  );

  const configured = runtime({ webhookSecret: "expected-secret" }).bot;
  assert.throws(
    () => configured.handleWebhook(
      { parameter: { secret: "wrong-secret" }, postData: { contents: "not json" } }
    ),
    (error) => !(error instanceof SyntaxError) && /secret/i.test(error.message)
  );
});

test("handleWebhook требует postData.contents после успешной проверки секрета", () => {
  const { bot } = runtime({ webhookSecret: "expected-secret" });

  for (const event of [
    { parameter: { secret: "expected-secret" } },
    { parameter: { secret: "expected-secret" }, postData: {} },
    { parameter: { secret: "expected-secret" }, postData: { contents: "" } },
  ]) {
    assert.throws(() => bot.handleWebhook(event), /postData|contents|body/i);
  }
});

test("handleWebhook парсит update, синхронно dispatch-ит и возвращает HtmlOutput OK", () => {
  const { bot } = runtime({ webhookSecret: "expected-secret" });
  let seen = null;
  bot.on("message_created", (ctx) => { seen = ctx.update; });
  const update = { update_type: "message_created", message: { body: { text: "hello", mid: "m1" } } };

  const output = bot.handleWebhook({
    parameter: { secret: "expected-secret" },
    headers: { "X-Max-Bot-Api-Secret": "ignored-header" },
    postData: { contents: JSON.stringify(update) },
  });

  assert.deepEqual(JSON.parse(JSON.stringify(seen)), update);
  assert.equal(output.getContent(), "OK");
});

test("handleWebhook не ловит ошибки JSON, validation и handlers", () => {
  const { bot } = runtime({ webhookSecret: "expected-secret" });

  assert.throws(
    () => bot.handleWebhook(
      { parameter: { secret: "expected-secret" }, postData: { contents: "not json" } }
    ),
    SyntaxError
  );
  assert.throws(
    () => bot.handleWebhook(
      { parameter: { secret: "expected-secret" }, postData: { contents: "{}" } }
    ),
    /update/i
  );

  const expected = new Error("handler failed");
  bot.on("*", () => { throw expected; });
  assert.throws(
    () => bot.handleWebhook({
      parameter: { secret: "expected-secret" },
      postData: { contents: '{"update_type":"future_update"}' },
    }),
    (error) => error === expected
  );
});