Connectors

import { createStripeConnector } from '@brainos/workers';

const stripe = createStripeConnector(process.env.STRIPE_API_KEY!);

// Full sync — pulls all historical data
await stripe.fullSync(supabase, 'org_123');

// Incremental sync — only new data since last sync
await stripe.incrementalSync(supabase, 'org_123', lastSyncDate);

// Real-time — handle Stripe webhooks
const signals = stripe.handleWebhook(stripeWebhookPayload);
// Generates: payment_success, payment_failed, subscription_mrr, churn_risk

import { createHubSpotConnector } from '@brainos/workers';

const hubspot = createHubSpotConnector(process.env.HUBSPOT_API_KEY!);
await hubspot.fullSync(supabase, 'org_123');
// Generates: deal_stage, deal_amount, deal_probability

import type { BrainOSConnector } from '@brainos/workers';

const myConnector: BrainOSConnector = {
  name: 'my-crm',
  domain: 'sales',

  async fullSync(supabase, orgId) {
    const data = await fetchFromMyCRM();
    const signals = data.map(item => ({
      source_domain: 'sales',
      signal_type: 'deal_closed',
      signal_value: item.amount,
      entity_id: item.customerId,
      signal_timestamp: item.closedAt,
    }));
    await storeConnectorSignals(supabase, orgId, signals);
    return { signalCount: signals.length };
  },

  async incrementalSync(supabase, orgId, since) {
    // Same as fullSync but filtered by date
  },

  handleWebhook(payload) {
    return [/* signals */];
  },
};

POST https://your-project.supabase.co/functions/v1/brainos-webhook?source=stripe&org=org_123

# Stripe sends webhooks here automatically.
# Supported sources: stripe, hubspot, intercom, slack