diff --git a/apps/web/package.json b/apps/web/package.json index 6edd236..ee775b8 100644 --- a/apps/web/package.json +++ b/apps/web/package.json @@ -9,6 +9,7 @@ "lint": "eslint" }, "dependencies": { + "@deolho/db": "workspace:*", "class-variance-authority": "^0.7.1", "clsx": "^2.1.1", "lucide-react": "^1.16.0", diff --git a/apps/web/src/app/eventos/page.tsx b/apps/web/src/app/eventos/page.tsx new file mode 100644 index 0000000..58707f0 --- /dev/null +++ b/apps/web/src/app/eventos/page.tsx @@ -0,0 +1,180 @@ +/** + * Linha do tempo cívica — a fundação de dados (civic_events) finalmente VISÍVEL. + * + * Lista os acontecimentos verificáveis de Americana vindos do banco canônico: + * pagamentos, contratos, atos do diário, sanções, receitas. Cada item mostra + * FONTE e (quando há) VALOR — fonte antes de conclusão, sempre. + * + * force-dynamic: lê o Postgres em runtime (não prerenderiza no build sem banco). + */ +import Link from "next/link"; +import { ExternalLink } from "lucide-react"; +import { AppShell } from "@/components/app-shell/app-shell"; +import { GeoBreadcrumb } from "@/components/feed/geo-breadcrumb"; +import { EmptyState } from "@/components/feed/empty-state"; +import { + getEventos, + getEventosStats, + categoriaMeta, + fonteLabel, + valorBRL, + dataExtensa, + type CategoriaEvento, +} from "@/lib/eventos"; + +export const dynamic = "force-dynamic"; + +const CATS_VALIDAS: CategoriaEvento[] = [ + "contratacao", + "pagamento", + "receita", + "ato_normativo", + "nomeacao_exoneracao", + "sancao", + "audiencia_conselho", + "obra_zeladoria", +]; + +interface PageProps { + searchParams: Promise<{ cat?: string }>; +} + +export default async function EventosPage({ searchParams }: PageProps) { + const sp = await searchParams; + const cat = (CATS_VALIDAS as readonly string[]).includes(sp.cat ?? "") + ? (sp.cat as CategoriaEvento) + : undefined; + + const [eventos, stats] = await Promise.all([ + getEventos({ categoria: cat, limit: 50 }), + getEventosStats(), + ]); + + return ( + +
+

linha do tempo cívica

+

+ O que aconteceu em Americana +

+

+ {stats.total > 0 + ? `${stats.total.toLocaleString("pt-BR")} acontecimentos públicos verificáveis — cada um com a fonte oficial.` + : "Conecte o banco (DATABASE_URL) para ver os eventos coletados."} +

+
+ +
+ +
+ + {/* Filtros por categoria (com contagem real) */} + + + {/* Lista de eventos */} +
+ {eventos.length === 0 ? ( + + ) : ( + eventos.map((e) => ) + )} +
+ + ); +} + +function FiltroChip({ + label, + emoji, + href, + ativo, +}: { + label: string; + emoji: string; + href: string; + ativo: boolean; +}) { + return ( + + {emoji} + {label} + + ); +} + +function EventoCard({ evento }: { evento: Awaited>[number] }) { + const meta = categoriaMeta(evento.categoria); + const valor = valorBRL(evento.valor); + + return ( +
+
+ + {meta.emoji} + {meta.label} + + {dataExtensa(evento.dataEvento)} +
+ +

+ {evento.titulo} +

+ + {valor && ( +

{valor}

+ )} + + {evento.resumo && ( +

{evento.resumo}

+ )} + + +
+ ); +} diff --git a/apps/web/src/lib/eventos.ts b/apps/web/src/lib/eventos.ts new file mode 100644 index 0000000..a3ca41d --- /dev/null +++ b/apps/web/src/lib/eventos.ts @@ -0,0 +1,167 @@ +/** + * Read model da LINHA DO TEMPO CÍVICA — lê os eventos reais do banco canônico + * (civic_events) populado pelos coletores (PNCP, TCE-SP, Diário, CEIS…). + * + * É a ponte que torna VISÍVEL a fundação cívica: ~130 mil acontecimentos + * verificáveis de Americana, cada um com fonte, data e (quando há) valor. + * + * Resiliente: se DATABASE_URL não estiver definida (ex.: build no CI sem banco), + * degrada para vazio em vez de quebrar — mesma filosofia do loader de átomos. + */ +import "server-only"; +import { createDb, schema, type DB, desc, eq, sql } from "@deolho/db"; + +const { civicEvents } = schema; + +export type CategoriaEvento = + | "pagamento" + | "receita" + | "contratacao" + | "ato_normativo" + | "nomeacao_exoneracao" + | "sancao" + | "audiencia_conselho" + | "obra_zeladoria"; + +export interface EventoCivico { + id: string; + categoria: string; + tipo: string; + titulo: string; + resumo: string | null; + dataEvento: string | null; + valor: string | null; + sourceId: string; + sourceUrl: string | null; + publishedAt: Date | null; + fetchedAt: Date | null; + limitacoes: unknown; + trustType: string; +} + +let _db: DB | null | undefined; + +/** Conexão lazy. null se não houver DATABASE_URL (degrada para vazio). */ +function getDb(): DB | null { + if (_db !== undefined) return _db; + const url = process.env.DATABASE_URL; + _db = url ? createDb(url, { max: 3 }) : null; + return _db; +} + +export interface FiltroEventos { + categoria?: CategoriaEvento; + limit?: number; + offset?: number; +} + +/** Eventos mais recentes primeiro (sem data caem no fim). */ +export async function getEventos(filtro: FiltroEventos = {}): Promise { + const db = getDb(); + if (!db) return []; + const { categoria, limit = 50, offset = 0 } = filtro; + try { + const rows = await db + .select({ + id: civicEvents.id, + categoria: civicEvents.categoria, + tipo: civicEvents.tipo, + titulo: civicEvents.titulo, + resumo: civicEvents.resumo, + dataEvento: civicEvents.dataEvento, + valor: civicEvents.valor, + sourceId: civicEvents.sourceId, + sourceUrl: civicEvents.sourceUrl, + publishedAt: civicEvents.publishedAt, + fetchedAt: civicEvents.fetchedAt, + limitacoes: civicEvents.limitacoes, + trustType: civicEvents.trustType, + }) + .from(civicEvents) + .where(categoria ? eq(civicEvents.categoria, categoria) : undefined) + .orderBy(sql`${civicEvents.dataEvento} desc nulls last`, desc(civicEvents.criadoEm)) + .limit(Math.min(limit, 200)) + .offset(offset); + return rows as EventoCivico[]; + } catch (e) { + console.warn(`[eventos] query falhou (${e instanceof Error ? e.message : e}) — degradando para vazio`); + return []; + } +} + +export interface EstatEventos { + total: number; + porCategoria: Array<{ categoria: string; total: number }>; +} + +/** Contagem total + por categoria, para o cabeçalho e os filtros. */ +export async function getEventosStats(): Promise { + const db = getDb(); + if (!db) return { total: 0, porCategoria: [] }; + try { + const rows = await db + .select({ categoria: civicEvents.categoria, total: sql`count(*)::int` }) + .from(civicEvents) + .groupBy(civicEvents.categoria) + .orderBy(sql`count(*) desc`); + const total = rows.reduce((acc, r) => acc + Number(r.total), 0); + return { total, porCategoria: rows.map((r) => ({ categoria: r.categoria, total: Number(r.total) })) }; + } catch (e) { + console.warn(`[eventos] stats falhou (${e instanceof Error ? e.message : e})`); + return { total: 0, porCategoria: [] }; + } +} + +// ── Apresentação legível (linguagem pro cidadão comum) ─────────────────────── + +export const CATEGORIA_META: Record< + string, + { label: string; emoji: string; frase: string } +> = { + pagamento: { label: "Pagamento", emoji: "💸", frase: "a prefeitura pagou" }, + receita: { label: "Receita", emoji: "🪙", frase: "a prefeitura recebeu" }, + contratacao: { label: "Contrato", emoji: "📋", frase: "a prefeitura contratou" }, + ato_normativo: { label: "Ato oficial", emoji: "📜", frase: "foi publicado no diário" }, + nomeacao_exoneracao: { label: "Nomeação/Exoneração", emoji: "👤", frase: "mudança de cargo público" }, + sancao: { label: "Sanção", emoji: "⚠️", frase: "empresa com sanção registrada" }, + audiencia_conselho: { label: "Audiência/Conselho", emoji: "🏛️", frase: "reunião pública" }, + obra_zeladoria: { label: "Obra/Zeladoria", emoji: "🚧", frase: "obra ou serviço urbano" }, +}; + +export function categoriaMeta(cat: string) { + return CATEGORIA_META[cat] ?? { label: cat, emoji: "•", frase: "" }; +} + +/** Fonte em linguagem humana. */ +export function fonteLabel(sourceId: string): string { + const map: Record = { + pncp: "Portal Nacional de Contratações (PNCP)", + "tce-sp": "Tribunal de Contas do Estado (TCE-SP)", + "diario-americana": "Diário Oficial de Americana", + "querido-diario": "Querido Diário", + "cgu-transparencia": "Portal da Transparência (CGU)", + "transparencia-americana": "Transparência Americana", + "camara-americana": "Câmara Municipal de Americana", + "receita-cnpj": "Receita Federal (CNPJ)", + tse: "Justiça Eleitoral (TSE)", + }; + return map[sourceId] ?? sourceId; +} + +/** "R$ 56.424,00" ou null se sem valor. */ +export function valorBRL(valor: string | null): string | null { + if (!valor) return null; + const n = Number(valor); + if (Number.isNaN(n) || n === 0) return null; + return n.toLocaleString("pt-BR", { style: "currency", currency: "BRL" }); +} + +/** "19 de maio de 2026" ou "sem data". */ +export function dataExtensa(iso: string | null): string { + if (!iso) return "sem data"; + return new Date(iso + "T12:00:00").toLocaleDateString("pt-BR", { + day: "2-digit", + month: "long", + year: "numeric", + }); +} diff --git a/packages/db/src/index.ts b/packages/db/src/index.ts index 28b631d..7123980 100644 --- a/packages/db/src/index.ts +++ b/packages/db/src/index.ts @@ -1,2 +1,19 @@ export { createDb, schema, type DB } from "./client"; export * from "./schema/index"; + +// Reexporta os operadores de query do Drizzle para os consumidores (app web, +// workers) não precisarem declarar drizzle-orm como dependência direta — o +// pacote @deolho/db encapsula o acesso ao banco. +export { + and, + asc, + count, + desc, + eq, + gte, + ilike, + inArray, + lte, + or, + sql, +} from "drizzle-orm"; diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml index 178f7c6..165652d 100644 --- a/pnpm-lock.yaml +++ b/pnpm-lock.yaml @@ -14,6 +14,9 @@ importers: apps/web: dependencies: + '@deolho/db': + specifier: workspace:* + version: link:../../packages/db class-variance-authority: specifier: ^0.7.1 version: 0.7.1