adding update

Author: alexnuttall

lambdas/backend-api/build.sh

@@ -31,6 +31,7 @@ npx esbuild \
     src/templates/submit.ts \
     src/templates/submit-routing-config.ts \
     src/templates/update.ts \
+    src/templates/update-routing-config.ts \
     src/templates/validate-letter-template-files.ts
 
 cp -r ../../utils/utils/src/email-templates ./dist/submit

lambdas/backend-api/src/templates/api/update-routing-config.ts

@@ -0,0 +1,48 @@
+import type { APIGatewayProxyHandler } from 'aws-lambda';
+import { apiFailure, apiSuccess } from './responses';
+import { RoutingConfigClient } from '../app/routing-config-client';
+import { logger } from 'nhs-notify-web-template-management-utils/logger';
+
+export function createHandler({
+  routingConfigClient,
+}: {
+  routingConfigClient: RoutingConfigClient;
+}): APIGatewayProxyHandler {
+  return async function (event) {
+    const { user: userId, clientId } = event.requestContext.authorizer ?? {};
+
+    const routingConfigId = event.pathParameters?.id;
+
+    if (!routingConfigId || !userId || !clientId) {
+      return apiFailure(400, 'Invalid request');
+    }
+
+    const payload = JSON.parse(event.body || '{}');
+
+    const log = logger.child({
+      clientId,
+      routingConfigId,
+      userId,
+    });
+
+    const { data, error } = await routingConfigClient.updateRoutingConfig(
+      routingConfigId,
+      payload,
+      { userId, clientId }
+    );
+
+    if (error) {
+      log
+        .child(error.errorMeta)
+        .error('Failed to update routing config', error.actualError);
+
+      return apiFailure(
+        error.errorMeta.code,
+        error.errorMeta.description,
+        error.errorMeta.details
+      );
+    }
+
+    return apiSuccess(200, data);
+  };
+}

lambdas/backend-api/src/templates/app/routing-config-client.ts

@@ -3,7 +3,6 @@ import {
   $CreateUpdateRoutingConfig,
   $ListRoutingConfigFilters,
   ErrorCase,
-  type CreateUpdateRoutingConfig,
   type ListRoutingConfigFilters,
   type Result,
   type RoutingConfig,
@@ -18,12 +17,12 @@ export class RoutingConfigClient {
   ) {}
 
   async createRoutingConfig(
-    routingConfig: CreateUpdateRoutingConfig,
+    payload: unknown,
     user: User
   ): Promise<Result<RoutingConfig>> {
     const validationResult = await validate(
       $CreateUpdateRoutingConfig,
-      routingConfig
+      payload
     );
 
     if (validationResult.error) return validationResult;
@@ -36,6 +35,25 @@ export class RoutingConfigClient {
     return createResult;
   }
 
+  async updateRoutingConfig(
+    routingConfigId: string,
+    payload: unknown,
+    user: User
+  ): Promise<Result<RoutingConfig>> {
+    const validationResult = await validate(
+      $CreateUpdateRoutingConfig,
+      payload
+    );
+
+    if (validationResult.error) return validationResult;
+
+    return await this.routingConfigRepository.update(
+      routingConfigId,
+      validationResult.data,
+      user
+    );
+  }
+
   async submitRoutingConfig(
     routingConfigId: string,
     user: User

lambdas/backend-api/src/templates/infra/routing-config-repository/repository.ts

@@ -62,10 +62,49 @@ export class RoutingConfigRepository {
   }
 
   async update(
-    _updateData: Partial<CreateUpdateRoutingConfig>,
-    _user: User
+    id: string,
+    updateData: Partial<CreateUpdateRoutingConfig>,
+    user: User
   ): Promise<ApplicationResult<RoutingConfig>> {
-    return {} as Promise<ApplicationResult<RoutingConfig>>;
+    const builder = new RoutingConfigUpdateBuilder(
+      this.tableName,
+      user.clientId,
+      id,
+      { ReturnValues: 'ALL_NEW' }
+    ).setUpdatedByUserAt(user.userId);
+
+    const { campaignId, cascade, cascadeGroupOverrides, name } = updateData;
+
+    if (campaignId) builder.setCampaignId(campaignId);
+    if (cascade) builder.setCascade(cascade);
+    if (name) builder.setName(name);
+    if (cascadeGroupOverrides) {
+      builder.setCascadeGroupOverrides(cascadeGroupOverrides);
+    }
+
+    const cmdInput = builder.build();
+
+    try {
+      const result = await this.client.send(new UpdateCommand(cmdInput));
+
+      const parsed = $RoutingConfig.safeParse(result.Attributes);
+
+      if (!parsed.success) {
+        return failure(
+          ErrorCase.INTERNAL,
+          'Error retrieving Routing Config',
+          parsed.error
+        );
+      }
+
+      return success(parsed.data);
+    } catch (error) {
+      return failure(
+        ErrorCase.INTERNAL,
+        'Failed to update routing config',
+        error
+      );
+    }
   }
 
   async submit(
@@ -80,14 +119,23 @@ export class RoutingConfigRepository {
     )
       .setStatus('COMPLETED')
       .expectedStatus('DRAFT')
+      .setUpdatedByUserAt(user.userId)
       .build();
 
     try {
       const result = await this.client.send(new UpdateCommand(cmdInput));
 
-      const routingConfig = $RoutingConfig.parse(result.Attributes);
+      const parsed = $RoutingConfig.safeParse(result.Attributes);
 
-      return success(routingConfig);
+      if (!parsed.success) {
+        return failure(
+          ErrorCase.INTERNAL,
+          'Error retrieving Routing Config',
+          parsed.error
+        );
+      }
+
+      return success(parsed.data);
     } catch (error) {
       return failure(
         ErrorCase.INTERNAL,

lambdas/backend-api/src/templates/update-routing-config.ts

@@ -0,0 +1,4 @@
+import { createHandler } from './api/update-routing-config';
+import { createContainer } from './container';
+
+export const handler = createHandler(createContainer());

utils/entity-update-command-builder/src/routing-config-update-builder.ts

@@ -1,4 +1,6 @@
 import type {
+  CascadeGroup,
+  CascadeItem,
   RoutingConfig,
   RoutingConfigStatus,
 } from 'nhs-notify-backend-client';
@@ -34,6 +36,26 @@ export class RoutingConfigUpdateBuilder extends EntityUpdateBuilder<
     return this;
   }
 
+  setCampaignId(campaignId: string) {
+    this.updateBuilder.setValue('campaignId', campaignId);
+    return this;
+  }
+
+  setCascade(cascade: CascadeItem[]) {
+    this.updateBuilder.setValue('cascade', cascade);
+    return this;
+  }
+
+  setCascadeGroupOverrides(cascadeGroupOverrides: CascadeGroup[]) {
+    this.updateBuilder.setValue('cascadeGroupOverrides', cascadeGroupOverrides);
+    return this;
+  }
+
+  setName(name: string) {
+    this.updateBuilder.setValue('name', name);
+    return this;
+  }
+
   setUpdatedByUserAt(userId: string) {
     this.updateBuilder
       .setValue('updatedAt', new Date().toISOString())