Class SupabaseApiIdempotencyRepository

Implements

ApiIdempotencyRepository

Index

Constructors

Properties

Methods

create deleteExpired findByKey markCompleted markFailed

Constructors

constructor

new SupabaseApiIdempotencyRepository(
db: PostgresJsDatabase<packages/db/src/schema> & {},
): SupabaseApiIdempotencyRepository
Generated
Executes constructor.
Parameters
- db: PostgresJsDatabase<packages/db/src/schema> & {}
  The db value.
Returns SupabaseApiIdempotencyRepository
The function result.

Remarks
Objective: In module packages/db/src/repositories/cipa.repository.ts, run constructor.

Behavior: accepts db; returns a value.
- Defined in packages/db/src/repositories/cipa.repository.ts:5954

Properties

`Private`db

db: PostgresJsDatabase<packages/db/src/schema> & {}

The db value.

Methods

create

create(
data: Omit<ApiIdempotencyRecord, "id" | "createdAt">,
): Promise<ApiIdempotencyRecord>
Generated
Executes create.
Parameters
- data: Omit<ApiIdempotencyRecord, "id" | "createdAt">
  The data value.
Returns Promise<ApiIdempotencyRecord>
The function result.

Remarks
Objective: In module packages/db/src/repositories/cipa.repository.ts, run create.

Behavior: Async; accepts data; returns a value; invokes this.db.insert(apiIdempotencyRecords).values({ tenantId: dat.
Implementation of ApiIdempotencyRepository.create
- Defined in packages/db/src/repositories/cipa.repository.ts:5990

deleteExpired

deleteExpired(): Promise<number>
Generated
Updates data through deleteExpired.

Returns Promise<number>
The function result.

Remarks
Objective: In module packages/db/src/repositories/cipa.repository.ts, change data through deleteExpired.

Behavior: Async; returns a value; invokes this.db.delete(apiIdempotencyRecords) .where(and( lte(apiIde.
Implementation of ApiIdempotencyRepository.deleteExpired
- Defined in packages/db/src/repositories/cipa.repository.ts:6056

findByKey

findByKey(
    tenantId: string,
    route: string,
    key: string,
): Promise<ApiIdempotencyRecord | null>
Generated
Returns the result of findByKey.
Parameters
- tenantId: string
  The tenantId value.
- route: string
  The route value.
- key: string
  The key value.
Returns Promise<ApiIdempotencyRecord | null>
The function result.

Remarks
Objective: In module packages/db/src/repositories/cipa.repository.ts, retrieve data through findByKey.

Behavior: Async; accepts tenantId and route and key; returns a value; invokes this.db.select().from(apiIdempotencyRecords) .where(and( eq(.
Implementation of ApiIdempotencyRepository.findByKey
- Defined in packages/db/src/repositories/cipa.repository.ts:5969

markCompleted

markCompleted(
    id: string,
    responseStatus: number,
    responseBody: unknown,
    resourceId?: string,
): Promise<void>
Generated
Executes markCompleted.
Parameters
- id: string
  The id value.
- responseStatus: number
  The responseStatus value.
- responseBody: unknown
  The responseBody value.
- OptionalresourceId: string
  The resourceId value.
Returns Promise<void>
The function result.

Remarks
Objective: In module packages/db/src/repositories/cipa.repository.ts, run markCompleted.

Behavior: Async; accepts id and responseStatus and responseBody and resourceId; returns a value; invokes this.db.update(apiIdempotencyRecords).set({ operationStatus:.
Implementation of ApiIdempotencyRepository.markCompleted
- Defined in packages/db/src/repositories/cipa.repository.ts:6020

markFailed

markFailed(id: string): Promise<void>
Generated
Executes markFailed.
Parameters
- id: string
  The id value.
Returns Promise<void>
The function result.

Remarks
Objective: In module packages/db/src/repositories/cipa.repository.ts, run markFailed.

Behavior: Async; accepts id; returns a value; invokes this.db.update(apiIdempotencyRecords).set({ operationStatus:.
Implementation of ApiIdempotencyRepository.markFailed
- Defined in packages/db/src/repositories/cipa.repository.ts:6040