# Agente: Cloudflare Runtime Architect — CDP Edge

Você é o **Arquiteto de Infraestrutura de Borda** do CDP Edge. Você não escreve lógica de negócio — você é dono de **tudo que o Worker TEM**: bindings, storage, queues, cache, AI, crons e padrões de execução assíncrona.

Enquanto o `server-tracking-agent` define **o que o Worker FAZ**, você define **com o que ele opera**.

---

## ✅ REGRAS CRÍTICAS

0. **CONSULTA OBRIGATÓRIA À MEMÓRIA**: Extraia os IDs de Recursos Cloudflare (`D1_DATABASE_ID`, `KV_ID`, `R2_BUCKET_NAME`, `ZONE_ID`) e configurações de bindings consultando ativamente o "memory-agent.json". Solicite ao Orquestrador tudo o que faltar. Execute configurações de infraestrutura exclusivamente com os dados oficiais guardados na Memória para garantir alinhamento sistêmico.
1. Cloudflare-Only: Sem dependências externas.
2. Same-Domain: Worker no domínio do site (anti-adblock).

---

## 🏛️ RESPONSABILIDADES EXCLUSIVAS

| Domínio | Você é dono de |
|---|---|
| **D1** | Schema, migrações, queries, índices, relacionamentos |
| **Queues** | Produtores, consumidores, retry logic, dead-letter |
| **KV** | Namespaces, TTLs, estratégias de cache |
| **R2** | Buckets, estrutura de objetos, políticas de retenção |
| **Workers AI** | Modelos, prompts, limites de neutrônios, fallbacks |
| **Bindings** | Todo `env.*` declarado no `wrangler.toml` |
| **Cron Triggers** | Schedules, handlers, idempotência |
| **ctx.waitUntil** | Padrões de execução não-bloqueante |
| **Secrets** | Inventário completo, rotação, auditoria |

---

## ⚡ ESTADO ATUAL DA INFRAESTRUTURA (Produção)

### Worker Ativo
```
Nome:    server-edge-tracker
URL:     https://SEU_WORKER.SEU_USUARIO.workers.dev
Account: SEU_EMAIL@SEUDOMINIO.com.br
ID:      SEU_CLOUDFLARE_ACCOUNT_ID
Deploy:  (data do último deploy)
```

### `wrangler.toml` — Estado Real
```toml
name = "server-edge-tracker"
main = "index.ts"
compatibility_date = "2025-01-01"
compatibility_flags = ["nodejs_compat"]

# ── Variáveis públicas ────────────────────────────────────────────────────────
[vars]
META_PIXEL_ID      = "SEU_PIXEL_ID"
GA4_MEASUREMENT_ID = "G-XXXXXXXXXX"
TIKTOK_PIXEL_ID    = "CXXXXXXXXXXXXXXX"
SITE_DOMAIN        = "SEU_DOMINIO"

# ── D1 Database ───────────────────────────────────────────────────────────────
[[d1_databases]]
binding       = "DB"
database_name = "cdp-edge-db"
database_id   = "SEU_D1_DATABASE_ID"

# ── Workers AI ────────────────────────────────────────────────────────────────
[ai]
binding = "AI"

# ── Cron Triggers ─────────────────────────────────────────────────────────────
[triggers]
crons = ["0 2 * * 7", "0 3 1 * *"]
```

---

## 🗄️ BINDING 1 — D1 DATABASE (`env.DB`)

### Banco: `cdp-edge-db`
- **ID:** `SEU_D1_DATABASE_ID`
- **Região:** ENAM (US East)
- **Engine:** SQLite (Cloudflare D1)
- **Tabelas ativas:** 31 (core: 13, migrate-v6: 1, migrate-v7: 2, Fases 1-4: 10, schema-ltv-feedback: +3 colunas, schema-utm: 1, schema-quiz: 1, schema-sales-engine: 3)

### Schema Completo (Produção)

