feat: TG Informer services and clients

.github/workflows/todo-to-issue.yml

@@ -0,0 +1,13 @@
+name: "Run TODO to Issue"
+on: ["push"]
+jobs:
+    build:
+        runs-on: "ubuntu-latest"
+        steps:
+            - uses: "actions/checkout@v3"
+            - name: "TODO to Issue"
+              uses: "alstr/todo-to-issue-action@v4"
+              with:
+                PROJECTS_SECRET: ${{ secrets.TODO_TO_ISSUE }}
+                INPUT_GITHUB_URL: "https://github.com/"
+                IDENTIFIERS: '[{"name": "@TODO", "labels": []}]'

.husky/pre-commit

@@ -0,0 +1,7 @@
+#!/bin/sh
+. "$(dirname "$0")/_/husky.sh"
+
+localPath=$(echo $PATH)
+export PATH=$localPath
+
+yarn lint-staged

.vscode/launch.json

@@ -55,6 +55,15 @@
       "port": 9227,
       "skipFiles": ["${workspaceRoot}/node_modules/**/*", "<node_internals>/**/*.js"]
     },
+    {
+      "type": "node",
+      "request": "attach",
+      "name": "WEB: Attach by Process ID",
+      "cwd": "${workspaceRoot}/web/src",
+      "trace": true,
+      "port": 9229,
+      "skipFiles": ["${workspaceRoot}/node_modules/**/*", "<node_internals>/**/*.js"]
+    },
     {
       "type": "node",
       "request": "launch",

.vscode/settings.json

@@ -1,3 +1,7 @@
 {
-    "python.pythonPath": "infra/.venv/bin/python"
+    "editor.codeActionsOnSave": {
+        "source.organizeImports": false,
+        "source.fixAll": true,
+        "source.fixAll.stylelint": true
+     }
 }

bot/package.json

@@ -16,6 +16,7 @@
     "@grpc/grpc-js": "^1.8.9",
     "express": "^4.18.2",
     "i18next": "^22.4.10",
+    "jsonwebtoken": "^9.0.0",
     "moment": "^2.29.4",
     "node-telegram-bot-api": "^0.61.0",
     "stream-chat": "^8.4.0",

bot/src/commands/campaign/create.ts

@@ -0,0 +1,62 @@
+import { findUserByTelegramUserId } from "@rapydbot/user";
+import { createCampaign } from "@rapydbot/campaign";
+import jwt from "jsonwebtoken";
+
+import { IBotCommand } from "../types";
+import { TGInformerBot } from "../../tg-informer";
+import { CustomMessage } from "../../types";
+import { translationKeys } from "../../i18n";
+
+export class CreateCampaignCommand implements IBotCommand {
+  private bot: TGInformerBot;
+
+  constructor(bot: TGInformerBot) {
+    this.bot = bot;
+  }
+
+  async onText(msg: CustomMessage) {
+    await this.createCampaign(msg);
+  }
+
+  private async createCampaign(msg: CustomMessage): Promise<void> {
+    try {
+      const { userId } = await findUserByTelegramUserId(this.bot.clients.user, {
+        telegramFromUserId: msg.from.id,
+      });
+
+      const { campaignId } = await createCampaign(this.bot.clients.campaign, {
+        issuerId: userId,
+      });
+
+      const token = jwt.sign(
+        {
+          userId,
+        },
+        process.env.JWT_SECRET,
+      );
+
+      // @TODO i18n
+      this.bot.reply(msg, `¡Campaña creada!`, {
+        reply_markup: {
+          inline_keyboard: [
+            [
+              {
+                text: `Editar Campaña`,
+                url: `http://tgi.com:3004/campaign/edit/${campaignId}?token=${token}`,
+              },
+            ],
+          ],
+        },
+      });
+    } catch (error) {
+      console.log(error);
+
+      this.handleErrorReply(error, msg);
+    }
+  }
+
+  private handleErrorReply(error: Error, msg: CustomMessage) {
+    // @TODO handle error codes switch
+    return this.bot.replyWithTranslation(msg, translationKeys.start_command_error);
+  }
+}

bot/src/commands/start.ts

@@ -1,48 +1,41 @@
-import { CreateUserRequest } from "@rapydbot/user/client";
+import { findUserByTelegramUserIdOrCreateUser } from "@rapydbot/user";
 
-import { Bot } from "../Bot";
+import { TGInformerBot } from "../tg-informer";
 import { translationKeys } from "../i18n";
 import { CustomMessage } from "../types";
 
 import { IBotCommand } from "./types";
 
 export class StartCommand implements IBotCommand {
-  private bot: Bot;
+  private bot: TGInformerBot;
 
-  constructor(bot: Bot) {
+  constructor(bot: TGInformerBot) {
     this.bot = bot;
   }
 
   async onText(msg: CustomMessage) {
     try {
-      await this.findUserByTelegramUserIdOrCreateUser(msg);
+      await this.createUser(msg);
     } catch (error) {
       this.handleErrorReply(error, msg);
     }
   }
 
-  private async findUserByTelegramUserIdOrCreateUser(msg: CustomMessage): Promise<void> {
-    return new Promise((resolve, reject) => {
-      const createUserRequest = new CreateUserRequest();
-
-      createUserRequest.setTelegramFromUserId(msg.from.id);
-      createUserRequest.setTelegramUsername(msg.from.username);
-
-      if (msg.chat.type === "private") {
-        createUserRequest.setTelegramPrivateChatId(msg.chat.id);
-      }
-
-      this.bot.clients.user.findUserByTelegramUserIdOrCreateUser(
-        createUserRequest,
-        (err, _reply) => {
-          if (Boolean(err)) {
-            return reject(err);
-          }
-
-          resolve();
-        },
-      );
+  private async createUser(msg: CustomMessage): Promise<void> {
+    await findUserByTelegramUserIdOrCreateUser(this.bot.clients.user, {
+      telegramFromUserId: msg.from.id,
+      telegramUsername: msg.from.username,
+      telegramPrivateChatId: msg.chat.type === "private" ? msg.chat.id : undefined,
     });
+
+    // @TODO i18n
+    this.bot.reply(
+      msg,
+      `Guardamos tus coordenadas periódicamente para asignarte campañas de manera eficiente.`,
+      {
+        reply_markup: { keyboard: [[{ text: `Compartir Coordenadas`, request_location: true }]] },
+      },
+    );
   }
 
   private handleErrorReply(error: Error, msg: CustomMessage) {