[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_168":169,"_170":171},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_61":133,"_16":-7,"_138":-5,"_17":139,"_140":141,"_28":142,"_21":143,"_23":144,"_145":-5,"_146":-5,"_147":-5,"_148":35,"_149":150,"_151":38,"_152":-5,"_153":-5,"_154":155},"routes/_app.x.$handle.$name._index",{"_11":12,"_13":14,"_15":-7,"_16":-7,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-7,"_26":-5,"_27":-5,"_28":29,"_30":31,"_32":-5,"_33":-5,"_34":35,"_36":35,"_37":38},"handle","henribogeski","name","dualwin-call-connector","branchName","version","project",{"_39":79,"_13":14,"_50":80,"_81":-5,"_82":35,"_83":84,"_85":84,"_86":87,"_88":-5,"_89":90,"_91":43,"_92":38,"_93":-5,"_94":-5,"_95":67,"_96":97,"_98":99,"_100":101,"_102":103,"_104":-5,"_105":106,"_107":106,"_108":109,"_110":109,"_111":109,"_112":106,"_113":106,"_114":115,"_116":117,"_118":119,"_120":35},"tags",[],"counts",{"_66":67,"_68":69,"_70":67,"_71":72,"_73":74},"contents",[63],"readme","upstream","pull","files",[31],"preview",{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":51,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_59":60,"_61":62},"ahead","behind","showHomeCustomizationHint",false,"showHTTPPreviewSettingsHint","hasHTTPFiles",true,"id","28bbe795-8448-4495-81fc-0e37d9605349","main.ts","fileId","da8b00ba-8d72-11f1-a9c7-1607ee4eb77e","parentId","branchId","c191a9f2-bc27-4f5c-86fe-44213c8486cf","branchVersion",14,"latest","createdAt",["D",1785568843319],13,"fileType","http","content","import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst DC_BASE = \"https://api.directcallsoft.com\";\nconst CLIENT_ID = Deno.env.get(\"DIRECTCALL_CLIENT_ID\")!;\nconst CLIENT_SECRET = Deno.env.get(\"DIRECTCALL_CLIENT_SECRET\")!;\nconst ORIGEM = Deno.env.get(\"DIRECTCALL_ORIGEM\")!;\nconst BITRIX_URL = Deno.env.get(\"BITRIX_WEBHOOK_URL\")!;\nconst BITRIX_LINE = Deno.env.get(\"BITRIX_LINE_NUMBER\") ?? \"dualwin-call-teste\";\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS calls (\n callerid TEXT PRIMARY KEY,\n bitrix_call_id TEXT,\n deal_id TEXT,\n destino TEXT,\n status TEXT,\n created_at TEXT\n)`);\n\n// Migracao idempotente: coluna adicionada depois da criacao original da tabela\ntry {\n await sqlite.execute(\"ALTER TABLE calls ADD COLUMN record_file_id TEXT\");\n} catch (_) {\n // coluna ja existe\n}\n\nfunction formUrlEncode(params: Record): string {\n return Object.entries(params)\n .map(([k, v]) => `${encodeURIComponent(k)}=${encodeURIComponent(v)}`)\n .join(\"&\");\n}\n\nasync function dcPost(path: string, params: Record) {\n const res = await fetch(`${DC_BASE}${path}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: formUrlEncode(params),\n });\n const json = await res.json();\n console.log(`[directcall] POST ${path} ->`, JSON.stringify(json));\n return json;\n}\n\nasync function dcGet(path: string, params: Record) {\n const qs = formUrlEncode(params);\n const res = await fetch(`${DC_BASE}${path}?${qs}`);\n const json = await res.json();\n console.log(`[directcall] GET ${path} ->`, JSON.stringify(json));\n return json;\n}\n\nasync function getDirectCallToken(): Promise {\n const auth = await dcPost(\"/request_token\", {\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n });\n if (!auth.access_token) {\n throw new Error(`Falha ao autenticar no DirectCall: ${JSON.stringify(auth)}`);\n }\n return auth.access_token;\n}\n\nasync function bitrixCall(method: string, params: Record) {\n const res = await fetch(`${BITRIX_URL}${method}.json`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(params),\n });\n const json = await res.json();\n console.log(`[bitrix] ${method} ->`, JSON.stringify(json));\n return json;\n}\n\n// POST /call { destino, dealId? }\napp.post(\"/call\", async (c) => {\n const body = await c.req.json();\n const destino: string = body.destino;\n const dealId: string | undefined = body.dealId;\n\n if (!destino) {\n return c.json({ error: \"destino é obrigatório\" }, 400);\n }\n\n const token = await getDirectCallToken();\n\n // O DirectCall deixa sessoes penduradas que derrubam a proxima chamada em 1-2s\n // (aceita a requisicao, retorna callerid, mas nunca toca e nem entra no extrato).\n // Encerrar explicitamente as chamadas nao finalizadas antes de discar.\n const pendentes = await sqlite.execute({\n sql: \"SELECT callerid FROM calls WHERE status IS NULL OR status != 'DESTROYED'\",\n args: [],\n });\n for (const p of pendentes.rows as Array>) {\n const cid = String(p.callerid);\n const r = await dcGet(\"/voz/end\", { callerid: cid, access_token: token });\n console.log(`[call] limpeza previa de ${cid}:`, r?.msg?.status ?? JSON.stringify(r));\n await sqlite.execute({\n sql: \"UPDATE calls SET status = 'DESTROYED' WHERE callerid = ?\",\n args: [cid],\n });\n }\n\n const callParams: Record = {\n origem: ORIGEM,\n destino,\n gravar: \"s\",\n access_token: token,\n };\n if (dealId) callParams[\"campos[deal_id]\"] = dealId;\n\n const callResp = await dcPost(\"/voz/call\", callParams);\n\n if (callResp.status !== \"ok\" || !callResp.callerid) {\n return c.json({ error: \"Falha ao iniciar chamada no DirectCall\", detail: callResp }, 502);\n }\n\n const callerid: string = callResp.callerid;\n\n // NAO registrar no Bitrix ainda. Uma parte das chamadas e aceita pela API mas\n // morre em 1-2s sem nunca tocar — registrar aqui criaria \"chamadas fantasma\"\n // no historico do CRM. O registro acontece no primeiro callback real (ver\n // ensureBitrixCall no /webhook), que so chega para chamadas que de fato saem.\n await sqlite.execute({\n sql: `INSERT INTO calls (callerid, bitrix_call_id, deal_id, destino, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [callerid, null, dealId ?? null, destino, \"CREATED\", new Date().toISOString()],\n });\n\n return c.json({ callerid, bitrixRegistered: false });\n});\n\n// Registra a chamada no Bitrix sob demanda (no primeiro callback real).\nasync function ensureBitrixCall(\n callerid: string,\n destino: string,\n record: Record,\n): Promise {\n if (record.bitrix_call_id) return String(record.bitrix_call_id);\n\n const reg = await bitrixCall(\"telephony.externalCall.register\", {\n USER_ID: 1,\n USER_PHONE_INNER: ORIGEM,\n PHONE_NUMBER: destino,\n TYPE: 1, // outbound\n CALL_START_DATE: new Date().toISOString(),\n CRM_CREATE: 1,\n SHOW: 1,\n // Sem EXTERNAL_CALL_ID o Bitrix reaproveita o mesmo CALL_ID entre chamadas\n // para o mesmo numero/usuario. O callerid do DirectCall garante unicidade.\n EXTERNAL_CALL_ID: callerid,\n // Sem LINE_NUMBER a chamada fica orfa como \"REST_APP:\" em vez de pertencer\n // a nossa linha externa.\n LINE_NUMBER: BITRIX_LINE,\n });\n\n const id = reg?.result?.CALL_ID;\n if (!id) {\n console.error(`[webhook] falha ao registrar ${callerid} no Bitrix:`, JSON.stringify(reg));\n return null;\n }\n\n await sqlite.execute({\n sql: \"UPDATE calls SET bitrix_call_id = ? WHERE callerid = ?\",\n args: [String(id), callerid],\n });\n console.log(`[webhook] chamada ${callerid} registrada no Bitrix como ${id}`);\n return String(id);\n}\n\n// POST /webhook - callback do DirectCall\napp.post(\"/webhook\", async (c) => {\n const form = await c.req.parseBody();\n const raw = form[\"data\"];\n if (!raw || typeof raw !== \"string\") {\n console.log(\"[webhook] payload sem campo 'data':\", JSON.stringify(form));\n return c.json({ received: true, warning: \"sem campo data\" });\n }\n\n const data = JSON.parse(raw);\n console.log(\"[webhook] data recebido:\", JSON.stringify(data));\n\n const callerid: string = data[\"uuid-origem\"];\n const status: string = data[\"origem-status\"] || data[\"destino-status\"];\n\n const row = await sqlite.execute({\n sql: \"SELECT * FROM calls WHERE callerid = ?\",\n args: [callerid],\n });\n\n if (row.rows.length === 0) {\n console.log(`[webhook] callerid ${callerid} não encontrado no banco`);\n return c.json({ received: true, warning: \"callerid desconhecido\" });\n }\n\n const record = row.rows[0] as Record;\n\n await sqlite.execute({\n sql: \"UPDATE calls SET status = ? WHERE callerid = ?\",\n args: [status, callerid],\n });\n\n // Chegou callback = a chamada saiu de verdade. So agora vale criar no Bitrix.\n const bitrixCallId = await ensureBitrixCall(callerid, String(record.destino ?? \"\"), record);\n if (bitrixCallId) record.bitrix_call_id = bitrixCallId;\n\n if (status === \"DESTROYED\" && record.bitrix_call_id) {\n // Calcular duracao real a partir dos timestamps do DirectCall.\n // Sem DURATION, o Bitrix assume STATUS_CODE 304 (perdida) por default.\n const times = data[\"status-times\"]?.destino ?? data[\"status-times\"]?.origem ?? {};\n let duration = 0;\n if (times.atendida && times.finalizada) {\n const atendida = new Date(times.atendida.replace(\" \", \"T\")).getTime();\n const finalizada = new Date(times.finalizada.replace(\" \", \"T\")).getTime();\n if (!isNaN(atendida) && !isNaN(finalizada) && finalizada > atendida) {\n duration = Math.round((finalizada - atendida) / 1000);\n }\n }\n // 200 = atendida, 304 = nao atendida/perdida\n const statusCode = duration > 0 ? \"200\" : \"304\";\n\n const fin = await bitrixCall(\"telephony.externalCall.finish\", {\n CALL_ID: record.bitrix_call_id,\n USER_ID: 1,\n DURATION: duration,\n STATUS_CODE: statusCode,\n });\n if (!fin?.result?.CALL_ID) {\n // Nao aborta: a chamada pode ja ter sido finalizada (callback duplicado),\n // e ainda assim vale a pena tentar anexar a gravacao.\n console.error(\n `[webhook] finish nao confirmou para ${callerid}:`,\n fin?.error_description ?? JSON.stringify(fin),\n );\n }\n\n // Poll pela gravação. Atencao: o gravacao_link aparece no extrato ANTES do\n // audio estar disponivel. Nao basta o link existir — precisa confirmar que o\n // arquivo ja baixa, senao o Bitrix rejeita com \"Tipo de arquivo incorreto\".\n const MIN_AUDIO_BYTES = 1024;\n let gravacaoLink: string | null = null;\n\n for (let i = 0; i < 6; i++) {\n await new Promise((r) => setTimeout(r, 5000));\n const token = await getDirectCallToken();\n const dataStr = new Date().toISOString().slice(0, 10).replace(/-/g, \"\");\n const extrato = await dcPost(\"/extrato/list\", {\n dataInicial: `${dataStr}000000`,\n dataFinal: `${dataStr}235959`,\n access_token: token,\n });\n const found = (extrato.msg || []).find((r: any) => r.callerid === callerid);\n if (!found?.gravacao_link) continue;\n\n // Confirmar que o audio realmente ja esta servivel\n try {\n const probe = await fetch(found.gravacao_link, { method: \"GET\" });\n const len = Number(probe.headers.get(\"content-length\") ?? 0);\n probe.body?.cancel();\n console.log(`[webhook] probe gravação tentativa ${i + 1}: HTTP ${probe.status}, ${len} bytes`);\n if (probe.ok && len >= MIN_AUDIO_BYTES) {\n gravacaoLink = found.gravacao_link;\n break;\n }\n } catch (e) {\n console.log(`[webhook] probe gravação falhou na tentativa ${i + 1}:`, String(e));\n }\n }\n\n if (gravacaoLink) {\n // RECORD_URL: o Bitrix baixa o audio sozinho. Evita carregar o arquivo\n // em memoria e o base64 manual (que estoura a pilha em arquivos grandes).\n // O DirectCall entrega WAV (header RIFF/WAVE) apesar do content-type\n // \"octet/stream\". Rotular como .mp3 faz o CoPilot falhar ao decodificar.\n const att = await bitrixCall(\"telephony.externalCall.attachRecord\", {\n CALL_ID: record.bitrix_call_id,\n RECORD_URL: gravacaoLink,\n FILENAME: `${callerid}.wav`,\n });\n // NUNCA assumir sucesso: o Bitrix responde 200 com error_description preenchido.\n if (att?.result?.FILE_ID) {\n console.log(`[webhook] gravação anexada ao CALL_ID ${record.bitrix_call_id} (FILE_ID ${att.result.FILE_ID})`);\n await sqlite.execute({\n sql: \"UPDATE calls SET record_file_id = ? WHERE callerid = ?\",\n args: [String(att.result.FILE_ID), callerid],\n });\n } else {\n console.error(\n `[webhook] FALHA ao anexar gravação de ${callerid}:`,\n att?.error_description ?? JSON.stringify(att),\n );\n }\n } else {\n console.error(`[webhook] gravação de ${callerid} não ficou disponível a tempo (6 tentativas / 30s)`);\n }\n }\n\n return c.json({ received: true });\n});\n\napp.get(\"/\", (c) => c.json({ ok: true, service: \"dualwin-call-connector\" }));\n\nexport default app.fetch;\n","deleted","label","children",[],"path",[41],{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":64,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_61":65},["D",1785568843319],[41],"pulls",0,"branches",1,"forks","envVars",{"_75":77,"_78":67},"connections",{"_75":67,"_76":67},"count","unfilledCount",5,"emptyCount","58fc140c-00d5-41ed-8801-e1cd2aa2ba79",["D",1785565985727],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Conector DirectCall <-> Bitrix24 telefonia (DualWin Call)","imageUrl","userId","8b96a799-eea9-4c7e-8f87-c7ddd5ca41a3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019ece1a-35f7-760e-a942-5a89674d1b07","tursoName","58fc140c00d541ed8801e1cd2aa2ba79","tursoHostname","58fc140c00d541ed8801e1cd2aa2ba79-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789476648181],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_137":133},"org",{"_11":12,"_130":131,"_132":133,"_89":90,"_134":135,"_136":35},"branch",{"_16":48,"_13":121,"_39":46,"_122":79,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":-5,"_128":14,"_129":12},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Henri Bogeski","avatar","","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_39":79,"_13":14,"_50":163,"_81":-5,"_82":35,"_83":84,"_85":84,"_86":87,"_88":-5,"_89":90,"_91":43,"_92":38,"_93":-5,"_94":-5,"_95":67,"_96":97,"_98":99,"_100":101,"_102":164,"_104":-5,"_105":106,"_107":106,"_108":109,"_110":109,"_111":109,"_112":106,"_113":106,"_114":165,"_116":166,"_118":167,"_120":35},"tree",[160],[160],{"_66":67,"_68":69,"_70":67,"_71":158,"_73":159},[156],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":64,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_61":157},[41],{"_75":77,"_78":67},{"_75":67,"_76":67},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":38,"_50":51,"_16":52,"_53":54,"_55":56,"_57":35,"_58":-5,"_59":161,"_61":162},[],[41],["D",1785565985727],["D",1789476648181],{"_11":12,"_137":133},{"_11":12,"_130":131,"_132":133,"_89":90,"_134":135,"_136":35},{"_16":48,"_13":121,"_39":46,"_122":79,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":-5,"_128":14,"_129":12},"ctx",{"_114":-5,"_153":201,"_202":203,"_204":205,"_206":35,"_207":35,"_208":35,"_209":38,"_210":-5,"_211":-7,"_212":-7,"_213":67,"_214":35,"_215":35,"_216":-5,"_217":35,"_218":35,"_219":35,"_220":-5},"ENV",{"_172":173,"_174":175,"_176":121,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200},"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"]