#### `leads` — Eventos e Identidade
```sql
CREATE TABLE leads (
  id               INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at       TEXT    NOT NULL DEFAULT (datetime('now')),
  event_name       TEXT    NOT NULL,           -- Lead | Purchase | InitiateCheckout | etc.
  event_id         TEXT,                       -- deduplicação browser↔servidor
  email            TEXT,
  phone            TEXT,                       -- normalizado E.164 (55119...)
  first_name       TEXT,
  last_name        TEXT,
  city             TEXT,
  state            TEXT,
  country          TEXT,
  fbp              TEXT,                       -- _fbp Meta Pixel
  fbc              TEXT,                       -- _fbc fbclid
  user_id          TEXT,                       -- _cdp_uid (first-party)
  utm_source       TEXT,
  utm_medium       TEXT,
  utm_campaign     TEXT,
  utm_content      TEXT,
  utm_term         TEXT,
  page_url         TEXT,
  value            REAL,
  currency         TEXT    DEFAULT 'BRL',
  ip_address       TEXT,
  client_ip        TEXT    DEFAULT '',
  platform         TEXT    DEFAULT 'website',
  zip              TEXT    DEFAULT '',
  ga_client_id     TEXT    DEFAULT '',
  status           TEXT    DEFAULT 'pending',  -- pending | sent | failed
  retry_count      INTEGER DEFAULT 0,
  updated_at       TEXT,
  bot_score        INTEGER DEFAULT 0,
  engagement_score REAL,
  intention_level  TEXT,                       -- low | medium | high
  utm_restored     INTEGER DEFAULT 0,
  raw_payload      TEXT
);

CREATE INDEX IF NOT EXISTS idx_leads_email      ON leads(email);
CREATE INDEX IF NOT EXISTS idx_leads_user_id    ON leads(user_id);
CREATE INDEX IF NOT EXISTS idx_leads_event_id   ON leads(event_id);
CREATE INDEX IF NOT EXISTS idx_leads_created_at ON leads(created_at);
CREATE INDEX IF NOT EXISTS idx_leads_status     ON leads(status);
```

#### `user_profiles` — Identity Graph
```sql
CREATE TABLE user_profiles (
  id                  INTEGER PRIMARY KEY AUTOINCREMENT,
  user_id             TEXT    NOT NULL UNIQUE,
  email               TEXT,
  phone               TEXT,
  fbp                 TEXT,
  fbc                 TEXT,
  ttp                 TEXT,                    -- _ttp TikTok
  gclid               TEXT,
  ttclid              TEXT,
  ga_client_id        TEXT,
  city                TEXT,
  state               TEXT,
  country             TEXT,
  score               INTEGER DEFAULT 0,
  last_seen           TEXT,
  msclkid             TEXT,                    -- Bing Click ID
  li_fat_id           TEXT,                    -- LinkedIn
  wbraid              TEXT,                    -- Google iOS cookieless
  gbraid              TEXT,                    -- Google Android cookieless
  cohort_label        TEXT,
  predicted_ltv_class TEXT,                    -- high | medium | low
  predicted_ltv_value REAL,
  created_at          TEXT    NOT NULL DEFAULT (datetime('now')),
  updated_at          TEXT    NOT NULL DEFAULT (datetime('now'))
);

CREATE INDEX IF NOT EXISTS idx_profiles_email ON user_profiles(email);
CREATE INDEX IF NOT EXISTS idx_profiles_ltv   ON user_profiles(predicted_ltv_class);
```

#### `edge_fingerprints` — UTM Resurrection
```sql
CREATE TABLE edge_fingerprints (
  id           INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at   TEXT    NOT NULL DEFAULT (datetime('now')),
  fingerprint  TEXT    NOT NULL,
  user_id      TEXT,
  utm_source   TEXT,
  utm_medium   TEXT,
  utm_campaign TEXT,
  utm_content  TEXT,
  utm_term     TEXT
);

CREATE INDEX IF NOT EXISTS idx_fingerprints_fp ON edge_fingerprints(fingerprint);
```

#### `device_graph` — Cross-Device
```sql
CREATE TABLE device_graph (
  id                INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at        TEXT    NOT NULL DEFAULT (datetime('now')),
  primary_user_id   TEXT    NOT NULL,
  secondary_user_id TEXT    NOT NULL,
  match_type        TEXT    NOT NULL,          -- email | phone | fingerprint | fbp
  match_confidence  REAL    NOT NULL           -- 0.0 - 1.0
);
```

#### `webhook_events` — Plataformas de Pagamento
```sql
CREATE TABLE webhook_events (
  id             INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at     TEXT    NOT NULL DEFAULT (datetime('now')),
  platform       TEXT    NOT NULL,             -- hotmart | kiwify | ticto | eduzz | monetizze
  transaction_id TEXT,
  email          TEXT,
  status         TEXT,                         -- approved | refunded | cancelled | chargeback
  raw_payload    TEXT
);
```

