feat!: telegram profile

apps/telegram-game/auto-imports.d.ts

@@ -70,6 +70,7 @@ declare global {
   const useRoute: typeof import('vue-router')['useRoute']
   const useRouter: typeof import('vue-router')['useRouter']
   const useSlots: typeof import('vue')['useSlots']
+  const useTelegramProfile: typeof import('./src/composables/useTelegramProfile')['useTelegramProfile']
   const useTemplateRef: typeof import('vue')['useTemplateRef']
   const viteConfig: typeof import('./vite.config')['default']
   const watch: typeof import('vue')['watch']

apps/telegram-game/src/App.vue

@@ -8,4 +8,5 @@
 
 <script setup lang="ts">
 useBackButton()
+useTelegramProfile()
 </script>

apps/telegram-game/src/components/Game.vue

@@ -8,31 +8,33 @@
         <div>Энергия: ??</div>
 
         <div class="opacity-15">
-          {{ gameClient.websocketService.socket.status.value }} {{ roomConnected }}
+          {{ game.websocketService.socket.status }} {{ roomConnected }}
         </div>
       </div>
     </div>
   </div>
 </template>
 
 <script setup lang="ts">
+import type { BaseGameAddon } from '@chat-game/game'
 import { initData } from '@telegram-apps/sdk-vue'
 import { gameClient, roomConnected } from '../utils/gameClient'
 
 const data = initData.user()
 const router = useRouter()
 const canvas = ref<HTMLElement>()
+const game = ref<BaseGameAddon>(gameClient)
 const isOpened = ref(false)
 
 onMounted(async () => {
   if (!data?.id) {
     return
   }
 
-  await gameClient.init(data.id.toString())
-  canvas.value?.appendChild(gameClient.app.canvas)
+  await game.value.init(data.id.toString())
+  canvas.value?.appendChild(game.value.app.canvas)
 
-  return () => gameClient.destroy()
+  return () => game.value.destroy()
 })
 
 watch(router.currentRoute, (value) => {

apps/telegram-game/src/composables/useTelegramProfile.ts

@@ -0,0 +1,28 @@
+import { initData } from '@telegram-apps/sdk-vue'
+import { useFetch } from '@vueuse/core'
+
+export function useTelegramProfile() {
+  const user = initData.user()
+
+  const { data } = useFetch(`https://chatgame.space/api/telegram/${user?.id}`, {
+    async onFetchError(ctx) {
+      if (ctx?.data?.statusCode === 404 && user?.id) {
+        await fetch('https://chatgame.space/api/telegram/profile', {
+          method: 'POST',
+          headers: {
+            'Content-Type': 'application/json',
+            'Authorization': `Bearer 123`,
+          },
+          body: JSON.stringify({
+            telegramId: user.id,
+            username: user?.username,
+          }),
+        })
+      }
+
+      return ctx
+    },
+  }).get().json()
+
+  return { profile: data }
+}

apps/telegram-game/src/views/InventoryView.vue

@@ -13,6 +13,7 @@
     </div>
 
     <div class="grid grid-cols-4 gap-2">
+      {{ profile }}
       <div v-for="item in items" :key="item.id" class="tg-section-bg aspect-square p-2 rounded-md">
         <div>Вещь</div>
       </div>
@@ -24,6 +25,7 @@
 import { initData } from '@telegram-apps/sdk-vue'
 
 const data = initData.user()
+const { profile } = useTelegramProfile()
 
 const items = [
   {

apps/website/nuxt.config.ts

@@ -21,6 +21,9 @@ export default defineNuxtConfig({
       ssr: false,
       cors: true,
     },
+    '/api/**': {
+      cors: true,
+    },
   },
   devtools: { enabled: true },
   devServer: {

apps/website/prisma/schema.prisma

@@ -25,6 +25,8 @@ model Profile {
   storytellerPoints  Int                @default(0) @map("storyteller_points")
   collectorPoints    Int                @default(0) @map("collector_points")
   activeEditionId    String             @map("active_edition_id")
+  telegramProfileId  String?            @unique @map("telegram_profile_id")
+  telegramProfile    TelegramProfile?   @relation(fields: [telegramProfileId], references: [id])
   posts              Post[]
   quests             Quest[]
   questEditions      QuestEdition[]
@@ -38,6 +40,20 @@ model Profile {
   @@map("profile")
 }
 
+model TelegramProfile {
+  id         String   @id
+  createdAt  DateTime @default(now()) @map("created_at")
+  updatedAt  DateTime @default(now()) @map("updated_at")
+  telegramId String   @map("telegram_id")
+  level      Int      @default(1)
+  coins      Int      @default(0)
+  energy     Int      @default(0)
+  username   String?
+  profile    Profile?
+
+  @@map("telegram_profile")
+}
+
 model Payment {
   id         String   @id
   createdAt  DateTime @default(now()) @map("created_at")

apps/website/server/api/telegram/[telegramId].get.ts

@@ -0,0 +1,21 @@
+export default defineEventHandler(async (event) => {
+  try {
+    const telegramId = getRouterParam(event, 'telegramId')
+
+    const profile = await prisma.telegramProfile.findFirst({
+      where: { telegramId },
+      include: {
+        profile: true,
+      },
+    })
+    if (!profile) {
+      throw createError({
+        status: 404,
+      })
+    }
+
+    return profile
+  } catch (error) {
+    throw errorResolver(error)
+  }
+})

apps/website/server/api/telegram/profile/[id].get.ts

@@ -0,0 +1,18 @@
+export default defineEventHandler(async (event) => {
+  try {
+    const id = getRouterParam(event, 'id')
+
+    const profile = await prisma.telegramProfile.findFirst({
+      where: { id },
+    })
+    if (!profile) {
+      throw createError({
+        status: 404,
+      })
+    }
+
+    return profile
+  } catch (error) {
+    throw errorResolver(error)
+  }
+})

apps/website/server/api/telegram/profile/index.post.ts

@@ -0,0 +1,27 @@
+import { DBRepository } from '../../../utils/repository'
+
+export default defineEventHandler(async (event) => {
+  try {
+    const body = await readBody(event)
+
+    if (!body.telegramId) {
+      throw createError({
+        statusCode: 400,
+        message: 'You must provide telegramId',
+      })
+    }
+
+    const repository = new DBRepository()
+    const profile = await repository.findOrCreateTelegramProfile({
+      telegramId: body.telegramId,
+      username: body.username,
+    })
+
+    return {
+      ok: true,
+      result: profile,
+    }
+  } catch (error) {
+    throw errorResolver(error)
+  }
+})

apps/website/server/utils/error.ts

@@ -0,0 +1,17 @@
+import { H3Error } from 'h3'
+
+const logger = useLogger('error')
+
+export function errorResolver(exception: unknown) {
+  if (exception instanceof H3Error) {
+    throw exception
+  }
+
+  // Ok, something intereresting happened
+  logger.error(exception)
+
+  return createError({
+    statusCode: 500,
+    statusMessage: 'Internal server error',
+  })
+}

apps/website/server/utils/repository.ts

@@ -4,6 +4,7 @@ import type {
   Profile,
   ProfileWithTokens,
   QuestEdition,
+  TelegramProfile,
   TwitchAccessToken,
   TwitchToken,
 } from '@chat-game/types'
@@ -107,6 +108,52 @@ export class DBRepository {
     return profile
   }
 
+  async findOrCreateTelegramProfile({ telegramId, username }: { telegramId: string, username?: string }) {
+    const profile = await prisma.telegramProfile.findFirst({
+      where: { telegramId },
+    })
+    if (!profile) {
+      const telegramProfileId = createId()
+      const profileId = createId()
+      const editionId = createId()
+
+      const createdProfile: TelegramProfile = await prisma.telegramProfile.create({
+        data: {
+          id: telegramProfileId,
+          telegramId,
+          username,
+          energy: 10,
+        },
+      })
+
+      const mainProfile = await this.findOrCreateProfile({
+        userId: profileId,
+        userName: `tg_${telegramId}`,
+      })
+
+      // Telegramo
+      const edition = await prisma.characterEdition.create({
+        data: {
+          id: editionId,
+          profileId: mainProfile.id,
+          characterId: 'c3hrpu39wodc2nlv6pmgmm2k',
+        },
+      })
+
+      await prisma.profile.update({
+        where: { id: mainProfile.id },
+        data: {
+          telegramProfileId,
+          activeEditionId: edition.id,
+        },
+      })
+
+      return createdProfile
+    }
+
+    return profile
+  }
+
   async findCharacterByEditionId(editionId: string): Promise<CharacterEditionWithCharacter> {
     const char = await prisma.characterEdition.findFirst({
       where: { id: editionId },

packages/types/src/lib/types.ts

@@ -3,6 +3,7 @@ export interface Profile {
   createdAt: Date
   updatedAt: Date
   twitchId: string
+  telegramProfileId: string | null
   userName: string
   isStreamer: boolean
   coupons: number
@@ -42,6 +43,17 @@ export interface ProfileCreateResponse {
   result: Profile
 }
 
+export interface TelegramProfile {
+  id: string
+  createdAt: Date
+  updatedAt: Date
+  telegramId: string
+  username: string | null
+  level: number
+  coins: number
+  energy: number
+}
+
 export interface TokenCreateRequest {
   data: {
     code: string