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",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_137":-5,"_20":138,"_22":139,"_140":141,"_142":143,"_26":144,"_24":145,"_146":-5,"_147":-5,"_148":65,"_149":150,"_151":59,"_152":-5,"_153":-5,"_154":155},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","luizarraes","name","garimpa-socia","branchName","main","version","path","new-file-6268.ts","project",{"_33":82,"_13":14,"_45":83,"_84":-5,"_85":65,"_86":87,"_88":87,"_89":-5,"_90":-5,"_91":92,"_93":38,"_94":59,"_95":-5,"_96":-5,"_97":98,"_99":100,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":106,"_107":106,"_108":109,"_110":109,"_111":109,"_112":106,"_113":106,"_114":115,"_116":117,"_118":119,"_120":65},"tree",[51,52,53],"file",{"_33":34,"_35":36,"_37":38,"_13":19,"_39":40,"_41":42,"_17":43,"_44":-5,"_45":46,"_47":48,"_49":14,"_18":50},"contents",[],"upstream","pull","ahead","behind","envVars","id","ed21e58d-2fd2-4697-8f6f-b48a9e822bdf","branchId","93365b8d-4b87-4a2c-a134-20a103db284f","fileId","e6c93e0c-a3c3-11f1-8c05-1607ee4eb77e","content","/**\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) — templates aleatórios, sem IA ----------\n\nconst TITULOS = [\n \"Achei o achadinho mais top da Shopee 😱\",\n \"PAREI TUDO quando vi esse preço 😱\",\n \"Gente, corre que isso aqui tá sumindo\",\n \"Isso aqui tá bombando na Shopee agora 🔥\",\n \"Vocês PRECISAM ver esse achado antes que acabe\",\n \"O item mais pedido da Shopee essa semana\",\n \"Shopee never disappoints 🛍️\",\n \"Esse achadinho é surreal, olha só\",\n \"Não acredito que achei isso por esse preço\",\n \"Já vendeu MUITO, corre que pode acabar\",\n \"Voltei pra contar sobre esse achado (vale muito)\",\n \"Isso deveria ser proibido de tão bom\",\n \"O achadinho que todo mundo tá comprando\",\n \"Comprei e já quero comprar mais um 😂\",\n \"Todo mundo comentando sobre esse achadinho\",\n \"Encontrei O item que faltava pra vocês\",\n \"Esse aqui rendeu demais, olha só\",\n \"O achadinho que salvou minha semana\",\n \"Shopee acertou em cheio dessa vez\",\n \"Gastei pouco e o resultado surpreendeu\",\n];\n\nconst DESCRICOES = [\n \"🚨 Corre que o estoque tá acabando! Link na bio pra garantir o seu\",\n \"Testei, aprovei e já indiquei pra 3 amigas ✨ Link na bio\",\n \"Preço incrível pra qualidade que entrega — clica no link e confere\",\n \"Já pedi o meu, agora é sua vez de garantir 👉 link na bio\",\n \"Melhor custo-benefício que já achei na Shopee, sem exagero\",\n \"Chegou rapidinho e já virou favorito aqui de casa — vale a pena\",\n \"Se não é a melhor oferta do mês, tá bem perto. Corre lá\",\n \"Vale MUITO a pena, super recomendo — link disponível\",\n \"A qualidade surpreendeu, não esperava tanto por esse valor\",\n \"Já usei bastante e continua ótimo, recomendo de olhos fechados\",\n \"Chegou rapidinho e é igualzinho à foto — clica e garante o seu\",\n \"Comprei pra mim e já separei outro de presente\",\n \"Um dos melhores achados que já fiz, sério\",\n \"Poupei bem comprando esse em vez do de loja física\",\n \"Virou item essencial aqui em casa — imperdível nesse preço\",\n];\n\nconst HASHTAGS_POOL = [\n \"#achadinhosdashopee\",\n \"#shopeefinds\",\n \"#achadinho\",\n \"#shopeebrasil\",\n \"#promocao\",\n \"#viral\",\n \"#tiktokmademebuyit\",\n \"#achadosdodia\",\n \"#compraonline\",\n \"#ofertadodia\",\n \"#shopeeoficial\",\n \"#queroisso\",\n \"#achadinhosdodia\",\n \"#shopeeviral\",\n \"#achadinhosviral\",\n \"#promoçãoimperdível\",\n \"#compradechina\",\n \"#shopeeaddict\",\n \"#achadinhosbaratos\",\n \"#lojaonline\",\n \"#shopeetiktok\",\n \"#custobeneficio\",\n \"#achadinhoshop\",\n \"#dicasdecompra\",\n];\n\nfunction sortear(lista: T[]): T {\n return lista[Math.floor(Math.random() * lista.length)];\n}\n\nfunction sortearVarios(lista: T[], n: number): T[] {\n const copia = [...lista].sort(() => Math.random() - 0.5);\n return copia.slice(0, n);\n}\n\nfunction generateCopy(product: {\n name: string;\n price: number;\n commissionRate: number;\n}): { title: string; description: string; hashtags: string[] } {\n const title = sortear(TITULOS);\n const description = `${sortear(DESCRICOES)} (R$ ${product.price.toFixed(2)})`;\n const hashtags = sortearVarios(HASHTAGS_POOL, 5);\n\n return { title, description, hashtags };\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}","fileType","http",8,"parentId","createdAt",["D",1788313716503],"branchVersion",17,"label",[19],{"_33":72,"_13":73,"_37":74,"_44":-5,"_35":36,"_47":75,"_58":59,"_45":76,"_17":77,"_41":78,"_39":79,"_64":65,"_49":-5,"_66":80,"_18":81},{"_33":34,"_13":19,"_37":38,"_44":-5,"_35":36,"_47":48,"_58":59,"_45":69,"_17":43,"_41":42,"_39":40,"_64":65,"_49":14,"_66":70,"_18":71},{"_33":54,"_13":55,"_37":56,"_44":-5,"_35":36,"_47":57,"_58":59,"_45":60,"_17":61,"_41":62,"_39":63,"_64":65,"_49":-5,"_66":67,"_18":68},"ed7b1acb-b4b2-455f-a2d8-87587feddf9e","new-file-9140.ts","aa9a6134-a66d-11f1-85f8-1607ee4eb77e",15,"latest",true,["D",1788312618486],2,"interval","/**\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}","deleted",false,"children",[],[55],["D",1788313716503],[],[19],"f1189965-ac6d-459a-b03d-c7e9e979102f","main.ts","a5f22602-a3c1-11f1-9642-1607ee4eb77e",9,["D",1788303953700],4,"script","/**\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}",[],[73],"b79b9fb9-0d4c-4ddc-bdcc-4124346e0bfc",["D",1788018753272],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","403bb087-0ba9-49d6-9729-5b75f65faaa0","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f7adf-7a74-7489-9a9d-2bd1a404c9c2","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_136":132},"org",{"_11":12,"_129":130,"_131":132,"_91":92,"_133":134,"_135":65},"branch",{"_17":48,"_13":16,"_33":36,"_121":82,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":14,"_128":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Luiz Arraes","avatar","https://lh3.googleusercontent.com/a/ACg8ocIIGgnRS5HdWAIu3ySgb1G03Itahle7xsG21QWJQVY7uCrWWdg3hA=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":82,"_13":14,"_45":178,"_84":-5,"_85":65,"_86":87,"_88":87,"_89":-5,"_90":-5,"_91":92,"_93":38,"_94":59,"_95":-5,"_96":-5,"_97":98,"_99":100,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":106,"_107":106,"_108":109,"_110":109,"_111":109,"_112":106,"_113":106,"_114":179,"_116":180,"_118":181,"_120":65},[169,170,171],"files",[169,170,171],"counts",{"_158":98,"_159":160,"_161":98,"_32":162,"_163":164},[],{"_33":34,"_13":19,"_37":38,"_44":-5,"_35":36,"_47":48,"_58":59,"_45":156,"_17":43,"_41":42,"_39":40,"_64":65,"_49":14,"_18":157},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1788313716503],[19],"pulls","branches",1,"forks",{"_165":167,"_168":98},"connections",{"_165":98,"_166":98},"count","unfilledCount",3,"emptyCount",{"_33":72,"_13":73,"_37":74,"_44":-5,"_35":36,"_47":75,"_58":59,"_45":76,"_17":77,"_41":78,"_39":79,"_64":65,"_49":-5,"_66":176,"_18":177},{"_33":34,"_13":19,"_37":38,"_44":-5,"_35":36,"_47":48,"_58":59,"_45":69,"_17":43,"_41":42,"_39":40,"_64":65,"_49":14,"_66":174,"_18":175},{"_33":54,"_13":55,"_37":56,"_44":-5,"_35":36,"_47":57,"_58":59,"_45":60,"_17":61,"_41":62,"_39":63,"_64":65,"_49":-5,"_66":172,"_18":173},[],[55],[],[19],[],[73],["D",1788018753272],{"_11":12,"_136":132},{"_11":12,"_129":130,"_131":132,"_91":92,"_133":134,"_135":65},{"_17":48,"_13":16,"_33":36,"_121":82,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":-5,"_127":14,"_128":12},"ctx",{"_114":-5,"_153":215,"_216":217,"_218":219,"_220":65,"_221":65,"_222":65,"_223":59,"_224":-5,"_225":-7,"_226":-7,"_227":98,"_228":65,"_229":65,"_230":-5,"_231":65,"_232":65,"_233":65,"_234":-5},"ENV",{"_186":187,"_188":189,"_190":16,"_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","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"]

🔍 Garimpa Sócia v2

🔍 Garimpa Sócia v2

🔒 Garimpa Sócia

🔍 Garimpa Sócia v2

🔒 Garimpa Sócia

🔍 Garimpa Sócia v2