, ver extractJsonFromFlareSolverr abaixo). Precisa das env vars\n  // \"flaresolverr_url\", \"flaresolverr_user\" e \"flaresolverr_password\"\n  // configuradas no Val Town (mesmo padrão da env var \"brevo\" já usada\n  // abaixo).\n  const flaresolverrUrl = Deno.env.get(\"flaresolverr_url\");\n  const flaresolverrUser = Deno.env.get(\"flaresolverr_user\");\n  const flaresolverrPassword = Deno.env.get(\"flaresolverr_password\");\n  if (!flaresolverrUrl) {\n    console.error(\n      \"Variável de ambiente 'flaresolverr_url' não está configurada no Val Town.\",\n    );\n    return;\n  }\n\n  function extractJsonFromFlareSolverr(html: string): any {\n    const match = /]*>([\\s\\S]*?)<\\/pre>/i.exec(html || \"\");\n    return JSON.parse(match ? match[1] : html);\n  }\n\n  let data: any = null;\n  let idx = -1;\n  const maxRetries = 2;\n  const retryDelayMs = 3000;\n\n  for (let attempt = 1; attempt <= maxRetries; attempt++) {\n    console.log(\n      `Tentativa ${attempt} de buscar dados da API via FlareSolverr...`,\n    );\n    try {\n      const authHeader = flaresolverrUser\n        ? {\n          Authorization: \"Basic \" +\n            btoa(`${flaresolverrUser}:${flaresolverrPassword}`),\n        }\n        : {};\n      const response = await fetch(flaresolverrUrl, {\n        method: \"POST\",\n        headers: { \"Content-Type\": \"application/json\", ...authHeader },\n        body: JSON.stringify({\n          cmd: \"request.get\",\n          url: API_URL,\n          maxTimeout: 30000,\n        }),\n      });\n\n      if (!response.ok) {\n        const errorBody = await response.text().catch(() =>\n          \"\"\n        );\n        console.warn(\n          `Tentativa ${attempt} falhou com status HTTP ${response.status}.\\nCorpo (primeiros 2000 chars):\\n${\n            errorBody.slice(0, 2000)\n          }`,\n        );\n        if (attempt < maxRetries) {\n          await new Promise((r) => setTimeout(r, retryDelayMs));\n          continue;\n        }\n        throw new Error(`Erro HTTP: ${response.status}`);\n      }\n\n      const outer = await response.json();\n      if (outer.status !== \"ok\") {\n        console.warn(\n          `Tentativa ${attempt}: FlareSolverr retornou status \"${outer.status}\": ${outer.message}`,\n        );\n        if (attempt < maxRetries) {\n          await new Promise((r) => setTimeout(r, retryDelayMs));\n          continue;\n        }\n        throw new Error(`FlareSolverr falhou: ${outer.message}`);\n      }\n\n      data = extractJsonFromFlareSolverr(outer.solution?.response);\n      const labels = data?.TrsrBd?.label || [];\n      idx = labels.indexOf(todayLabel);\n\n      if (idx !== -1) {\n        console.log(`Dados encontrados!`);\n        break;\n      } else {\n        console.warn(\n          `Tentativa ${attempt}: Dados de hoje (${todayLabel}) ainda não constavam no JSON recebido.`,\n        );\n        if (attempt < maxRetries) {\n          await new Promise((r) => setTimeout(r, retryDelayMs));\n        }\n      }\n    } catch (err: any) {\n      console.warn(\n        `Tentativa ${attempt} falhou devido ao erro: ${err.message}`,\n      );\n      if (attempt === maxRetries) {\n        throw err;\n      }\n      await new Promise((r) => setTimeout(r, retryDelayMs));\n    }\n  }\n\n  if (idx === -1) {\n    console.log(\n      `Dados de hoje (${todayLabel}) indisponíveis na API após ${maxRetries} tentativas.`,\n    );\n    return;\n  }\n\n  const bond = data.TrsrBd;\n  const currentRate = bond.anulInvstmtRate[idx];\n  const currentRedRate = bond.anulRedRate[idx];\n  const untrInvstmtVal = bond.untrInvstmtVal[idx];\n  const untrRedVal = bond.untrRedVal[idx];\n  const bondName = bond.nm;\n\n  const timeStr = `${hour.toString().padStart(2, \"0\")}:${\n    minute.toString().padStart(2, \"0\")\n  }`;\n  console.log(`Taxa atual (${todayLabel} ${timeStr}): ${currentRate}% a.a.`);\n\n  // 3. Inicializar Tabela do SQLite (se não existir)\n  await sqlite.execute(`\n    CREATE TABLE IF NOT EXISTS tesouro_alert_state (\n      key TEXT PRIMARY KEY,\n      value TEXT\n    )\n  `);\n\n  const getVal = async (key: string): Promise => {\n    const res = await sqlite.execute({\n      sql: \"SELECT value FROM tesouro_alert_state WHERE key = :key\",\n      args: { key },\n    });\n    return res.rows[0]?.[0] ?? null;\n  };\n\n  const setVal = async (key: string, value: string) => {\n    await sqlite.execute({\n      sql:\n        \"INSERT OR REPLACE INTO tesouro_alert_state (key, value) VALUES (:key, :value)\",\n      args: { key, value },\n    });\n  };\n\n  // 4. Ler estado anterior\n  const lastRateRaw = await getVal(\"last-known-rate\");\n  const lastRedRateRaw = await getVal(\"last-known-red-rate\");\n  const lastInvValRaw = await getVal(\"last-known-inv-val\");\n  const lastRedValRaw = await getVal(\"last-known-red-val\");\n  const lastRunDate = await getVal(\"last-run-date\");\n\n  const lastRate = lastRateRaw ? parseFloat(lastRateRaw) : null;\n  const lastRedRate = lastRedRateRaw\n    ? parseFloat(lastRedRateRaw)\n    : currentRedRate;\n  const lastInvVal = lastInvValRaw ? parseFloat(lastInvValRaw) : untrInvstmtVal;\n  const lastRedVal = lastRedValRaw ? parseFloat(lastRedValRaw) : untrRedVal;\n\n  // ── Função auxiliar para enviar o e-mail via Brevo ────────────────────────\n  async function sendAlert(\n    isFirstRun: boolean,\n    prevRate: number,\n    prevRedRate: number,\n    prevInvVal: number,\n    prevRedVal: number,\n  ) {\n    const delta = currentRate - prevRate;\n    const taxaCaiu = delta < 0;\n\n    const typeLabel = isFirstRun ? \"Abertura\" : (taxaCaiu ? \"Caiu\" : \"Subiu\");\n    const subLabel = isFirstRun\n      ? \"snapshot de abertura do mercado\"\n      : (taxaCaiu\n        ? \"preço subiu — título mais valorizado\"\n        : \"preço caiu — momento mais atrativo para comprar\");\n    const color = isFirstRun ? \"#2d5fa6\" : (taxaCaiu ? \"#1a6b3c\" : \"#b20f03\");\n    const icon = isFirstRun ? \"📊\" : (taxaCaiu ? \"📉\" : \"📈\");\n\n    const brevoApiKey = Deno.env.get(\"brevo\");\n    if (!brevoApiKey) {\n      console.error(\n        \"Variável de ambiente 'brevo' não está configurada no Val Town.\",\n      );\n      return false;\n    }\n\n    const formatDiff = (\n      now: number,\n      prev: number,\n      isPercent = false,\n    ): string => {\n      if (isFirstRun) return \"—\";\n      const diff = now - prev;\n      if (diff === 0) return \"—\";\n      const sign = diff > 0 ? \"+\" : \"\";\n      const suffix = isPercent ? \"%\" : \"\";\n      const diffColor = diff < 0 ? \"#1a6b3c\" : \"#b20f03\";\n      return `${sign}${\n        diff.toFixed(2)\n      }${suffix}`;\n    };\n\n    // Lucro/Prejuízo = PU Compra - PU Venda\n    const spreadAtual = untrInvstmtVal - untrRedVal;\n    const spreadAnterior = prevInvVal - prevRedVal;\n    const spreadColor = spreadAtual >= 0 ? \"#b20f03\" : \"#1a6b3c\";\n    const spreadLabel = spreadAtual >= 0\n      ? `R$ +${spreadAtual.toFixed(2)} (custo ao comprar agora)`\n      : `R$ ${spreadAtual.toFixed(2)} (ganho ao resgatar agora)`;\n\n    const htmlBody = `\n      \n        \n          ${icon} Tesouro Direto — Taxa ${typeLabel}!
\n          ${subLabel}
\n          ${todayLabel} às ${timeStr} (Horário de Brasília)
\n        
\n        \n          ${bondName}
\n          \n            \n              \n              \n              \n              \n            \n            \n              \n              \n              \n              \n            \n            \n              \n              \n              \n              \n            \n            \n              \n              \n              \n              \n            \n            \n              \n              \n              \n              \n            \n            \n              \n              \n            \n          Métrica Anterior Agora Variação
Taxa de Compra ${\n      prevRate.toFixed(2)\n    }% ${\n      currentRate.toFixed(2)\n    }% ${\n      formatDiff(currentRate, prevRate, true)\n    }
Preço Unitário (Compra) R$ ${\n      prevInvVal.toFixed(2)\n    } R$ ${\n      untrInvstmtVal.toFixed(2)\n    } ${\n      formatDiff(untrInvstmtVal, prevInvVal)\n    }
Taxa de Venda (Resgate) ${\n      prevRedRate.toFixed(2)\n    }% ${\n      currentRedRate.toFixed(2)\n    }% ${\n      formatDiff(currentRedRate, prevRedRate, true)\n    }
Preço Unitário (Venda) R$ ${\n      prevRedVal.toFixed(2)\n    } R$ ${\n      untrRedVal.toFixed(2)\n    } ${\n      formatDiff(untrRedVal, prevRedVal)\n    }
Compra − Venda (PU atual) ${spreadLabel}
\n          \n            \n              Ir para o Tesouro Direto\n            \n          
\n        
\n      \n    `;\n\n    const formattedRecipients = RECIPIENTS.map((email) => ({ email }));\n    const emailResponse = await fetch(\"https://api.brevo.com/v3/smtp/email\", {\n      method: \"POST\",\n      headers: {\n        \"accept\": \"application/json\",\n        \"api-key\": brevoApiKey,\n        \"content-type\": \"application/json\",\n      },\n      body: JSON.stringify({\n        sender: { name: \"Tesouro Alerta\", email: EMAIL_SENDER },\n        to: formattedRecipients,\n        subject:\n          `${icon} Tesouro Direto — Taxa ${typeLabel.toLowerCase()} para ${\n            currentRate.toFixed(2)\n          }% a.a.`,\n        htmlContent: htmlBody,\n      }),\n    });\n\n    if (emailResponse.ok) {\n      console.log(\"E-mails enviados com sucesso via Brevo!\");\n      return true;\n    } else {\n      const errText = await emailResponse.text();\n      console.error(`Falha ao enviar e-mail pelo Brevo: ${errText}`);\n      return false;\n    }\n  }\n  // ──────────────────────────────────────────────────────────────────────────\n\n  // 5. Primeira execução do dia: envia snapshot de abertura e salva estado\n  if (lastRate === null || lastRunDate !== todayStr) {\n    console.log(\n      `Primeira execução do dia (${todayLabel}). Enviando snapshot de abertura...`,\n    );\n    const sent = await sendAlert(\n      true,\n      currentRate,\n      currentRedRate,\n      untrInvstmtVal,\n      untrRedVal,\n    );\n    if (sent) {\n      await setVal(\"last-known-rate\", currentRate.toString());\n      await setVal(\"last-known-red-rate\", currentRedRate.toString());\n      await setVal(\"last-known-inv-val\", untrInvstmtVal.toString());\n      await setVal(\"last-known-red-val\", untrRedVal.toString());\n      await setVal(\"last-run-date\", todayStr);\n    }\n    return;\n  }\n\n  // 6. Execuções seguintes: alerta somente se a taxa mudou\n  if (currentRate !== lastRate) {\n    console.log(\n      `A taxa mudou! Anterior: ${lastRate}% -> Atual: ${currentRate}%. Enviando e-mail...`,\n    );\n    const sent = await sendAlert(\n      false,\n      lastRate,\n      lastRedRate,\n      lastInvVal,\n      lastRedVal,\n    );\n    if (sent) {\n      await setVal(\"last-known-rate\", currentRate.toString());\n      await setVal(\"last-known-red-rate\", currentRedRate.toString());\n      await setVal(\"last-known-inv-val\", untrInvstmtVal.toString());\n      await setVal(\"last-known-red-val\", untrRedVal.toString());\n    }\n  } else {\n    console.log(`Taxa não se alterou (${currentRate}%). Nenhuma ação.`);\n  }\n}","deleted","label",[109],"pulls","branches",1,"forks","envVars",{"_134":136,"_137":40},"connections",{"_134":40,"_135":40},"count","unfilledCount",6,"emptyCount",{"_18":108,"_20":109,"_110":111,"_112":-5,"_113":69,"_114":67,"_115":116,"_22":139,"_66":118,"_119":120,"_121":122,"_123":26,"_124":-5,"_140":141,"_86":142},["D",1789142089891],"children",[],[109],["D",1781280995443],["D",1789499469860],{"_16":17,"_84":80},{"_16":17,"_78":17,"_79":80,"_33":34,"_81":82,"_83":26},{"_66":67,"_20":68,"_18":69,"_70":19,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":21,"_77":17},"ctx",{"_59":-5,"_104":181,"_182":183,"_184":185,"_186":26,"_187":26,"_188":26,"_189":116,"_190":-5,"_191":-7,"_192":-7,"_193":40,"_194":26,"_195":26,"_196":-5,"_197":26,"_198":26,"_199":26,"_200":-5},"ENV",{"_152":153,"_154":155,"_156":68,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180},"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"]
Métrica	Anterior	Agora	Variação
Taxa de Compra	${\n prevRate.toFixed(2)\n }%	${\n currentRate.toFixed(2)\n }%	${\n formatDiff(currentRate, prevRate, true)\n }
Preço Unitário (Compra)	R$ ${\n prevInvVal.toFixed(2)\n }	R$ ${\n untrInvstmtVal.toFixed(2)\n }	${\n formatDiff(untrInvstmtVal, prevInvVal)\n }
Taxa de Venda (Resgate)	${\n prevRedRate.toFixed(2)\n }%	${\n currentRedRate.toFixed(2)\n }%	${\n formatDiff(currentRedRate, prevRedRate, true)\n }
Preço Unitário (Venda)	R$ ${\n prevRedVal.toFixed(2)\n }	R$ ${\n untrRedVal.toFixed(2)\n }	${\n formatDiff(untrRedVal, prevRedVal)\n }
Compra − Venda (PU atual)	${spreadLabel}
Search
