[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",13,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","bot.ts","latestPath","fileId","59311b96-fa45-11f0-817f-42dde27851f2","name","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// Idioma per defecte\nlet selectedLanguage = \"auto\";\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// IDIOMES DISPONIBLES\n// ============================================\n\nconst LANGUAGES: Record = {\n auto: { name: \"Automàtic\", flag: \"🌍\" },\n ca: { name: \"Català\", flag: \"🇦🇩\" },\n es: { name: \"Español\", flag: \"🇪🇸\" },\n en: { name: \"English\", flag: \"🇬🇧\" },\n fr: { name: \"Français\", flag: \"🇫🇷\" },\n de: { name: \"Deutsch\", flag: \"🇩🇪\" },\n it: { name: \"Italiano\", flag: \"🇮🇹\" },\n pt: { name: \"Português\", flag: \"🇵🇹\" },\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ó detallada i extensa de la tasca amb tot el context necessari. Inclou passos, requisits, notes o qualsevol detall rellevant.\",\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 ser extensa i detallada, amb tot el context que l'usuari ha donat. Pot tenir diversos paràgrafs.\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 ni dates si l'usuari no les 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\n// ============================================\n// TECLATS\n// ============================================\n\nconst MAIN_KEYBOARD = {\n inline_keyboard: [\n [{ text: \"🌍 Language\", callback_data: \"language\" }],\n ],\n};\n\nconst LANGUAGE_KEYBOARD = {\n inline_keyboard: [\n [\n { text: \"🌍 Auto\", callback_data: \"lang_auto\" },\n { text: \"🇦🇩 Català\", callback_data: \"lang_ca\" },\n ],\n [\n { text: \"🇪🇸 Español\", callback_data: \"lang_es\" },\n { text: \"🇬🇧 English\", callback_data: \"lang_en\" },\n ],\n [\n { text: \"🇫🇷 Français\", callback_data: \"lang_fr\" },\n { text: \"🇩🇪 Deutsch\", callback_data: \"lang_de\" },\n ],\n [\n { text: \"🇮🇹 Italiano\", callback_data: \"lang_it\" },\n { text: \"🇵🇹 Português\", callback_data: \"lang_pt\" },\n ],\n [{ text: \"⬅️ Tornar\", callback_data: \"back\" }],\n ],\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 = selectedLanguage === \"auto\"\n ? { languages: [], code_switching: true }\n : { languages: [selectedLanguage], code_switching: false };\n\n logger.info(\"GLADIA\", \"Sol·licitant transcripció\", {\n language: selectedLanguage,\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 const lang = LANGUAGES[selectedLanguage];\n logger.info(\"HANDLER\", \"Veu rebuda\", { duration: `${voice.duration}s` });\n\n const waitMsg = await sendMessage(chatId, `🎤 Transcrivint... ${lang.flag}`);\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 const lang = LANGUAGES[selectedLanguage];\n logger.info(\"HANDLER\", \"Àudio rebut\", { filename: audio.file_name });\n\n const waitMsg = await sendMessage(chatId, `🎵 Transcrivint... ${lang.flag}`);\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 const lang = LANGUAGES[selectedLanguage];\n logger.info(\"HANDLER\", `Comanda ${text}`);\n await sendMessage(\n chatId,\n `🤖 *Bot de Transcripció, IA i Plane*\\n\\nIdioma: ${lang.flag} ${lang.name}\\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 === \"/lang\" || text === \"/language\") {\n const lang = LANGUAGES[selectedLanguage];\n logger.info(\"HANDLER\", \"Comanda language\");\n await sendMessage(\n chatId,\n `🌍 *Selecciona l'idioma*\\n\\nActual: ${lang.flag} ${lang.name}`,\n { reply_markup: LANGUAGE_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 `/lang — Canviar idioma transcripció\\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\n if (data.startsWith(\"lang_\")) {\n const langCode = data.replace(\"lang_\", \"\");\n selectedLanguage = langCode;\n const lang = LANGUAGES[langCode];\n logger.info(\"CALLBACK\", `Idioma: ${lang.name}`);\n await answerCallbackQuery(callbackQueryId, `${lang.flag} ${lang.name}`);\n await editMessage(\n chatId,\n messageId,\n `${lang.flag} *Idioma:* ${lang.name}\\n\\nEnvia àudio o text.`,\n { reply_markup: MAIN_KEYBOARD },\n );\n return;\n }\n\n if (data === \"language\") {\n const lang = LANGUAGES[selectedLanguage];\n await answerCallbackQuery(callbackQueryId);\n await editMessage(\n chatId,\n messageId,\n `🌍 *Selecciona idioma*\\n\\nActual: ${lang.flag} ${lang.name}`,\n { reply_markup: LANGUAGE_KEYBOARD },\n );\n return;\n }\n\n if (data === \"back\") {\n const lang = LANGUAGES[selectedLanguage];\n await answerCallbackQuery(callbackQueryId);\n await editMessage(\n chatId,\n messageId,\n `🤖 *Bot IA + Plane*\\n\\nIdioma: ${lang.flag} ${lang.name}\\n\\n📝 Text → IA\\n🎤 Àudio → Transcriu + IA\\n📋 Tasques → Plane`,\n { reply_markup: MAIN_KEYBOARD },\n );\n return;\n }\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 query.message.chat.id,\n query.message.message_id,\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}","// 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ó detallada i extensa de la tasca amb tot el context necessari. Inclou passos, requisits, notes o qualsevol detall rellevant. Pero sense escriure res poc rellevant, si tens poca informació per part de l'usuari no te n'inventis, posa'n poca i ja.\",\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 ser extensa i detallada, amb tot el context que l'usuari ha donat. Pot tenir diversos paràgrafs.\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 ni dates si l'usuari no les 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\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 || \"

Diff · v13