Class Airtable

integrations/airtable/src/index.ts:29–132

export type AirtableRunTask = InstanceType<typeof Airtable>["runTask"];

export class Airtable implements TriggerIntegration {
  // @internal
  private _options: AirtableIntegrationOptions;
  // @internal
  private _client?: AirtableSDK;
  // @internal
  private _io?: IO;
  // @internal
  private _connectionKey?: string;

  constructor(options: Prettify<AirtableIntegrationOptions>) {
    if (Object.keys(options).includes("token") && !options.token) {
      throw `Can't create Airtable integration (${options.id}) as token was passed in but undefined`;
    }

    this._options = options;
  }

  get authSource() {
    return this._options.token ? ("LOCAL" as const) : ("HOSTED" as const);
  }

  get id() {
    return this._options.id;
  }

  get metadata() {
    return { id: "airtable", name: "Airtable" };
  }

  get source() {
    return createWebhookSource(this);
  }

  cloneForRun(io: IO, connectionKey: string, auth?: ConnectionAuth) {
    const airtable = new Airtable(this._options);
    airtable._io = io;
    airtable._connectionKey = connectionKey;
    airtable._client = this.createClient(auth);
    return airtable;
  }

  createClient(auth?: ConnectionAuth) {
    if (auth) {
      return new AirtableSDK({
        apiKey: auth.accessToken,
      });
    }

    if (this._options.token) {
      return new AirtableSDK({
        apiKey: this._options.token,
      });
    }

    throw new Error("No auth");
  }