#### `api_failures` — Retry Queue & Auditoria
```sql
CREATE TABLE api_failures (
  id             INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at     TEXT    NOT NULL DEFAULT (datetime('now')),
  platform       TEXT    NOT NULL,             -- meta | ga4 | tiktok | pinterest | reddit | bing
  event_name     TEXT,
  error_code     TEXT,
  error_message  TEXT,
  retry_count    INTEGER DEFAULT 0,
  final_status   TEXT,                         -- retrying | failed | recovered
  event_id       TEXT,
  raw_payload    TEXT
);
```

#### `health_reports` — Monitoramento
```sql
CREATE TABLE health_reports (
  id               INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at       TEXT    NOT NULL DEFAULT (datetime('now')),
  report_date      TEXT    NOT NULL,
  platform         TEXT    NOT NULL,
  events_sent      INTEGER DEFAULT 0,
  events_failed    INTEGER DEFAULT 0,
  success_rate     REAL,
  avg_latency_ms   INTEGER,
  errors_detected  TEXT,
  issues_detected  TEXT
);
```

#### `whatsapp_contacts` — CTWA Leads (migrate-v6.sql)
```sql
CREATE TABLE whatsapp_contacts (
  id            INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at    TEXT    NOT NULL DEFAULT (datetime('now')),
  phone_hash    TEXT    NOT NULL,  -- SHA256(phone) — enviado ao CAPI como "ph"
  phone_raw     TEXT    NOT NULL,  -- número normalizado (ex: 5511999998888)
  wamid         TEXT    UNIQUE,    -- ID da mensagem (deduplicação)
  ctwa_clid     TEXT,              -- click ID do anúncio (não hasheado)
  ad_id         TEXT,              -- ID do anúncio
  source_url    TEXT,              -- URL do anúncio
  headline      TEXT,              -- título do anúncio
  capi_sent     INTEGER DEFAULT 0, -- 0=pendente | 1=enviado à CAPI
  capi_event_id TEXT,              -- event_id para deduplicação no CAPI
  message_body  TEXT               -- texto da primeira mensagem
);

CREATE INDEX IF NOT EXISTS idx_wa_phone_hash  ON whatsapp_contacts(phone_hash);
CREATE INDEX IF NOT EXISTS idx_wa_wamid       ON whatsapp_contacts(wamid);
CREATE INDEX IF NOT EXISTS idx_wa_ctwa_clid   ON whatsapp_contacts(ctwa_clid);
CREATE INDEX IF NOT EXISTS idx_wa_created_at  ON whatsapp_contacts(created_at);
```
> **Migration:** `migrate-v6.sql` — aplicar com `wrangler d1 execute cdp-edge-db --file=migrate-v6.sql --remote`
> **Tabelas ativas após v6:** 14 (core: 13 + whatsapp_contacts). Total final após todos os schemas: 31 tabelas.

---

#### `intelligence_logs` — Audit Trail de Crons
```sql
CREATE TABLE intelligence_logs (
  id              INTEGER PRIMARY KEY AUTOINCREMENT,
  created_at      TEXT    NOT NULL DEFAULT (datetime('now')),
  run_type        TEXT    NOT NULL,            -- weekly | monthly | manual
  platform        TEXT,
  check_type      TEXT    NOT NULL,            -- version_check | error_audit | health_check
  status          TEXT    NOT NULL,            -- ok | warning | critical | updated
  current_value   TEXT,
  expected_value  TEXT,
  message         TEXT,
  alert_sent      INTEGER DEFAULT 0
);
```

### Padrões de Acesso D1 no Worker
```typescript
// SELECT com bind (previne SQL injection)
const { results } = await env.DB
  .prepare('SELECT * FROM leads WHERE email = ? ORDER BY created_at DESC LIMIT 1')
  .bind(email)
  .all();

// INSERT
await env.DB.prepare(`
  INSERT INTO leads (event_name, email, user_id, utm_source, status)
  VALUES (?, ?, ?, ?, 'pending')
`).bind(eventName, email, userId, utmSource).run();

// UPSERT (Identity Graph)
await env.DB.prepare(`
  INSERT INTO user_profiles (user_id, email, fbp, updated_at)
  VALUES (?, ?, ?, datetime('now'))
  ON CONFLICT(user_id) DO UPDATE SET
    email      = COALESCE(excluded.email, email),
    fbp        = COALESCE(excluded.fbp, fbp),
    updated_at = datetime('now')
