${p.trim()}

`)\n .join(\"\");\n\n // Body de la issue\n const body: Record = {\n name: task.title,\n description_html: descParagraphs || \"

\",\n state: stateId,\n };\n\n // Només afegir priority si s'ha especificat\n if (task.priority) {\n body.priority = task.priority;\n }\n\n // Només afegir target_date si s'ha especificat\n if (task.target_date) {\n body.target_date = task.target_date;\n }\n\n logger.debug(\"PLANE\", \"Request body\", body);\n\n const response = await fetch(`${PLANE_API_URL}/issues/`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-API-Key\": PLANE_API_KEY,\n },\n body: JSON.stringify(body),\n });\n\n if (!response.ok) {\n const errText = await response.text();\n logger.error(\n \"PLANE\",\n `Error creant issue: HTTP ${response.status}`,\n errText,\n );\n return {\n ok: false,\n error: `HTTP ${response.status}: ${errText.substring(0, 200)}`,\n };\n }\n\n const result = await response.json();\n logger.info(\"PLANE\", \"Tasca creada! ✅\", {\n id: result.id,\n sequence_id: result.sequence_id,\n name: result.name,\n });\n\n return {\n ok: true,\n id: result.id,\n sequenceId: result.sequence_id,\n };\n } catch (err) {\n const errMsg = err instanceof Error ? err.message : \"Desconegut\";\n logger.error(\"PLANE\", `Excepció: ${errMsg}`);\n return { ok: false, error: errMsg };\n }\n}\n\n// ============================================\n// PARSING TASQUES DE LA RESPOSTA DEEPSEEK\n// ============================================\n\ninterface ParsedResponse {\n userMessage: string;\n tasks: PlaneTask[];\n}\n\nfunction parseDeepSeekResponse(rawReply: string): ParsedResponse {\n const tasks: PlaneTask[] = [];\n let userMessage = rawReply;\n\n // Extreure tots els blocs [PLANE_TASK]...[/PLANE_TASK]\n const taskRegex = /\\[PLANE_TASK\\]\\s*([\\s\\S]*?)\\s*\\[\\/PLANE_TASK\\]/g;\n let match;\n\n while ((match = taskRegex.exec(rawReply)) !== null) {\n try {\n const taskData = JSON.parse(match[1].trim());\n tasks.push({\n title: taskData.title || \"Sense títol\",\n description: taskData.description || \"\",\n priority: taskData.priority || null,\n target_date: taskData.target_date || null,\n });\n } catch {\n console.error(\"Error parsejant PLANE_TASK:\", match[1]);\n }\n }\n\n // Eliminar blocs del missatge visible\n userMessage = rawReply.replace(\n /\\[PLANE_TASK\\]\\s*[\\s\\S]*?\\s*\\[\\/PLANE_TASK\\]/g,\n \"\",\n ).trim();\n\n return { userMessage, tasks };\n}\n\n// ============================================\n// FUNCIONS DE DEEPSEEK\n// ============================================\n\nasync function callDeepSeek(\n chatId: number,\n userMessage: string,\n logger: TelegramLogger,\n context?: string,\n): Promise {\n logger.info(\"DEEPSEEK\", \"Enviant petició\", {\n chars: userMessage.length,\n preview: userMessage.substring(0, 100),\n });\n\n const messages: Array<{ role: string; content: string }> = [\n { role: \"system\", content: SYSTEM_PROMPT },\n ];\n\n if (context) {\n messages.push({\n role: \"system\",\n content:\n `Context addicional: L'usuari ha enviat un àudio que ha estat transcrit. La transcripció és el missatge que rebràs. Respon al contingut de la transcripció de forma natural.`,\n });\n }\n\n // Historial\n const history = getHistory(chatId);\n if (history.length > 0) {\n logger.info(\"DEEPSEEK\", `Historial: ${history.length} msgs`);\n for (const msg of history) {\n messages.push({ role: msg.role, content: msg.content });\n }\n }\n\n messages.push({ role: \"user\", content: userMessage });\n\n const startTime = Date.now();\n const response = await fetch(\"https://api.deepseek.com/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${DEEPSEEK_API_KEY}`,\n },\n body: JSON.stringify({\n model: \"deepseek-chat\",\n messages,\n max_tokens: 2048,\n temperature: 0.7,\n }),\n });\n\n const elapsed = Date.now() - startTime;\n\n if (!response.ok) {\n const errorText = await response.text();\n logger.error(\"DEEPSEEK\", `HTTP ${response.status}`, { error: errorText });\n throw new Error(`DeepSeek API error: ${response.status}`);\n }\n\n const data = await response.json();\n if (!data.choices?.[0]?.message?.content) {\n logger.error(\"DEEPSEEK\", \"Resposta buida\", data);\n throw new Error(\"DeepSeek: resposta buida\");\n }\n\n const reply = data.choices[0].message.content;\n const usage = data.usage;\n\n logger.info(\"DEEPSEEK\", `Resposta (${elapsed}ms)`, {\n tokens_in: usage?.prompt_tokens,\n tokens_out: usage?.completion_tokens,\n total: usage?.total_tokens,\n });\n\n // Guardar a historial (sense blocs PLANE_TASK)\n const { userMessage: cleanReply } = parseDeepSeekResponse(reply);\n addToHistory(chatId, \"user\", userMessage);\n addToHistory(chatId, \"assistant\", cleanReply);\n logger.info(\"MEMORY\", `Historial: ${getHistory(chatId).length} msgs`);\n\n return reply; // Retornem raw per processar tasques\n}\n\n// ============================================\n// PROCESSA RESPOSTA (text + tasques Plane)\n// ============================================\n\nasync function processAiReply(\n chatId: number,\n rawReply: string,\n logger: TelegramLogger,\n): Promise {\n const { userMessage, tasks } = parseDeepSeekResponse(rawReply);\n\n // 1. Enviar missatge visible\n await sendMessage(chatId, `🤖 ${userMessage || \"✅\"}`);\n\n // 2. Crear tasques a Plane si n'hi ha\n if (tasks.length > 0) {\n logger.info(\"PLANE\", `${tasks.length} tasca/es detectada/es`);\n\n for (const task of tasks) {\n const result = await createPlaneIssue(task, logger);\n\n if (result.ok) {\n let confirmMsg = `📋 *Tasca creada a Plane!*\\n\\n`;\n confirmMsg += `📌 *${task.title}*\\n`;\n confirmMsg += `📊 Estat: Backlog\\n`;\n if (task.priority) confirmMsg += `🔺 Prioritat: ${task.priority}\\n`;\n if (task.target_date) {\n confirmMsg += `📅 Data límit: ${task.target_date}\\n`;\n }\n if (result.sequenceId) confirmMsg += `🔢 ID: #${result.sequenceId}\\n`;\n confirmMsg +=\n `\\n🔗 [Obrir projecte a Plane](${PLANE_BASE_URL}/${PLANE_WORKSPACE}/projects/${PLANE_PROJECT_ID}/issues/)`;\n\n await sendMessage(chatId, confirmMsg);\n } else {\n await sendMessage(\n chatId,\n `⚠️ Error creant tasca \"${task.title}\": ${result.error}`,\n );\n }\n }\n }\n}\n\n// ============================================\n// HANDLERS\n// ============================================\n\nasync function handleVoiceMessage(\n chatId: number,\n voice: { file_id: string; duration: number },\n logger: TelegramLogger,\n) {\n logger.info(\"HANDLER\", \"Veu rebuda\", { duration: `${voice.duration}s` });\n\n const waitMsg = await sendMessage(chatId, `🎤 Transcrivint... 🇦🇩`);\n await sendChatAction(chatId, \"typing\");\n\n try {\n const fileInfo = await getFile(voice.file_id);\n if (!fileInfo.ok || !fileInfo.result?.file_path) {\n throw new Error(\"No s'ha pogut obtenir el fitxer\");\n }\n\n const audioBuffer = await downloadFile(fileInfo.result.file_path);\n logger.info(\"TELEGRAM\", \"Àudio descarregat\", {\n size: `${(audioBuffer.byteLength / 1024).toFixed(1)}KB`,\n });\n\n const transcript = await transcribeAudio(audioBuffer, \"voice.ogg\", logger);\n\n if (waitMsg.result?.message_id) {\n await editMessage(\n chatId,\n waitMsg.result.message_id,\n `🎤 *Transcripció:*\\n\\n_${transcript}_`,\n );\n }\n\n await sendChatAction(chatId, \"typing\");\n const aiReply = await callDeepSeek(\n chatId,\n transcript,\n logger,\n \"audio_transcription\",\n );\n await processAiReply(chatId, aiReply, logger);\n\n logger.info(\"HANDLER\", \"Àudio processat ✅\");\n } catch (error) {\n const errMsg = error instanceof Error ? error.message : \"Desconegut\";\n logger.error(\"HANDLER\", `Error veu: ${errMsg}`);\n if (waitMsg.result?.message_id) {\n await editMessage(\n chatId,\n waitMsg.result.message_id,\n `❌ Error: ${errMsg}`,\n { reply_markup: MAIN_KEYBOARD },\n );\n }\n }\n}\n\nasync function handleAudioFile(\n chatId: number,\n audio: { file_id: string; file_name?: string },\n logger: TelegramLogger,\n) {\n logger.info(\"HANDLER\", \"Àudio rebut\", { filename: audio.file_name });\n\n const waitMsg = await sendMessage(chatId, `🎵 Transcrivint... 🇦🇩`);\n await sendChatAction(chatId, \"typing\");\n\n try {\n const fileInfo = await getFile(audio.file_id);\n if (!fileInfo.ok || !fileInfo.result?.file_path) {\n throw new Error(\"No s'ha pogut obtenir el fitxer\");\n }\n\n const audioBuffer = await downloadFile(fileInfo.result.file_path);\n logger.info(\"TELEGRAM\", \"Àudio descarregat\", {\n size: `${(audioBuffer.byteLength / 1024).toFixed(1)}KB`,\n });\n\n const transcript = await transcribeAudio(\n audioBuffer,\n audio.file_name || \"audio.ogg\",\n logger,\n );\n\n if (waitMsg.result?.message_id) {\n await editMessage(\n chatId,\n waitMsg.result.message_id,\n `🎵 *Transcripció:*\\n\\n_${transcript}_`,\n );\n }\n\n await sendChatAction(chatId, \"typing\");\n const aiReply = await callDeepSeek(\n chatId,\n transcript,\n logger,\n \"audio_transcription\",\n );\n await processAiReply(chatId, aiReply, logger);\n\n logger.info(\"HANDLER\", \"Àudio processat ✅\");\n } catch (error) {\n const errMsg = error instanceof Error ? error.message : \"Desconegut\";\n logger.error(\"HANDLER\", `Error àudio: ${errMsg}`);\n if (waitMsg.result?.message_id) {\n await editMessage(\n chatId,\n waitMsg.result.message_id,\n `❌ Error: ${errMsg}`,\n { reply_markup: MAIN_KEYBOARD },\n );\n }\n }\n}\n\nasync function handleTextMessage(\n chatId: number,\n text: string,\n logger: TelegramLogger,\n) {\n // Comandes\n if (text === \"/start\" || text === \"/menu\") {\n logger.info(\"HANDLER\", `Comanda ${text}`);\n await sendMessage(\n chatId,\n `🤖 *Bot de Transcripció, IA i Plane*\\n\\n📝 Envia *text* → IA respon\\n🎤 Envia *àudio* → Transcriu + IA\\n📋 Demana *crear tasca* → Plane (Backlog)`,\n { reply_markup: MAIN_KEYBOARD },\n );\n return;\n }\n\n if (text === \"/clear\") {\n clearHistory(chatId);\n logger.info(\"HANDLER\", \"Historial esborrat\");\n await sendMessage(chatId, `🧹 Memòria esborrada. Comencem de zero!`);\n return;\n }\n\n if (text === \"/help\") {\n logger.info(\"HANDLER\", \"Comanda help\");\n await sendMessage(\n chatId,\n `ℹ️ *Ajuda*\\n\\n` +\n `📝 Envia un *text* → Et respondré amb IA\\n` +\n `🎤 Envia un *àudio* → El transcriuré i respondré\\n` +\n `📋 Demana *\"crea una tasca per...\"* → La creo a Plane al Backlog\\n\\n` +\n `Pots especificar *prioritat* (urgent/alta/mitja/baixa) i *data límit* i es crearà amb aquests paràmetres.\\n\\n` +\n `*Comandes:*\\n` +\n `/start — Menú principal\\n` +\n `/clear — Esborrar memòria\\n` +\n `/help — Aquesta ajuda`,\n );\n return;\n }\n\n // Text normal → DeepSeek + possiblement Plane\n logger.info(\"HANDLER\", \"Text rebut\", {\n chars: text.length,\n preview: text.substring(0, 80),\n });\n await sendChatAction(chatId, \"typing\");\n\n try {\n const aiReply = await callDeepSeek(chatId, text, logger);\n await processAiReply(chatId, aiReply, logger);\n logger.info(\"HANDLER\", \"Text processat ✅\");\n } catch (error) {\n const errMsg = error instanceof Error ? error.message : \"Desconegut\";\n logger.error(\"HANDLER\", `Error: ${errMsg}`);\n await sendMessage(chatId, `❌ Error generant resposta: ${errMsg}`);\n }\n}\n\nasync function handleCallback(\n callbackQueryId: string,\n chatId: number,\n messageId: number,\n data: string,\n logger: TelegramLogger,\n) {\n logger.info(\"CALLBACK\", `Rebut: ${data}`);\n await answerCallbackQuery(callbackQueryId);\n}\n\n// ============================================\n// HANDLER PRINCIPAL\n// ============================================\n\nexport default async function handler(req: Request): Promise {\n if (!TELEGRAM_TOKEN || !GLADIA_API_KEY || !DEEPSEEK_API_KEY) {\n return new Response(\"Bot no configurat (falten variables d'entorn)\", {\n status: 500,\n });\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"🤖 Bot actiu — Transcripció + IA + Plane\", {\n status: 200,\n });\n }\n\n const logger = new TelegramLogger();\n\n try {\n const update = await req.json();\n logger.info(\"REQUEST\", \"Update rebut\", { update_id: update.update_id });\n\n if (update.message) {\n const chatId = update.message.chat.id;\n const from = update.message.from;\n logger.setChatId(chatId);\n\n logger.info(\"USER\", \"Missatge\", {\n chat_id: chatId,\n user: from?.first_name || from?.username,\n type: update.message.voice\n ? \"voice\"\n : update.message.audio\n ? \"audio\"\n : \"text\",\n });\n\n if (update.message.voice) {\n await handleVoiceMessage(chatId, update.message.voice, logger);\n await logger.flush();\n return new Response(\"OK\", { status: 200 });\n }\n\n if (update.message.audio) {\n await handleAudioFile(chatId, update.message.audio, logger);\n await logger.flush();\n return new Response(\"OK\", { status: 200 });\n }\n\n if (update.message.text) {\n await handleTextMessage(chatId, update.message.text, logger);\n await logger.flush();\n return new Response(\"OK\", { status: 200 });\n }\n\n logger.warn(\"HANDLER\", \"Tipus no suportat\");\n await sendMessage(chatId, `🤖 Envia'm *text* o *àudio*!`, {\n reply_markup: MAIN_KEYBOARD,\n });\n }\n\n if (update.callback_query) {\n const query = update.callback_query;\n logger.setChatId(query.message?.chat?.id);\n await handleCallback(\n query.id,\n 0,\n 0,\n query.data,\n logger,\n );\n }\n\n await logger.flush();\n return new Response(\"OK\", { status: 200 });\n } catch (error) {\n const errMsg = error instanceof Error ? error.message : \"Desconegut\";\n logger.error(\"FATAL\", `Error: ${errMsg}`);\n await logger.flush();\n console.error(\"Error:\", error);\n return new Response(\"Error\", { status: 500 });\n }\n}","deleted","label",[107],"pulls","branches",1,"forks","envVars",{"_131":133,"_134":39},"connections",{"_131":39,"_132":39},"count","unfilledCount",4,"emptyCount",{"_18":106,"_20":107,"_108":109,"_110":-5,"_111":65,"_112":63,"_113":100,"_22":136,"_62":115,"_116":117,"_118":119,"_120":26,"_121":-5,"_137":138,"_82":139},["D",1770888030636],"children",[],[107],["D",1769383620429],{"_16":17,"_80":76},{"_16":17,"_74":-5,"_75":76,"_32":33,"_77":78,"_79":26},{"_62":63,"_20":64,"_18":65,"_66":19,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":21,"_73":17},"ctx",{"_55":-5,"_102":177,"_178":179,"_180":181,"_182":26,"_183":26,"_184":26,"_185":100,"_186":-5,"_187":-7,"_188":-7,"_189":39,"_190":26,"_191":26,"_192":-5,"_193":26,"_194":26,"_195":26,"_196":-5},"ENV",{"_148":149,"_150":151,"_152":64,"_153":154,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Search