Skip to main content
KaireonAI’s connector framework now covers 39 integrations across 7 categories, with production-grade HTTP executors for each. Every connector has:
  • a typed registry entry with connection + auth field definitions (drives the UI form automatically),
  • a real executor in lib/connector-executors/ with test-connection, send, and pull methods where appropriate,
  • deterministic error mapping via the shared ConnectorResponse envelope ({ ok, status, latencyMs, body, error }),
  • rate-limit / circuit-breaker integration via the existing pipeline runner.

​
What shipped in the expansion (22 integrations)

​
Messaging destinations (7)

ConnectorAuthNotes
SlackWebhook URLPosts JSON payloads; rejects non-hooks.slack.com URLs.
Microsoft TeamsWebhook URLWraps plain text in MessageCard schema when card isn’t set.
WhatsApp BusinessSystem user access tokenMeta Graph API v20, /messages.
PagerDutyIntegration Routing KeyEvents API v2 /enqueue with optional dedup_key from idempotency key.
Twilio SMSAccount SID + Auth TokenForm-encoded /Messages.json, Basic auth.
SendGridAPI Key/v3/mail/send, Bearer auth, personalizations schema.
PostmarkServer Token/email, X-Postmark-Server-Token header, configurable message stream.

​
CDP / Support (6)

ConnectorAuthNotes
IntercomAccess Token/events for track, /contacts for upsert.
Zendeskemail / tokenBasic auth email/token:APITOKEN, creates tickets by default.
IterableAPI Key/api/events/track with Api-Key header.
KlaviyoPrivate Key/api/events/ JSON:API envelope, revision 2024-10-15.
SegmentWrite KeySupports track / identify / group; Base64 Basic auth.
Braze (was coming-soon)API Key + REST Host/users/track batch endpoint.

​
Commerce sources (3)

ConnectorAuthNotes
ShopifyAccess TokenAdmin REST, /orders.json pagination with updated_at_min.
StripeAPI Key/v1/charges with created[gte] filter.
MailchimpAPI Key (format: key-dcN)DC-aware endpoint; /lists/{id}/members?since_last_changed=….

​
Reverse-ETL / data movement (6)

ConnectorAuthNotes
SnowpipeKeypair JWT/v1/data/pipes/{pipe}/insertFiles.
FivetranAPI key + secret/connectors list + /connectors/{id}/sync trigger.
HightouchWorkspace API Key/syncs/{id}/trigger with optional fullResync.
CensusWorkspace API Key/syncs/{id}/trigger.
Databricks (was coming-soon)Host + tokenStatement Execution API v2; requires warehouseId.
Amazon Kinesis (was coming-soon)SigV4Caller signs upstream; PutRecord via Kinesis_20131202 JSON RPC.

​
UI wiring

Every connector appears automatically in the Data → Connectors page because the UI reads connectorRegistry from src/domain/connector-registry.ts. Each entry declares connectionFields + authFields for each auth method; the dynamic form builder renders the right inputs (text / password / textarea / select / number) without any per-connector UI code.

​
Executor interface

All executors implement ConnectorExecutor: 
interface ConnectorExecutor {
  readonly type: ConnectorType;
  testConnection(config: ConnectorConfig): Promise<ConnectorResponse>;
  send?(config: ConnectorConfig, payload: SendPayload): Promise<ConnectorResponse>;
  pull?(config: ConnectorConfig, opts?: PullOptions): Promise<ConnectorResponse<PulledRow[]>>;
}
Returned response envelope: 
interface ConnectorResponse<T = unknown> {
  ok: boolean;
  status: number;
  latencyMs: number;
  body?: T;
  error?: string;
}
Timeouts are enforced with AbortController; the default is 10 s.

​
Testing + auth hygiene

All 22 new executors ship with 26 unit tests that mock global.fetch and assert:
  • URL validation (Slack rejects non-hooks.slack.com; Teams requires webhook.office.com).
  • Body shape (Teams MessageCard, Klaviyo JSON:API envelope, Twilio form-encoded Basic auth, SendGrid Bearer).
  • Auth-required paths fail-closed when required secrets are absent (WhatsApp, Zendesk, Snowpipe, Kinesis).
  • Pull-shape normalization (Shopify orders[], Stripe data[], Mailchimp members[]).
  • Idempotency-key plumbing (PagerDuty dedup_key, Twilio Idempotency-Key).
See src/lib/connector-executors/__tests__/executors.test.ts.
See also: Connectors | Pipelines