feat: flow item on telegram (#231)

Author: hmbanan666

apps/core-telegram/server/services/queue/index.ts

@@ -1,4 +1,4 @@
-import type { EventHandlerMap, NotificationUserBeaconOnEpicCommentCreated, TicketMessageCreated } from '@roll-stack/queue'
+import type { EventHandlerMap, FlowItemCreated, NotificationUserBeaconOnEpicCommentCreated, TicketMessageCreated } from '@roll-stack/queue'
 import { db } from '@roll-stack/database'
 import { queue } from '@roll-stack/queue'
 import { useAtriumBot } from '../telegram/atrium-bot'
@@ -10,6 +10,7 @@ export async function setupConsumers() {
   return queue.consume<EventHandlerMap>(queue.telegram.name, {
     ticketMessageCreated: handleTicketMessageCreated,
     notificationUserBeaconOnEpicCommentCreated: handleUserBeaconOnEpicCommentCreated,
+    flowItemCreated: handleFlowItemCreated,
   })
 }
 
@@ -59,3 +60,31 @@ async function handleUserBeaconOnEpicCommentCreated(data: NotificationUserBeacon
     return false
   }
 }
+
+async function handleFlowItemCreated(data: FlowItemCreated['data']): Promise<boolean> {
+  try {
+    const separator = 'zzzzz'
+    const startAppData = `flow${separator}${data.itemId}`
+
+    // Get first words
+    const messageIntro = data.description.split(' ').slice(0, 45).join(' ')
+    const preparedMessage = `${messageIntro}...\n\nОстальное в Атриуме 🙃`
+
+    await useAtriumBot().api.sendMessage(telegram.teamGroupId, preparedMessage, {
+      link_preview_options: {
+        is_disabled: true,
+      },
+      reply_markup: {
+        inline_keyboard: [[{
+          text: '👉 Открыть Атриум',
+          url: `https://t.me/sushi_atrium_bot/app?startapp=${startAppData}`,
+        }]],
+      },
+    })
+
+    return true
+  } catch (error) {
+    console.error(error)
+    return false
+  }
+}

apps/web-app/server/tasks/ai/daily-report.ts

@@ -61,25 +61,6 @@ export default defineTask({
         title: `Задачи ${date}`,
         description: finalMessage,
       })
-
-      // const separator = 'zzzzz'
-      // const startAppData = `flow${separator}${flowItem?.id}`
-
-      // // Get first words
-      // const messageIntro = finalMessage.split(' ').slice(0, 40).join(' ')
-      // const preparedMessage = `${messageIntro}...\n\nПродолжение внутри Атриума? 🙃`
-
-      // await useAtriumBot().api.sendMessage(telegram.teamGroupId, preparedMessage, {
-      //   link_preview_options: {
-      //     is_disabled: true,
-      //   },
-      //   reply_markup: {
-      //     inline_keyboard: [[{
-      //       text: '👉 Открыть Атриум',
-      //       url: `https://t.me/sushi_atrium_bot/app?startapp=${startAppData}`,
-      //     }]],
-      //   },
-      // })
     } catch (error) {
       errorResolver(error)
     }

apps/web-app/server/tasks/ai/weekly-report.ts

@@ -1,5 +1,7 @@
+import type { FlowItemCreated } from '@roll-stack/queue'
 import process from 'node:process'
 import { db } from '@roll-stack/database'
+import { Events, queue } from '@roll-stack/queue'
 import { format } from 'date-fns'
 import { ru } from 'date-fns/locale/ru'
 import OpenAI from 'openai'
@@ -77,11 +79,19 @@ export default defineTask({
 
       // Flow item
       const week = format(new Date(), 'w', { locale: ru })
-      await db.flow.createItem({
+      const item = await db.flow.createItem({
         type: 'weekly_task_report',
         title: `Задачи за неделю ${week}`,
         description: finalMessage,
       })
+
+      // Push Event
+      await queue.publish<FlowItemCreated>(Events.flowItemCreated, {
+        itemId: item.id,
+        type: item.type,
+        title: item.title,
+        description: item.description ?? '',
+      })
     } catch (error) {
       errorResolver(error)
     }

packages/queue/src/repository/entities/flow.ts

@@ -0,0 +1,12 @@
+import type { Repository } from '@nextorders/queue'
+import { Entity } from '@nextorders/queue'
+
+export class Flow extends Entity {
+  constructor(repository: Repository) {
+    super({
+      name: 'flow',
+      eventsToConsume: [],
+      repository,
+    })
+  }
+}

packages/queue/src/repository/entities/index.ts

@@ -1,3 +1,4 @@
+export { Flow } from './flow'
 export { Notification } from './notification'
 export { Telegram } from './telegram'
 export { Ticket } from './ticket'

packages/queue/src/repository/entities/telegram.ts

@@ -9,6 +9,7 @@ export class Telegram extends Entity {
       eventsToConsume: [
         Events.ticketMessageCreated,
         Events.notificationUserBeaconOnEpicCommentCreated,
+        Events.flowItemCreated,
       ],
       repository,
     })

packages/queue/src/repository/index.ts

@@ -1,7 +1,8 @@
 import { Repository } from '@nextorders/queue'
-import { Notification, Telegram, Ticket } from './entities'
+import { Flow, Notification, Telegram, Ticket } from './entities'
 
 class QueueRepository extends Repository {
+  flow: Flow = new Flow(this)
   notification: Notification = new Notification(this)
   telegram: Telegram = new Telegram(this)
   ticket: Ticket = new Ticket(this)

packages/queue/src/repository/types.ts

@@ -3,9 +3,10 @@ import type { BaseEventMap, BaseEventMessage, BaseEventMessageHandlerMap } from
 export enum Events {
   ticketMessageCreated = 'ticketMessageCreated',
   notificationUserBeaconOnEpicCommentCreated = 'notificationUserBeaconOnEpicCommentCreated',
+  flowItemCreated = 'flowItemCreated',
 }
 
-type EventMessage = TicketMessageCreated | NotificationUserBeaconOnEpicCommentCreated
+type EventMessage = TicketMessageCreated | NotificationUserBeaconOnEpicCommentCreated | FlowItemCreated
 type EventMap = BaseEventMap<EventMessage>
 
 export type EventHandlerMap = Partial<BaseEventMessageHandlerMap<EventMap>>
@@ -35,3 +36,13 @@ type NotificationUserBeaconOnEpicCommentCreatedData = {
 export interface NotificationUserBeaconOnEpicCommentCreated extends BaseEventMessage<NotificationUserBeaconOnEpicCommentCreatedData> {
   event: typeof Events.notificationUserBeaconOnEpicCommentCreated
 }
+
+type FlowItemCreatedData = {
+  itemId: string
+  type: string
+  title: string
+  description: string
+}
+export interface FlowItemCreated extends BaseEventMessage<FlowItemCreatedData> {
+  event: typeof Events.flowItemCreated
+}