elioria-sst-x
    Preparing search index...

    Class SupabaseIntegrationOutboxRepository

    Implements

    Index
    constructor
    db
    claimBatch enqueue getHealth markFailed markProcessed
    db: PostgresJsDatabase<packages/db/src/schema> & {}

    The db value.

    • Generated

      Executes claimBatch.

      Parameters

      • limit: number

        The limit value.

      • now: Date

        The now value.

      Returns Promise<
          {
              aggregateId: string;
              aggregateType: string;
              attempts: number;
              availableAt: Date;
              createdAt: Date;
              eventType: string;
              id: string;
              lastError: string
              | null;
              lockedAt: Date | null;
              payload: Record<string, unknown>;
              processedAt: Date | null;
              status: string;
              tenantId: string;
          }[],
      >

      The function result.

      Objective: In module packages/db/src/repositories/integration-outbox.repository.ts, run claimBatch.

      Behavior: Async; accepts limit and now; returns a value; invokes this.db.transaction.

    • Generated

      Returns the result of getHealth.

      Parameters

      • now: Date

        The now value.

      • OptionaleventTypePrefix: string

        The eventTypePrefix value.

      Returns Promise<
          {
              counts: { [k: string]: number };
              oldestPendingAgeSeconds: number | null;
          },
      >

      The function result.

      Objective: In module packages/db/src/repositories/integration-outbox.repository.ts, retrieve data through getHealth.

      Behavior: Async; accepts now and eventTypePrefix; returns a value; invokes this.db.select({ status: integrationOutbox.status, count: sq.

    • Generated

      Executes markFailed.

      Parameters

      • id: string

        The id value.

      • error: string

        The error value.

      • availableAt: Date

        The availableAt value.

      • dead: boolean

        The dead value.

      Returns Promise<void>

      The function result.

      Objective: In module packages/db/src/repositories/integration-outbox.repository.ts, run markFailed.

      Behavior: Async; accepts id and error and availableAt and dead; returns a value; invokes this.db.update(integrationOutbox).set({ status: dead ? "dead.

    • Generated

      Executes markProcessed.

      Parameters

      • id: string

        The id value.

      • processedAt: Date

        The processedAt value.

      Returns Promise<void>

      The function result.

      Objective: In module packages/db/src/repositories/integration-outbox.repository.ts, run markProcessed.

      Behavior: Async; accepts id and processedAt; returns a value; invokes this.db.update(integrationOutbox).set({ status: "processed",.

    Settings
    Member Visibility

    On This Page
    Constructors
    Properties
    Methods