feat(lamdba): add admin function for NOSO 2

lib/lambda/sinkChangelog.ts

@@ -6,6 +6,7 @@ import {
   transformUpdateValuesSchema,
   transformDeleteSchema,
   transformedUpdateIdSchema,
+  transformSubmitValuesSchema,
 } from "./update/adminChangeSchemas";
 import { getPackageChangelog } from "libs/api/package";
 
@@ -67,7 +68,9 @@ const processAndIndex = async ({
       // query all changelog entries for this ID and create copies of all entries with new ID
       if (record.isAdminChange) {
         const schema = transformDeleteSchema(offset).or(
-          transformUpdateValuesSchema(offset).or(transformedUpdateIdSchema),
+          transformUpdateValuesSchema(offset)
+            .or(transformedUpdateIdSchema)
+            .or(transformSubmitValuesSchema),
         );
 
         const result = schema.safeParse(record);

lib/lambda/sinkMainProcessors.ts

@@ -7,12 +7,14 @@ import {
   deleteAdminChangeSchema,
   updateValuesAdminChangeSchema,
   updateIdAdminChangeSchema,
+  submitNOSOAdminSchema,
 } from "./update/adminChangeSchemas";
 
 const removeDoubleQuotesSurroundingString = (str: string) => str.replace(/^"|"$/g, "");
 const adminRecordSchema = deleteAdminChangeSchema
   .or(updateValuesAdminChangeSchema)
-  .or(updateIdAdminChangeSchema);
+  .or(updateIdAdminChangeSchema)
+  .or(submitNOSOAdminSchema);
 
 type OneMacRecord = {
   id: string;

lib/lambda/update/adminChangeSchemas.ts

@@ -48,3 +48,25 @@ export const transformedUpdateIdSchema = updateIdAdminChangeSchema.transform((da
   id: `${data.id}`,
   timestamp: Date.now(),
 }));
+
+export const submitNOSOAdminSchema = z
+  .object({
+    id: z.string(),
+    authority: z.string(),
+    status: z.string(),
+    submitterEmail: z.string(),
+    submitterName: z.string(),
+    adminChangeType: z.literal("NOSO"),
+    changeMade: z.string(),
+    changeReason: z.string(),
+  })
+  .and(z.record(z.string(), z.any()));
+
+export const transformSubmitValuesSchema = submitNOSOAdminSchema.transform((data) => ({
+  ...data,
+  adminChangeType: "NOSO",
+  event: "NOSO",
+  id: data.id,
+  packageId: data.id,
+  timestamp: Date.now(),
+}));

lib/lambda/update/submitNOSO.test.ts

@@ -0,0 +1,111 @@
+import { describe, it, expect, vi, beforeEach } from "vitest";
+import { handler } from "./submitNOSO";
+import { APIGatewayEvent } from "node_modules/shared-types";
+
+import { NOT_EXISTING_ITEM_ID, TEST_ITEM_ID } from "mocks";
+
+vi.mock("libs/handler-lib", () => ({
+  response: vi.fn((data) => data),
+}));
+
+describe("handler", () => {
+  beforeEach(() => {
+    vi.clearAllMocks();
+    process.env.topicName = "test-topic";
+  });
+
+  it("should return 400 if event body is missing", async () => {
+    const event = {} as APIGatewayEvent;
+    const result = await handler(event);
+    const expectedResult = { statusCode: 400, body: { message: "Event body required" } };
+
+    expect(result).toStrictEqual(expectedResult);
+  });
+
+  it("should return 400 if package ID is not found", async () => {
+    const noActionevent = {
+      body: JSON.stringify({ packageId: "123", changeReason: "Nunya", authority: "test" }),
+    } as APIGatewayEvent;
+
+    const resultPackage = await handler(noActionevent);
+
+    expect(resultPackage?.statusCode).toBe(400);
+  });
+  it("should return 400 if admingChangeType is not found", async () => {
+    const noApackageEvent = {
+      body: JSON.stringify({ action: "123", changeReason: "Nunya" }),
+    } as APIGatewayEvent;
+
+    const resultAction = await handler(noApackageEvent);
+
+    expect(resultAction?.statusCode).toBe(400);
+  });
+  it("should return 400 if existing item is entered", async () => {
+    const noActionevent = {
+      body: JSON.stringify({
+        id: TEST_ITEM_ID,
+        adminChangeType: "NOSO",
+        authority: "SPA",
+        submitterEmail: "[email protected]",
+        submitterName: "Name",
+        status: "submitted",
+        changeMade: "change",
+        changeReason: "reason",
+      }),
+    } as APIGatewayEvent;
+
+    const result = await handler(noActionevent);
+
+    const expectedResult = {
+      statusCode: 400,
+      body: { message: `Package with id: ${TEST_ITEM_ID} already exists.` },
+    };
+    expect(result).toStrictEqual(expectedResult);
+  });
+
+  it("should submit a new item", async () => {
+    const validItem = {
+      body: JSON.stringify({
+        id: NOT_EXISTING_ITEM_ID,
+        authority: "Medicaid SPA",
+        status: "submitted",
+        submitterEmail: "[email protected]",
+        submitterName: "Name",
+        adminChangeType: "NOSO",
+        changeMade: "change",
+        changeReason: "reason",
+      }),
+    } as APIGatewayEvent;
+
+    const result = await handler(validItem);
+
+    const expectedResult = {
+      statusCode: 200,
+      body: { message: `${NOT_EXISTING_ITEM_ID} has been submitted.` },
+    };
+    expect(result).toStrictEqual(expectedResult);
+  });
+
+  it("should fail to create a package ID with no topic name", async () => {
+    process.env.topicName = "";
+    const validItem = {
+      body: JSON.stringify({
+        id: NOT_EXISTING_ITEM_ID,
+        authority: "Medicaid SPA",
+        status: "submitted",
+        submitterEmail: "[email protected]",
+        submitterName: "Name",
+        adminChangeType: "NOSO",
+        changeMade: "change",
+        changeReason: "reason",
+      }),
+    } as APIGatewayEvent;
+
+    const result = await handler(validItem);
+    const expectedResult = {
+      statusCode: 500,
+      body: { message: "Topic name is not defined" },
+    };
+    expect(result).toStrictEqual(expectedResult);
+  });
+});

lib/lambda/update/submitNOSO.ts

@@ -0,0 +1,98 @@
+import { response } from "libs/handler-lib";
+import { APIGatewayEvent } from "aws-lambda";
+import { produceMessage } from "libs/api/kafka";
+import { getPackage } from "libs/api/package";
+import { ItemResult } from "shared-types/opensearch/main";
+import { submitNOSOAdminSchema } from "./adminChangeSchemas";
+import { z } from "zod";
+
+import { getStatus } from "shared-types";
+
+interface submitMessageType {
+  id: string;
+  authority: string;
+  status: string;
+  submitterEmail: string;
+  submitterName: string;
+  adminChangeType: string;
+  stateStatus: string;
+  cmsStatus: string;
+}
+
+const sendSubmitMessage = async (item: submitMessageType) => {
+  const topicName = process.env.topicName as string;
+  if (!topicName) {
+    throw new Error("Topic name is not defined");
+  }
+
+  const currentTime = Date.now();
+
+  await produceMessage(
+    topicName,
+    item.id,
+    JSON.stringify({
+      ...item,
+      packageId: item.id,
+      origin: "SEATool",
+      isAdminChange: true,
+      adminChangeType: "NOSO",
+      description: null,
+      event: "NOSO",
+      state: item.id.substring(0, 2),
+      makoChangedDate: currentTime,
+      changedDate: currentTime,
+      statusDate: currentTime,
+    }),
+  );
+
+  return response({
+    statusCode: 200,
+    body: { message: `${item.id} has been submitted.` },
+  });
+};
+
+export const handler = async (event: APIGatewayEvent) => {
+  if (!event.body) {
+    return response({
+      statusCode: 400,
+      body: { message: "Event body required" },
+    });
+  }
+
+  try {
+    const item = submitNOSOAdminSchema.parse(
+      typeof event.body === "string" ? JSON.parse(event.body) : event.body,
+    );
+
+    const { stateStatus, cmsStatus } = getStatus(item.status);
+    // check if it already exsists
+    const currentPackage: ItemResult | undefined = await getPackage(item.id);
+
+    if (currentPackage && currentPackage.found == true) {
+      // if it exists and has origin OneMAC we shouldn't override it
+      if (currentPackage._source.origin === "OneMAC") {
+        return response({
+          statusCode: 400,
+          body: { message: `Package with id: ${item.id} already exists.` },
+        });
+      }
+      //otherwise we need to add the property origin so it shows up on our dashboard
+      item["origin"] = "SEATool";
+    }
+
+    return await sendSubmitMessage({ ...item, stateStatus, cmsStatus });
+  } catch (err) {
+    console.error("Error has occured submitting package:", err);
+    if (err instanceof z.ZodError) {
+      return response({
+        statusCode: 400,
+        body: { message: err.errors },
+      });
+    }
+
+    return response({
+      statusCode: 500,
+      body: { message: err.message || "Internal Server Error" },
+    });
+  }
+};

lib/packages/shared-types/opensearch/changelog/index.ts

@@ -82,7 +82,8 @@ export type Document = Omit<AppkDocument, "event"> &
       | "withdraw-rai"
       | "update-values"
       | "update-id"
-      | "delete";
+      | "delete"
+      | "NOSO";
   };
 
 export type Response = Res<Document>;

lib/stacks/api.ts

@@ -293,6 +293,17 @@ export class Api extends cdk.NestedStack {
           indexNamespace,
         },
       },
+      {
+        id: "submitNOSO",
+        entry: join(__dirname, "../lambda/update/submitNOSO.ts"),
+        environment: {
+          dbInfoSecretName,
+          topicName,
+          brokerString,
+          osDomain: `https://${openSearchDomainEndpoint}`,
+          indexNamespace,
+        },
+      },
       {
         id: "getSystemNotifs",
         entry: join(__dirname, "../lambda/getSystemNotifs.ts"),

react-app/src/features/package/admin-changes/index.tsx

@@ -59,12 +59,13 @@ export const AdminChange: FC<opensearch.changelog.Document> = (props) => {
         }
         return ["Disable Formal RAI Response Withdraw", AC_WithdrawDisabled];
       }
+      case "NOSO":
       case "legacy-admin-change":
         return [props.changeType || "Manual Update", AC_LegacyAdminChange];
       default:
         return [BLANK_VALUE, AC_Update];
     }
-  }, [props.actionType, props.changeType]);
+  }, [props.event, props.changeType, props.raiWithdrawEnabled]);
 
   return (
     <AccordionItem key={props.id} value={props.id}>