[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_115":-5,"_20":116,"_22":117,"_118":119,"_120":121,"_25":122,"_24":-5,"_123":-5,"_124":-5,"_125":53,"_126":127,"_128":44,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","arbofa","name","TelegramBotTest","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","138b487a-07f4-11f1-8a83-42dde27851f2","bot.ts","fileId","59311b96-fa45-11f0-817f-42dde27851f2","parentId","branchId","592e0d84-fa45-11f0-817f-42dde27851f2","branchVersion",15,"latest",true,"createdAt",["D",1770888030636],14,"fileType","http","content","// Bot de Telegram amb transcripció Gladia + DeepSeek AI + Plane per Val Town\n// Variables d'entorn: TELEGRAM_TOKEN, GLADIA_API_KEY, DEEPSEEK_API_KEY, PLANE_API_KEY\n\nconst TELEGRAM_TOKEN = Deno.env.get(\"TELEGRAM_TOKEN\") || \"\";\nconst GLADIA_API_KEY = Deno.env.get(\"GLADIA_API_KEY\") || \"\";\nconst DEEPSEEK_API_KEY = Deno.env.get(\"DEEPSEEK_API_KEY\") || \"\";\nconst PLANE_API_KEY = Deno.env.get(\"PLANE_API_KEY\") || \"\";\n\nconst TELEGRAM_API = `https://api.telegram.org/bot${TELEGRAM_TOKEN}`;\n\n// ============================================\n// CONFIGURACIÓ DE PLANE\n// ============================================\n\nconst PLANE_BASE_URL = \"https://plane.laremolatxa.cat\";\nconst PLANE_WORKSPACE = \"general\";\nconst PLANE_PROJECT_ID = \"28fa2b0c-cdda-4ee4-8065-3b71bd817e9e\";\nconst PLANE_API_URL =\n `${PLANE_BASE_URL}/api/v1/workspaces/${PLANE_WORKSPACE}/projects/${PLANE_PROJECT_ID}`;\n\n// Cache de l'estat Backlog (es carrega un cop)\nlet backlogStateId: string | null = null;\n\n// ============================================\n// MEMÒRIA DE CONVERSA (últims 10 missatges per chat)\n// ============================================\n\nconst MAX_HISTORY = 10;\n\ninterface ChatMessage {\n role: \"user\" | \"assistant\";\n content: string;\n}\n\nconst conversationHistory = new Map();\n\nfunction getHistory(chatId: number): ChatMessage[] {\n return conversationHistory.get(chatId) || [];\n}\n\nfunction addToHistory(\n chatId: number,\n role: \"user\" | \"assistant\",\n content: string,\n) {\n if (!conversationHistory.has(chatId)) {\n conversationHistory.set(chatId, []);\n }\n const history = conversationHistory.get(chatId)!;\n history.push({ role, content });\n while (history.length > MAX_HISTORY) {\n history.shift();\n }\n}\n\nfunction clearHistory(chatId: number) {\n conversationHistory.delete(chatId);\n}\n\n// ============================================\n// SISTEMA DE LOGS\n// ============================================\n\ninterface LogEntry {\n timestamp: string;\n level: \"INFO\" | \"WARN\" | \"ERROR\" | \"DEBUG\";\n category: string;\n message: string;\n data?: unknown;\n}\n\nclass TelegramLogger {\n private logs: LogEntry[] = [];\n private chatId: number | null = null;\n private startTime: number;\n\n constructor() {\n this.startTime = Date.now();\n }\n\n setChatId(chatId: number) {\n this.chatId = chatId;\n }\n\n private addEntry(\n level: LogEntry[\"level\"],\n category: string,\n message: string,\n data?: unknown,\n ) {\n const entry: LogEntry = {\n timestamp: new Date().toISOString(),\n level,\n category,\n message,\n data,\n };\n this.logs.push(entry);\n console.log(\n `[${level}] [${category}] ${message}`,\n data ? JSON.stringify(data) : \"\",\n );\n }\n\n info(category: string, message: string, data?: unknown) {\n this.addEntry(\"INFO\", category, message, data);\n }\n warn(category: string, message: string, data?: unknown) {\n this.addEntry(\"WARN\", category, message, data);\n }\n error(category: string, message: string, data?: unknown) {\n this.addEntry(\"ERROR\", category, message, data);\n }\n debug(category: string, message: string, data?: unknown) {\n this.addEntry(\"DEBUG\", category, message, data);\n }\n\n private formatDuration(ms: number): string {\n if (ms < 1000) return `${ms}ms`;\n if (ms < 60000) return `${(ms / 1000).toFixed(1)}s`;\n return `${(ms / 60000).toFixed(1)}min`;\n }\n\n private levelIcon(level: LogEntry[\"level\"]): string {\n switch (level) {\n case \"INFO\":\n return \"ℹ️\";\n case \"WARN\":\n return \"⚠️\";\n case \"ERROR\":\n return \"🔴\";\n case \"DEBUG\":\n return \"🔧\";\n }\n }\n\n async flush() {\n if (!this.chatId || this.logs.length === 0) return;\n\n const totalDuration = Date.now() - this.startTime;\n const hasErrors = this.logs.some((l) => l.level === \"ERROR\");\n const hasWarnings = this.logs.some((l) => l.level === \"WARN\");\n\n const logLines = this.logs.map((entry) => {\n const icon = this.levelIcon(entry.level);\n const time = entry.timestamp.split(\"T\")[1]?.split(\".\")[0] || \"\";\n let line = `${icon} \\`${time}\\` *${entry.category}*: ${\n escapeMarkdown(entry.message)\n }`;\n if (entry.data) {\n const dataStr = typeof entry.data === \"string\"\n ? entry.data\n : JSON.stringify(entry.data, null, 0);\n const truncated = dataStr.length > 200\n ? dataStr.substring(0, 200) + \"...\"\n : dataStr;\n line += `\\n 📎 \\`${truncated}\\``;\n }\n return line;\n }).join(\"\\n\");\n\n const statusIcon = hasErrors ? \"🔴\" : hasWarnings ? \"⚠️\" : \"✅\";\n const header = `${statusIcon} *LOG* — ${\n this.formatDuration(totalDuration)\n }`;\n const fullLog = `${header}\\n\\n${logLines}`;\n const finalLog = fullLog.length > 4000\n ? fullLog.substring(0, 4000) + \"\\n\\n⚠️ _Log truncat_\"\n : fullLog;\n\n try {\n await fetch(`${TELEGRAM_API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: this.chatId,\n text: finalLog,\n parse_mode: \"Markdown\",\n disable_notification: true,\n }),\n });\n } catch (err) {\n console.error(\"Error enviant log a Telegram:\", err);\n }\n }\n}\n\nfunction escapeMarkdown(text: string): string {\n return text.replace(/([_*\\[\\]()~`>#+\\-=|{}.!])/g, \"\\\\$1\");\n}\n\n// ============================================\n// SYSTEM PROMPT PER DEEPSEEK (amb Plane)\n// ============================================\n\nconst SYSTEM_PROMPT =\n `Ets un assistent intel·ligent integrat en un bot de Telegram amb capacitat de crear tasques a Plane (gestor de projectes).\n\nINSTRUCCIONS GENERALS:\n- Respon de manera concisa, útil i amigable.\n- Pots respondre en qualsevol idioma segons el que faci servir l'usuari.\n- Si reps una transcripció d'àudio, respon al contingut de la transcripció de forma natural.\n- No facis servir Markdown excessiu — limita't a *negreta* i text pla, ja que estàs en Telegram.\n\nCREACIÓ DE TASQUES A PLANE:\nQuan l'usuari demani crear una tasca, afegir una issue, apuntar alguna cosa per fer, o qualsevol intent de crear un element de treball, has d'incloure al FINAL de la teva resposta un bloc JSON amb el format següent:\n\n[PLANE_TASK]\n{\n \"title\": \"Títol curt i explicatiu de la tasca\",\n \"description\": \"Descripció concisa amb NOMÉS la informació que l'usuari ha donat. Si ha donat poca info: una o dues línies. Si ha donat molt context: aleshores més detalls. ABSOLUTAMENT CAP INVENCIÓ de pasos, accions o context addicional.\",\n \"priority\": null,\n \"target_date\": null\n}\n[/PLANE_TASK]\n\nREGLES PER LES TASQUES:\n- El \"title\" ha de ser curt però explicatiu (màx ~80 chars). No hi posies prefixos com \"Tasca:\".\n- La \"description\" ha de COPIAR quasi literalment el que ha dit l'usuari. NO afegeixis: verificacions, accions, passos, configuracions, proves, context addicional, explicacions.\n- El \"priority\" NOMÉS s'ha d'omplir si l'usuari menciona explícitament prioritat o urgència. Valors possibles: \"urgent\", \"high\", \"medium\", \"low\". Si no es menciona, deixa null.\n- El \"target_date\" NOMÉS s'ha d'omplir si l'usuari menciona una data de venciment. Format: \"YYYY-MM-DD\". Si no es menciona, deixa null. La data d'avui és: ${\n new Date().toISOString().split(\"T\")[0]\n }.\n- NO inventis prioritats, dates, pasos, accions ni context si l'usuari no els ha mencionat explícitament.\n- Si l'usuari demana crear múltiples tasques en un sol missatge, inclou múltiples blocs [PLANE_TASK]...[/PLANE_TASK].\n- La resposta visible per l'usuari ha d'estar ABANS dels blocs [PLANE_TASK].\n\nEXEMPLES DE DESCRIPCIONS:\n\n❌ MALAMENT (inventa coses):\nUsuari diu: \"Reactivar notificacions per vaga i ventades\"\nDescripció: \"Cal verificar la configuració actual, assegurar que els canals estan operatius, reactivar alertes i fer proves\"\n\n✅ BÉ (copia el que diu l'usuari):\nUsuari diu: \"Reactivar notificacions per vaga i ventades\"\nDescripció: \"Reactivar notificacions per vaga i ventades\"\n\n❌ MALAMENT (afegeix passos):\nUsuari diu: \"Actualitzar la base de dades\"\nDescripció: \"1. Fer backup, 2. Revisar schema, 3. Aplicar canvis, 4. Validar\"\n\n✅ BÉ (directe):\nUsuari diu: \"Actualitzar la base de dades\"\nDescripció: \"Actualitzar la base de dades\"`;\n\n// ============================================\n// TECLATS\n// ============================================\n\nconst MAIN_KEYBOARD = {\n inline_keyboard: [],\n};\n\n// ============================================\n// FUNCIONS DE TELEGRAM\n// ============================================\n\nasync function sendMessage(\n chatId: number,\n text: string,\n options: Record = {},\n) {\n const response = await fetch(`${TELEGRAM_API}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text: text,\n parse_mode: \"Markdown\",\n ...options,\n }),\n });\n return response.json();\n}\n\nasync function sendChatAction(chatId: number, action: string) {\n await fetch(`${TELEGRAM_API}/sendChatAction`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, action }),\n });\n}\n\nasync function answerCallbackQuery(callbackQueryId: string, text?: string) {\n await fetch(`${TELEGRAM_API}/answerCallbackQuery`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ callback_query_id: callbackQueryId, text }),\n });\n}\n\nasync function editMessage(\n chatId: number,\n messageId: number,\n text: string,\n options: Record = {},\n) {\n await fetch(`${TELEGRAM_API}/editMessageText`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n message_id: messageId,\n text: text,\n parse_mode: \"Markdown\",\n ...options,\n }),\n });\n}\n\nasync function getFile(fileId: string) {\n const response = await fetch(`${TELEGRAM_API}/getFile`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ file_id: fileId }),\n });\n return response.json();\n}\n\nasync function downloadFile(filePath: string): Promise {\n const url = `https://api.telegram.org/file/bot${TELEGRAM_TOKEN}/${filePath}`;\n const response = await fetch(url);\n return response.arrayBuffer();\n}\n\n// ============================================\n// FUNCIONS DE GLADIA\n// ============================================\n\nasync function uploadToGladia(\n audioBuffer: ArrayBuffer,\n filename: string,\n logger: TelegramLogger,\n): Promise {\n logger.info(\"GLADIA\", \"Pujant àudio\", {\n filename,\n size: `${(audioBuffer.byteLength / 1024).toFixed(1)}KB`,\n });\n\n const formData = new FormData();\n const blob = new Blob([audioBuffer], { type: \"audio/ogg\" });\n formData.append(\"audio\", blob, filename);\n\n const response = await fetch(\"https://api.gladia.io/v2/upload\", {\n method: \"POST\",\n headers: { \"x-gladia-key\": GLADIA_API_KEY },\n body: formData,\n });\n\n const data = await response.json();\n if (!data.audio_url) {\n logger.error(\"GLADIA\", \"Error upload\", data);\n throw new Error(`Error pujant àudio: ${JSON.stringify(data)}`);\n }\n logger.info(\"GLADIA\", \"Upload OK\");\n return data.audio_url;\n}\n\nasync function requestTranscription(\n audioUrl: string,\n logger: TelegramLogger,\n): Promise<{ id: string; result_url: string }> {\n const languageConfig = {\n languages: [\"ca\"],\n code_switching: false,\n };\n\n logger.info(\"GLADIA\", \"Sol·licitant transcripció\", {\n language: \"ca\",\n });\n\n const response = await fetch(\"https://api.gladia.io/v2/pre-recorded\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-gladia-key\": GLADIA_API_KEY,\n },\n body: JSON.stringify({\n audio_url: audioUrl,\n language_config: languageConfig,\n }),\n });\n\n const data = await response.json();\n if (!data.id || !data.result_url) {\n logger.error(\"GLADIA\", \"Error request\", data);\n throw new Error(`Error sol·licitant transcripció: ${JSON.stringify(data)}`);\n }\n logger.info(\"GLADIA\", \"Transcripció sol·licitada\", { id: data.id });\n return { id: data.id, result_url: data.result_url };\n}\n\nasync function getTranscriptionResult(\n resultUrl: string,\n logger: TelegramLogger,\n maxAttempts = 30,\n): Promise {\n logger.info(\"GLADIA\", \"Esperant resultat...\");\n\n for (let attempt = 0; attempt < maxAttempts; attempt++) {\n const response = await fetch(resultUrl, {\n headers: { \"x-gladia-key\": GLADIA_API_KEY },\n });\n const data = await response.json();\n\n if (data.status === \"done\") {\n logger.info(\"GLADIA\", `Completada (intent ${attempt + 1})`);\n if (data.result?.transcription?.full_transcript) {\n return data.result.transcription.full_transcript;\n }\n if (data.result?.transcription?.utterances) {\n return data.result.transcription.utterances.map((u: { text: string }) =>\n u.text\n ).join(\" \");\n }\n throw new Error(\"Format de resposta desconegut\");\n }\n if (data.status === \"error\") {\n throw new Error(`Error Gladia: ${data.error || \"Desconegut\"}`);\n }\n await new Promise((resolve) => setTimeout(resolve, 1000));\n }\n throw new Error(\"Temps d'espera excedit\");\n}\n\nasync function transcribeAudio(\n audioBuffer: ArrayBuffer,\n filename: string,\n logger: TelegramLogger,\n): Promise {\n const audioUrl = await uploadToGladia(audioBuffer, filename, logger);\n const { result_url } = await requestTranscription(audioUrl, logger);\n return await getTranscriptionResult(result_url, logger);\n}\n\n// ============================================\n// FUNCIONS DE PLANE\n// ============================================\n\ninterface PlaneTask {\n title: string;\n description: string;\n priority: string | null;\n target_date: string | null;\n}\n\ninterface PlaneCreateResult {\n ok: boolean;\n id?: string;\n sequenceId?: number;\n error?: string;\n}\n\nasync function fetchBacklogStateId(logger: TelegramLogger): Promise {\n if (backlogStateId) return backlogStateId;\n\n logger.info(\"PLANE\", \"Obtenint estats del projecte...\");\n\n const response = await fetch(`${PLANE_API_URL}/states/`, {\n headers: {\n \"X-API-Key\": PLANE_API_KEY,\n \"Content-Type\": \"application/json\",\n },\n });\n\n if (!response.ok) {\n const errText = await response.text();\n logger.error(\"PLANE\", `Error estats: HTTP ${response.status}`, errText);\n throw new Error(`Plane states error: ${response.status}`);\n }\n\n const data = await response.json();\n const states = data.results || data;\n\n logger.info(\"PLANE\", `${states.length} estats trobats`, {\n estats: states.map((s: { name: string; group: string }) =>\n `${s.name}(${s.group})`\n ),\n });\n\n // Buscar l'estat amb group=\"backlog\"\n const backlog = states.find((s: { group: string }) => s.group === \"backlog\");\n if (!backlog) {\n logger.error(\"PLANE\", \"No s'ha trobat estat Backlog!\");\n throw new Error(\"No s'ha trobat l'estat Backlog al projecte\");\n }\n\n backlogStateId = backlog.id;\n logger.info(\"PLANE\", `Backlog: ${backlog.name} (${backlog.id})`);\n return backlog.id;\n}\n\nasync function createPlaneIssue(\n task: PlaneTask,\n logger: TelegramLogger,\n): Promise {\n logger.info(\"PLANE\", \"Creant tasca...\", {\n title: task.title,\n priority: task.priority,\n target_date: task.target_date,\n });\n\n try {\n const stateId = await fetchBacklogStateId(logger);\n\n // Construir description_html amb paràgrafs\n const descParagraphs = task.description\n .split(\"\\n\")\n .filter((p) => p.trim())\n .map((p) => `

${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",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1770888030636],"children",[],[35],"592da88a-fa45-11f0-817f-42dde27851f2",["D",1769383620429],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","019bf779-4112-74bd-896a-fb9735878605","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019bf779-4112-74bd-896a-ff45699cb0bd","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_114":110},"org",{"_11":12,"_108":-5,"_109":110,"_70":71,"_111":112,"_113":53},"branch",{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zOGxvTjFFdmNCNHBiMWxOQ0VUcHF0bTdldHAifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":149,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":-5,"_81":-5,"_82":-5,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":150,"_95":151,"_97":152,"_99":53},[146],"files",[146],"counts",{"_135":77,"_136":137,"_138":77,"_31":139,"_140":141},[133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":134},[35],"pulls","branches",1,"forks",{"_142":144,"_145":77},"connections",{"_142":77,"_143":77},"count","unfilledCount",4,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":147,"_18":148},[],[35],["D",1769383620429],{"_11":12,"_114":110},{"_11":12,"_108":-5,"_109":110,"_70":71,"_111":112,"_113":53},{"_17":42,"_13":16,"_33":40,"_100":61,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":14,"_107":12},"ctx",{"_93":-5,"_130":186,"_187":188,"_189":190,"_191":53,"_192":53,"_193":53,"_194":44,"_195":-5,"_196":-7,"_197":-7,"_198":77,"_199":53,"_200":53,"_201":-5,"_202":53,"_203":53,"_204":53,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":16,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"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"]

Code