feat: telegram core service (#168)

* feat: telegram core service

* fix: css

Author: hmbanan666

.github/workflows/docker-nightly.yml

@@ -26,7 +26,7 @@ jobs:
       - name: Set matrix
         id: set-matrix
         run: |
-          APPS=("web-app" "web-storefront" "web-parser" "atrium-telegram" "storefront-telegram")
+          APPS=("web-app" "web-storefront" "web-parser" "atrium-telegram" "storefront-telegram" "core-telegram")
           CHANGED=()
 
           if [ "${{ github.event_name }}" == "workflow_dispatch" ]; then

.github/workflows/docker-release.yml

@@ -33,7 +33,7 @@ jobs:
       - name: Set package in env
         id: set-package
         run: |
-          APPS=("web-app" "web-storefront" "web-parser" "atrium-telegram" "storefront-telegram")
+          APPS=("web-app" "web-storefront" "web-parser" "atrium-telegram" "storefront-telegram" "core-telegram")
           MATCH="${{ steps.regex-match.outputs.match }}"
 
           if [ -z "$MATCH" ]; then

apps/core-telegram/.env.example

@@ -0,0 +1,27 @@
+# Main database
+DATABASE_URL=
+
+# Queue
+QUEUE_URL=
+
+# S3 file storage
+NUXT_S3_ACCESS_KEY_ID=
+NUXT_S3_BUCKET=
+NUXT_S3_ENDPOINT=
+NUXT_S3_REGION=
+NUXT_S3_SECRET_ACCESS_KEY=
+
+# URL to media server (probably s3 bucket with static URL)
+NUXT_PUBLIC_MEDIA_URL=
+
+# Telegram
+NUXT_TELEGRAM_LOCAL_BOT_API_SERVER_URL=
+NUXT_TELEGRAM_ADMIN_ID=
+NUXT_TELEGRAM_WASABI_BOT_ID=
+NUXT_TELEGRAM_ATRIUM_BOT_ID=
+NUXT_TELEGRAM_ORDER_BOT_ID=
+NUXT_TELEGRAM_TEAM_GROUP_ID=
+NUXT_TELEGRAM_FILES_GROUP_ID=
+
+# App version
+VERSION=

apps/core-telegram/nuxt.config.ts

@@ -0,0 +1,27 @@
+export default defineNuxtConfig({
+  devtools: {
+    componentInspector: false,
+  },
+  runtimeConfig: {
+    s3: {
+      bucket: '',
+      region: '',
+      endpoint: '',
+      accessKeyId: '',
+      secretAccessKey: '',
+    },
+    telegram: {
+      localBotApiServerUrl: '',
+      wasabiBotId: '',
+      atriumBotId: '',
+      orderBotId: '',
+      adminId: '',
+      teamGroupId: '',
+      filesGroupId: '',
+    },
+    public: {
+      mediaUrl: '',
+    },
+  },
+  compatibilityDate: '2025-02-20',
+})

apps/core-telegram/package.json

@@ -0,0 +1,30 @@
+{
+  "name": "@roll-stack/core-telegram",
+  "type": "module",
+  "version": "0.0.0",
+  "private": true,
+  "scripts": {
+    "build": "nuxt build",
+    "dev": "nuxt dev --port 3502",
+    "preview": "PORT=3502 nuxt preview",
+    "clean": "rm -rf .output",
+    "clean:modules": "rm -rf .nuxt node_modules",
+    "typecheck": "nuxt typecheck",
+    "postinstall": "nuxt prepare"
+  },
+  "dependencies": {
+    "@roll-stack/database": "workspace:*",
+    "@roll-stack/queue": "workspace:*",
+    "@roll-stack/ui": "workspace:*",
+    "arktype": "catalog:",
+    "aws4fetch": "catalog:",
+    "date-fns": "catalog:",
+    "grammy": "catalog:",
+    "libphonenumber-js": "catalog:",
+    "sharp": "catalog:"
+  },
+  "devDependencies": {
+    "@types/node": "catalog:",
+    "nuxt": "catalog:"
+  }
+}

apps/core-telegram/server/api/health/index.get.ts

@@ -0,0 +1,11 @@
+import { repository } from '@roll-stack/database'
+
+export default defineEventHandler(async () => {
+  try {
+    await repository.checkHealth()
+
+    return { ok: true }
+  } catch (error) {
+    throw errorResolver(error)
+  }
+})

apps/core-telegram/server/middleware/01.auth.ts

@@ -0,0 +1,61 @@
+import type { User } from '@roll-stack/database'
+import type { H3Event } from 'h3'
+import { repository } from '@roll-stack/database'
+
+const logger = useLogger('middleware:auth')
+
+const routesWithoutAuth = [
+  '/api/health',
+]
+
+/**
+ * Cover all requests (except the ones without auth)
+ */
+export default defineEventHandler(async (event) => {
+  // Skip if preflight
+  if (event.method === 'OPTIONS') {
+    return
+  }
+
+  // Skip routes without auth
+  if (!event.path.startsWith('/api') || routesWithoutAuth.includes(event.path)) {
+    return
+  }
+
+  const user = await getUserFromToken(event)
+
+  // No auth?
+  if (!user) {
+    throw createError({
+      statusCode: 401,
+      message: 'Unauthorized',
+    })
+  }
+
+  event.context.user = user
+})
+
+async function getUserFromToken(event: H3Event): Promise<User | null> {
+  try {
+    const authToken = getHeader(event, 'Authorization') ?? getHeader(event, 'authorization')
+    if (!authToken) {
+      return null
+    }
+
+    const [_, token] = authToken.split(' ')
+    if (!token) {
+      return null
+    }
+
+    const user = await repository.user.find(token)
+    if (!user?.id) {
+      return null
+    }
+
+    return user
+  } catch (e) {
+    logger.error(e)
+  }
+
+  return null
+}

apps/core-telegram/server/plugins/01.database.ts

@@ -0,0 +1,13 @@
+import process from 'node:process'
+import { useCreateDatabase } from '@roll-stack/database'
+
+/**
+ * DB init
+ */
+export default defineNitroPlugin(async () => {
+  if (!process.env.DATABASE_URL) {
+    throw new Error('DATABASE_URL is not defined')
+  }
+
+  useCreateDatabase(process.env.DATABASE_URL)
+})

apps/core-telegram/server/plugins/02.queue.ts

@@ -0,0 +1,16 @@
+import process from 'node:process'
+import { useCreateConnection } from '@roll-stack/queue'
+import { setupConsumers } from '../services/queue'
+
+/**
+ * Queue init
+ */
+export default defineNitroPlugin(async () => {
+  if (!process.env.QUEUE_URL) {
+    throw new Error('QUEUE_URL is not defined')
+  }
+
+  await useCreateConnection(process.env.QUEUE_URL)
+
+  await setupConsumers()
+})