Jhon-Mosk · Jhon-Mosk · Jun 29, 2024 · Jun 21, 2024 · Jun 28, 2024 · Jun 28, 2024
diff --git a/README.md b/README.md
@@ -21,8 +21,8 @@ const logger = pino({
       chatId: -1234567890,
       botToken: "123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11",
       extra: {
-              parse_mode: "HTML",
-            },
+        parse_mode: "HTML",
+      },
     },
   },
 })

diff --git a/index.js b/index.js
@@ -1,10 +1,8 @@
-"use strict";
-
-const build = require("pino-abstract-transport");
+import build from "pino-abstract-transport";
 
 const API_URL = "https://api.telegram.org/bot";
 
-const sendMsgToTg = async (chatId, botToken, text, extra = {}) => {
+export async function sendMsgToTg(chatId, botToken, text, extra = {}) {
   const method = "sendMessage";
   const url = `${API_URL}${botToken}/${method}`;
   const response = await fetch(url, {
@@ -30,18 +28,18 @@ const sendMsgToTg = async (chatId, botToken, text, extra = {}) => {
 
   const { status, statusText } = response;
   throw new Error(`${status}: ${statusText}`);
-};
+}
 
 /**
  *
- * @param {object} params - параметры для создания транспорта
- * @param {number} params.chatId - идентификатор чата
- * @param {string} params.botToken - токен бота
- * @param {boolean} params.verbose - отправить отладочную информацию
- * @param {object} params.extra - дополнительные параметры для отправки сообщения https://core.telegram.org/bots/api#sendmessage
+ * @param {object} params - parameters for creating a transport
+ * @param {number} params.chatId - chat ID
+ * @param {string} params.botToken - bot token
+ * @param {boolean} params.verbose - send debugging information
+ * @param {object} params.extra - additional parameters for sending a message https://core.telegram.org/bots/api#sendmessage
  * @returns {Promise}
  */
-module.exports = function ({ chatId, botToken, verbose = false, extra = {} }) {
+export default function ({ chatId, botToken, verbose = false, extra = {} }) {
   return build(async function (source) {
     for await (const obj of source) {
       const text = verbose ? JSON.stringify(obj) : obj.msg;
@@ -52,4 +50,4 @@ module.exports = function ({ chatId, botToken, verbose = false, extra = {} }) {
       }
     }
   });
-};
+}
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,22 +1,41 @@
 {
   "name": "pino-telegram-webhook",
-  "version": "0.0.0",
+  "version": "0.1.0",
+  "type": "module",
   "description": "A [Pino v7+ transport](https://getpino.io/#/docs/transports?id=v7-transports) to send message to [Telegram](https://telegram.org/)",
+  "keywords": [
+    "pino",
+    "telegram",
+    "webhook",
+    "telegram webhook",
+    "transport"
+  ],
   "main": "index.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "node test/transport.test.js"
   },
   "engines": {
     "node": ">=18.0.0",
     "npm": ">=7.24.2"
   },
+  "dependencies": {
+    "pino-abstract-transport": "^1.2.0"
+  },
+  "devDependencies": {
+    "undici": "^6.19.2"
+  },
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/Jhon-Mosk/pino-telegram-webhook"
+  },
+  "bugs": {
+    "url": "https://github.com/Jhon-Mosk/pino-telegram-webhook/issues"
+  },
+  "homepage": "https://github.com/Jhon-Mosk/pino-telegram-webhook",
   "author": {
     "name": "Evgeniy Politiko",
     "email": "Jhon-mosk@yandex.ru",
     "url": "https://jhon-mosk.ru/"
   },
-  "license": "MIT",
-  "dependencies": {
-    "pino-abstract-transport": "^1.2.0"
-  }
+  "license": "MIT"
 }
diff --git a/test/transport.test.js b/test/transport.test.js
@@ -0,0 +1,132 @@
+import assert from "node:assert/strict";
+import { after, describe, it } from "node:test";
+import { Transform } from "stream";
+import { MockAgent, setGlobalDispatcher } from "undici";
+import createTransport, { sendMsgToTg } from "../index.js";
+
+const API_URL = "https://api.telegram.org";
+const chatId = -1234567890;
+const incorrectChatId = -9876543210;
+const botToken = "123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew11";
+const incorrectBotToken = "123456:ABC-DEF1234ghIkl-zyx57W2v1u123ew12";
+const text = "Test message";
+const incorrectText = "?/:,*~@#$%^&()-+=_<.>|";
+const extra = {
+  parse_mode: "HTML",
+};
+const incorrectExtra = {
+  parse_mode: "hHtml",
+};
+
+const mockAgent = new MockAgent({ connections: 1 });
+setGlobalDispatcher(mockAgent);
+
+const mockClient = mockAgent.get(API_URL);
+
+mockClient
+  .intercept({
+    path: `/bot${botToken}/sendMessage`,
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({
+      chat_id: chatId,
+      text: text,
+      ...extra,
+    }),
+  })
+  .reply(200, JSON.stringify({ ok: true, result: text }));
+
+mockClient
+  .intercept({
+    path: `/bot${botToken}/sendMessage`,
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({
+      chat_id: incorrectChatId,
+      text: text,
+      ...extra,
+    }),
+  })
+  .reply(400, "Bad Request");
+
+mockClient
+  .intercept({
+    path: `/bot${incorrectBotToken}/sendMessage`,
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({
+      chat_id: chatId,
+      text: text,
+      ...extra,
+    }),
+  })
+  .reply(401, "Unauthorized");
+
+mockClient
+  .intercept({
+    path: `/bot${botToken}/sendMessage`,
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({
+      chat_id: chatId,
+      text: incorrectText,
+      ...extra,
+    }),
+  })
+  .reply(400, "Bad Request");
+
+mockClient
+  .intercept({
+    path: `/bot${botToken}/sendMessage`,
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({
+      chat_id: chatId,
+      text: text,
+      ...incorrectExtra,
+    }),
+  })
+  .reply(400, "Bad Request");
+
+describe("pino-telegram-webhook", () => {
+  it("build transport", async () => {
+    const transport = await createTransport({ chatId, botToken, extra });
+    assert.ok(transport instanceof Transform, "Failed to build transport.");
+  });
+
+  describe("send message to telegram", () => {
+    after(async () => await mockClient.close());
+
+    it("wrong chat ID", () => {
+      assert.rejects(
+        async () => await sendMsgToTg(incorrectChatId, botToken, text, extra),
+        new Error("400: Bad Request")
+      );
+    });
+
+    it("wrong bot token", () => {
+      assert.rejects(
+        async () => await sendMsgToTg(chatId, incorrectBotToken, text, extra),
+        new Error("401: Unauthorized")
+      );
+    });
+
+    it("wrong text", () => {
+      assert.rejects(
+        async () => await sendMsgToTg(chatId, botToken, incorrectText, extra),
+        new Error("400: Bad Request")
+      );
+    });
+
+    it("wrong extra", () => {
+      assert.rejects(
+        async () => await sendMsgToTg(chatId, botToken, text, incorrectExtra),
+        new Error("400: Bad Request")
+      );
+    });
+
+    it("success sent", async () => {
+      await sendMsgToTg(chatId, botToken, text, extra);
+    });
+  });
+});