Build Connectors

import { NotificationConnector } from '@human/connector-sdk';

export class SlackConnector extends NotificationConnector {
  readonly id = 'slack-notifications';
  readonly name = 'Slack Notifications';
  readonly version = '1.0.0';

  async send(notification: Notification, config: SlackConfig): Promise<void> {
    const token = await this.getToken(config.teamId);
    await fetch('https://slack.com/api/chat.postMessage', {
      method: 'POST',
      headers: { 'Authorization': `Bearer ${token}`, 'Content-Type': 'application/json' },
      body: JSON.stringify({ channel: config.channel, text: notification.message }),
    });
  }
}

import { StorageConnector } from '@human/connector-sdk';

export class S3Connector extends StorageConnector {
  readonly id = 'storage-s3';
  readonly name = 'Amazon S3';
  readonly version = '1.0.0';

  async read(path: string, config: S3Config): Promise<Uint8Array> {
    const credentials = await this.getCredentials(config.orgId);
    // Read a file from S3 using the scoped credentials
    return this.s3Get(credentials, config.bucket, path);
  }

  async write(path: string, data: Uint8Array, config: S3Config): Promise<void> {
    const credentials = await this.getCredentials(config.orgId);
    await this.s3Put(credentials, config.bucket, path, data);
  }
}

import { PaymentConnector } from '@human/connector-sdk';

export class StripeConnector extends PaymentConnector {
  readonly id = 'payments-stripe';
  readonly name = 'Stripe';
  readonly version = '1.0.0';

  async charge(amount: number, currency: string, config: StripeConfig): Promise<ChargeResult> {
    const apiKey = await this.getSecret(config.orgId, 'stripe_secret_key');
    const response = await fetch('https://api.stripe.com/v1/payment_intents', {
      method: 'POST',
      headers: { 'Authorization': `Bearer ${apiKey}` },
      body: new URLSearchParams({ amount: String(amount), currency }),
    });
    return response.json();
  }
}

import { OAuthConnector } from '@human/connector-sdk';

export class GoogleWorkspaceConnector extends OAuthConnector {
  readonly id = 'email-google-workspace';
  readonly oauthConfig = {
    authUrl: 'https://accounts.google.com/o/oauth2/auth',
    tokenUrl: 'https://oauth2.googleapis.com/token',
    scopes: ['https://www.googleapis.com/auth/gmail.send'],
    pkce: true,
  };

  async sendEmail(to: string, subject: string, body: string, orgId: string) {
    // Tokens stored encrypted — connector never stores credentials in source
    const accessToken = await this.getAccessToken(orgId);
    await fetch('https://gmail.googleapis.com/gmail/v1/users/me/messages/send', {
      method: 'POST',
      headers: { 'Authorization': `Bearer ${accessToken}` },
      body: JSON.stringify({ raw: this.encodeEmail(to, subject, body) }),
    });
  }
}