Garimpa Sócia v2 — Busca com comissão real

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_182":183,"_184":185},"routes/_app.x.$handle.$name",{"_96":95,"_32":45,"_105":86,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":58,"_123":-5,"_124":-5,"_125":126},"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":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":25},"version",15,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","new-file-9140.ts","latestPath","fileId","aa9a6134-a66d-11f1-85f8-1607ee4eb77e","name","fileType","script","content","/**\n * CRON — Coleta diária do radar de crescimento\n * ------------------------------------------------\n * Roda sozinho, 1x por dia, independente de alguém abrir o app.\n * Garante que o histórico do \"Radar de crescimento\" não tenha buracos.\n *\n * COMO CONFIGURAR NO VAL TOWN:\n * 1. Cria um arquivo novo nesse mesmo Val (não precisa ser HTTP)\n * 2. Cola este código\n * 3. Clica em \"Add trigger\" (no topo do editor) → escolhe \"Cron job\"\n * 4. Define o horário (ex: todo dia às 6h da manhã)\n *\n * Usa as MESMAS env vars já cadastradas nesse Val:\n * SHOPEE_APP_ID, SHOPEE_APP_SECRET\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst APP_ID = Deno.env.get(\"SHOPEE_APP_ID\")!;\nconst APP_SECRET = Deno.env.get(\"SHOPEE_APP_SECRET\")!;\nconst API_URL = \"https://open-api.affiliate.shopee.com.br/graphql\";\n\nasync function buildSignature(\n appId: string,\n timestamp: number,\n payload: string,\n secret: string,\n): Promise {\n const raw = `${appId}${timestamp}${payload}${secret}`;\n const encoder = new TextEncoder();\n const data = encoder.encode(raw);\n const hashBuffer = await crypto.subtle.digest(\"SHA-256\", data);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function callShopeeApi(query: string): Promise {\n const timestamp = Math.floor(Date.now() / 1000);\n const payload = JSON.stringify({ query });\n const signature = await buildSignature(\n APP_ID,\n timestamp,\n payload,\n APP_SECRET,\n );\n\n const res = await fetch(API_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization:\n `SHA256 Credential=${APP_ID}, Timestamp=${timestamp}, Signature=${signature}`,\n },\n body: payload,\n });\n\n return res.json();\n}\n\ninterface Product {\n itemId: string;\n shopId: string;\n name: string;\n imageUrl: string;\n price: number;\n commissionRate: number;\n commission: number;\n rating: number;\n sales: number;\n score: number;\n}\n\nfunction normalize(text: string): string {\n return text.toLowerCase().normalize(\"NFD\").replace(/[\\u0300-\\u036f]/g, \"\");\n}\n\nfunction relevanceScore(productName: string, keyword: string): number {\n const nameNorm = normalize(productName);\n const words = normalize(keyword).split(/\\s+/).filter(Boolean);\n if (words.length === 0) return 0;\n const matched = words.filter((w) => nameNorm.includes(w)).length;\n return matched / words.length;\n}\n\nfunction scoreOpportunity(\n p: { commission: number; sales: number; rating: number },\n): number {\n const commissionScore = p.commission * 10;\n const salesScore = Math.log10(Math.max(p.sales, 1)) * 5;\n const ratingPenalty = p.rating < 4.3 ? 20 : 0;\n return commissionScore + salesScore - ratingPenalty;\n}\n\nasync function searchProducts(keyword: string): Promise {\n const query = `\n query {\n productOfferV2(keyword: \"${keyword.replace(/\"/g, \"\")}\", limit: 30) {\n nodes {\n itemId shopId productName imageUrl price\n commissionRate commission ratingStar sales\n }\n }\n }\n `;\n const data = await callShopeeApi(query);\n const nodes = data?.data?.productOfferV2?.nodes ?? [];\n\n const allProducts: Product[] = nodes.map((n: any) => ({\n itemId: n.itemId,\n shopId: n.shopId,\n name: n.productName,\n imageUrl: n.imageUrl,\n price: Number(n.price),\n commissionRate: Number(n.commissionRate),\n commission: Number(n.commission),\n rating: Number(n.ratingStar),\n sales: Number(n.sales),\n score: 0,\n }));\n\n const relevant = allProducts.filter((p) =>\n relevanceScore(p.name, keyword) >= 0.5\n );\n const pool = relevant.length > 0 ? relevant : allProducts;\n pool.forEach((p) => (p.score = scoreOpportunity(p)));\n return pool.sort((a, b) => b.score - a.score).slice(0, 15);\n}\n\nconst NICHOS_POPULARES = [\n \"cozinha organizador\",\n \"beleza skincare\",\n \"casa decoração\",\n \"pet acessório\",\n \"bebê organizador\",\n \"fitness academia\",\n];\n\nasync function coletarSnapshotDiario() {\n await sqlite.execute(`\n create table if not exists product_snapshots (\n item_id text, shop_id text, name text, image_url text,\n price real, commission_rate real, commission real,\n rating real, sales integer, score real, captured_at text\n )\n `);\n await sqlite.execute(\n `create table if not exists meta (key text primary key, value text)`,\n );\n\n const resultsPerNicho = await Promise.all(\n NICHOS_POPULARES.map(async (nicho) => {\n try {\n return (await searchProducts(nicho)).slice(0, 6);\n } catch {\n return [];\n }\n }),\n );\n\n const merged = resultsPerNicho.flat();\n const seen = new Set();\n const unique = merged.filter((p) => {\n if (seen.has(p.itemId)) return false;\n seen.add(p.itemId);\n return true;\n });\n const top20 = unique.sort((a, b) => b.score - a.score).slice(0, 20);\n\n const agora = new Date().toISOString();\n for (const p of top20) {\n await sqlite.execute({\n sql: `insert into product_snapshots\n (item_id, shop_id, name, image_url, price, commission_rate, commission, rating, sales, score, captured_at)\n values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n p.itemId,\n p.shopId,\n p.name,\n p.imageUrl,\n p.price,\n p.commissionRate,\n p.commission,\n p.rating,\n p.sales,\n p.score,\n agora,\n ],\n });\n }\n await sqlite.execute({\n sql:\n `insert into meta (key, value) values ('last_trending_refresh', ?) on conflict(key) do update set value = excluded.value`,\n args: [agora],\n });\n\n console.log(`Snapshot diário salvo: ${top20.length} produtos.`);\n}\n\nexport default async function () {\n await coletarSnapshotDiario();\n}","interval","createdAt",["D",1788312618486],"branchVersion","branchId","93365b8d-4b87-4a2c-a134-20a103db284f","id","b79b9fb9-0d4c-4ddc-bdcc-4124346e0bfc","garimpa-socia",["D",1788018753272],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","403bb087-0ba9-49d6-9729-5b75f65faaa0","pinnedFileId","e6c93e0c-a3c3-11f1-8c05-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f7adf-7a74-7489-9a9d-2bd1a404c9c2","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":25},"branch",{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"isOwned",17,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","luizarraes","handle","displayName","Luiz Arraes","avatar","https://lh3.googleusercontent.com/a/ACg8ocIIGgnRS5HdWAIu3ySgb1G03Itahle7xsG21QWJQVY7uCrWWdg3hA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":178,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":179,"_80":180,"_82":181,"_84":25},"tree",[165,166,167],"files",[165,166,167],"counts",{"_153":62,"_154":155,"_156":62,"_157":158,"_159":160},"contents",[127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":145,"_32":146,"_30":147,"_131":-5,"_41":42,"_40":148,"_132":58,"_38":149,"_13":150,"_33":34,"_35":151,"_24":25,"_135":-5,"_27":152},{"_43":137,"_32":138,"_30":56,"_131":-5,"_41":42,"_40":139,"_132":25,"_38":140,"_13":141,"_33":142,"_35":143,"_24":25,"_135":45,"_27":144},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":58,"_38":133,"_13":134,"_33":37,"_35":36,"_24":25,"_135":-5,"_27":136},"ed7b1acb-b4b2-455f-a2d8-87587feddf9e","parentId","latest",["D",1788312618486],2,"label",[28],"bbc90a82-ad80-40e4-951d-881a058d1d00","new-file-6268.ts",12,["D",1788312224476],6,"http","/**\n * GARIMPA SÓCIA v2 — Protótipo com comissão real\n * -------------------------------------------------\n * Um único arquivo HTTP no Val Town. Serve a página de busca E a API\n * por dentro do mesmo Val — não precisa mexer no Netlify ainda.\n *\n * COMO USAR:\n * 1. Cria um arquivo HTTP novo no Val Town (ou substitui o de teste)\n * 2. Cola este código\n * 3. Salva\n * 4. Clica em \"App\" — abre a página de busca, pronta pra usar\n *\n * Pré-requisito: as env vars SHOPEE_APP_ID e SHOPEE_APP_SECRET já\n * cadastradas nesse Val (mesmas que já usamos no teste).\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\nconst APP_ID = Deno.env.get(\"SHOPEE_APP_ID\")!;\nconst APP_SECRET = Deno.env.get(\"SHOPEE_APP_SECRET\")!;\nconst API_URL = \"https://open-api.affiliate.shopee.com.br/graphql\";\n\n// ---------- Autenticação (mesma lógica já testada) ----------\n\nasync function buildSignature(\n appId: string,\n timestamp: number,\n payload: string,\n secret: string,\n): Promise {\n const raw = `${appId}${timestamp}${payload}${secret}`;\n const encoder = new TextEncoder();\n const data = encoder.encode(raw);\n const hashBuffer = await crypto.subtle.digest(\"SHA-256\", data);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function callShopeeApi(query: string): Promise {\n const timestamp = Math.floor(Date.now() / 1000);\n const payload = JSON.stringify({ query });\n const signature = await buildSignature(\n APP_ID,\n timestamp,\n payload,\n APP_SECRET,\n );\n\n const res = await fetch(API_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization:\n `SHA256 Credential=${APP_ID}, Timestamp=${timestamp}, Signature=${signature}`,\n },\n body: payload,\n });\n\n return res.json();\n}\n\n// ---------- Busca de produtos ----------\n\ninterface Product {\n itemId: string;\n shopId: string;\n name: string;\n imageUrl: string;\n price: number;\n commissionRate: number;\n commission: number;\n rating: number;\n sales: number;\n score: number;\n}\n\nfunction normalize(text: string): string {\n return text\n .toLowerCase()\n .normalize(\"NFD\")\n .replace(/[\\u0300-\\u036f]/g, \"\"); // remove acentos\n}\n\nfunction relevanceScore(productName: string, keyword: string): number {\n const nameNorm = normalize(productName);\n const words = normalize(keyword).split(/\\s+/).filter(Boolean);\n if (words.length === 0) return 0;\n const matched = words.filter((w) => nameNorm.includes(w)).length;\n return matched / words.length; // 0 a 1 — proporção de palavras da busca encontradas no nome\n}\n\nfunction scoreOpportunity(\n p: { commission: number; sales: number; rating: number },\n): number {\n const commissionScore = p.commission * 10;\n const salesScore = Math.log10(Math.max(p.sales, 1)) * 5;\n const ratingPenalty = p.rating < 4.3 ? 20 : 0;\n return commissionScore + salesScore - ratingPenalty;\n}\n\nasync function searchProducts(\n keyword: string,\n): Promise<{ products: Product[]; approximate: boolean }> {\n const query = `\n query {\n productOfferV2(keyword: \"${keyword.replace(/\"/g, \"\")}\", limit: 30) {\n nodes {\n itemId\n shopId\n productName\n imageUrl\n price\n commissionRate\n commission\n ratingStar\n sales\n }\n }\n }\n `;\n\n const data = await callShopeeApi(query);\n const nodes = data?.data?.productOfferV2?.nodes ?? [];\n\n const allProducts: Product[] = nodes.map((n: any) => ({\n itemId: n.itemId,\n shopId: n.shopId,\n name: n.productName,\n imageUrl: n.imageUrl,\n price: Number(n.price),\n commissionRate: Number(n.commissionRate),\n commission: Number(n.commission),\n rating: Number(n.ratingStar),\n sales: Number(n.sales),\n score: 0,\n }));\n\n // Só considera relevante se pelo menos metade das palavras da busca\n // aparecem no nome do produto\n const relevant = allProducts.filter(\n (p) => relevanceScore(p.name, keyword) >= 0.5,\n );\n\n const approximate = relevant.length === 0;\n const pool = approximate ? allProducts : relevant;\n\n pool.forEach((p) => (p.score = scoreOpportunity(p)));\n const sorted = pool.sort((a, b) => b.score - a.score);\n\n return { products: sorted.slice(0, 15), approximate };\n}\n\n// ---------- Geração de copy (título, descrição, hashtags) ----------\n\nconst ANTHROPIC_API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n\nasync function generateCopy(product: {\n name: string;\n price: number;\n commissionRate: number;\n}): Promise<{ title: string; description: string; hashtags: string[] }> {\n if (!ANTHROPIC_API_KEY) {\n throw new Error(\n \"ANTHROPIC_API_KEY não configurada. Cadastre essa env var no Val (console.anthropic.com > API Keys) pra habilitar a geração de copy.\",\n );\n }\n\n const prompt =\n `Você é especialista em vídeos de afiliado que viralizam no Shopee Vídeo e TikTok Shop.\n\nProduto: \"${product.name}\"\nPreço: R$ ${product.price.toFixed(2)}\nComissão: ${(product.commissionRate * 100).toFixed(0)}%\n\nGere, em português do Brasil, no formato JSON exato abaixo (sem texto antes ou depois, só o JSON):\n{\n \"title\": \"título curto e chamativo pro vídeo, no máximo 60 caracteres\",\n \"description\": \"descrição de 1-2 frases, tom de achadinho/oferta, sem emojis em excesso\",\n \"hashtags\": [\"#tag1\", \"#tag2\", \"#tag3\", \"#tag4\", \"#tag5\"]\n}`;\n\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-api-key\": ANTHROPIC_API_KEY,\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({\n model: \"claude-sonnet-4-6\",\n max_tokens: 500,\n messages: [{ role: \"user\", content: prompt }],\n }),\n });\n\n const data = await res.json();\n const text = data?.content?.find((c: any) => c.type === \"text\")?.text ?? \"{}\";\n const cleaned = text.replace(/```json|```/g, \"\").trim();\n return JSON.parse(cleaned);\n}\n\n// ---------- \"Em alta agora\" — varre nichos populares automaticamente ----------\n\nconst NICHOS_POPULARES = [\n \"cozinha organizador\",\n \"beleza skincare\",\n \"casa decoração\",\n \"pet acessório\",\n \"bebê organizador\",\n \"fitness academia\",\n];\n\nasync function getTrendingProducts(): Promise {\n const resultsPerNicho = await Promise.all(\n NICHOS_POPULARES.map(async (nicho) => {\n try {\n const { products } = await searchProducts(nicho);\n return products.slice(0, 6); // top 6 de cada nicho\n } catch {\n return [];\n }\n }),\n );\n\n const merged = resultsPerNicho.flat();\n\n // remove duplicados (mesmo itemId)\n const seen = new Set();\n const unique = merged.filter((p) => {\n if (seen.has(p.itemId)) return false;\n seen.add(p.itemId);\n return true;\n });\n\n return unique.sort((a, b) => b.score - a.score).slice(0, 20);\n}\n\n// ---------- Banco de dados (histórico + cache) ----------\n\nlet schemaReady = false;\n\nasync function ensureSchema() {\n if (schemaReady) return;\n await sqlite.execute(`\n create table if not exists product_snapshots (\n item_id text,\n shop_id text,\n name text,\n image_url text,\n price real,\n commission_rate real,\n commission real,\n rating real,\n sales integer,\n score real,\n captured_at text\n )\n `);\n await sqlite.execute(`\n create table if not exists meta (\n key text primary key,\n value text\n )\n `);\n schemaReady = true;\n}\n\nasync function getMeta(key: string): Promise {\n const res = await sqlite.execute({\n sql: \"select value from meta where key = ?\",\n args: [key],\n });\n const r = res.rows[0] as any;\n if (!r) return null;\n const v = Array.isArray(r) ? r : Object.values(r);\n return v[0] ?? null;\n}\n\nasync function setMeta(key: string, value: string) {\n await sqlite.execute({\n sql:\n \"insert into meta (key, value) values (?, ?) on conflict(key) do update set value = excluded.value\",\n args: [key, value],\n });\n}\n\nasync function salvarSnapshot(products: Product[]) {\n const agora = new Date().toISOString();\n for (const p of products) {\n await sqlite.execute({\n sql: `insert into product_snapshots\n (item_id, shop_id, name, image_url, price, commission_rate, commission, rating, sales, score, captured_at)\n values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n p.itemId,\n p.shopId,\n p.name,\n p.imageUrl,\n p.price,\n p.commissionRate,\n p.commission,\n p.rating,\n p.sales,\n p.score,\n agora,\n ],\n });\n }\n await setMeta(\"last_trending_refresh\", agora);\n}\n\nasync function getUltimoSnapshot(): Promise {\n const res = await sqlite.execute(`\n select item_id, shop_id, name, image_url, price, commission_rate, commission, rating, sales, score\n from product_snapshots\n where captured_at = (select max(captured_at) from product_snapshots)\n order by score desc\n `);\n return (res.rows as any[]).map((r: any) => {\n // O Val Town pode devolver a linha como array posicional OU objeto\n // nomeado, dependendo do caso — normaliza pra um array de valores\n // e lê por posição, que funciona nos dois formatos.\n const v = Array.isArray(r) ? r : Object.values(r);\n return {\n itemId: v[0],\n shopId: v[1],\n name: v[2],\n imageUrl: v[3],\n price: Number(v[4]),\n commissionRate: Number(v[5]),\n commission: Number(v[6]),\n rating: Number(v[7]),\n sales: Number(v[8]),\n score: Number(v[9]),\n };\n });\n}\n\n// Busca em alta agora — usa cache de até 3h; se mais velho (ou vazio), busca de novo na Shopee e salva\nasync function getTrendingProductsComCache(): Promise<\n { products: Product[]; cached: boolean }\n> {\n await ensureSchema();\n\n const ultimaAtualizacao = await getMeta(\"last_trending_refresh\");\n const horasDeCache = 12 * 60 * 60 * 1000;\n const limiteCache = Date.now() - horasDeCache;\n const precisaAtualizar = !ultimaAtualizacao ||\n new Date(ultimaAtualizacao).getTime() < limiteCache;\n\n if (!precisaAtualizar) {\n const cache = await getUltimoSnapshot();\n if (cache.length > 0) return { products: cache, cached: true };\n }\n\n const fresh = await getTrendingProducts();\n await salvarSnapshot(fresh);\n return { products: fresh, cached: false };\n}\n\n// Radar de crescimento — compara o snapshot mais recente com um de ~7 dias atrás\nasync function getRadarCrescimento(): Promise<\n { products: (Product & { salesGrowth: number })[]; suficiente: boolean }\n> {\n await ensureSchema();\n\n const seteDiasAtras = new Date(Date.now() - 7 * 24 * 60 * 60 * 1000)\n .toISOString();\n\n const maisAntigo = await sqlite.execute(\n `select min(captured_at) as v from product_snapshots`,\n );\n const linhaAntiga = maisAntigo.rows[0] as any;\n const dataMaisAntiga = linhaAntiga\n ? (Array.isArray(linhaAntiga)\n ? linhaAntiga[0]\n : Object.values(linhaAntiga)[0])\n : null;\n\n if (!dataMaisAntiga || dataMaisAntiga > seteDiasAtras) {\n // ainda não tem 7 dias de histórico — mostra o que tiver, avisando que é parcial\n const atual = await getUltimoSnapshot();\n return {\n products: atual.map((p) => ({ ...p, salesGrowth: 0 })),\n suficiente: false,\n };\n }\n\n const atual = await getUltimoSnapshot();\n\n const comparacao = await Promise.all(\n atual.map(async (p) => {\n const antigo = await sqlite.execute({\n sql: `select sales from product_snapshots\n where item_id = ? and captured_at <= ?\n order by captured_at desc limit 1`,\n args: [p.itemId, seteDiasAtras],\n });\n const linhaAntiga = antigo.rows[0] as any;\n const salesAntigo = linhaAntiga\n ? Number(\n Array.isArray(linhaAntiga)\n ? linhaAntiga[0]\n : Object.values(linhaAntiga)[0],\n )\n : p.sales;\n return { ...p, salesGrowth: p.sales - salesAntigo };\n }),\n );\n\n const ordenado = comparacao.sort((a, b) => b.salesGrowth - a.salesGrowth)\n .slice(0, 20);\n return { products: ordenado, suficiente: true };\n}\n\n// ---------- Página HTML ----------\n\nconst HTML_PAGE = `\n\n\n\n \n \n Garimpa Sócia v2 — Busca com comissão real\n \n\n\n \n\n \n\n \n\n\n`;\n\n// ---------- Roteamento ----------\n\nconst GARIMPA_SENHA = Deno.env.get(\"GARIMPA_SENHA\");\n\nfunction checarSenha(req: Request): boolean {\n if (!GARIMPA_SENHA) return true; // se não configurou senha, não bloqueia (modo aberto)\n const auth = req.headers.get(\"Authorization\") ?? \"\";\n const senhaEnviada = auth.replace(\"Bearer \", \"\").trim();\n return senhaEnviada === GARIMPA_SENHA;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // A página HTML sempre carrega — a trava acontece nas chamadas de API,\n // que é onde o consumo de cota realmente acontece\n if (url.pathname.startsWith(\"/api/\") && !checarSenha(req)) {\n return new Response(\n JSON.stringify({ error: \"Senha incorreta ou não informada.\" }),\n {\n status: 401,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n if (url.pathname === \"/api/search\") {\n const keyword = url.searchParams.get(\"q\") ?? \"\";\n if (!keyword) {\n return new Response(\n JSON.stringify({ products: [], approximate: false }),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n try {\n const result = await searchProducts(keyword);\n return new Response(JSON.stringify(result), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n if (url.pathname === \"/api/trending\") {\n try {\n const { products, cached } = await getTrendingProductsComCache();\n return new Response(JSON.stringify({ products, cached }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n if (url.pathname === \"/api/radar\") {\n try {\n const { products, suficiente } = await getRadarCrescimento();\n return new Response(JSON.stringify({ products, suficiente }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n if (url.pathname === \"/api/copy\" && req.method === \"POST\") {\n try {\n const body = await req.json();\n const copy = await generateCopy(body);\n return new Response(JSON.stringify(copy), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n return new Response(HTML_PAGE, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}",[138],"f1189965-ac6d-459a-b03d-c7e9e979102f","main.ts","a5f22602-a3c1-11f1-9642-1607ee4eb77e",9,["D",1788303953700],4,"/**\n * GARIMPA SÓCIA v2 — Protótipo com comissão real\n * -------------------------------------------------\n * Um único arquivo HTTP no Val Town. Serve a página de busca E a API\n * por dentro do mesmo Val — não precisa mexer no Netlify ainda.\n *\n * COMO USAR:\n * 1. Cria um arquivo HTTP novo no Val Town (ou substitui o de teste)\n * 2. Cola este código\n * 3. Salva\n * 4. Clica em \"App\" — abre a página de busca, pronta pra usar\n *\n * Pré-requisito: as env vars SHOPEE_APP_ID e SHOPEE_APP_SECRET já\n * cadastradas nesse Val (mesmas que já usamos no teste).\n */\n\nconst APP_ID = Deno.env.get(\"SHOPEE_APP_ID\")!;\nconst APP_SECRET = Deno.env.get(\"SHOPEE_APP_SECRET\")!;\nconst API_URL = \"https://open-api.affiliate.shopee.com.br/graphql\";\n\n// ---------- Autenticação (mesma lógica já testada) ----------\n\nasync function buildSignature(\n appId: string,\n timestamp: number,\n payload: string,\n secret: string,\n): Promise {\n const raw = `${appId}${timestamp}${payload}${secret}`;\n const encoder = new TextEncoder();\n const data = encoder.encode(raw);\n const hashBuffer = await crypto.subtle.digest(\"SHA-256\", data);\n const hashArray = Array.from(new Uint8Array(hashBuffer));\n return hashArray.map((b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\n\nasync function callShopeeApi(query: string): Promise {\n const timestamp = Math.floor(Date.now() / 1000);\n const payload = JSON.stringify({ query });\n const signature = await buildSignature(\n APP_ID,\n timestamp,\n payload,\n APP_SECRET,\n );\n\n const res = await fetch(API_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization:\n `SHA256 Credential=${APP_ID}, Timestamp=${timestamp}, Signature=${signature}`,\n },\n body: payload,\n });\n\n return res.json();\n}\n\n// ---------- Busca de produtos ----------\n\ninterface Product {\n itemId: string;\n shopId: string;\n name: string;\n imageUrl: string;\n price: number;\n commissionRate: number;\n commission: number;\n rating: number;\n sales: number;\n score: number;\n}\n\nfunction normalize(text: string): string {\n return text\n .toLowerCase()\n .normalize(\"NFD\")\n .replace(/[\\u0300-\\u036f]/g, \"\"); // remove acentos\n}\n\nfunction relevanceScore(productName: string, keyword: string): number {\n const nameNorm = normalize(productName);\n const words = normalize(keyword).split(/\\s+/).filter(Boolean);\n if (words.length === 0) return 0;\n const matched = words.filter((w) => nameNorm.includes(w)).length;\n return matched / words.length; // 0 a 1 — proporção de palavras da busca encontradas no nome\n}\n\nfunction scoreOpportunity(\n p: { commission: number; sales: number; rating: number },\n): number {\n const commissionScore = p.commission * 10;\n const salesScore = Math.log10(Math.max(p.sales, 1)) * 5;\n const ratingPenalty = p.rating < 4.3 ? 20 : 0;\n return commissionScore + salesScore - ratingPenalty;\n}\n\nasync function searchProducts(\n keyword: string,\n): Promise<{ products: Product[]; approximate: boolean }> {\n const query = `\n query {\n productOfferV2(keyword: \"${keyword.replace(/\"/g, \"\")}\", limit: 30) {\n nodes {\n itemId\n shopId\n productName\n imageUrl\n price\n commissionRate\n commission\n ratingStar\n sales\n }\n }\n }\n `;\n\n const data = await callShopeeApi(query);\n const nodes = data?.data?.productOfferV2?.nodes ?? [];\n\n const allProducts: Product[] = nodes.map((n: any) => ({\n itemId: n.itemId,\n shopId: n.shopId,\n name: n.productName,\n imageUrl: n.imageUrl,\n price: Number(n.price),\n commissionRate: Number(n.commissionRate),\n commission: Number(n.commission),\n rating: Number(n.ratingStar),\n sales: Number(n.sales),\n score: 0,\n }));\n\n // Só considera relevante se pelo menos metade das palavras da busca\n // aparecem no nome do produto\n const relevant = allProducts.filter(\n (p) => relevanceScore(p.name, keyword) >= 0.5,\n );\n\n const approximate = relevant.length === 0;\n const pool = approximate ? allProducts : relevant;\n\n pool.forEach((p) => (p.score = scoreOpportunity(p)));\n const sorted = pool.sort((a, b) => b.score - a.score);\n\n return { products: sorted.slice(0, 15), approximate };\n}\n\n// ---------- Geração de copy (título, descrição, hashtags) ----------\n\nconst ANTHROPIC_API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n\nasync function generateCopy(product: {\n name: string;\n price: number;\n commissionRate: number;\n}): Promise<{ title: string; description: string; hashtags: string[] }> {\n if (!ANTHROPIC_API_KEY) {\n throw new Error(\n \"ANTHROPIC_API_KEY não configurada. Cadastre essa env var no Val (console.anthropic.com > API Keys) pra habilitar a geração de copy.\",\n );\n }\n\n const prompt =\n `Você é especialista em vídeos de afiliado que viralizam no Shopee Vídeo e TikTok Shop.\n\nProduto: \"${product.name}\"\nPreço: R$ ${product.price.toFixed(2)}\nComissão: ${(product.commissionRate * 100).toFixed(0)}%\n\nGere, em português do Brasil, no formato JSON exato abaixo (sem texto antes ou depois, só o JSON):\n{\n \"title\": \"título curto e chamativo pro vídeo, no máximo 60 caracteres\",\n \"description\": \"descrição de 1-2 frases, tom de achadinho/oferta, sem emojis em excesso\",\n \"hashtags\": [\"#tag1\", \"#tag2\", \"#tag3\", \"#tag4\", \"#tag5\"]\n}`;\n\n const res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"x-api-key\": ANTHROPIC_API_KEY,\n \"anthropic-version\": \"2023-06-01\",\n },\n body: JSON.stringify({\n model: \"claude-sonnet-4-6\",\n max_tokens: 500,\n messages: [{ role: \"user\", content: prompt }],\n }),\n });\n\n const data = await res.json();\n const text = data?.content?.find((c: any) => c.type === \"text\")?.text ?? \"{}\";\n const cleaned = text.replace(/```json|```/g, \"\").trim();\n return JSON.parse(cleaned);\n}\n\n// ---------- \"Em alta agora\" — varre nichos populares automaticamente ----------\n\nconst NICHOS_POPULARES = [\n \"cozinha organizador\",\n \"beleza skincare\",\n \"casa decoração\",\n \"pet acessório\",\n \"bebê organizador\",\n \"fitness academia\",\n];\n\nasync function getTrendingProducts(): Promise {\n const resultsPerNicho = await Promise.all(\n NICHOS_POPULARES.map(async (nicho) => {\n try {\n const { products } = await searchProducts(nicho);\n return products.slice(0, 6); // top 6 de cada nicho\n } catch {\n return [];\n }\n }),\n );\n\n const merged = resultsPerNicho.flat();\n\n // remove duplicados (mesmo itemId)\n const seen = new Set();\n const unique = merged.filter((p) => {\n if (seen.has(p.itemId)) return false;\n seen.add(p.itemId);\n return true;\n });\n\n return unique.sort((a, b) => b.score - a.score).slice(0, 20);\n}\n\n// ---------- Página HTML ----------\n\nconst HTML_PAGE = `\n\n\n\n \n \n Garimpa Sócia v2 — Busca com comissão real\n \n\n\n \n\n \n\n \n\n\n`;\n\n// ---------- Roteamento ----------\n\nconst GARIMPA_SENHA = Deno.env.get(\"GARIMPA_SENHA\");\n\nfunction checarSenha(req: Request): boolean {\n if (!GARIMPA_SENHA) return true; // se não configurou senha, não bloqueia (modo aberto)\n const auth = req.headers.get(\"Authorization\") ?? \"\";\n const senhaEnviada = auth.replace(\"Bearer \", \"\").trim();\n return senhaEnviada === GARIMPA_SENHA;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // A página HTML sempre carrega — a trava acontece nas chamadas de API,\n // que é onde o consumo de cota realmente acontece\n if (url.pathname.startsWith(\"/api/\") && !checarSenha(req)) {\n return new Response(\n JSON.stringify({ error: \"Senha incorreta ou não informada.\" }),\n {\n status: 401,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n\n if (url.pathname === \"/api/search\") {\n const keyword = url.searchParams.get(\"q\") ?? \"\";\n if (!keyword) {\n return new Response(\n JSON.stringify({ products: [], approximate: false }),\n {\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n try {\n const result = await searchProducts(keyword);\n return new Response(JSON.stringify(result), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n if (url.pathname === \"/api/trending\") {\n try {\n const products = await getTrendingProducts();\n return new Response(JSON.stringify({ products }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n if (url.pathname === \"/api/copy\" && req.method === \"POST\") {\n try {\n const body = await req.json();\n const copy = await generateCopy(body);\n return new Response(JSON.stringify(copy), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (err) {\n return new Response(JSON.stringify({ error: String(err) }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n return new Response(HTML_PAGE, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}",[146],"pulls","branches",1,"forks","envVars",{"_161":163,"_164":62},"connections",{"_161":62,"_162":62},"count","unfilledCount",3,"emptyCount",{"_43":145,"_32":146,"_30":147,"_131":-5,"_41":42,"_40":148,"_132":58,"_38":175,"_13":150,"_33":34,"_35":151,"_24":25,"_135":-5,"_169":176,"_27":177},{"_43":137,"_32":138,"_30":56,"_131":-5,"_41":42,"_40":139,"_132":25,"_38":172,"_13":141,"_33":142,"_35":143,"_24":25,"_135":45,"_169":173,"_27":174},{"_43":130,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_132":58,"_38":168,"_13":134,"_33":37,"_35":36,"_24":25,"_135":-5,"_169":170,"_27":171},["D",1788312618486],"children",[],[28],["D",1788312224476],[],[138],["D",1788303953700],[],[146],["D",1788018753272],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":85,"_32":86,"_43":42,"_87":44,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":45,"_94":95},"ctx",{"_78":-5,"_124":215,"_216":217,"_218":219,"_220":25,"_221":25,"_222":25,"_223":58,"_224":-5,"_225":-7,"_226":-7,"_227":62,"_228":25,"_229":25,"_230":-5,"_231":25,"_232":25,"_233":25,"_234":-5},"ENV",{"_186":187,"_188":189,"_190":86,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

🔍 Garimpa Sócia v2

🔍 Garimpa Sócia v2

🔒 Garimpa Sócia

🔍 Garimpa Sócia v2

🔒 Garimpa Sócia

🔍 Garimpa Sócia v2

Diff · v15