Class CustomerOriginService

Manage the per-customer origin allowlist and reconcile the aggregate allowlist onto the entity-document S3 buckets' CORS configuration.

Hierarchy (View Summary)

CustomerOriginQueryService
- CustomerOriginService

Index

Constructors

constructor

Properties

Methods

create delete get reconcile search update

Constructors

constructor

new CustomerOriginService(
    __namedParameters: {
        baseOrigins: string[];
        db: B2bDatabase;
        s3Bucket: string;
        s3Client: S3Client;
        s3StagingBucket: string;
    },
): CustomerOriginService
Parameters
- __namedParameters: {
      baseOrigins: string[];
      db: B2bDatabase;
      s3Bucket: string;
      s3Client: S3Client;
      s3StagingBucket: string;
  }
Returns CustomerOriginService
Overrides CustomerOriginQueryService.constructor
- Defined in packages/customer-services/src/CustomerOriginService.ts:138

Properties

`Protected` `Readonly`db

db: B2bDatabase

Methods

create

create(
    __namedParameters: { customerId: string; origin: string },
): Promise<
    { ok: true; value: CustomerOrigin }
    | { error: ServiceError; ok: false },
>
Add an origin to the customer's allowlist and reconcile the buckets. The origin is canonicalized (lower-cased scheme/host) before storage.
Parameters
- __namedParameters: { customerId: string; origin: string }
Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>
- Defined in packages/customer-services/src/CustomerOriginService.ts:162

delete

delete(
    __namedParameters: { customerId: string; id: string },
): Promise<
    { ok: true; value: CustomerOrigin }
    | { error: ServiceError; ok: false },
>
Remove an origin from the customer's allowlist and reconcile the buckets.
Parameters
- __namedParameters: { customerId: string; id: string }
Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>
- Defined in packages/customer-services/src/CustomerOriginService.ts:316

get

get(
__namedParameters: { customerId: string; id: string },
): Promise<{ ok: true; value: CustomerOrigin | null }>
Parameters
- __namedParameters: { customerId: string; id: string }
Returns Promise<{ ok: true; value: CustomerOrigin | null }>
Inherited from CustomerOriginQueryService.get
- Defined in packages/customer-services/src/CustomerOriginService.ts:45

reconcile

reconcile(): Promise<{ ok: true; value: { origins: string[] } }>
Push the aggregate origin allowlist (all customers' origins merged with the base origins) onto both entity-document buckets' CORS configuration.

Standalone repair entrypoint: opens its own transaction, acquires the advisory lock, and reconciles. create/update/delete do NOT call this — they run the reconcile INLINE within their own mutation tx (via reconcileWithin) so the row write and the CORS write are atomic.

Returns Promise<{ ok: true; value: { origins: string[] } }>
- Defined in packages/customer-services/src/CustomerOriginService.ts:366

search

search(
    __namedParameters: {
        customerId: string;
        origin?: string;
        page?: number;
        pageSize?: number;
    },
): Promise<
    {
        ok: true;
        value: { hasNext: boolean; items: CustomerOrigin[]; total: number };
    },
>
Parameters
- __namedParameters: { customerId: string; origin?: string; page?: number; pageSize?: number }
  - customerId: string
  - Optionalorigin?: string
    
    Exact-match filter on the canonical origin
  - Optionalpage?: number
    
    Defaults to 1
  - OptionalpageSize?: number
    
    Defaults to 50
Returns Promise<
    {
        ok: true;
        value: { hasNext: boolean; items: CustomerOrigin[]; total: number };
    },
>
The customer's allowlisted origins, ordered by origin, paginated.
Inherited from CustomerOriginQueryService.search
- Defined in packages/customer-services/src/CustomerOriginService.ts:74

update

update(
    __namedParameters: {
        customerId: string;
        data: { origin: string };
        id: string;
    },
): Promise<
    { ok: true; value: CustomerOrigin }
    | { error: ServiceError; ok: false },
>
Replace an allowlist entry's origin and reconcile the buckets.
Parameters
- __namedParameters: { customerId: string; data: { origin: string }; id: string }
Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>
- Defined in packages/customer-services/src/CustomerOriginService.ts:232

Class CustomerOriginService

Hierarchy (View Summary)

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Returns CustomerOriginService

Properties

`Protected` `Readonly`db

Methods

create

Parameters

Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>

delete

Parameters

Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>

get

Parameters

Returns Promise<{ ok: true; value: CustomerOrigin | null }>

reconcile

Returns Promise<{ ok: true; value: { origins: string[] } }>

search

Parameters

customerId: string

`Optional`origin?: string

`Optional`page?: number

`Optional`pageSize?: number

Returns Promise<
    {
        ok: true;
        value: { hasNext: boolean; items: CustomerOrigin[]; total: number };
    },
>

update

Parameters

Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>

Settings

On This Page

Class CustomerOriginService

Hierarchy (View Summary)

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

Returns CustomerOriginService

Properties

Protected Readonlydb

Methods

create

Parameters

Returns Promise< { ok: true; value: CustomerOrigin } | { error: ServiceError; ok: false },>

delete

Parameters

Returns Promise< { ok: true; value: CustomerOrigin } | { error: ServiceError; ok: false },>

get

Parameters

Returns Promise<{ ok: true; value: CustomerOrigin | null }>

reconcile

Returns Promise<{ ok: true; value: { origins: string[] } }>

search

Parameters

customerId: string

Optionalorigin?: string

Optionalpage?: number

OptionalpageSize?: number

Returns Promise< { ok: true; value: { hasNext: boolean; items: CustomerOrigin[]; total: number }; },>

update

Parameters

Returns Promise< { ok: true; value: CustomerOrigin } | { error: ServiceError; ok: false },>

Settings

On This Page

`Protected` `Readonly`db

Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>

Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>

`Optional`origin?: string

`Optional`page?: number

`Optional`pageSize?: number

Returns Promise<
{
ok: true;
value: { hasNext: boolean; items: CustomerOrigin[]; total: number };
},
>

Returns Promise<
{ ok: true; value: CustomerOrigin }
| { error: ServiceError; ok: false },
>