fix: avatar upload (#219)

* fix: avatar upload

* chore: logger on photos

* fix: type

Author: hmbanan666

apps/core-telegram/server/services/telegram/atrium-bot.ts

@@ -113,7 +113,7 @@ async function handleContact(ctx: Context) {
       userId: user.id,
     })
 
-    logger.log('new user', createdTelegramUser)
+    logger.log('New Telegram user', createdTelegramUser)
 
     await ctx.setChatMenuButton({
       chat_id: ctx.message.chat.id,
@@ -157,6 +157,8 @@ async function getAndUploadUserPhoto(ctx: Context, botToken: string): Promise<st
   }
 
   const photos = await ctx.api.getUserProfilePhotos(ctx.message.from.id)
+  logger.log(`User ${ctx.message.from.id} have ${photos.total_count} photos:`, JSON.stringify(photos.photos))
+
   const userPhoto = photos.photos[0]?.pop()
   if (userPhoto?.file_id) {
     const fileDownloadUrl = await getFileDownloadUrl({ ctx, fileId: userPhoto.file_id, botToken, isLocalBot: false })
@@ -180,14 +182,17 @@ async function findOrCreateAtriumUser(data: { phone: string, user: { name: strin
     const avatarUrl = await getAndUploadUserPhoto(data.ctx, data.botToken)
     logger.log('New user avatar', avatarUrl)
 
-    return db.user.create({
+    const createdUser = await db.user.create({
       id,
       phone: data.phone,
       type: 'staff',
       name: data.user.name,
       surname: data.user.surname,
       avatarUrl: avatarUrl ?? defaultAvatarUrl,
     })
+    logger.log('New user', createdUser)
+
+    return createdUser
   }
 
   return userInDB

apps/core-telegram/server/services/telegram/common.ts

@@ -1,4 +1,5 @@
 import type { Context } from 'grammy'
+import { Buffer } from 'node:buffer'
 import fs from 'node:fs/promises'
 import { db } from '@roll-stack/database'
 import { useAtriumBot } from './atrium-bot'
@@ -59,12 +60,13 @@ export async function uploadToStorage(downloadUrl: string, fileId: string) {
   try {
     const extension = downloadUrl.split('.').pop()
 
-    let buffer
+    let buffer: Buffer
 
     if (downloadUrl.startsWith('http://') || downloadUrl.startsWith('https://')) {
       // Download file
       const response = await fetch(downloadUrl)
-      buffer = await response.arrayBuffer()
+      const arrayBuffer = await response.arrayBuffer()
+      buffer = Buffer.from(arrayBuffer)
     } else {
       // Read file
       buffer = await fs.readFile(downloadUrl)
@@ -96,11 +98,15 @@ export async function getFileDownloadUrl(data: { ctx: Context, fileId: string, b
 
     // as /var/lib/bot/token/documents/file_id.ext
     if (data.isLocalBot) {
+      logger.log('getFileDownloadUrl: local mode', file.file_path)
       return file.file_path
     }
 
     // or from telegram api
-    return `https://api.telegram.org/file/bot${data.botToken}/${file.file_path}`
+    const telegramServerUrl = `https://api.telegram.org/file/bot${data.botToken}/${file.file_path}`
+    logger.log('getFileDownloadUrl: remote mode', telegramServerUrl)
+
+    return telegramServerUrl
   } catch (e) {
     logger.error('getFileDownloadUrl', e)
     return null