4leads Integration -- Technische Architektur

// worker.js -- HubSpot → 4leads Sync Bridge
// Laeuft als Cron-Trigger alle 15 Minuten

const HUBSPOT_API_KEY = "pat-xxx";
const FOURLEADS_WEBHOOK_URL = "https://app.4leads.de/webhook/xxx";

export default {
  async scheduled(event, env, ctx) {
    await syncContacts(env);
  },

  // Optional: Manueller Trigger via HTTP
  async fetch(request, env, ctx) {
    if (request.headers.get("X-Sync-Key") !== env.SYNC_SECRET) {
      return new Response("Unauthorized", { status: 401 });
    }
    const result = await syncContacts(env);
    return new Response(JSON.stringify(result));
  }
};

async function syncContacts(env) {
  const results = { synced: 0, errors: 0, contacts: [] };

  // 1. Hole Kontakte mit sync_status = "Pending"
  const searchPayload = {
    filterGroups: [{
      filters: [
        { propertyName: "in_4leads_migriert", operator: "EQ", value: "Ja" },
        { propertyName: "fl_sync_status", operator: "EQ", value: "Pending" }
      ]
    }],
    properties: [
      "email", "firstname", "lastname", "company",
      "norm_standard", "dienstleistung_interesse",
      "produkt_interesse", "sales_status",
      "kundenkategorie", "lead_score_custom"
    ],
    limit: 50
  };

  const searchResponse = await fetch(
    "https://api.hubapi.com/crm/v3/objects/contacts/search",
    {
      method: "POST",
      headers: {
        "Authorization": `Bearer ${env.HUBSPOT_API_KEY}`,
        "Content-Type": "application/json"
      },
      body: JSON.stringify(searchPayload)
    }
  );
  const searchData = await searchResponse.json();

  if (!searchData.results?.length) {
    return { ...results, message: "Keine neuen Kontakte" };
  }

  // 2. Fuer jeden Kontakt: An 4leads senden
  for (const contact of searchData.results) {
    try {
      const payload = {
        email: contact.properties.email,
        firstname: contact.properties.firstname,
        lastname: contact.properties.lastname,
        company: contact.properties.company,
        tags: [
          contact.properties.norm_standard,
          contact.properties.dienstleistung_interesse,
          contact.properties.sales_status
        ].filter(Boolean),
        custom_fields: {
          hubspot_id: contact.id,
          kundenkategorie: contact.properties.kundenkategorie,
          lead_score: contact.properties.lead_score_custom
        }
      };

      const res = await fetch(env.FOURLEADS_WEBHOOK_URL, {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify(payload)
      });

      // 3. Status in HubSpot aktualisieren
      await fetch(
        `https://api.hubapi.com/crm/v3/objects/contacts/${contact.id}`,
        {
          method: "PATCH",
          headers: {
            "Authorization": `Bearer ${env.HUBSPOT_API_KEY}`,
            "Content-Type": "application/json"
          },
          body: JSON.stringify({
            properties: {
              fl_sync_status: res.ok ? "Synced" : "Error"
            }
          })
        }
      );
      res.ok ? results.synced++ : results.errors++;
    } catch (e) { results.errors++; }
  }
  return results;
}