[HOTE-1209] feat: Reactive Results: Set TEST_PROCESSED status

lambdas/goose-migrator-lambda/migrations/000018_add_result_processed_status.sql

@@ -0,0 +1,8 @@
+-- +goose Up
+INSERT INTO result_type (result_code, description)
+VALUES ('RESULT_PROCESSED', 'Test has been processed at the lab but results are not yet available')
+ON CONFLICT DO NOTHING;
+
+-- +goose Down
+DELETE FROM result_type
+WHERE result_code = 'RESULT_PROCESSED';

lambdas/src/lib/types/status.ts

@@ -11,4 +11,5 @@ export enum OrderStatus {
 export enum ResultStatus {
   Result_Available = "RESULT_AVAILABLE",
   Result_Withheld = "RESULT_WITHHELD",
+  Result_Processed = "RESULT_PROCESSED",
 }

lambdas/src/order-status-lambda/db/commands/insert-result-status.test.ts

@@ -0,0 +1,60 @@
+import { type DBClient } from "../../../lib/db/db-client";
+import { ResultStatus } from "../../../lib/types/status";
+import { InsertResultStatusCommand } from "./insert-result-status";
+
+const normalizeWhitespace = (sql: string): string => sql.replace(/\s+/g, " ").trim();
+
+describe("InsertResultStatusCommand", () => {
+  let dbClient: jest.Mocked<Pick<DBClient, "query" | "withTransaction" | "close">>;
+  let command: InsertResultStatusCommand;
+
+  beforeEach(() => {
+    jest.clearAllMocks();
+
+    dbClient = {
+      query: jest.fn(),
+      withTransaction: jest.fn(),
+      close: jest.fn().mockResolvedValue(undefined),
+    };
+
+    command = new InsertResultStatusCommand(dbClient as DBClient);
+  });
+
+  const expectedQuery = `
+      INSERT INTO result_status (order_uid, status, correlation_id)
+      VALUES ($1::uuid, $2, $3::uuid)
+      ON CONFLICT (correlation_id) DO NOTHING;
+    `;
+
+  it("executes the correct SQL with all parameters", async () => {
+    dbClient.query.mockResolvedValue({ rows: [], rowCount: 1 });
+
+    await command.execute(
+      "9f44d6e9-7829-49f1-a327-8eca95f5db32",
+      ResultStatus.Result_Processed,
+      "c1a2b3c4-d5e6-7890-abcd-ef1234567890",
+    );
+
+    expect(dbClient.query).toHaveBeenCalledTimes(1);
+    expect(normalizeWhitespace(dbClient.query.mock.calls[0][0])).toBe(
+      normalizeWhitespace(expectedQuery),
+    );
+    expect(dbClient.query.mock.calls[0][1]).toEqual([
+      "9f44d6e9-7829-49f1-a327-8eca95f5db32",
+      ResultStatus.Result_Processed,
+      "c1a2b3c4-d5e6-7890-abcd-ef1234567890",
+    ]);
+  });
+
+  it("inserts with ON CONFLICT DO NOTHING for duplicate correlation IDs", async () => {
+    dbClient.query.mockResolvedValue({ rows: [], rowCount: 0 });
+
+    await command.execute(
+      "9f44d6e9-7829-49f1-a327-8eca95f5db32",
+      ResultStatus.Result_Processed,
+      "c1a2b3c4-d5e6-7890-abcd-ef1234567890",
+    );
+
+    expect(dbClient.query).toHaveBeenCalledTimes(1);
+  });
+});

lambdas/src/order-status-lambda/db/commands/insert-result-status.ts

@@ -0,0 +1,20 @@
+import { type DBClient } from "../../../lib/db/db-client";
+import { ResultStatus } from "../../../lib/types/status";
+
+export class InsertResultStatusCommand {
+  constructor(private readonly dbClient: DBClient) {}
+
+  async execute(orderId: string, status: ResultStatus, correlationId: string): Promise<void> {
+    const query = `
+      INSERT INTO result_status (order_uid, status, correlation_id)
+      VALUES ($1::uuid, $2, $3::uuid)
+      ON CONFLICT (correlation_id) DO NOTHING;
+    `;
+
+    await this.dbClient.query<void, [string, ResultStatus, string]>(query, [
+      orderId,
+      status,
+      correlationId,
+    ]);
+  }
+}