Class SupabaseManagement

integrations/supabase/src/management/index.ts:268–544

}

export class SupabaseManagement implements TriggerIntegration {
  // @internal
  private _options: SupabaseManagementIntegrationOptions;
  // @internal
  private _client?: SupabaseManagementAPI;
  // @internal
  private _io?: IO;
  // @internal
  private _connectionKey?: string;

  constructor(private options: SupabaseManagementIntegrationOptions) {
    this._options = options;

    if ("apiKey" in options) {
      if (!options.apiKey || options.apiKey === "") {
        throw `Can't create SupabaseManagement integration (${options.id}) as apiKey is undefined`;
      }
    }
  }

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

  get metadata() {
    return { id: "supabase-management", name: "Supabase Management API" };
  }

  get source(): WebhookEventSource {
    return createWebhookEventSource(this);
  }

  get authSource() {
    if ("apiKey" in this._options) {
      return "LOCAL";
    }

    return "HOSTED" as const;
  }

  cloneForRun(io: IO, connectionKey: string, auth?: ConnectionAuth) {
    const supabase = new SupabaseManagement(this._options);
    supabase._io = io;
    supabase._connectionKey = connectionKey;

    if ("apiKey" in this._options) {
      if (!this._options.apiKey || this._options.apiKey === "") {
        throw `Can't create SupabaseManagement integration (${this._options.id}) as apiKey is undefined`;
      }
      supabase._client = new SupabaseManagementAPI({ accessToken: this._options.apiKey });
    } else if (auth) {
      supabase._client = new SupabaseManagementAPI({ accessToken: auth.accessToken });
    } else {
      throw `Can't create SupabaseManagement integration (${this._options.id}) as auth is undefined`;
    }

    return supabase;
  }