Class Supabase

integrations/supabase/src/database/index.ts:48–169

 * ```
 */
export class Supabase<
  Database = any,
  SchemaName extends string & keyof Database = "public" extends keyof Database
    ? "public"
    : string & keyof Database,
  Schema extends GenericSchema = Database[SchemaName] extends GenericSchema
    ? Database[SchemaName]
    : any,
> implements TriggerIntegration
{
  // @internal
  private _options: SupabaseIntegrationOptions<SchemaName>;
  // @internal
  private _client?: SupabaseClient<Database, SchemaName, Schema>;
  // @internal
  private _io?: IO;
  // @internal
  private _connectionKey?: string;

  /**
   * The native Supabase client. This is exposed for use outside of Trigger.dev jobs
   *
   * @example
   * ```ts
   * import { Supabase } from "@trigger.dev/supabase";
   * import { Database } from "@/supabase.types";
   *
   * const supabase = new Supabase<Database>({
   *   id: "my-supabase",
   *   projectId: process.env.SUPABASE_ID!,
   *   supabaseKey: process.env.SUPABASE_API_KEY!,
   * });
   *
   * const { data, error } = await supabase.native.from("users").select("*");
   * ```
   */
  public readonly native: SupabaseClient<Database, SchemaName, Schema>;

  constructor(private options: SupabaseIntegrationOptions<SchemaName>) {
    this._options = options;

    const supabaseOptions = options.options || {};
    const supabaseUrl =
      "projectId" in options ? `https://${options.projectId}.supabase.co` : options.supabaseUrl;

    this.native = createClient(supabaseUrl, options.supabaseKey, {
      ...supabaseOptions,
      auth: {
        ...supabaseOptions.auth,
        persistSession: false,
      },
    });
  }

  get authSource() {
    return "LOCAL" as const;
  }