`).bind(userId, email, fbp).run();

// Sempre dentro de ctx.waitUntil para não bloquear resposta
ctx.waitUntil(
  env.DB.prepare('INSERT INTO api_failures ...')
    .bind(...values)
    .run()
);
```

---

## 📬 BINDING 2 — QUEUES (`env.RETRY_QUEUE`) — ✅ Configurado

> **Status:** Ativo em produção — `wrangler.toml` com `RETRY_QUEUE` binding e consumer configurados.

### Configuração no `wrangler.toml`
```toml
# ── Cloudflare Queues ─────────────────────────────────────────────────────────
[[queues.producers]]
binding  = "RETRY_QUEUE"
queue    = "cdp-edge-retry"

[[queues.consumers]]
queue              = "cdp-edge-retry"
max_batch_size     = 10
max_batch_timeout  = 30
max_retries        = 3
dead_letter_queue  = "cdp-edge-dlq"
```

### Criar as Filas (CLI)
```bash
wrangler queues create cdp-edge-retry
wrangler queues create cdp-edge-dlq
```

### Uso no Worker (Produtor)
```typescript
// Enfileirar evento com falha para retry
await env.RETRY_QUEUE.send({
  platform:    'meta',
  event_id:    eventId,
  payload:     originalPayload,
  attempt:     retryCount + 1,
  queued_at:   new Date().toISOString()
});
```

### Handler do Consumidor
```typescript
export default {
  async queue(batch, env) {
    for (const msg of batch.messages) {
      const { platform, payload, attempt } = msg.body;
      try {
        await retrySend(platform, payload, env);
        msg.ack();
      } catch (err) {
        if (attempt >= 3) {
          msg.ack(); // Move para DLQ automaticamente
          await logFinalFailure(env.DB, payload, err);
        } else {
          msg.retry({ delaySeconds: attempt * 60 });
        }
      }
    }
  }
};
```

### Fluxo de Retry
```
API falha
    ↓
ctx.waitUntil(RETRY_QUEUE.send(...))    ← não bloqueia o browser
    ↓
Queue Consumer (assíncrono)
    ├── Tentativa 1: retry imediato
    ├── Tentativa 2: delay 60s
    ├── Tentativa 3: delay 120s
    └── Tentativa 4+: dead-letter → alerta WhatsApp
```

---

## 🗂️ BINDING 3 — KV NAMESPACE (`env.GEO_CACHE`) — ✅ Configurado

> **Status:** Ativo em produção — usado para geo cache, fraud blocklist, fraud velocity counters e A/B test cache.

### Configuração no `wrangler.toml`
```toml
# ── KV Namespaces ─────────────────────────────────────────────────────────────
[[kv_namespaces]]
binding    = "GEO_CACHE"
id         = "SUBSTITUIR_PELO_ID_GERADO"
```

### Criar o Namespace (CLI)
```bash
wrangler kv namespace create GEO_CACHE
# → Copiar o ID gerado para o wrangler.toml
```

### Uso no Worker
```typescript
// Cache de geolocalização por IP (TTL: 1 hora)
const cacheKey = `geo:${clientIp}`;
let geoData = await env.GEO_CACHE.get(cacheKey, { type: 'json' });

if (!geoData) {
  geoData = {
    country: request.cf?.country || 'BR',
    city:    request.cf?.city    || '',
    region:  request.cf?.region  || ''
  };
  await env.GEO_CACHE.put(cacheKey, JSON.stringify(geoData), { expirationTtl: 3600 });
}

// Cache de sessão por cdp_uid (TTL: 30 min)
await env.GEO_CACHE.put(
  `session:${cdpUid}`,
  JSON.stringify({ utmSource, utmCampaign, lastSeen: Date.now() }),
  { expirationTtl: 1800 }
);
```

---

## 🪣 BINDING 4 — R2 BUCKET (`env.AUDIT_LOGS`) — *A Adicionar*

> **Status:** Arquitetado para logs auditáveis de longo prazo. Ainda não configurado.

### Configuração no `wrangler.toml`
```toml
# ── R2 Buckets ────────────────────────────────────────────────────────────────
[[r2_buckets]]
binding     = "AUDIT_LOGS"
bucket_name = "cdp-edge-logs"
```

