Cloudflare Worker — Proxy OMIE

/**
 * FinSight — Cloudflare Worker v3 (DEFINITIVO)
 * Proxy CORS para API OMIE ERP — Prospecta
 *
 * FORMATO: Service Worker clássico — sem "export default", sem módulos ES.
 * Funciona em 100% das contas Cloudflare sem configuração adicional.
 *
 * VERSÃO: 3.0 — 2026-03-31
 * IDENTIFICADOR: FINSIGHT_WORKER_V3
 */

var OMIE_BASE = 'https://app.omie.com.br/api/v1';

addEventListener('fetch', function (event) {
  event.respondWith(handleRequest(event.request));
});

async function handleRequest(request) {

  // 1. Preflight CORS
  if (request.method === 'OPTIONS') {
    return new Response(null, { status: 204, headers: corsH() });
  }

  // 2. Health-check: GET / retorna JSON de status
  if (request.method === 'GET') {
    var u = new URL(request.url);
    var path = u.pathname.replace(/^\/+|\/+$/g, '');
    if (!path || path === 'health') {
      return json({ ok: true, version: 'FINSIGHT_WORKER_V3', ts: Date.now() }, 200);
    }
    return json({ error: 'Use POST para chamadas OMIE.' }, 405);
  }

  // 3. Apenas POST daqui em diante
  if (request.method !== 'POST') {
    return json({ error: 'Método não permitido. Use POST.' }, 405);
  }

  // 4. Extrai o endpoint do path
  var url      = new URL(request.url);
  var endpoint = url.pathname.replace(/^\/+|\/+$/g, '');

  if (!endpoint) {
    return json({ error: 'Endpoint OMIE não informado. Exemplo: POST /geral/categorias' }, 400);
  }

  var omieUrl = OMIE_BASE + '/' + endpoint + '/';

  // 5. Lê o body
  var body;
  try {
    body = await request.text();
    JSON.parse(body);
  } catch (e) {
    return json({ error: 'Body inválido ou não é JSON.', detail: e.message }, 400);
  }

  // 6. Encaminha para OMIE
  var omieRes;
  try {
    omieRes = await fetch(omieUrl, {
      method:  'POST',
      headers: { 'Content-Type': 'application/json', 'Accept': 'application/json' },
      body:    body,
    });
  } catch (e) {
    return json({ error: 'Falha ao conectar com OMIE.', detail: e.message, url: omieUrl }, 502);
  }

  // 7. Repassa resposta com headers CORS
  var respBody = await omieRes.text();
  var ct       = omieRes.headers.get('Content-Type') || 'application/json';

  return new Response(respBody, {
    status:  omieRes.status,
    headers: Object.assign({ 'Content-Type': ct, 'X-Worker-Version': 'FINSIGHT_WORKER_V3' }, corsH()),
  });
}

function corsH() {
  return {
    'Access-Control-Allow-Origin':  '*',
    'Access-Control-Allow-Methods': 'GET, POST, OPTIONS',
    'Access-Control-Allow-Headers': 'Content-Type, X-Proxy-Token',
    'Access-Control-Max-Age':       '86400',
  };
}

function json(obj, status) {
  return new Response(JSON.stringify(obj), {
    status: status || 200,
    headers: Object.assign({ 'Content-Type': 'application/json' }, corsH()),
  });
}