[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"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","conversas.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":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/conversas.ts","extension","id","7b61bb17-98ef-49d1-9827-c6f570cf4172","fileId","d45c3a6e-a9f7-11f1-9797-1607ee4eb77e","parentId","branchId","009a213a-5d13-4852-b42f-8e801dff5e7d","branchVersion",172,"latest",true,"createdAt",["D",1788742774405],"version",7,"fileType","script","content","// Central TC — Conversas: canais por caso, presos ao cliente.\n//\n// A conversa mora em espaços do Google Chat, mas quem escreve é a Central:\n// as mensagens vão pela API do Chat com a conta da própria pessoa. O Chat\n// continua servindo de aplicativo no celular, mostrando a mesma linha do tempo.\n//\n// Três regras, todas verificadas aqui no servidor porque é aqui que se decide:\n// 1. A área vem da pessoa. Ninguém cria canal em área que não é sua.\n// 2. Cliente com nome idêntico não vira cadastro novo (índice UNIQUE garante).\n// 3. Nome parecido não bloqueia, avisa. Quem decide é o usuário.\n//\n// Escopos que o Workspace precisa autorizar por pessoa, uma vez:\n// chat.spaces chat.memberships chat.messages\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { getCookie, setCookie } from \"npm:hono/cookie\";\nimport {\n chaveOrdem,\n conferir,\n gerarSlug,\n slugDoCanal,\n slugLivre,\n sugerir,\n} from \"./nomes.ts\";\n\n// ---------------------------------------------------------------------------\n// Banco\n// ---------------------------------------------------------------------------\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS clientes (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n nome TEXT NOT NULL,\n chave TEXT NOT NULL,\n area_id INTEGER,\n created_at INTEGER,\n created_by TEXT DEFAULT ''\n)`);\n// A trava de cadastro repetido é do banco, não só da conferência da tela:\n// duas pessoas clicando ao mesmo tempo não conseguem criar o mesmo cliente.\nawait sqlite.execute(\n `CREATE UNIQUE INDEX IF NOT EXISTS clientes_chave_unica ON clientes(chave)`,\n);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS canais (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n cliente_id INTEGER NOT NULL,\n area_id INTEGER NOT NULL,\n slug TEXT NOT NULL,\n titulo TEXT NOT NULL,\n chave TEXT NOT NULL,\n space TEXT DEFAULT '',\n processo TEXT DEFAULT '',\n drive_url TEXT DEFAULT '',\n arquivado INTEGER DEFAULT 0,\n created_at INTEGER,\n created_by TEXT DEFAULT ''\n)`);\nawait sqlite.execute(\n `CREATE UNIQUE INDEX IF NOT EXISTS canais_slug_unico ON canais(slug)`,\n);\n\n// Quem participa de cada canal, espelhando a associação do espaço no Chat.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS canal_membros (\n canal_id INTEGER NOT NULL,\n email TEXT NOT NULL,\n entrou_at INTEGER,\n PRIMARY KEY (canal_id, email)\n)`);\n\n// Consentimento do Chat, por pessoa. Guarda só o refresh token.\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS google_chat_tokens (\n email TEXT PRIMARY KEY,\n refresh_token TEXT NOT NULL,\n escopos TEXT DEFAULT '',\n updated_at INTEGER\n)`);\n// O id da pessoa no Google (users/123). A API do Chat identifica o autor por\n// ele e NÃO devolve o nome na listagem de mensagens; sem este vínculo toda\n// mensagem apareceria como \"Alguém\". É aprendido no primeiro envio.\ntry {\n await sqlite.execute(\n `ALTER TABLE google_chat_tokens ADD COLUMN google_id TEXT DEFAULT ''`,\n );\n} catch { /* já existe */ }\n\n// Papel de sócio: enxerga tudo na Central e abre canal em qualquer área.\n// É diferente de admin — o sócio não administra conteúdo nem pessoas.\ntry {\n await sqlite.execute(`ALTER TABLE people ADD COLUMN socio INTEGER DEFAULT 0`);\n} catch { /* já existe */ }\n\n// ---------------------------------------------------------------------------\n// Google Chat\n// ---------------------------------------------------------------------------\nexport const ESCOPOS_CHAT = [\n \"https://www.googleapis.com/auth/chat.spaces\",\n \"https://www.googleapis.com/auth/chat.memberships\",\n \"https://www.googleapis.com/auth/chat.messages\",\n];\n\nconst CHAT_API = \"https://chat.googleapis.com/v1\";\n\n/** Troca o refresh token guardado por um access token de curta duração. */\nasync function accessToken(email: string): Promise {\n const row = (await sqlite.execute({\n sql: \"SELECT refresh_token FROM google_chat_tokens WHERE email = ?\",\n args: [email.toLowerCase()],\n })).rows[0];\n if (!row) return null;\n\n const r = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: Deno.env.get(\"GOOGLE_CLIENT_ID\") || \"\",\n client_secret: Deno.env.get(\"GOOGLE_CLIENT_SECRET\") || \"\",\n refresh_token: String(row.refresh_token),\n grant_type: \"refresh_token\",\n }),\n });\n if (!r.ok) return null;\n const j = await r.json();\n return j.access_token || null;\n}\n\nasync function chamarChat(\n token: string,\n caminho: string,\n init: RequestInit = {},\n): Promise {\n const r = await fetch(`${CHAT_API}${caminho}`, {\n ...init,\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n ...(init.headers || {}),\n },\n });\n const corpo = await r.json().catch(() => ({}));\n if (!r.ok) {\n const msg = corpo?.error?.message || `Chat API ${r.status}`;\n throw Object.assign(new Error(msg), { status: r.status, corpo });\n }\n return corpo;\n}\n\nasync function criarEspaco(token: string, nomeVisivel: string) {\n return chamarChat(token, \"/spaces\", {\n method: \"POST\",\n body: JSON.stringify({ spaceType: \"SPACE\", displayName: nomeVisivel }),\n });\n}\n\nasync function convidar(token: string, space: string, email: string) {\n return chamarChat(token, `/${space}/members`, {\n method: \"POST\",\n body: JSON.stringify({ member: { name: `users/${email}`, type: \"HUMAN\" } }),\n });\n}\n\n/** Nomes que a própria Central conhece, por id do Google. */\nasync function nomesConhecidos(): Promise> {\n const mapa: Record = {};\n try {\n const linhas = (await sqlite.execute(\n `SELECT t.google_id AS gid, t.email AS email, p.name AS nome\n FROM google_chat_tokens t\n LEFT JOIN people p ON LOWER(p.email) = LOWER(t.email)\n WHERE t.google_id IS NOT NULL AND t.google_id != ''`,\n )).rows as any[];\n for (const l of linhas) {\n const bruto = String(l.nome || \"\").trim();\n const doEmail = String(l.email || \"\").split(\"@\")[0].replace(\n /[._-]+/g,\n \" \",\n );\n const nome = bruto || doEmail.replace(/\\b\\w/g, (c) => c.toUpperCase());\n if (l.gid) mapa[`users/${l.gid}`] = nome;\n }\n } catch { /* sem nomes o fio ainda aparece */ }\n return mapa;\n}\n\n/**\n * Quem é quem no espaço, por id do Google.\n * Existe porque `spaces.messages.list` devolve `sender.name` (users/123) mas\n * deixa `sender.displayName` vazio — sem isto toda mensagem vira \"Alguém\".\n */\nasync function nomesDoEspaco(\n token: string,\n space: string,\n): Promise> {\n const nomes: Record = {};\n try {\n const j = await chamarChat(token, `/${space}/members?pageSize=200`);\n for (const m of j.memberships || []) {\n const u = m.member || {};\n if (u.name) nomes[u.name] = u.displayName || \"\";\n }\n } catch { /* sem os nomes o fio ainda aparece, só sem autor */ }\n return nomes;\n}\n\nasync function listarMensagens(token: string, space: string, teto = 60) {\n const q = new URLSearchParams({\n pageSize: String(teto),\n orderBy: \"createTime desc\",\n showDeleted: \"false\",\n });\n const j = await chamarChat(token, `/${space}/messages?${q}`);\n return (j.messages || []).reverse();\n}\n\nasync function enviarMensagem(token: string, space: string, texto: string) {\n return chamarChat(token, `/${space}/messages`, {\n method: \"POST\",\n body: JSON.stringify({ text: texto }),\n });\n}\n\n// ---------------------------------------------------------------------------\n// Helpers de domínio\n// ---------------------------------------------------------------------------\ntype Usuario = {\n email: string;\n name: string;\n picture: string;\n isAdmin: boolean;\n};\n\n/** As áreas em que a pessoa atua. É o que trava o campo Área na criação. */\nasync function areasDe(email: string, isAdmin: boolean): Promise {\n const socio = isAdmin || (await sqlite.execute({\n sql: \"SELECT socio FROM people WHERE email = ?\",\n args: [email.toLowerCase()],\n })).rows.some((r: any) => Number(r.socio) === 1);\n\n // Sócio (e admin) abre canal em qualquer área do escritório.\n if (socio) {\n return (await sqlite.execute(\"SELECT id FROM areas ORDER BY position, id\"))\n .rows.map((r: any) => Number(r.id));\n }\n return (await sqlite.execute({\n sql: \"SELECT area_id FROM people_areas WHERE email = ? ORDER BY area_id\",\n args: [email.toLowerCase()],\n })).rows.map((r: any) => Number(r.area_id));\n}\n\nasync function listaClientes() {\n return (await sqlite.execute(\n `SELECT c.id, c.nome, c.area_id,\n (SELECT COUNT(*) FROM canais k WHERE k.cliente_id = c.id AND k.arquivado = 0) AS canais\n FROM clientes c ORDER BY c.nome`,\n )).rows as any[];\n}\n\n/** Todos os slugs em uso. O nome do canal é único no escritório inteiro. */\nasync function todosOsSlugs(): Promise {\n return (await sqlite.execute(\"SELECT slug FROM canais\")).rows.map((r: any) =>\n String(r.slug)\n );\n}\n\nasync function casosDoCliente(clienteId: number) {\n return (await sqlite.execute({\n sql: `SELECT id, slug, titulo, area_id FROM canais\n WHERE cliente_id = ? AND arquivado = 0 ORDER BY created_at DESC`,\n args: [clienteId],\n })).rows as any[];\n}\n\n/** Só os canais em que a pessoa está. Quem manda no sigilo é o Chat. */\nasync function canaisDe(user: Usuario) {\n const sql = `\n SELECT k.*, c.nome AS cliente_nome, a.name AS area_nome, a.color AS area_cor,\n (SELECT COUNT(*) FROM canal_membros m2 WHERE m2.canal_id = k.id) AS membros\n FROM canais k\n JOIN clientes c ON c.id = k.cliente_id\n LEFT JOIN areas a ON a.id = k.area_id\n WHERE k.arquivado = 0\n AND EXISTS (SELECT 1 FROM canal_membros m\n WHERE m.canal_id = k.id AND m.email = ?)\n ORDER BY k.created_at DESC`;\n const canais =\n (await sqlite.execute({ sql, args: [user.email.toLowerCase()] }))\n .rows as any[];\n if (!canais.length) return canais;\n\n // Quem está em cada canal, para a tela do canal listar sem uma volta extra.\n const todos = (await sqlite.execute(\n \"SELECT canal_id, email FROM canal_membros\",\n )).rows as any[];\n const porCanal: Record = {};\n for (const m of todos) {\n const k = Number(m.canal_id);\n (porCanal[k] ||= []).push(String(m.email));\n }\n for (const k of canais) k.membros_lista = porCanal[Number(k.id)] || [];\n return canais;\n}\n\nasync function participa(canalId: number, email: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT 1 FROM canal_membros WHERE canal_id = ? AND email = ?\",\n args: [canalId, email.toLowerCase()],\n });\n return r.rows.length > 0;\n}\n\n// ---------------------------------------------------------------------------\n// Rotas\n// ---------------------------------------------------------------------------\nexport function montar(\n app: any,\n deps: { getUser: (c: any) => Promise },\n) {\n const { getUser } = deps;\n\n async function exigir(c: any): Promise {\n const u = await getUser(c);\n if (!u) {\n c.status(401);\n return null;\n }\n return u;\n }\n\n // ---- consentimento do Chat, incremental e por pessoa -------------------\n app.get(\"/auth/chat\", async (c: any) => {\n const user = await getUser(c);\n if (!user) return c.redirect(\"/login\");\n const estado = crypto.randomUUID();\n setCookie(c, \"chat_state\", estado, {\n httpOnly: true,\n secure: true,\n sameSite: \"Lax\",\n path: \"/\",\n maxAge: 600,\n });\n const u = new URL(\"https://accounts.google.com/o/oauth2/v2/auth\");\n u.searchParams.set(\"client_id\", Deno.env.get(\"GOOGLE_CLIENT_ID\") || \"\");\n u.searchParams.set(\n \"redirect_uri\",\n new URL(c.req.url).origin + \"/auth/chat/callback\",\n );\n u.searchParams.set(\"response_type\", \"code\");\n u.searchParams.set(\"scope\", ESCOPOS_CHAT.join(\" \"));\n u.searchParams.set(\"access_type\", \"offline\");\n u.searchParams.set(\"prompt\", \"consent\");\n u.searchParams.set(\"include_granted_scopes\", \"true\");\n u.searchParams.set(\"login_hint\", user.email);\n u.searchParams.set(\"state\", estado);\n return c.redirect(u.toString());\n });\n\n app.get(\"/auth/chat/callback\", async (c: any) => {\n const user = await getUser(c);\n if (!user) return c.redirect(\"/login\");\n const code = c.req.query(\"code\");\n const estado = c.req.query(\"state\");\n if (!code || !estado || estado !== getCookie(c, \"chat_state\")) {\n return c.redirect(\"/conversas?erro=consentimento\");\n }\n const r = await fetch(\"https://oauth2.googleapis.com/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n code,\n client_id: Deno.env.get(\"GOOGLE_CLIENT_ID\") || \"\",\n client_secret: Deno.env.get(\"GOOGLE_CLIENT_SECRET\") || \"\",\n redirect_uri: new URL(c.req.url).origin + \"/auth/chat/callback\",\n grant_type: \"authorization_code\",\n }),\n });\n const j = await r.json().catch(() => ({}));\n if (!r.ok || !j.refresh_token) {\n return c.redirect(\"/conversas?erro=sem_refresh\");\n }\n await sqlite.execute({\n sql:\n `INSERT INTO google_chat_tokens (email, refresh_token, escopos, updated_at)\n VALUES (?, ?, ?, ?)\n ON CONFLICT(email) DO UPDATE SET\n refresh_token = excluded.refresh_token,\n escopos = excluded.escopos,\n updated_at = excluded.updated_at`,\n args: [\n user.email.toLowerCase(),\n j.refresh_token,\n j.scope || \"\",\n Date.now(),\n ],\n });\n return c.redirect(\"/conversas\");\n });\n\n /**\n * Endpoint de gatilho do app de Chat.\n *\n * Existe só para o app ter identidade no Google Chat. Com os recursos\n * interativos desligados, toda mensagem enviada pela Central aparecia\n * assinada como \"App anônimo\" ao lado do nome da pessoa. O console exige um\n * URL de gatilho para ligá-los, então este é o URL: aceita o evento e não\n * faz nada, porque a Central não responde a interações dentro do Chat.\n */\n app.post(\"/api/conversas/chat-evento\", (c: any) => c.json({}));\n\n // ---- estado da tela ----------------------------------------------------\n app.get(\"/api/conversas\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n\n const ligado = (await sqlite.execute({\n sql: \"SELECT 1 FROM google_chat_tokens WHERE email = ?\",\n args: [user.email.toLowerCase()],\n })).rows.length > 0;\n\n const minhas = await areasDe(user.email, user.isAdmin);\n const areas =\n (await sqlite.execute(\n \"SELECT id, name, color FROM areas ORDER BY position, id\",\n ))\n .rows.filter((a: any) => minhas.includes(Number(a.id)));\n\n return c.json({ ligado, canais: await canaisDe(user), minhasAreas: areas });\n });\n\n /** Colegas do escritório, para escolher quem entra no canal. Não é dado sigiloso. */\n app.get(\"/api/conversas/equipe\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const linhas = (await sqlite.execute(\n \"SELECT email, name FROM people ORDER BY name, email\",\n )).rows as any[];\n const equipe = linhas\n .filter((p) => String(p.email).toLowerCase() !== user.email.toLowerCase())\n .map((p) => ({\n email: String(p.email),\n name: String(p.name || p.email),\n }));\n return c.json({ equipe });\n });\n\n // ---- clientes ----------------------------------------------------------\n app.get(\"/api/conversas/clientes\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const q = c.req.query(\"q\") || \"\";\n const todos = await listaClientes();\n return c.json({ clientes: q ? sugerir(q, todos) : todos.slice(0, 8) });\n });\n\n app.get(\"/api/conversas/clientes/:id/casos\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n return c.json({ casos: await casosDoCliente(Number(c.req.param(\"id\"))) });\n });\n\n /** Confere um nome de cliente. Não grava nada: só responde o que a tela deve mostrar. */\n app.post(\"/api/conversas/clientes/conferir\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const { termo } = await c.req.json().catch(() => ({ termo: \"\" }));\n const r = conferir(String(termo || \"\"), await listaClientes());\n return c.json({\n identico: r.identico,\n parecidos: r.parecidos.map((p) => ({\n ...p.item,\n grau: Math.round(p.grau * 100),\n motivo: p.motivo,\n })),\n });\n });\n\n app.post(\"/api/conversas/clientes\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const body = await c.req.json().catch(() => ({}));\n const nome = String(body.nome || \"\").trim();\n if (!nome) return c.json({ error: \"informe o nome do cliente\" }, 400);\n\n const chave = chaveOrdem(nome);\n if (!chave) {\n return c.json({ error: \"nome sem palavras aproveitáveis\" }, 400);\n }\n\n const r = conferir(nome, await listaClientes());\n if (r.identico) {\n return c.json(\n { error: \"cliente já cadastrado\", identico: r.identico },\n 409,\n );\n }\n const area = Number(body.area_id) || null;\n try {\n const ins = await sqlite.execute({\n sql:\n `INSERT INTO clientes (nome, chave, area_id, created_at, created_by)\n VALUES (?, ?, ?, ?, ?) RETURNING id`,\n args: [nome, chave, area, Date.now(), user.email],\n });\n return c.json({ id: Number(ins.rows[0].id), nome, canais: 0 });\n } catch (e) {\n // O índice UNIQUE é a última linha de defesa contra dois cliques simultâneos.\n return c.json({ error: \"cliente já cadastrado\" }, 409);\n }\n });\n\n // ---- casos dentro do cliente ------------------------------------------\n app.post(\"/api/conversas/casos/conferir\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const { cliente_id, termo } = await c.req.json().catch(() => ({}));\n if (!cliente_id) return c.json({ identico: null, parecidos: [] });\n const casos = await casosDoCliente(Number(cliente_id));\n const r = conferir(String(termo || \"\"), casos, \"titulo\");\n const nomeCli = (await sqlite.execute({\n sql: \"SELECT nome FROM clientes WHERE id = ?\",\n args: [Number(cliente_id)],\n })).rows[0]?.nome || \"\";\n return c.json({\n identico: r.identico,\n parecidos: r.parecidos.map((p) => ({\n ...p.item,\n grau: Math.round(p.grau * 100),\n motivo: p.motivo,\n })),\n slug: slugLivre(\n slugDoCanal(String(nomeCli), String(termo || \"\")),\n await todosOsSlugs(),\n ),\n });\n });\n\n // ---- criar o canal -----------------------------------------------------\n app.post(\"/api/conversas/canais\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n\n const body = await c.req.json().catch(() => ({}));\n const clienteId = Number(body.cliente_id);\n const titulo = String(body.titulo || \"\").trim();\n const areaId = Number(body.area_id);\n const convidados: string[] = Array.isArray(body.membros)\n ? body.membros\n : [];\n\n if (!clienteId || !titulo) {\n return c.json({ error: \"informe o cliente e o caso\" }, 400);\n }\n\n // Regra 1: a área é da pessoa. Recusar aqui, não só esconder na tela.\n const minhas = await areasDe(user.email, user.isAdmin);\n if (!minhas.includes(areaId)) {\n return c.json({ error: \"você só cria canais nas suas áreas\" }, 403);\n }\n\n const cliente = (await sqlite.execute({\n sql: \"SELECT id, nome FROM clientes WHERE id = ?\",\n args: [clienteId],\n })).rows[0];\n if (!cliente) return c.json({ error: \"cliente não encontrado\" }, 404);\n\n const casos = await casosDoCliente(clienteId);\n const conf = conferir(titulo, casos, \"titulo\");\n if (conf.identico && !body.forcar) {\n return c.json({\n error: \"este cliente já tem um canal com esse assunto\",\n identico: conf.identico,\n }, 409);\n }\n\n const token = await accessToken(user.email);\n if (!token) {\n return c.json(\n { error: \"autorize o Google Chat\", precisaConsentir: true },\n 428,\n );\n }\n\n // Nome do canal = iniciais do cliente + o caso, único no escritório inteiro.\n // Sem o prefixo, o \"Divórcio\" de um cliente brigava com o de outro.\n const base = String(body.slug || \"\").trim() ||\n slugDoCanal(String(cliente.nome), titulo);\n const slug = slugLivre(base, await todosOsSlugs());\n\n let space = \"\";\n try {\n const criado = await criarEspaco(token, `${cliente.nome} · ${titulo}`);\n space = criado.name || \"\";\n } catch (e: any) {\n return c.json({\n error: `Google Chat recusou criar o espaço: ${e.message}`,\n }, 502);\n }\n\n const agora = Date.now();\n const ins = await sqlite.execute({\n sql: `INSERT INTO canais\n (cliente_id, area_id, slug, titulo, chave, space, created_at, created_by)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?) RETURNING id`,\n args: [\n clienteId,\n areaId,\n slug,\n titulo,\n chaveOrdem(titulo),\n space,\n agora,\n user.email,\n ],\n });\n const canalId = Number(ins.rows[0].id);\n\n // Quem criou entra sempre; os demais são convidados no Chat e espelhados aqui.\n const membros = Array.from(\n new Set([\n user.email.toLowerCase(),\n ...convidados.map((e) => String(e).toLowerCase()).filter(Boolean),\n ]),\n );\n const falhas: string[] = [];\n for (const email of membros) {\n if (email !== user.email.toLowerCase()) {\n try {\n await convidar(token, space, email);\n } catch {\n falhas.push(email);\n continue;\n }\n }\n await sqlite.execute({\n sql:\n \"INSERT OR IGNORE INTO canal_membros (canal_id, email, entrou_at) VALUES (?, ?, ?)\",\n args: [canalId, email, agora],\n });\n }\n\n return c.json({ id: canalId, slug, space, titulo, falhas });\n });\n\n /** Chamar mais alguém depois, de dentro do canal. */\n app.post(\"/api/conversas/canais/:id/membros\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const canalId = Number(c.req.param(\"id\"));\n if (!await participa(canalId, user.email)) {\n return c.json({ error: \"você não está neste canal\" }, 403);\n }\n\n const { email } = await c.req.json().catch(() => ({}));\n const alvo = String(email || \"\").toLowerCase().trim();\n if (!alvo) return c.json({ error: \"informe o e-mail\" }, 400);\n\n const canal = (await sqlite.execute({\n sql: \"SELECT space FROM canais WHERE id = ?\",\n args: [canalId],\n })).rows[0];\n const token = await accessToken(user.email);\n if (!token) {\n return c.json(\n { error: \"autorize o Google Chat\", precisaConsentir: true },\n 428,\n );\n }\n\n try {\n await convidar(token, String(canal.space), alvo);\n } catch (e: any) {\n return c.json({ error: e.message }, 502);\n }\n\n await sqlite.execute({\n sql:\n \"INSERT OR IGNORE INTO canal_membros (canal_id, email, entrou_at) VALUES (?, ?, ?)\",\n args: [canalId, alvo, Date.now()],\n });\n return c.json({ ok: true });\n });\n\n // ---- mensagens ---------------------------------------------------------\n app.get(\"/api/conversas/canais/:id/mensagens\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const canalId = Number(c.req.param(\"id\"));\n if (!await participa(canalId, user.email)) {\n return c.json({ error: \"você não está neste canal\" }, 403);\n }\n\n const canal = (await sqlite.execute({\n sql: \"SELECT space FROM canais WHERE id = ?\",\n args: [canalId],\n })).rows[0];\n if (!canal?.space) return c.json({ mensagens: [] });\n\n const token = await accessToken(user.email);\n if (!token) {\n return c.json(\n { error: \"autorize o Google Chat\", precisaConsentir: true },\n 428,\n );\n }\n\n try {\n const [brutas, doEspaco, daCentral] = await Promise.all([\n listarMensagens(token, String(canal.space)),\n nomesDoEspaco(token, String(canal.space)),\n nomesConhecidos(),\n ]);\n const nomes = { ...doEspaco, ...daCentral };\n return c.json({\n mensagens: brutas.map((m: any) => ({\n id: m.name,\n texto: m.text || \"\",\n autor: m.sender?.displayName || nomes[m.sender?.name] || \"\",\n autor_id: m.sender?.name || \"\",\n quando: m.createTime || \"\",\n anexos: (m.attachment || []).map((a: any) => ({\n nome: a.contentName || \"arquivo\",\n tipo: a.contentType || \"\",\n })),\n })),\n });\n } catch (e: any) {\n return c.json({ error: e.message }, 502);\n }\n });\n\n app.post(\"/api/conversas/canais/:id/mensagens\", async (c: any) => {\n const user = await exigir(c);\n if (!user) return c.json({ error: \"não autenticado\" }, 401);\n const canalId = Number(c.req.param(\"id\"));\n if (!await participa(canalId, user.email)) {\n return c.json({ error: \"você não está neste canal\" }, 403);\n }\n\n const { texto } = await c.req.json().catch(() => ({}));\n const corpo = String(texto || \"\").trim();\n if (!corpo) return c.json({ error: \"mensagem vazia\" }, 400);\n\n const canal = (await sqlite.execute({\n sql: \"SELECT space FROM canais WHERE id = ?\",\n args: [canalId],\n })).rows[0];\n const token = await accessToken(user.email);\n if (!token) {\n return c.json(\n { error: \"autorize o Google Chat\", precisaConsentir: true },\n 428,\n );\n }\n\n try {\n const m = await enviarMensagem(token, String(canal.space), corpo);\n // O Google devolve quem assinou: guardamos o vínculo id -> e-mail para a\n // listagem conseguir nomear o autor daqui em diante.\n const gid = String(m.sender?.name || \"\").replace(\"users/\", \"\");\n if (gid) {\n await sqlite.execute({\n sql:\n \"UPDATE google_chat_tokens SET google_id = ? WHERE email = ? AND (google_id IS NULL OR google_id = '')\",\n args: [gid, user.email.toLowerCase()],\n });\n }\n return c.json({ id: m.name, quando: m.createTime });\n } catch (e: any) {\n return c.json({ error: e.message }, 502);\n }\n });\n}\n\nexport { areasDe, canaisDe, casosDoCliente, gerarSlug, listaClientes };","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","747cc3ce-9be8-11f1-880b-1607ee4eb77e","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,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_55":56,"_103":104,"_105":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":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",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":42,"_147":42,"_148":42,"_149":32,"_150":-5,"_151":-7,"_152":-7,"_153":63,"_154":42,"_155":42,"_156":-5,"_157":42,"_158":42,"_159":42,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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"]