feat(containers): add trigger CRUD (#737)

Author: scaleway-bot

packages/clients/src/api/container/v1beta1/api.gen.ts

@@ -15,16 +15,19 @@ import {
   DOMAIN_TRANSIENT_STATUSES,
   NAMESPACE_TRANSIENT_STATUSES,
   TOKEN_TRANSIENT_STATUSES,
+  TRIGGER_TRANSIENT_STATUSES,
 } from './content.gen'
 import {
   marshalCreateContainerRequest,
   marshalCreateCronRequest,
   marshalCreateDomainRequest,
   marshalCreateNamespaceRequest,
   marshalCreateTokenRequest,
+  marshalCreateTriggerRequest,
   marshalUpdateContainerRequest,
   marshalUpdateCronRequest,
   marshalUpdateNamespaceRequest,
+  marshalUpdateTriggerRequest,
   unmarshalContainer,
   unmarshalCron,
   unmarshalDomain,
@@ -34,8 +37,10 @@ import {
   unmarshalListLogsResponse,
   unmarshalListNamespacesResponse,
   unmarshalListTokensResponse,
+  unmarshalListTriggersResponse,
   unmarshalNamespace,
   unmarshalToken,
+  unmarshalTrigger,
 } from './marshalling.gen'
 import type {
   Container,
@@ -44,19 +49,22 @@ import type {
   CreateDomainRequest,
   CreateNamespaceRequest,
   CreateTokenRequest,
+  CreateTriggerRequest,
   Cron,
   DeleteContainerRequest,
   DeleteCronRequest,
   DeleteDomainRequest,
   DeleteNamespaceRequest,
   DeleteTokenRequest,
+  DeleteTriggerRequest,
   DeployContainerRequest,
   Domain,
   GetContainerRequest,
   GetCronRequest,
   GetDomainRequest,
   GetNamespaceRequest,
   GetTokenRequest,
+  GetTriggerRequest,
   IssueJWTRequest,
   ListContainersRequest,
   ListContainersResponse,
@@ -70,11 +78,15 @@ import type {
   ListNamespacesResponse,
   ListTokensRequest,
   ListTokensResponse,
+  ListTriggersRequest,
+  ListTriggersResponse,
   Namespace,
   Token,
+  Trigger,
   UpdateContainerRequest,
   UpdateCronRequest,
   UpdateNamespaceRequest,
+  UpdateTriggerRequest,
 } from './types.gen'
 
 const jsonContentHeaders = {
@@ -794,4 +806,153 @@ export class API extends ParentAPI {
       },
       unmarshalToken,
     )
+
+  /**
+   * Create a trigger. Create a new trigger for a specified container.
+   *
+   * @param request - The request {@link CreateTriggerRequest}
+   * @returns A Promise of Trigger
+   */
+  createTrigger = (request: Readonly<CreateTriggerRequest>) =>
+    this.client.fetch<Trigger>(
+      {
+        body: JSON.stringify(
+          marshalCreateTriggerRequest(request, this.client.settings),
+        ),
+        headers: jsonContentHeaders,
+        method: 'POST',
+        path: `/containers/v1beta1/regions/${validatePathParam(
+          'region',
+          request.region ?? this.client.settings.defaultRegion,
+        )}/triggers`,
+      },
+      unmarshalTrigger,
+    )
+
+  /**
+   * Get a trigger. Get a trigger with a specified ID.
+   *
+   * @param request - The request {@link GetTriggerRequest}
+   * @returns A Promise of Trigger
+   */
+  getTrigger = (request: Readonly<GetTriggerRequest>) =>
+    this.client.fetch<Trigger>(
+      {
+        method: 'GET',
+        path: `/containers/v1beta1/regions/${validatePathParam(
+          'region',
+          request.region ?? this.client.settings.defaultRegion,
+        )}/triggers/${validatePathParam('triggerId', request.triggerId)}`,
+      },
+      unmarshalTrigger,
+    )
+
+  /**
+   * Waits for {@link Trigger} to be in a final state.
+   *
+   * @param request - The request {@link GetTriggerRequest}
+   * @param options - The waiting options
+   * @returns A Promise of Trigger
+   */
+  waitForTrigger = (
+    request: Readonly<GetTriggerRequest>,
+    options?: Readonly<WaitForOptions<Trigger>>,
+  ) =>
+    waitForResource(
+      options?.stop ??
+        (res =>
+          Promise.resolve(!TRIGGER_TRANSIENT_STATUSES.includes(res.status))),
+      this.getTrigger,
+      request,
+      options,
+    )
+
+  protected pageOfListTriggers = (
+    request: Readonly<ListTriggersRequest> = {},
+  ) =>
+    this.client.fetch<ListTriggersResponse>(
+      {
+        method: 'GET',
+        path: `/containers/v1beta1/regions/${validatePathParam(
+          'region',
+          request.region ?? this.client.settings.defaultRegion,
+        )}/triggers`,
+        urlParams: urlParams(
+          ['order_by', request.orderBy ?? 'created_at_asc'],
+          ['page', request.page],
+          [
+            'page_size',
+            request.pageSize ?? this.client.settings.defaultPageSize,
+          ],
+          ...Object.entries(
+            resolveOneOf([
+              {
+                default: this.client.settings.defaultProjectId,
+                param: 'project_id',
+                value: request.projectId,
+              },
+              {
+                param: 'container_id',
+                value: request.containerId,
+              },
+              {
+                param: 'namespace_id',
+                value: request.namespaceId,
+              },
+            ]),
+          ),
+        ),
+      },
+      unmarshalListTriggersResponse,
+    )
+
+  /**
+   * List all triggers. List all triggers belonging to a specified Organization
+   * or Project.
+   *
+   * @param request - The request {@link ListTriggersRequest}
+   * @returns A Promise of ListTriggersResponse
+   */
+  listTriggers = (request: Readonly<ListTriggersRequest> = {}) =>
+    enrichForPagination('triggers', this.pageOfListTriggers, request)
+
+  /**
+   * Update a trigger. Update a trigger with a specified ID.
+   *
+   * @param request - The request {@link UpdateTriggerRequest}
+   * @returns A Promise of Trigger
+   */
+  updateTrigger = (request: Readonly<UpdateTriggerRequest>) =>
+    this.client.fetch<Trigger>(
+      {
+        body: JSON.stringify(
+          marshalUpdateTriggerRequest(request, this.client.settings),
+        ),
+        headers: jsonContentHeaders,
+        method: 'PATCH',
+        path: `/containers/v1beta1/regions/${validatePathParam(
+          'region',
+          request.region ?? this.client.settings.defaultRegion,
+        )}/triggers/${validatePathParam('triggerId', request.triggerId)}`,
+      },
+      unmarshalTrigger,
+    )
+
+  /**
+   * Delete a trigger. Delete a trigger with a specified ID.
+   *
+   * @param request - The request {@link DeleteTriggerRequest}
+   * @returns A Promise of Trigger
+   */
+  deleteTrigger = (request: Readonly<DeleteTriggerRequest>) =>
+    this.client.fetch<Trigger>(
+      {
+        method: 'DELETE',
+        path: `/containers/v1beta1/regions/${validatePathParam(
+          'region',
+          request.region ?? this.client.settings.defaultRegion,
+        )}/triggers/${validatePathParam('triggerId', request.triggerId)}`,
+      },
+      unmarshalTrigger,
+    )
 }

packages/clients/src/api/container/v1beta1/content.gen.ts

@@ -6,6 +6,7 @@ import type {
   DomainStatus,
   NamespaceStatus,
   TokenStatus,
+  TriggerStatus,
 } from './types.gen'
 
 /** Lists transient statutes of the enum {@link ContainerStatus}. */
@@ -38,3 +39,10 @@ export const NAMESPACE_TRANSIENT_STATUSES: NamespaceStatus[] = [
 
 /** Lists transient statutes of the enum {@link TokenStatus}. */
 export const TOKEN_TRANSIENT_STATUSES: TokenStatus[] = ['deleting', 'creating']
+
+/** Lists transient statutes of the enum {@link TriggerStatus}. */
+export const TRIGGER_TRANSIENT_STATUSES: TriggerStatus[] = [
+  'deleting',
+  'creating',
+  'pending',
+]

packages/clients/src/api/container/v1beta1/index.gen.ts

@@ -13,13 +13,18 @@ export type {
   CreateDomainRequest,
   CreateNamespaceRequest,
   CreateTokenRequest,
+  CreateTriggerRequest,
+  CreateTriggerRequestMnqNatsClientConfig,
+  CreateTriggerRequestMnqSqsClientConfig,
+  CreateTriggerRequestSqsClientConfig,
   Cron,
   CronStatus,
   DeleteContainerRequest,
   DeleteCronRequest,
   DeleteDomainRequest,
   DeleteNamespaceRequest,
   DeleteTokenRequest,
+  DeleteTriggerRequest,
   DeployContainerRequest,
   Domain,
   DomainStatus,
@@ -28,6 +33,7 @@ export type {
   GetDomainRequest,
   GetNamespaceRequest,
   GetTokenRequest,
+  GetTriggerRequest,
   IssueJWTRequest,
   ListContainersRequest,
   ListContainersRequestOrderBy,
@@ -47,6 +53,9 @@ export type {
   ListTokensRequest,
   ListTokensRequestOrderBy,
   ListTokensResponse,
+  ListTriggersRequest,
+  ListTriggersRequestOrderBy,
+  ListTriggersResponse,
   Log,
   LogStream,
   Namespace,
@@ -56,7 +65,15 @@ export type {
   SecretHashedValue,
   Token,
   TokenStatus,
+  Trigger,
+  TriggerInputType,
+  TriggerMnqNatsClientConfig,
+  TriggerMnqSqsClientConfig,
+  TriggerSqsClientConfig,
+  TriggerStatus,
   UpdateContainerRequest,
   UpdateCronRequest,
   UpdateNamespaceRequest,
+  UpdateTriggerRequest,
+  UpdateTriggerRequestSqsClientConfig,
 } from './types.gen'