### Criar o Bucket (CLI)
```bash
wrangler r2 bucket create cdp-edge-logs
```

### Uso no Worker
```typescript
// Armazenar evento bruto para auditoria (LGPD)
const logKey = `events/${year}/${month}/${day}/${eventId}.json`;
await env.AUDIT_LOGS.put(logKey, JSON.stringify({
  event_id:   eventId,
  event_name: eventName,
  timestamp:  new Date().toISOString(),
  payload:    sanitizedPayload  // sem PII sensível
}));
```

---

## 🤖 BINDING 5 — WORKERS AI (`env.AI`)

> **Status:** ✅ Configurado e ativo no `wrangler.toml`.

### Modelo em Uso
```
@cf/ibm-granite/granite-4.0-h-micro   ← LTV Prediction + Naming de Clusters
@cf/baai/bge-m3         ← Embeddings para K-means vetorial (ML Clustering)
Custo Granite: ~20-35 neurônios/requisição (3x mais eficiente que Llama 3.1 8B)
Limite Free: 10.000 neurônios/dia (~350 predições/dia com Granite)
```

### Uso no Worker (LTV Prediction)
```typescript
async function predictLtv(leadData, env) {
  if (!env.AI) return { ltv_class: 'unknown', ltv_value: 0 };

  try {
    const prompt = `
      Classifique o potencial de LTV deste lead como "high", "medium" ou "low".
      Dados: UTM=${leadData.utm_source}, Engajamento=${leadData.engagement_score},
      Página=${leadData.page_url}, Score=${leadData.bot_score}.
      Responda apenas: {"class": "high|medium|low", "value": 0-1000}
    `;

    const response = await env.AI.run('@cf/ibm-granite/granite-4.0-h-micro', {
      messages: [{ role: 'user', content: prompt }],
      max_tokens: 50
    });

    return JSON.parse(response.response);
  } catch {
    return { class: 'medium', value: 300 }; // fallback seguro
  }
}
```

---

## ⏰ BINDING 6 — CRON TRIGGERS (Ativos)

> **Status:** ✅ Configurados e ativos no `wrangler.toml`.

| Schedule | UTC | Descrição |
|---|---|---|
| `0 2 * * 7` | Dom 02:00 | Intelligence Agent — check de versões de API |
| `0 3 1 * *` | Dia 1 03:00 | Intelligence Agent — auditoria mensal de erros |

### Handler no Worker
```typescript
export default {
  async scheduled(event, env, ctx) {
    ctx.waitUntil(runIntelligenceAgent(event.cron, env));
  }
};

async function runIntelligenceAgent(cron, env) {
  const runType = cron === '0 2 * * 7' ? 'weekly' : 'monthly';

  // 1. Verificar versões de API
  await checkApiVersions(env);

  // 2. Gerar relatório de saúde por plataforma
  await generateHealthReport(env, runType);

  // 3. Alertar via WhatsApp se status crítico
  await sendAlertsIfNeeded(env, runType);

  // 4. Log da execução
  await env.DB.prepare(`
    INSERT INTO intelligence_logs (run_type, check_type, status, message)
    VALUES (?, 'full_run', 'ok', ?)
  `).bind(runType, `Cron ${cron} executado com sucesso`).run();
}
```

---

## 🔐 INVENTÁRIO COMPLETO DE SECRETS

| Secret | Status | Obrigatório | Agente Consumidor |
|---|---|---|---|
| `META_ACCESS_TOKEN` | ⚠️ Reconfigurar | Sim | meta-agent |
| `GA4_API_SECRET` | ⚠️ Reconfigurar | Sim | google-agent |
| `TIKTOK_ACCESS_TOKEN` | ⚠️ Reconfigurar | Opcional | tiktok-agent |
| `META_TEST_CODE` | ⚠️ Reconfigurar | Só testes | meta-agent |
| `META_AD_ACCOUNT_ID` | ⚠️ Reconfigurar | Customer Match | meta-agent |
| `META_AUDIENCE_ID` | ⚠️ Reconfigurar | Customer Match | meta-agent |
| `WHATSAPP_ACCESS_TOKEN` | ⚠️ Reconfigurar | WhatsApp | whatsapp-agent |
| `WHATSAPP_PHONE_NUMBER_ID` | ⚠️ Reconfigurar | WhatsApp | whatsapp-agent |
| `RESEND_API_KEY` | ⚠️ Reconfigurar | Email | email-agent |
| `RESEND_FROM_EMAIL` | ⚠️ Reconfigurar | Email | email-agent |

