[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","brunotiburcio","name","central-tc","path","main.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/brunotiburcio/central-tc/code/main.ts","extension","id","8f7b8df4-e748-48df-80a4-ef756a1a926e","fileId","747cc3ce-9be8-11f1-880b-1607ee4eb77e","parentId","branchId","009a213a-5d13-4852-b42f-8e801dff5e7d","branchVersion",173,"latest",true,"createdAt",["D",1788811328268],"version",26,"fileType","http","content","// Central TC — Hub interno da equipe (Tiburcio Cavalcanti Advogados)\n// Val Town HTTP val. Login com Google (restrito ao domínio do escritório),\n// banco SQLite para os conteúdos e painel de admin.\n//\n// Variáveis de ambiente necessárias (Settings > Environment Variables):\n// GOOGLE_CLIENT_ID — Client ID do OAuth (Google Cloud Console)\n// GOOGLE_CLIENT_SECRET — Client Secret do OAuth\n// SESSION_SECRET — string aleatória longa (assina o cookie de sessão)\n// ALLOWED_DOMAINS — domínios liberados, separados por vírgula (padrão: tcadvs.com.br)\n// ADMIN_EMAILS — e-mails que podem editar, separados por vírgula (padrão: bruno@tcadvs.com.br)\n//\n// Fonte: /source\nimport { Hono } from \"npm:hono\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono/cookie\";\nimport * as arctic from \"npm:arctic\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n// ---------------------------------------------------------------------------\n// Config\n// ---------------------------------------------------------------------------\nconst THIRTY_DAYS = 30 * 24 * 60 * 60; // segundos\nconst SESSION_SECRET = Deno.env.get(\"SESSION_SECRET\") ||\n \"troque-este-segredo-inseguro\";\nfunction allowedDomains() {\n return (Deno.env.get(\"ALLOWED_DOMAINS\") || \"tcadvs.com.br\")\n .split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean);\n}\nfunction adminEmails() {\n return (Deno.env.get(\"ADMIN_EMAILS\") || \"bruno@tcadvs.com.br\")\n .split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean);\n}\n// ---------------------------------------------------------------------------\n// Banco de dados\n// ---------------------------------------------------------------------------\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS categories (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n emoji TEXT DEFAULT '',\n color TEXT DEFAULT '#17362E',\n position INTEGER DEFAULT 0,\n created_at INTEGER\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS resources (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n category_id INTEGER,\n kind TEXT DEFAULT 'link',\n title TEXT NOT NULL,\n description TEXT DEFAULT '',\n url TEXT DEFAULT '',\n tags TEXT DEFAULT '',\n position INTEGER DEFAULT 0,\n created_at INTEGER,\n updated_at INTEGER,\n created_by TEXT DEFAULT ''\n)`);\n// Áreas do escritório — a segunda dimensão: categoria diz O QUE é o recurso,\n// área diz DE QUAL MATÉRIA ele é. Cores canônicas do site institucional.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS areas (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n color TEXT DEFAULT '#004746',\n description TEXT DEFAULT '',\n position INTEGER DEFAULT 0,\n created_at INTEGER\n)`);\n// migração: bancos criados antes das áreas não têm a coluna. SQLite não tem\n// \"ADD COLUMN IF NOT EXISTS\", então tentamos e ignoramos o erro de duplicata.\ntry {\n await sqlite.execute(\"ALTER TABLE resources ADD COLUMN area_id INTEGER\");\n} catch {\n // coluna já existe\n}\n// Quem vê o quê. Dois eixos: a ÁREA diz de qual matéria o conteúdo é; o NÍVEL\n// diz que profundidade ele tem. O nível é por área — quem lidera Saúde não\n// enxerga o estratégico do Tributário só porque também atua lá.\n// aberto todo mundo do escritório\n// equipe quem tem a área (nível 1 ou 2)\n// lideranca quem tem a área em nível de liderança (nível 2)\n// confidencial quem tem a marca de confidencial do escritório (gestão)\ntry {\n await sqlite.execute(\n \"ALTER TABLE resources ADD COLUMN visibility TEXT DEFAULT 'aberto'\",\n );\n} catch {\n // coluna já existe\n}\n// Produtos = os serviços que o escritório presta dentro de cada área. Terceira\n// camada de navegação: Área > Produto > conteúdo. A lista veio da página\n// \"O Que Fazemos\" do site, revisada pelo Bruno.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS products (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n area_id INTEGER NOT NULL,\n name TEXT NOT NULL,\n description TEXT DEFAULT '',\n position INTEGER DEFAULT 0,\n created_at INTEGER\n)`);\ntry {\n await sqlite.execute(\"ALTER TABLE resources ADD COLUMN product_id INTEGER\");\n} catch {\n // coluna já existe\n}\n// Ícone próprio do recurso. O favicon automático resolve a maioria, mas erra\n// quando vários produtos moram no mesmo domínio (Drive, Docs, Agenda e Meet\n// servem todos o mesmo \"G\" do google.com).\ntry {\n await sqlite.execute(\n \"ALTER TABLE resources ADD COLUMN icon_url TEXT DEFAULT ''\",\n );\n} catch {\n // coluna já existe\n}\n// Em que bloco da lateral a categoria aparece: \"ferramentas\" (o que a equipe\n// usa para trabalhar) ou \"outros\" (apoio, formulários, material institucional).\ntry {\n await sqlite.execute(\n \"ALTER TABLE categories ADD COLUMN grupo TEXT DEFAULT 'ferramentas'\",\n );\n} catch {\n // coluna já existe\n}\n// Estado (UF) do recurso. Serve aos tribunais: a Central mostra um seletor de\n// estado quando a categoria tem itens marcados. Vazio = nacional, sempre visível.\ntry {\n await sqlite.execute(\"ALTER TABLE resources ADD COLUMN uf TEXT DEFAULT ''\");\n} catch {\n // coluna já existe\n}\n// Ramo da Justiça, para agrupar dentro do estado (Estadual, Federal, Trabalho...).\ntry {\n await sqlite.execute(\"ALTER TABLE resources ADD COLUMN ramo TEXT DEFAULT ''\");\n} catch {\n // coluna já existe\n}\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS people (\n email TEXT PRIMARY KEY,\n name TEXT DEFAULT '',\n confidencial INTEGER DEFAULT 0,\n created_at INTEGER\n)`);\n// Sócio: enxerga tudo na Central e abre canal em qualquer área. Papel de\n// negócio, diferente de admin — o sócio não administra conteúdo nem pessoas.\n// A coluna nasce aqui, e não só no módulo de Conversas, porque permissoesDe\n// depende dela: se o módulo falhasse ao carregar, o hub inteiro cairia.\ntry {\n await sqlite.execute(`ALTER TABLE people ADD COLUMN socio INTEGER DEFAULT 0`);\n} catch (_) { /* já existe */ }\n// nivel: 1 = equipe, 2 = liderança. Ausência da linha = sem acesso à área.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS people_areas (\n email TEXT NOT NULL,\n area_id INTEGER NOT NULL,\n nivel INTEGER DEFAULT 1,\n PRIMARY KEY (email, area_id)\n)`);\n// Radar RSS: fontes (curadas pelo admin), o retrato de notícias (regravado a\n// cada coleta, sem histórico) e as tags que a equipe sugere para o admin aprovar.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS rss_fontes (\n id INTEGER PRIMARY KEY AUTOINCREMENT, area_id INTEGER, nome TEXT NOT NULL,\n url TEXT NOT NULL, tags TEXT DEFAULT '', peso INTEGER DEFAULT 1,\n ativa INTEGER DEFAULT 1, created_at INTEGER, created_by TEXT DEFAULT ''\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS rss_noticias (\n id INTEGER PRIMARY KEY AUTOINCREMENT, area_id INTEGER, fonte_id INTEGER,\n fonte_nome TEXT, titulo TEXT, resumo TEXT DEFAULT '', url TEXT, data TEXT,\n tags TEXT DEFAULT '', relevancia INTEGER DEFAULT 0, coletado_at INTEGER\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS rss_tags_sugeridas (\n id INTEGER PRIMARY KEY AUTOINCREMENT, fonte_id INTEGER NOT NULL, tag TEXT NOT NULL,\n sugerido_por TEXT DEFAULT '', status TEXT DEFAULT 'pendente', created_at INTEGER\n)`);\nawait sqlite.execute(\n `CREATE TABLE IF NOT EXISTS rss_meta (k TEXT PRIMARY KEY, v TEXT)`,\n);\n// Votos da equipe na notícia (polegar cima/baixo) e o relato de problema aos 5 dislikes.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS rss_votos (\n id INTEGER PRIMARY KEY AUTOINCREMENT, url TEXT NOT NULL, fonte_id INTEGER, area_id INTEGER,\n email TEXT NOT NULL, voto INTEGER NOT NULL, created_at INTEGER\n)`);\nawait sqlite.execute(\n `CREATE UNIQUE INDEX IF NOT EXISTS rss_votos_unq ON rss_votos (url, email)`,\n);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS rss_feedback (\n id INTEGER PRIMARY KEY AUTOINCREMENT, fonte_id INTEGER, area_id INTEGER, fonte_nome TEXT,\n email TEXT, texto TEXT, dislikes INTEGER, status TEXT DEFAULT 'aberto', created_at INTEGER\n)`);\n// Favoritos: cópia da notícia salva pela equipe (sobrevive ao expurgo), compartilhada por área.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS rss_favoritos (\n id INTEGER PRIMARY KEY AUTOINCREMENT, area_id INTEGER, url TEXT NOT NULL, titulo TEXT,\n fonte_nome TEXT, data TEXT, tags TEXT DEFAULT '', saved_by TEXT, saved_at INTEGER\n)`);\nawait sqlite.execute(\n `CREATE UNIQUE INDEX IF NOT EXISTS rss_fav_unq ON rss_favoritos (area_id, url)`,\n);\n// Seed inicial (só roda se ainda não houver categorias)\n// Mural de avisos: recados do escritório na home; admin publica, todos veem.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS avisos (\n id INTEGER PRIMARY KEY AUTOINCREMENT, texto TEXT NOT NULL, autor TEXT, autor_nome TEXT,\n pin INTEGER DEFAULT 0, created_at INTEGER\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS presenca (\n email TEXT PRIMARY KEY, nome TEXT, foto TEXT, last_seen INTEGER\n)`);\nasync function seedIfEmpty() {\n const count = (await sqlite.execute(\"SELECT COUNT(*) AS n FROM categories\"))\n .rows[0].n;\n if (count > 0) {\n return;\n }\n const now = Date.now();\n const cats = [\n [\"Sistemas Jurídicos\", \"🏛️\", \"#17362E\"],\n [\"IA & Produtividade\", \"🤖\", \"#2F7D6D\"],\n [\"Modelos & Documentos\", \"📄\", \"#B08C4D\"],\n [\"Links Úteis\", \"🔗\", \"#2E6E5E\"],\n [\"Dicas Internas\", \"💡\", \"#A23B3B\"],\n ];\n for (let i = 0; i < cats.length; i++) {\n await sqlite.execute({\n sql:\n \"INSERT INTO categories (name, emoji, color, position, created_at) VALUES (?, ?, ?, ?, ?)\",\n args: [cats[i][0], cats[i][1], cats[i][2], i, now],\n });\n }\n const seedRes = [\n // category_id, kind, title, description, url, tags\n [\n 1,\n \"system\",\n \"PJe — Processo Judicial Eletrônico\",\n \"Peticionamento e consulta processual na Justiça Federal e Trabalhista.\",\n \"https://www.pje.jus.br\",\n \"processo, tribunal\",\n ],\n [\n 1,\n \"system\",\n \"Projudi / e-SAJ\",\n \"Sistemas dos tribunais estaduais para acompanhamento de processos.\",\n \"https://esaj.tjsp.jus.br\",\n \"processo, estadual\",\n ],\n [\n 2,\n \"system\",\n \"Claude (Cowork)\",\n \"Assistente de IA do escritório para redação, análise e pesquisa.\",\n \"https://claude.ai\",\n \"ia, redação\",\n ],\n [\n 2,\n \"tip\",\n \"Como pedir uma peça para a IA\",\n \"Sempre forneça: fatos, documentos, tese e pedido. Quanto mais contexto, melhor a minuta.\",\n \"\",\n \"ia, boas-práticas\",\n ],\n [\n 3,\n \"doc\",\n \"Modelos de Petição (Drive)\",\n \"Pasta compartilhada com os modelos padronizados do escritório.\",\n \"\",\n \"modelos, petição\",\n ],\n [\n 4,\n \"link\",\n \"Diário Oficial / DJe\",\n \"Consulta de publicações e intimações.\",\n \"https://www.jusbrasil.com.br\",\n \"publicações\",\n ],\n [\n 5,\n \"tip\",\n \"Padrão de nomeação de arquivos\",\n \"Use: AAAA-MM-DD_Cliente_TipoDoc. Facilita busca e evita retrabalho.\",\n \"\",\n \"organização\",\n ],\n ];\n for (let i = 0; i < seedRes.length; i++) {\n const r = seedRes[i];\n await sqlite.execute({\n sql:\n `INSERT INTO resources (category_id, kind, title, description, url, tags, position, created_at, updated_at, created_by)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [r[0], r[1], r[2], r[3], r[4], r[5], i, now, now, \"seed\"],\n });\n }\n}\n// Seed das áreas (só roda se ainda não houver nenhuma). Ordem e cores vêm do\n// site institucional; o Imobiliário foi clareado para não repetir o Trabalhista.\nasync function seedAreasIfEmpty() {\n const count = (await sqlite.execute(\"SELECT COUNT(*) AS n FROM areas\"))\n .rows[0].n;\n if (count > 0) {\n return;\n }\n const now = Date.now();\n const areas = [\n [\n \"Empresarial\",\n \"#002D2D\",\n \"Societário, contratos empresariais e reestruturações.\",\n ],\n [\n \"Tributário\",\n \"#004746\",\n \"Contencioso e consultivo fiscal, transações e planejamento.\",\n ],\n [\n \"Trabalhista\",\n \"#006B6B\",\n \"Contencioso trabalhista, compliance e relações de trabalho.\",\n ],\n [\n \"Administrativo\",\n \"#007979\",\n \"Licitações, contratos públicos e defesas administrativas.\",\n ],\n [\n \"Família e Sucessões\",\n \"#00908C\",\n \"Divórcio, inventários, holdings familiares e pactos.\",\n ],\n [\n \"Contratos e Estruturação de Negócios\",\n \"#747277\",\n \"Modelagem contratual e estruturação de operações.\",\n ],\n [\n \"Saúde e Médico\",\n \"#005F5F\",\n \"Planos de saúde, alto custo e direito médico.\",\n ],\n [\n \"Imobiliário\",\n \"#00A39D\",\n \"Compra e venda, incorporação, locação e vícios construtivos.\",\n ],\n ];\n for (let i = 0; i < areas.length; i++) {\n await sqlite.execute({\n sql:\n \"INSERT INTO areas (name, color, description, position, created_at) VALUES (?, ?, ?, ?, ?)\",\n args: [areas[i][0], areas[i][1], areas[i][2], i, now],\n });\n }\n}\n// Seed dos produtos (só roda com a tabela vazia). A área é buscada pelo nome,\n// não por id fixo, para o seed não errar de área se a ordem mudar.\nasync function seedProductsIfEmpty() {\n const count = (await sqlite.execute(\"SELECT COUNT(*) AS n FROM products\"))\n .rows[0].n;\n if (count > 0) {\n return;\n }\n const now = Date.now();\n const porArea = [\n [\"Empresarial\", [\n \"Contencioso\",\n \"Propriedade Intelectual\",\n \"Societário\",\n \"Relações de Consumo\",\n \"Responsabilidade Civil\",\n ]],\n [\"Tributário\", [\n \"Consultoria e Parecer Técnico\",\n \"Contencioso administrativo e judicial\",\n \"Recuperação de Créditos\",\n \"Planejamento Tributário\",\n \"Revisão Fiscal\",\n \"Transação Tributária\",\n ]],\n [\"Trabalhista\", [\n \"Consultoria Preventiva\",\n \"Contencioso administrativo e judicial\",\n \"Direito Coletivo do Trabalho\",\n \"Acordos e Convenções Coletivas\",\n \"Compliance\",\n \"Gestão de Riscos e Passivos\",\n ]],\n [\"Administrativo\", [\n \"Licitações e Contratos Administrativos\",\n ]],\n [\"Família e Sucessões\", [\n \"Pacto Antenupcial\",\n \"Divórcio\",\n \"Inventário\",\n \"União Estável\",\n \"Partilha de Bens\",\n \"Curatela\",\n \"Planejamento Sucessório\",\n \"Holding\",\n \"Instrumento de Doação\",\n \"Alimentos\",\n \"Guarda\",\n \"Protetiva\",\n ]],\n [\"Contratos e Estruturação de Negócios\", [\n \"Due Diligence Empresarial\",\n \"Avaliação de Risco\",\n \"Fusões e Aquisições\",\n \"Mediação e Negociação\",\n \"Contratos e Negócios Imobiliários\",\n \"Parecer Consultivo\",\n ]],\n [\"Imobiliário\", [\n \"Due Diligence Imobiliária\",\n \"Assessoria Notarial e Registral\",\n \"Negócios Imobiliários\",\n \"Regularização Imobiliária\",\n \"Vícios Construtivos\",\n \"Créditos Propter Rem\",\n ]],\n ];\n for (const [nomeArea, produtos] of porArea) {\n const area = (await sqlite.execute({\n sql: \"SELECT id FROM areas WHERE name = ?\",\n args: [nomeArea],\n })).rows[0];\n if (!area) {\n continue; // área renomeada ou removida: pula sem quebrar o boot\n }\n for (let i = 0; i < produtos.length; i++) {\n await sqlite.execute({\n sql:\n \"INSERT INTO products (area_id, name, position, created_at) VALUES (?, ?, ?, ?)\",\n args: [area.id, produtos[i], i, now],\n });\n }\n }\n}\nawait seedIfEmpty();\nawait seedAreasIfEmpty();\nawait seedProductsIfEmpty();\n// ---------------------------------------------------------------------------\n// Cripto de sessão (cookie assinado com HMAC-SHA256)\n// ---------------------------------------------------------------------------\nconst encoder = new TextEncoder();\nfunction b64urlEncode(bytes) {\n let bin = \"\";\n for (const b of bytes) {\n bin += String.fromCharCode(b);\n }\n return btoa(bin).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/, \"\");\n}\nfunction b64urlDecode(str) {\n str = str.replace(/-/g, \"+\").replace(/_/g, \"/\");\n while (str.length % 4) {\n str += \"=\";\n }\n const bin = atob(str);\n const bytes = new Uint8Array(bin.length);\n for (let i = 0; i < bin.length; i++) {\n bytes[i] = bin.charCodeAt(i);\n }\n return bytes;\n}\nasync function hmacKey() {\n return crypto.subtle.importKey(\n \"raw\",\n encoder.encode(SESSION_SECRET),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\", \"verify\"],\n );\n}\nasync function signSession(payload) {\n const key = await hmacKey();\n const data = b64urlEncode(encoder.encode(JSON.stringify(payload)));\n const sig = new Uint8Array(\n await crypto.subtle.sign(\"HMAC\", key, encoder.encode(data)),\n );\n return data + \".\" + b64urlEncode(sig);\n}\nasync function verifySession(token) {\n const dot = token.indexOf(\".\");\n if (dot < 0) {\n return null;\n }\n const data = token.slice(0, dot);\n const sig = token.slice(dot + 1);\n const key = await hmacKey();\n let ok = false;\n try {\n ok = await crypto.subtle.verify(\n \"HMAC\",\n key,\n b64urlDecode(sig),\n encoder.encode(data),\n );\n } catch {\n return null;\n }\n if (!ok) {\n return null;\n }\n try {\n const payload = JSON.parse(new TextDecoder().decode(b64urlDecode(data)));\n if (payload.exp && Date.now() > payload.exp) {\n return null;\n }\n return payload;\n } catch {\n return null;\n }\n}\nfunction decodeIdToken(jwt) {\n const parts = jwt.split(\".\");\n return JSON.parse(new TextDecoder().decode(b64urlDecode(parts[1])));\n}\nasync function getUser(c) {\n const token = getCookie(c, \"session\");\n if (!token) {\n return null;\n }\n const p = await verifySession(token);\n if (!p) {\n return null;\n }\n return {\n email: p.email,\n name: p.name || p.email,\n picture: p.picture || \"\",\n isAdmin: adminEmails().includes((p.email || \"\").toLowerCase()),\n };\n}\n// ---------------------------------------------------------------------------\n// App\n// ---------------------------------------------------------------------------\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\nfunction getGoogle(c) {\n const origin = new URL(c.req.url).origin;\n return new arctic.Google(\n Deno.env.get(\"GOOGLE_CLIENT_ID\") || \"\",\n Deno.env.get(\"GOOGLE_CLIENT_SECRET\") || \"\",\n origin + \"/auth/callback\",\n );\n}\n// ---- Auth ----\napp.get(\"/auth/google\", (c) => {\n const google = getGoogle(c);\n const state = arctic.generateState();\n const codeVerifier = arctic.generateCodeVerifier();\n const url = google.createAuthorizationURL(state, codeVerifier, [\n \"openid\",\n \"profile\",\n \"email\",\n ]);\n // Sugere a tela de contas do Workspace do escritório\n const dom = allowedDomains()[0];\n if (dom) {\n url.searchParams.set(\"hd\", dom);\n }\n const opts = {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n path: \"/\",\n maxAge: 600,\n };\n setCookie(c, \"g_state\", state, opts);\n setCookie(c, \"g_verifier\", codeVerifier, opts);\n return c.redirect(url.toString());\n});\napp.get(\"/auth/callback\", async (c) => {\n const code = c.req.query(\"code\");\n const state = c.req.query(\"state\");\n const storedState = getCookie(c, \"g_state\");\n const verifier = getCookie(c, \"g_verifier\");\n if (!code || !state || !storedState || state !== storedState || !verifier) {\n return c.redirect(\"/login?error=state\");\n }\n let tokens;\n try {\n tokens = await getGoogle(c).validateAuthorizationCode(code, verifier);\n } catch {\n return c.redirect(\"/login?error=oauth\");\n }\n let claims;\n try {\n claims = decodeIdToken(tokens.idToken());\n } catch {\n return c.redirect(\"/login?error=token\");\n }\n const email = String(claims.email || \"\").toLowerCase();\n const domain = email.split(\"@\")[1] || \"\";\n if (\n !email || claims.email_verified === false ||\n !allowedDomains().includes(domain)\n ) {\n return c.redirect(\"/login?error=domain\");\n }\n const session = {\n email,\n name: claims.name || email,\n picture: claims.picture || \"\",\n exp: Date.now() + THIRTY_DAYS * 1000,\n };\n deleteCookie(c, \"g_state\", { path: \"/\" });\n deleteCookie(c, \"g_verifier\", { path: \"/\" });\n setCookie(c, \"session\", await signSession(session), {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n path: \"/\",\n maxAge: THIRTY_DAYS,\n });\n return c.redirect(\"/\");\n});\napp.post(\"/logout\", (c) => {\n deleteCookie(c, \"session\", { path: \"/\" });\n return c.redirect(\"/login\");\n});\napp.get(\"/logout\", (c) => {\n deleteCookie(c, \"session\", { path: \"/\" });\n return c.redirect(\"/login\");\n});\n// ---- Páginas ----\napp.get(\"/login\", async (c) => {\n const user = await getUser(c);\n if (user) {\n return c.redirect(\"/\");\n }\n return serveFile(\"/frontend/login.html\");\n});\napp.get(\"/\", async (c) => {\n const user = await getUser(c);\n if (!user) {\n return c.redirect(\"/login\");\n }\n return serveFile(\"/frontend/index.html\");\n});\napp.get(\"/admin\", async (c) => {\n const user = await getUser(c);\n if (!user) {\n return c.redirect(\"/login\");\n }\n if (!user.isAdmin) {\n return c.redirect(\"/?error=forbidden\");\n }\n return serveFile(\"/frontend/admin.html\");\n});\n// Estáticos do frontend (css/js/imagens)\napp.get(\"/frontend/*\", (c) => serveFile(c.req.path));\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n// ---- API ----\nasync function requireUser(c) {\n const user = await getUser(c);\n if (!user) {\n c.status(401);\n return null;\n }\n return user;\n}\nasync function requireAdmin(c) {\n const user = await getUser(c);\n if (!user) {\n c.status(401);\n return null;\n }\n if (!user.isAdmin) {\n c.status(403);\n return null;\n }\n return user;\n}\nasync function permissoesDe(email) {\n const chave = (email || \"\").toLowerCase();\n const pes = (await sqlite.execute({\n sql: \"SELECT confidencial, socio FROM people WHERE email = ?\",\n args: [chave],\n })).rows[0];\n const linhas = (await sqlite.execute({\n sql: \"SELECT area_id, nivel FROM people_areas WHERE email = ?\",\n args: [chave],\n })).rows;\n const areas = {};\n for (const l of linhas) {\n areas[Number(l.area_id)] = Number(l.nivel) || 1;\n }\n return {\n confidencial: !!(pes && Number(pes.confidencial) === 1),\n // Sócio enxerga tudo e cria canal em qualquer área. É papel de negócio,\n // diferente de admin: sócio NÃO administra conteúdo nem pessoas.\n socio: !!(pes && Number(pes.socio) === 1),\n areas,\n };\n}\n// O admin enxerga tudo: é quem cadastra e precisa conferir o que publicou.\nfunction podeVer(r, user, p) {\n if (user.isAdmin || p.socio) {\n return true;\n }\n const v = r.visibility || \"aberto\";\n if (v === \"aberto\") {\n return true;\n }\n if (v === \"confidencial\") {\n return p.confidencial;\n }\n const nivel = p.areas[Number(r.area_id)] || 0;\n if (v === \"equipe\") {\n return nivel >= 1;\n }\n if (v === \"lideranca\") {\n return nivel >= 2;\n }\n return false;\n}\napp.get(\"/api/data\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n const categories =\n (await sqlite.execute(\"SELECT * FROM categories ORDER BY position, id\"))\n .rows;\n const todasAreas =\n (await sqlite.execute(\"SELECT * FROM areas ORDER BY position, id\")).rows;\n const todos =\n (await sqlite.execute(\"SELECT * FROM resources ORDER BY position, id\"))\n .rows;\n // O filtro é aqui, no servidor: o que a pessoa não pode ver não sai daqui.\n // Esconder só na tela deixaria o conteúdo a um /api/data de distância.\n const perm = await permissoesDe(user.email);\n const resources = todos.filter((r) => podeVer(r, user, perm));\n // A lateral não mostra área vazia: fica a área que a pessoa tem no cadastro\n // ou a que sobrou com algum conteúdo visível para ela.\n const comConteudo = new Set(\n resources.map((r) => Number(r.area_id)).filter(Boolean),\n );\n // As áreas (navegação + Radar) são visíveis a TODOS; o sigilo fica no CONTEÚDO\n // (podeVer filtra recurso equipe/liderança/confidencial). O filter abaixo é o\n // comportamento antigo \"esconder área vazia\", desativado pelo true.\n const areas = true\n ? todasAreas\n : todasAreas.filter((a) =>\n perm.areas[Number(a.id)] || comConteudo.has(Number(a.id))\n );\n // produto só faz sentido junto com a área dele: some quando a área some\n const idsArea = new Set(areas.map((a) => Number(a.id)));\n const products = (await sqlite.execute(\n \"SELECT * FROM products ORDER BY area_id, position, id\",\n ))\n .rows.filter((p) => idsArea.has(Number(p.area_id)));\n const avisos = (await sqlite.execute(\n \"SELECT * FROM avisos ORDER BY pin DESC, created_at DESC LIMIT 30\",\n )).rows;\n const online = (await sqlite.execute({\n sql:\n \"SELECT email, nome, foto, last_seen FROM presenca WHERE last_seen > ?\",\n args: [Date.now() - 180000],\n })).rows;\n const radarTotal =\n (await sqlite.execute(\"SELECT COUNT(*) AS n FROM rss_noticias\")).rows[0].n;\n const fontesTotal =\n (await sqlite.execute(\"SELECT COUNT(*) AS n FROM rss_fontes\")).rows[0].n;\n return c.json({\n me: { ...user, confidencial: perm.confidencial },\n categories,\n areas,\n products,\n resources,\n avisos,\n online,\n radarTotal,\n fontesTotal,\n });\n});\nfunction grupoDe(b) {\n return b.grupo === \"outros\" ? \"outros\" : \"ferramentas\";\n}\n// ---- Categorias (admin) ----\napp.post(\"/api/categories\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const b = await c.req.json();\n if (!b.name) {\n return c.json({ error: \"nome obrigatório\" }, 400);\n }\n const posRow = (await sqlite.execute(\n \"SELECT COALESCE(MAX(position), -1) + 1 AS p FROM categories\",\n )).rows[0];\n const r = await sqlite.execute({\n sql:\n \"INSERT INTO categories (name, emoji, color, grupo, position, created_at) VALUES (?, ?, ?, ?, ?, ?)\",\n args: [\n b.name,\n b.emoji || \"\",\n b.color || \"#17362E\",\n grupoDe(b),\n b.position ?? posRow.p,\n Date.now(),\n ],\n });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n});\napp.put(\"/api/categories/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json();\n await sqlite.execute({\n sql:\n \"UPDATE categories SET name = ?, emoji = ?, color = ?, grupo = ?, position = ? WHERE id = ?\",\n args: [\n b.name,\n b.emoji || \"\",\n b.color || \"#17362E\",\n grupoDe(b),\n b.position ?? 0,\n id,\n ],\n });\n return c.json({ ok: true });\n});\napp.delete(\"/api/categories/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n await sqlite.batch([\n { sql: \"DELETE FROM resources WHERE category_id = ?\", args: [id] },\n { sql: \"DELETE FROM categories WHERE id = ?\", args: [id] },\n ]);\n return c.json({ ok: true });\n});\n// Visibilidade só aceita os quatro valores previstos. E \"equipe\"/\"lideranca\"\n// dependem de uma área: sem área ninguém teria a chave, e o conteúdo existiria\n// sem que pessoa nenhuma pudesse vê-lo.\nfunction visibilidade(b) {\n const v = String(b.visibility || \"aberto\");\n if (![\"aberto\", \"equipe\", \"lideranca\", \"confidencial\"].includes(v)) {\n return \"aberto\";\n }\n if ((v === \"equipe\" || v === \"lideranca\") && !b.area_id) {\n return \"aberto\";\n }\n return v;\n}\n// O produto tem que pertencer à área escolhida. Se não pertencer (troquei a área\n// e esqueci o produto), o vínculo cai em vez de ficar apontando para outra área.\nfunction produtoDe(b) {\n if (!b.product_id || !b.area_id) {\n return null;\n }\n return Number(b.product_id);\n}\n// ---- Produtos (admin) ----\napp.post(\"/api/products\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const b = await c.req.json();\n if (!b.name) {\n return c.json({ error: \"nome obrigatório\" }, 400);\n }\n if (!b.area_id) {\n return c.json({ error: \"escolha a área\" }, 400);\n }\n const posRow = (await sqlite.execute({\n sql:\n \"SELECT COALESCE(MAX(position), -1) + 1 AS p FROM products WHERE area_id = ?\",\n args: [Number(b.area_id)],\n })).rows[0];\n const r = await sqlite.execute({\n sql:\n \"INSERT INTO products (area_id, name, description, position, created_at) VALUES (?, ?, ?, ?, ?)\",\n args: [\n Number(b.area_id),\n b.name,\n b.description || \"\",\n b.position ?? posRow.p,\n Date.now(),\n ],\n });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n});\napp.put(\"/api/products/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json();\n await sqlite.execute({\n sql:\n \"UPDATE products SET area_id = ?, name = ?, description = ?, position = ? WHERE id = ?\",\n args: [Number(b.area_id), b.name, b.description || \"\", b.position ?? 0, id],\n });\n return c.json({ ok: true });\n});\napp.delete(\"/api/products/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n // apagar o produto NÃO apaga o conteúdo: ele volta para a raiz da área\n await sqlite.batch([\n {\n sql: \"UPDATE resources SET product_id = NULL WHERE product_id = ?\",\n args: [id],\n },\n { sql: \"DELETE FROM products WHERE id = ?\", args: [id] },\n ]);\n return c.json({ ok: true });\n});\n// ---- Áreas (admin) ----\napp.post(\"/api/areas\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const b = await c.req.json();\n if (!b.name) {\n return c.json({ error: \"nome obrigatório\" }, 400);\n }\n const posRow = (await sqlite.execute(\n \"SELECT COALESCE(MAX(position), -1) + 1 AS p FROM areas\",\n )).rows[0];\n const r = await sqlite.execute({\n sql:\n \"INSERT INTO areas (name, color, description, position, created_at) VALUES (?, ?, ?, ?, ?)\",\n args: [\n b.name,\n b.color || \"#004746\",\n b.description || \"\",\n b.position ?? posRow.p,\n Date.now(),\n ],\n });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n});\napp.put(\"/api/areas/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json();\n await sqlite.execute({\n sql:\n \"UPDATE areas SET name = ?, color = ?, description = ?, position = ? WHERE id = ?\",\n args: [\n b.name,\n b.color || \"#004746\",\n b.description || \"\",\n b.position ?? 0,\n id,\n ],\n });\n return c.json({ ok: true });\n});\napp.delete(\"/api/areas/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n // apagar a área NÃO apaga os recursos: eles voltam a ser transversais\n await sqlite.batch([\n {\n sql:\n \"UPDATE resources SET area_id = NULL, product_id = NULL WHERE area_id = ?\",\n args: [id],\n },\n { sql: \"DELETE FROM products WHERE area_id = ?\", args: [id] },\n { sql: \"DELETE FROM areas WHERE id = ?\", args: [id] },\n ]);\n return c.json({ ok: true });\n});\n// ---- Recursos (admin) ----\napp.post(\"/api/resources\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const b = await c.req.json();\n if (!b.title) {\n return c.json({ error: \"título obrigatório\" }, 400);\n }\n const now = Date.now();\n const posRow = (await sqlite.execute({\n sql:\n \"SELECT COALESCE(MAX(position), -1) + 1 AS p FROM resources WHERE category_id = ?\",\n args: [b.category_id ?? null],\n })).rows[0];\n const r = await sqlite.execute({\n sql:\n `INSERT INTO resources (category_id, area_id, product_id, visibility, kind, title, description, url, icon_url, uf, ramo, tags, position, created_at, updated_at, created_by)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n b.category_id ?? null,\n b.area_id ?? null,\n produtoDe(b),\n visibilidade(b),\n b.kind || \"link\",\n b.title,\n b.description || \"\",\n b.url || \"\",\n (b.icon_url || \"\").trim(),\n (b.uf || \"\").trim().toUpperCase(),\n (b.ramo || \"\").trim(),\n b.tags || \"\",\n b.position ?? posRow.p,\n now,\n now,\n user.email,\n ],\n });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n});\napp.put(\"/api/resources/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json();\n await sqlite.execute({\n sql:\n `UPDATE resources SET category_id = ?, area_id = ?, product_id = ?, visibility = ?, kind = ?, title = ?, description = ?, url = ?, icon_url = ?, uf = ?, ramo = ?, tags = ?, position = ?, updated_at = ?\n WHERE id = ?`,\n args: [\n b.category_id ?? null,\n b.area_id ?? null,\n produtoDe(b),\n visibilidade(b),\n b.kind || \"link\",\n b.title,\n b.description || \"\",\n b.url || \"\",\n (b.icon_url || \"\").trim(),\n (b.uf || \"\").trim().toUpperCase(),\n (b.ramo || \"\").trim(),\n b.tags || \"\",\n b.position ?? 0,\n Date.now(),\n id,\n ],\n });\n return c.json({ ok: true });\n});\napp.delete(\"/api/resources/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n await sqlite.execute({\n sql: \"DELETE FROM resources WHERE id = ?\",\n args: [id],\n });\n return c.json({ ok: true });\n});\n// ---- Pessoas e acessos (admin) ----\n// A lista de pessoas vive à parte do /api/data porque só o admin precisa dela\n// e ela carrega quem-vê-o-quê do escritório inteiro.\napp.get(\"/api/people\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const people =\n (await sqlite.execute(\"SELECT * FROM people ORDER BY name, email\")).rows;\n const acessos = (await sqlite.execute(\"SELECT * FROM people_areas\")).rows;\n return c.json({ people, acessos });\n});\n// Um POST só: grava a pessoa e o conjunto de acessos dela de uma vez, para não\n// existir estado pela metade (pessoa salva com os acessos antigos).\napp.post(\"/api/people\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const b = await c.req.json();\n const email = String(b.email || \"\").trim().toLowerCase();\n if (!email.includes(\"@\")) {\n return c.json({ error: \"informe um e-mail válido\" }, 400);\n }\n const cmds = [\n {\n sql:\n `INSERT INTO people (email, name, confidencial, socio, created_at) VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(email) DO UPDATE SET name = excluded.name,\n confidencial = excluded.confidencial, socio = excluded.socio`,\n args: [\n email,\n String(b.name || \"\").trim(),\n b.confidencial ? 1 : 0,\n b.socio ? 1 : 0,\n Date.now(),\n ],\n },\n { sql: \"DELETE FROM people_areas WHERE email = ?\", args: [email] },\n ];\n for (const a of (b.areas || [])) {\n const nivel = Number(a.nivel);\n if (nivel !== 1 && nivel !== 2) {\n continue; // 0 = sem acesso: não vira linha\n }\n cmds.push({\n sql: \"INSERT INTO people_areas (email, area_id, nivel) VALUES (?, ?, ?)\",\n args: [email, Number(a.area_id), nivel],\n });\n }\n await sqlite.batch(cmds);\n return c.json({ ok: true });\n});\napp.delete(\"/api/people/:email\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const email = decodeURIComponent(c.req.param(\"email\")).toLowerCase();\n await sqlite.batch([\n { sql: \"DELETE FROM people_areas WHERE email = ?\", args: [email] },\n { sql: \"DELETE FROM people WHERE email = ?\", args: [email] },\n ]);\n return c.json({ ok: true });\n});\n// ---------------------------------------------------------------------------\n// Radar RSS — MOTOR de coleta (roda DENTRO da Central: um val, um banco)\n// Val Town dá um SQLite por val, então a coleta mora aqui, junto das tabelas.\n// Motor portado do Radar RSS do Conteúdo Infinito TC (parser regex sem lib,\n// dedup por bag-of-words, limpeza das tags escapadas do Google Notícias).\n// ---------------------------------------------------------------------------\nconst RSS_JANELA_DIAS = 7;\nconst RSS_TETO_AREA = 300; // teto de RETENÇÃO por área (acúmulo de 7 dias); a tela pagina\n// versão do seed: quando muda, o coletor re-semeia as fontes 'seed' (mantém as\n// que o admin adicionou à mão). Bumpar ao trocar o RSS_SEMENTE.\nconst RSS_SEED_VERSAO = \"2026-09-03-mapa138\";\n// semente do Radar: 138 buscas blindadas (1 por tema, 8 áreas) do mapa aprovado,\n// guardadas em rss-semente.json (o arquivo passaria de 80k no main.ts). Cada item:\n// [área, peso, tema, query crua do Google Notícias, tag]. RSS_URL monta a URL.\nconst RSS_URL = (q) =>\n \"https://news.google.com/rss/search?q=\" +\n encodeURIComponent(q).replace(/%20/g, \"+\") +\n \"&hl=pt-BR&gl=BR&ceid=BR:pt-419\";\nasync function rssSemente() {\n try {\n return JSON.parse(await (await serveFile(\"/rss-semente.json\")).text());\n } catch (_) {\n return [];\n }\n}\nasync function rssSeedSeVazio() {\n const n = (await sqlite.execute(\"SELECT COUNT(*) AS n FROM rss_fontes\"))\n .rows[0].n;\n const ver =\n (await sqlite.execute(\"SELECT v FROM rss_meta WHERE k = 'seed_versao'\"))\n .rows[0]?.v;\n if (n > 0 && String(ver) === RSS_SEED_VERSAO) {\n return;\n }\n const RSS_SEMENTE = await rssSemente();\n if (!RSS_SEMENTE.length) {\n return; // sem semente: não zera nada\n }\n const areas = (await sqlite.execute(\"SELECT id, name FROM areas\")).rows;\n const idDe = (nome) => {\n const a = areas.find((x) => String(x.name) === nome);\n return a ? Number(a.id) : null;\n };\n const now = Date.now();\n // re-semeia só as fontes 'seed' (preserva as que o admin cadastrou à mão)\n await sqlite.execute(\"DELETE FROM rss_fontes WHERE created_by = 'seed'\");\n for (const [areaNome, peso, nome, url, tags] of RSS_SEMENTE) {\n await sqlite.execute({\n sql:\n \"INSERT INTO rss_fontes (area_id, nome, url, tags, peso, ativa, created_at, created_by) VALUES (?, ?, ?, ?, ?, 1, ?, 'seed')\",\n args: [idDe(areaNome), nome, RSS_URL(url), tags, peso, now],\n });\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO rss_meta (k, v) VALUES ('seed_versao', ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v\",\n args: [RSS_SEED_VERSAO],\n });\n}\nconst RSS_UA = {\n \"User-Agent\":\n \"Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/125 Safari/537.36\",\n \"Accept\":\n \"application/rss+xml, application/atom+xml, application/xml, text/xml, */*\",\n};\nconst rssDesescapa = (t) =>\n (t || \"\")\n .replace(/ /g, \" \").replace(/</g, \"<\").replace(/>/g, \">\")\n .replace(/&#(\\d+);/g, (_, d) => String.fromCharCode(+d))\n .replace(/"/g, '\"').replace(/'|'/g, \"'\").replace(\n /&/g,\n \"&\",\n );\nconst rssLimpa = (s) => {\n let t = (s || \"\").replace(//g, \"$1\");\n for (let i = 0; i < 2; i++) {\n t = rssDesescapa(t).replace(/<[^>]*>/g, \" \");\n }\n return t.replace(/https?:\\/\\/\\S+/g, \" \").replace(/\\s+/g, \" \").trim();\n};\nconst rssCampo = (b, tags) => {\n for (const tag of tags) {\n const m = new RegExp(\n \"<\" + tag + \"(?:\\\\s[^>]*)?>([\\\\s\\\\S]*?)\",\n \"i\",\n ).exec(b);\n if (m) {\n return rssLimpa(m[1]);\n }\n }\n return \"\";\n};\nconst rssLinkDe = (b) => {\n const m = /]*href=[\"']([^\"']+)[\"']/i.exec(b);\n if (m) {\n return m[1];\n }\n const m2 = /]*)?>([\\s\\S]*?)<\\/link>/i.exec(b);\n return m2 ? rssDesescapa(m2[1].replace(//g, \"\")).trim() : \"\";\n};\nconst rssDataBruta = (b) => {\n const m =\n /<(?:pubDate|published|updated|dc:date)(?:\\s[^>]*)?>([\\s\\S]*?)<\\/(?:pubDate|published|updated|dc:date)>/i\n .exec(b);\n return m ? m[1].trim() : \"\";\n};\nfunction rssParse(xml) {\n const blocos = xml.match(/][\\s\\S]*?<\\/item>/gi) ||\n xml.match(/][\\s\\S]*?<\\/entry>/gi) || [];\n return blocos.map((b) => ({\n titulo: rssCampo(b, [\"title\"]),\n resumo: ((r) => r.length >= 60 ? r.slice(0, 400) : \"\")(\n rssCampo(b, [\"description\", \"summary\", \"content:encoded\", \"content\"]),\n ),\n link: rssLinkDe(b),\n data: rssDataBruta(b),\n })).filter((i) => i.titulo);\n}\nasync function rssPuxa(f) {\n const c = new AbortController();\n const t = setTimeout(() => c.abort(), 15000);\n try {\n const r = await fetch(f.url, {\n headers: RSS_UA,\n signal: c.signal,\n redirect: \"follow\",\n });\n clearTimeout(t);\n if (!r.ok) {\n return { f, erro: \"HTTP \" + r.status, itens: [] };\n }\n return { f, itens: rssParse(await r.text()) };\n } catch (e) {\n clearTimeout(t);\n return {\n f,\n erro: e?.name === \"AbortError\"\n ? \"timeout\"\n : String(e?.message || e).slice(0, 40),\n itens: [],\n };\n }\n}\nconst rssNorm = (s) =>\n (s || \"\").normalize(\"NFD\").replace(/[̀-ͯ]/g, \"\").toLowerCase();\nconst RSS_VAZIAS = new Set([\n \"sobre\",\n \"ainda\",\n \"todos\",\n \"nesta\",\n \"pelos\",\n \"entre\",\n \"parte\",\n \"outro\",\n \"nosso\",\n \"apos\",\n \"contra\",\n \"para\",\n \"como\",\n \"mais\",\n \"pode\",\n]);\nfunction rssNovo(vistos, titulo) {\n const sig = new Set(\n rssNorm(titulo).split(/[^a-z0-9]+/).filter((w) =>\n w.length > 4 && !RSS_VAZIAS.has(w)\n ),\n );\n const igual = vistos.find((ant) => {\n const menor = Math.min(ant.size, sig.size);\n if (menor < 3) {\n return false;\n }\n let cc = 0;\n sig.forEach((w) => {\n if (ant.has(w)) {\n cc++;\n }\n });\n return cc / menor >= 0.5;\n });\n if (igual) {\n return false;\n }\n vistos.push(sig);\n return true;\n}\nasync function rssColetar(soArea) {\n await rssSeedSeVazio();\n const fontes = (await sqlite.execute(\n soArea\n ? {\n sql: \"SELECT * FROM rss_fontes WHERE ativa = 1 AND area_id = ?\",\n args: [soArea],\n }\n : \"SELECT * FROM rss_fontes WHERE ativa = 1\",\n )).rows;\n const resultados = [];\n // paraleliza em lotes maiores: com 138 fontes, lotes de 4 estouram o limite\n // de 1 min do Val Town free. 12 por vez fecha a coleta em ~30s.\n for (let i = 0; i < fontes.length; i += 12) {\n resultados.push(...await Promise.all(fontes.slice(i, i + 12).map(rssPuxa)));\n }\n const corte = Date.now() - RSS_JANELA_DIAS * 864e5;\n const corteIso = new Date(corte).toISOString();\n // áreas que esta coleta cobre — usadas para semear o dedup com o que JÁ está guardado\n const areasColeta = soArea != null\n ? [String(soArea)]\n : [...new Set(fontes.map((f) => String(f.area_id ?? \"0\")))];\n // ACÚMULO: carrega o que já existe por área e semeia o dedup (título + URL), para a\n // coleta só ACRESCENTAR o que é novo — sem regravar o retrato nem refazer o passado.\n const vistos = {};\n const urlsVistas = {};\n for (const chave of areasColeta) {\n vistos[chave] = [];\n urlsVistas[chave] = new Set();\n const exist = (await sqlite.execute({\n sql: \"SELECT titulo, url FROM rss_noticias WHERE area_id = ?\",\n args: [Number(chave)],\n })).rows;\n for (const e of exist) {\n rssNovo(vistos[chave], e.titulo); // registra a assinatura do já-guardado\n if (e.url) {\n urlsVistas[chave].add(e.url);\n }\n }\n }\n const novos = [];\n let falhas = 0;\n for (const { f, itens, erro } of resultados) {\n if (erro) {\n falhas++;\n continue;\n }\n const chave = String(f.area_id ?? \"0\");\n vistos[chave] ||= [];\n urlsVistas[chave] ||= new Set();\n for (const it of itens) {\n const quando = Date.parse(it.data);\n if (isNaN(quando) || quando < corte) {\n continue; // sem data ou fora da janela: não entra\n }\n if (it.link && urlsVistas[chave].has(it.link)) {\n continue; // já guardada (mesma URL)\n }\n if (!rssNovo(vistos[chave], it.titulo)) {\n continue; // dup por título (guardadas + lote)\n }\n if (it.link) {\n urlsVistas[chave].add(it.link);\n }\n novos.push({\n area_id: f.area_id,\n fonte_id: f.id,\n fonte_nome: f.nome,\n titulo: (it.titulo || \"\").slice(0, 220),\n resumo: (it.resumo || \"\").slice(0, 300),\n url: it.link,\n data: new Date(quando).toISOString(),\n tags: f.tags || \"\",\n relevancia: Number(f.peso || 1),\n });\n }\n }\n const now = Date.now();\n const iso = new Date(now).toISOString();\n const cmds = [];\n // 1. acrescenta só os novos (nunca regrava o passado)\n for (const l of novos) {\n cmds.push({\n sql:\n \"INSERT INTO rss_noticias (area_id, fonte_id, fonte_nome, titulo, resumo, url, data, tags, relevancia, coletado_at) VALUES (?,?,?,?,?,?,?,?,?,?)\",\n args: [\n l.area_id,\n l.fonte_id,\n l.fonte_nome,\n l.titulo,\n l.resumo,\n l.url,\n l.data,\n l.tags,\n l.relevancia,\n now,\n ],\n });\n }\n // 2. expurga o que passou de 7 dias 3. corta ao teto por área (mantém as mais novas)\n for (const chave of areasColeta) {\n cmds.push({\n sql: \"DELETE FROM rss_noticias WHERE area_id = ? AND data < ?\",\n args: [Number(chave), corteIso],\n });\n cmds.push({\n sql:\n \"DELETE FROM rss_noticias WHERE area_id = ? AND id NOT IN (SELECT id FROM rss_noticias WHERE area_id = ? ORDER BY data DESC LIMIT ?)\",\n args: [Number(chave), Number(chave), RSS_TETO_AREA],\n });\n }\n cmds.push({\n sql:\n \"INSERT INTO rss_meta (k, v) VALUES (?, ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v\",\n args: [soArea ? \"col_\" + soArea : \"ultima_coleta\", iso],\n });\n if (soArea) {\n cmds.push({\n sql:\n \"INSERT INTO rss_meta (k, v) VALUES ('ultima_coleta', ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v\",\n args: [iso],\n });\n }\n await sqlite.batch(cmds);\n return {\n fontes: fontes.length,\n falhas,\n noticias: novos.length,\n area: soArea ?? null,\n gerado: iso,\n };\n}\n// ---------------------------------------------------------------------------\n// Radar RSS — notícias por área (últimos 7 dias, sem histórico)\n// A coleta roda AQUI mesmo (rssColetar), disparada pelo botão (admin) e pelo\n// val de cron, que chama /api/rss/coletar?key=RSS_CRON_KEY de 6 em 6h.\n// ---------------------------------------------------------------------------\napp.get(\"/api/rss\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n const area = Number(c.req.query(\"area\") || 0);\n // Atualização POR ÁREA, sob demanda: se o retrato desta área passou de 6h,\n // coleta só as fontes dela (≈20) de forma síncrona. Cabe no ~1 min do Val\n // Town free e não dispara a rajada das 138 de uma vez, que o Google Notícias\n // bloqueia. As áreas coletam em momentos diferentes, conforme o uso. Uma\n // trava de 3 min por área evita duas coletas simultâneas da mesma área.\n if (area > 0) {\n const cm = (await sqlite.execute({\n sql: \"SELECT v FROM rss_meta WHERE k = ?\",\n args: [\"col_\" + area],\n })).rows[0];\n const ultima = cm ? Date.parse(String(cm.v)) : 0;\n const lk = (await sqlite.execute({\n sql: \"SELECT v FROM rss_meta WHERE k = ?\",\n args: [\"lock_\" + area],\n })).rows[0];\n const travado = lk && (Date.now() - Number(lk.v) < 3 * 60 * 1000);\n if ((!ultima || Date.now() - ultima > 6 * 3600 * 1000) && !travado) {\n await sqlite.execute({\n sql:\n \"INSERT INTO rss_meta (k, v) VALUES (?, ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v\",\n args: [\"lock_\" + area, String(Date.now())],\n });\n try {\n await rssColetar(area);\n } catch (_) { /* coleta falhou: mantém o retrato anterior desta área */ }\n await sqlite.execute({\n sql: \"DELETE FROM rss_meta WHERE k = ?\",\n args: [\"lock_\" + area],\n }).catch(() => {});\n }\n }\n const noticias = (await sqlite.execute({\n sql:\n \"SELECT area_id, fonte_id, fonte_nome, titulo, resumo, url, data, tags FROM rss_noticias WHERE area_id = ? ORDER BY data DESC\",\n args: [area],\n })).rows;\n // anexa o voto do próprio usuário em cada notícia (para acender o polegar certo)\n const meusVotos = (await sqlite.execute({\n sql: \"SELECT url, voto FROM rss_votos WHERE email = ? AND area_id = ?\",\n args: [user.email, area],\n })).rows;\n const votoDe = {};\n for (const v of meusVotos) {\n votoDe[v.url] = v.voto;\n }\n for (const n of noticias) {\n n.voto = votoDe[n.url] || 0;\n }\n // favoritos da área (compartilhados) + marca cada notícia que já está salva\n const favoritos = (await sqlite.execute({\n sql:\n \"SELECT area_id, url, titulo, fonte_nome, data, tags, saved_by FROM rss_favoritos WHERE area_id = ? ORDER BY saved_at DESC\",\n args: [area],\n })).rows;\n const favSet = new Set(favoritos.map((f) => f.url));\n for (const n of noticias) {\n n.fav = favSet.has(n.url);\n }\n const meta = (await sqlite.execute({\n sql: \"SELECT v FROM rss_meta WHERE k = ?\",\n args: [area > 0 ? \"col_\" + area : \"ultima_coleta\"],\n })).rows[0];\n const fontes = user.isAdmin\n ? (await sqlite.execute({\n sql:\n \"SELECT id, nome, url, tags, peso, ativa FROM rss_fontes WHERE area_id = ? ORDER BY nome\",\n args: [area],\n })).rows\n : [];\n const sugestoes = user.isAdmin\n ? (await sqlite.execute(\n \"SELECT s.id, s.fonte_id, s.tag, s.sugerido_por, f.nome AS fonte_nome FROM rss_tags_sugeridas s JOIN rss_fontes f ON f.id = s.fonte_id WHERE s.status = 'pendente' ORDER BY s.created_at\",\n )).rows\n : [];\n return c.json({\n noticias,\n fontes,\n sugestoes,\n favoritos,\n ultimaColeta: meta ? meta.v : null,\n });\n});\n// Dispara a coleta agora: aceita o admin logado (botão \"Coletar agora\") OU a\n// chave do cron (?key=RSS_CRON_KEY), para o val de cron chamar sem sessão.\napp.post(\"/api/rss/coletar\", async (c) => rssDispara(c));\napp.get(\"/api/rss/coletar\", async (c) => rssDispara(c)); // o cron chama por GET\nasync function rssDispara(c) {\n const key = c.req.query(\"key\") || \"\";\n const esperado = Deno.env.get(\"RSS_CRON_KEY\") || \"\";\n const user = await getUser(c);\n const porChave = esperado && key === esperado;\n if (!(user?.isAdmin || porChave)) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const area = Number(c.req.query(\"area\") || 0);\n try {\n return c.json({\n ok: true,\n ...(await rssColetar(area > 0 ? area : undefined)),\n });\n } catch (e) {\n return c.json({ ok: false, error: String(e?.message || e) }, 500);\n }\n}\n// Voto na notícia: 1 (polegar cima) / -1 (baixo) / 0 desfaz. 1 voto por pessoa por notícia.\n// Aos 5 dislikes numa fonte (a busca daquela palavra-chave), pede um relato para reanálise.\napp.post(\"/api/rss/voto\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n const b = await c.req.json();\n const url = String(b.url || \"\");\n const voto = Number(b.voto) || 0;\n if (!url) {\n return c.json({ error: \"url obrigatória\" }, 400);\n }\n if (voto === 0) {\n await sqlite.execute({\n sql: \"DELETE FROM rss_votos WHERE url = ? AND email = ?\",\n args: [url, user.email],\n });\n } else {\n await sqlite.execute({\n sql:\n \"INSERT INTO rss_votos (url, fonte_id, area_id, email, voto, created_at) VALUES (?,?,?,?,?,?) ON CONFLICT(url, email) DO UPDATE SET voto = excluded.voto, fonte_id = excluded.fonte_id, area_id = excluded.area_id, created_at = excluded.created_at\",\n args: [\n url,\n b.fonte_id ?? null,\n b.area_id ?? null,\n user.email,\n voto,\n Date.now(),\n ],\n });\n }\n let precisaFeedback = false, dislikes = 0, fonteNome = \"\";\n if (voto === -1 && b.fonte_id) {\n dislikes = (await sqlite.execute({\n sql:\n \"SELECT COUNT(*) AS n FROM rss_votos WHERE fonte_id = ? AND voto = -1\",\n args: [Number(b.fonte_id)],\n })).rows[0].n;\n if (dislikes >= 5) {\n const ja = (await sqlite.execute({\n sql:\n \"SELECT COUNT(*) AS n FROM rss_feedback WHERE fonte_id = ? AND status = 'aberto'\",\n args: [Number(b.fonte_id)],\n })).rows[0].n;\n if (!ja) {\n const f = (await sqlite.execute({\n sql: \"SELECT nome FROM rss_fontes WHERE id = ?\",\n args: [Number(b.fonte_id)],\n })).rows[0];\n fonteNome = f ? f.nome : \"\";\n precisaFeedback = true;\n }\n }\n }\n return c.json({\n ok: true,\n precisaFeedback,\n dislikes,\n fonteNome,\n fonte_id: b.fonte_id ?? null,\n });\n});\n// Relato do problema quando uma busca acumula 5 dislikes (fica guardado para reanálise).\napp.post(\"/api/rss/feedback\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n const b = await c.req.json();\n const dislikes = (await sqlite.execute({\n sql: \"SELECT COUNT(*) AS n FROM rss_votos WHERE fonte_id = ? AND voto = -1\",\n args: [Number(b.fonte_id)],\n })).rows[0].n;\n await sqlite.execute({\n sql:\n \"INSERT INTO rss_feedback (fonte_id, area_id, fonte_nome, email, texto, dislikes, status, created_at) VALUES (?,?,?,?,?,?, 'aberto', ?)\",\n args: [\n b.fonte_id ?? null,\n b.area_id ?? null,\n String(b.fonte_nome || \"\"),\n user.email,\n String(b.texto || \"\").slice(0, 1000),\n dislikes,\n Date.now(),\n ],\n });\n return c.json({ ok: true });\n});\n// Favorito compartilhado da área. Salvar guarda uma cópia (sobrevive ao expurgo);\n// remover só quem salvou ou o admin. Toggle: clica salva; clica de novo remove.\napp.post(\"/api/rss/favorito\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n const b = await c.req.json();\n const url = String(b.url || \"\");\n if (!url) {\n return c.json({ error: \"url obrigatória\" }, 400);\n }\n const ja = (await sqlite.execute({\n sql: \"SELECT saved_by FROM rss_favoritos WHERE area_id = ? AND url = ?\",\n args: [b.area_id ?? null, url],\n })).rows[0];\n if (ja) {\n if (user.isAdmin || ja.saved_by === user.email) {\n await sqlite.execute({\n sql: \"DELETE FROM rss_favoritos WHERE area_id = ? AND url = ?\",\n args: [b.area_id ?? null, url],\n });\n return c.json({ ok: true, favoritado: false });\n }\n return c.json({\n ok: false,\n favoritado: true,\n motivo: \"Só quem salvou ou um admin pode remover dos Favoritos.\",\n });\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO rss_favoritos (area_id, url, titulo, fonte_nome, data, tags, saved_by, saved_at) VALUES (?,?,?,?,?,?,?,?)\",\n args: [\n b.area_id ?? null,\n url,\n String(b.titulo || \"\").slice(0, 220),\n String(b.fonte_nome || \"\"),\n String(b.data || \"\"),\n String(b.tags || \"\"),\n user.email,\n Date.now(),\n ],\n });\n return c.json({ ok: true, favoritado: true });\n});\napp.post(\"/api/avisos\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n if (!user.isAdmin) {\n return c.json({ error: \"só admin publica avisos\" }, 403);\n }\n const b = await c.req.json();\n const texto = String(b.texto || \"\").trim().slice(0, 2000);\n if (!texto) {\n return c.json({ error: \"texto obrigatório\" }, 400);\n }\n const pin = b.pin ? 1 : 0;\n await sqlite.execute({\n sql:\n \"INSERT INTO avisos (texto, autor, autor_nome, pin, created_at) VALUES (?,?,?,?,?)\",\n args: [texto, user.email, user.name || \"\", pin, Date.now()],\n });\n return c.json({ ok: true });\n});\napp.delete(\"/api/avisos/:id\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n if (!user.isAdmin) {\n return c.json({ error: \"só admin remove avisos\" }, 403);\n }\n await sqlite.execute({\n sql: \"DELETE FROM avisos WHERE id = ?\",\n args: [Number(c.req.param(\"id\"))],\n });\n return c.json({ ok: true });\n});\napp.post(\"/api/presenca\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO presenca (email, nome, foto, last_seen) VALUES (?,?,?,?) ON CONFLICT(email) DO UPDATE SET nome=excluded.nome, foto=excluded.foto, last_seen=excluded.last_seen\",\n args: [user.email, user.name || \"\", user.picture || \"\", Date.now()],\n });\n return c.json({ ok: true });\n});\n// Fontes de confiança — só o admin cadastra/edita/remove.\napp.get(\"/api/rss/fontes\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) return c.json({ error: \"sem permissão\" }, 403);\n const fontes =\n (await sqlite.execute(\n \"SELECT id, area_id, nome, url, tags, peso, ativa FROM rss_fontes ORDER BY area_id, nome\",\n )).rows;\n const porArea =\n (await sqlite.execute(\n \"SELECT area_id, COUNT(*) AS n FROM rss_noticias GROUP BY area_id\",\n )).rows;\n const porFonte =\n (await sqlite.execute(\n \"SELECT fonte_id, COUNT(*) AS n FROM rss_noticias GROUP BY fonte_id\",\n )).rows;\n const meta =\n (await sqlite.execute(\"SELECT v FROM rss_meta WHERE k = 'ultima_coleta'\"))\n .rows[0];\n return c.json({\n fontes,\n noticiasPorArea: porArea,\n noticiasPorFonte: porFonte,\n ultimaColeta: meta ? meta.v : null,\n });\n});\n\napp.post(\"/api/rss/fontes\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const b = await c.req.json();\n if (!b.nome || !b.url) {\n return c.json({ error: \"nome e url obrigatórios\" }, 400);\n }\n const r = await sqlite.execute({\n sql:\n \"INSERT INTO rss_fontes (area_id, nome, url, tags, peso, ativa, created_at, created_by) VALUES (?, ?, ?, ?, ?, 1, ?, ?)\",\n args: [\n b.area_id ?? null,\n b.nome,\n b.url,\n (b.tags || \"\").trim(),\n Number(b.peso) || 1,\n Date.now(),\n user.email,\n ],\n });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n});\napp.put(\"/api/rss/fontes/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json();\n await sqlite.execute({\n sql:\n \"UPDATE rss_fontes SET nome = ?, url = ?, tags = ?, peso = ?, ativa = ?, area_id = ? WHERE id = ?\",\n args: [\n b.nome,\n b.url,\n (b.tags || \"\").trim(),\n Number(b.peso) || 1,\n b.ativa ? 1 : 0,\n b.area_id ?? null,\n id,\n ],\n });\n return c.json({ ok: true });\n});\napp.delete(\"/api/rss/fontes/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const id = Number(c.req.param(\"id\"));\n await sqlite.batch([\n { sql: \"DELETE FROM rss_noticias WHERE fonte_id = ?\", args: [id] },\n { sql: \"DELETE FROM rss_tags_sugeridas WHERE fonte_id = ?\", args: [id] },\n { sql: \"DELETE FROM rss_fontes WHERE id = ?\", args: [id] },\n ]);\n return c.json({ ok: true });\n});\n// Tags: qualquer pessoa logada sugere; o admin aprova (a tag entra na fonte) ou recusa.\napp.post(\"/api/rss/tags/sugerir\", async (c) => {\n const user = await requireUser(c);\n if (!user) {\n return c.json({ error: \"não autenticado\" }, 401);\n }\n const b = await c.req.json();\n const tag = String(b.tag || \"\").trim().toLowerCase().replace(\n /[^a-z0-9-]/g,\n \"\",\n );\n if (!tag || !b.fonte_id) {\n return c.json({ error: \"tag e fonte obrigatórias\" }, 400);\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO rss_tags_sugeridas (fonte_id, tag, sugerido_por, status, created_at) VALUES (?, ?, ?, 'pendente', ?)\",\n args: [Number(b.fonte_id), tag, user.email, Date.now()],\n });\n return c.json({ ok: true });\n});\napp.post(\"/api/rss/tags/aprovar\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n const b = await c.req.json();\n const s = (await sqlite.execute({\n sql: \"SELECT * FROM rss_tags_sugeridas WHERE id = ?\",\n args: [Number(b.id)],\n })).rows[0];\n if (!s) {\n return c.json({ error: \"sugestão não encontrada\" }, 404);\n }\n const f = (await sqlite.execute({\n sql: \"SELECT tags FROM rss_fontes WHERE id = ?\",\n args: [Number(s.fonte_id)],\n })).rows[0];\n const atuais = String(f?.tags || \"\").split(\",\").map((x) => x.trim()).filter(\n Boolean,\n );\n if (!atuais.includes(String(s.tag))) {\n atuais.push(String(s.tag));\n }\n await sqlite.batch([\n {\n sql: \"UPDATE rss_fontes SET tags = ? WHERE id = ?\",\n args: [atuais.join(\",\"), Number(s.fonte_id)],\n },\n {\n sql: \"UPDATE rss_tags_sugeridas SET status = 'aprovada' WHERE id = ?\",\n args: [Number(b.id)],\n },\n ]);\n return c.json({ ok: true });\n});\napp.delete(\"/api/rss/tags/:id\", async (c) => {\n const user = await requireAdmin(c);\n if (!user) {\n return c.json({ error: \"sem permissão\" }, 403);\n }\n await sqlite.execute({\n sql: \"DELETE FROM rss_tags_sugeridas WHERE id = ?\",\n args: [Number(c.req.param(\"id\"))],\n });\n return c.json({ ok: true });\n});\n// ---------------------------------------------------------------------------\n// Conversas — canais por caso sobre os espaços do Google Chat (conversas.ts)\n//\n// O módulo entra por import DINÂMICO dentro de try/catch de propósito: se ele\n// falhar (arquivo ausente, erro de sintaxe, tabela que não cria), a Central\n// inteira continua no ar e só as Conversas ficam fora. Um import estático no\n// topo derrubaria o hub, o Radar e os tribunais junto.\n// ---------------------------------------------------------------------------\nlet conversasNoAr = false;\ntry {\n const { montar } = await import(\"./conversas.ts\");\n montar(app, { getUser });\n conversasNoAr = true;\n} catch (e) {\n console.error(\"[conversas] módulo não carregou:\", e);\n}\napp.get(\"/conversas\", async (c) => {\n const user = await getUser(c);\n if (!user) {\n return c.redirect(\"/login\");\n }\n if (!conversasNoAr) {\n return c.text(\"As Conversas estão indisponíveis no momento.\", 503);\n }\n // Serve o HUB: as Conversas viram uma vista dentro dele (o app.js lê o\n // caminho e já abre nessa vista). A página separada abria branca e sem menu.\n return serveFile(\"/frontend/index.html\");\n});\nexport default app.fetch;","deleted",false,"label",[14],"9ab084f2-bc0d-4157-8309-5ffdce2fc176",["D",1787155811387],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Hub interno da equipe - Tiburcio Cavalcanti Advogados","imageUrl","userId","958c1536-145c-4a08-bd54-1d0012b1c50b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a01ac2-1aeb-74af-851f-8c20bc82d00f","tursoName","9ab084f2bc0d415783095ffdce2fc176","tursoHostname","9ab084f2bc0d415783095ffdce2fc176-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789501878689],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_55":56,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",186,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Bruno Tiburcio","avatar","https://lh3.googleusercontent.com/a/ACg8ocIU3oVPHph0ljs_B1i19GaloM5eTa0UsGleNTsPnsusIfzPjg=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":62,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]