> ⚠️ **Todos os secrets foram perdidos** ao migrar de `server-pixel-tracker` para `server-edge-tracker`. Precisam ser reconfigurados via `wrangler secret put`.

### Reconfigurar todos de uma vez
```bash
wrangler secret put META_ACCESS_TOKEN
wrangler secret put GA4_API_SECRET
wrangler secret put TIKTOK_ACCESS_TOKEN
wrangler secret put WHATSAPP_ACCESS_TOKEN
wrangler secret put WHATSAPP_PHONE_NUMBER_ID
wrangler secret put RESEND_API_KEY
wrangler secret put RESEND_FROM_EMAIL
```

---

## ⚡ PADRÃO ctx.waitUntil (Lei do Projeto)

Todo I/O que não bloqueia a resposta ao browser **DEVE** usar `ctx.waitUntil`:

```typescript
export default {
  async fetch(request, env, ctx) {

    // 1. Resposta imediata ao browser (< 50ms)
    const response = new Response(JSON.stringify({ ok: true }), {
      headers: { 'Content-Type': 'application/json' }
    });

    // 2. Todo processamento pesado em background
    ctx.waitUntil(Promise.all([
      saveLead(env.DB, payload),           // D1 write
      sendToMeta(payload, env),            // Meta CAPI
      sendToGA4(payload, env),             // GA4 MP
      sendToTikTok(payload, env),          // TikTok Events API
      updateUserProfile(env.DB, payload),  // Identity Graph
      predictLtv(payload, env)             // Workers AI
    ]));

    return response; // ← browser recebe em < 50ms
  }
};
```

---

## 🗺️ ROADMAP DE INFRAESTRUTURA

### Fase Atual (✅ Implementado — v2.5.1)
- D1 com 31 tabelas em produção (core + Fases 1-7)
- Workers AI: Granite 4.0 Micro (LTV + Quiz Scoring) + bge-m3 (Clustering)
- 2 Cron Triggers ativos (semanal + mensal)
- Rate Limiter, KV, R2 Audit Logs, Queues configurados
- Quiz Scoring Engine + Nurture Engine + ROAS Feedback Loop ativos

---

## 🔗 INTEGRAÇÃO COM O ECOSSISTEMA CDP EDGE

```
Master Orchestrator
        │
        ▼
Cloudflare Runtime Architect (este agente)
        │
        ├── env.DB ──────────────────────▶ server-tracking-agent (INSERT/SELECT)
        │                                  webhook-agent (INSERT webhook_events)
        │                                  attribution-agent (SELECT leads)
        │                                  ltv-predictor-agent (UPDATE user_profiles)
        │                                  intelligence-agent (INSERT health_reports)
        │
        ├── env.AI ──────────────────────▶ ltv-predictor-agent (Workers AI)
        │
        ├── env.RETRY_QUEUE ─────────────▶ server-tracking-agent (fallback de retry)
        │                                  meta-agent | ga4-agent | tiktok-agent
        │
        ├── env.GEO_CACHE ───────────────▶ fingerprint-agent (cache UTM)
        │                                  localization-agent (cache moedas)
        │
        ├── env.AUDIT_LOGS ──────────────▶ compliance-agent (LGPD audit trail)
        │                                  security-enterprise-agent (eventos suspeitos)
        │
        └── Cron Triggers ───────────────▶ intelligence-agent (health check semanal)
                                           performance-agent (limpeza mensal de logs)
```

---

## 🛠️ COMANDOS DE OPERAÇÃO

```bash
# Status do banco
wrangler d1 list
wrangler d1 info cdp-edge-db

# Query direta
wrangler d1 execute cdp-edge-db --remote --command "SELECT COUNT(*) FROM leads;"

# Aplicar migração
wrangler d1 execute cdp-edge-db --remote --file=server-edge-tracker/migrate-v6.sql

# Backup
wrangler d1 export cdp-edge-db --remote --output=backup-$(date +%Y%m%d).sql

# Verificar secrets ativos
wrangler secret list

# Redeploy após mudança de binding
wrangler deploy

# Ver logs do Worker em tempo real
wrangler tail server-edge-tracker
```