feature(medicaid submission): Medicaid Form Submission

src/packages/shared-types/onemac.ts

@@ -9,11 +9,22 @@ const onemacAttachmentSchema = z.object({
   url: z.string().url(),
 });
 
+const microAttachmentSchema = z.object({
+  bucket: z.string(),
+  key: z.string(),
+  filename: z.string(),
+  title: z.string(),
+  uploadDate: z.number(),
+});
+
 export const onemacSchema = z.object({
   additionalInformation: z.string().nullable().default(null),
   submitterName: z.string(),
   submitterEmail: z.string(),
-  attachments: z.array(onemacAttachmentSchema).nullish(),
+  attachments: z
+    .array(onemacAttachmentSchema)
+    .or(z.array(microAttachmentSchema))
+    .nullish(),
   raiResponses: z
     .array(
       z.object({
@@ -30,17 +41,29 @@ export const transformOnemac = (id: string) => {
     id,
     attachments:
       data.attachments?.map((attachment) => {
-        const uploadDate = parseInt(attachment.s3Key.split("/")[0]);
-        const parsedUrl = s3ParseUrl(attachment.url);
-        if (!parsedUrl) return null;
-        const { bucket, key } = parsedUrl;
+        if ("uploadDate" in attachment) {
+          // this is a micro attachment
+          return {
+            bucket: attachment.bucket,
+            key: attachment.key,
+            filename: attachment.filename,
+            title: attachment.title,
+            uploadDate: attachment.uploadDate,
+          };
+        } else {
+          // this is a legacy onemac attachment
+          const uploadDate = parseInt(attachment.s3Key.split("/")[0]);
+          const parsedUrl = s3ParseUrl(attachment.url);
+          if (!parsedUrl) return null;
+          const { bucket, key } = parsedUrl;
 
-        return {
-          ...attachment,
-          uploadDate,
-          bucket,
-          key,
-        };
+          return {
+            ...attachment,
+            uploadDate,
+            bucket,
+            key,
+          };
+        }
       }) ?? null,
     raiResponses:
       data.raiResponses?.map((response) => {

src/services/api/handlers/getAttachmentUrl.ts

@@ -16,7 +16,7 @@
   try {
     const body = JSON.parse(event.body);
 
     let query: any = {};
     query = {
       query: {
         bool: {
@@ -69,7 +69,12 @@
     }
 
     // Now we can generate the presigned url
-    const url = await generateLegacyPresignedS3Url(body.bucket, body.key, 60);
+    const url = await generatePresignedUrl(
+      body.bucket,
+      body.key,
+      body.filename,
+      60
+    );
 
     return response<unknown>({
       statusCode: 200,
@@ -112,14 +117,20 @@
   }
 }
 
-async function generateLegacyPresignedS3Url(bucket, key, expirationInSeconds) {
+async function generatePresignedUrl(
+  bucket,
+  key,
+  filename,
+  expirationInSeconds
+) {
   // Get an S3 client
   const client = await getClient(bucket);
 
   // Create a command to get the object (you can adjust this according to your use case)
   const getObjectCommand = new GetObjectCommand({
     Bucket: bucket,
     Key: key,
+    ResponseContentDisposition: `filename ="${filename}"`,
   });
 
   // Generate a presigned URL

src/services/api/handlers/submit.ts

@@ -15,6 +15,23 @@ const config = {
   database: "SEA",
 };
 
+import { Kafka, KafkaMessage } from "kafkajs";
+import { OneMacSink, transformOnemac } from "shared-types";
+
+const kafka = new Kafka({
+  clientId: "submit",
+  brokers: process.env.brokerString.split(","),
+  retry: {
+    initialRetryTime: 300,
+    retries: 8,
+  },
+  ssl: {
+    rejectUnauthorized: false,
+  },
+});
+
+const producer = kafka.producer();
+
 export const submit = async (event: APIGatewayEvent) => {
   try {
     const body = JSON.parse(event.body);
@@ -27,10 +44,20 @@ export const submit = async (event: APIGatewayEvent) => {
       });
     }
 
-    const pool = await sql.connect(config);
+    if (body.authority !== "medicaid spa") {
+      return response({
+        statusCode: 400,
+        body: {
+          message:
+            "The Mako Submissions API only supports Medicaid SPA at this time",
+        },
+      });
+    }
 
+    const pool = await sql.connect(config);
+    console.log(body);
     const query = `
-      Insert into SEA.dbo.State_Plan (ID_Number, State_Code, Region_ID, Plan_Type, Submission_Date, Status_Date, SPW_Status_ID, Budget_Neutrality_Established_Flag)
+      Insert into SEA.dbo.State_Plan (ID_Number, State_Code, Region_ID, Plan_Type, Submission_Date, Status_Date, Proposed_Date, SPW_Status_ID, Budget_Neutrality_Established_Flag)
         values ('${body.id}'
           ,'${body.state}'
           ,(Select Region_ID from SEA.dbo.States where State_Code = '${
@@ -41,6 +68,9 @@ export const submit = async (event: APIGatewayEvent) => {
           }')
           ,dateadd(s, convert(int, left(${Date.now()}, 10)), cast('19700101' as datetime))
           ,dateadd(s, convert(int, left(${Date.now()}, 10)), cast('19700101' as datetime))
+          ,dateadd(s, convert(int, left(${
+            body.proposedEffectiveDate
+          }, 10)), cast('19700101' as datetime))
           ,(Select SPW_Status_ID from SEA.dbo.SPW_Status where SPW_Status_DESC = 'Pending')
           ,0)
     `;
@@ -50,10 +80,29 @@ export const submit = async (event: APIGatewayEvent) => {
 
     await pool.close();
 
-    return response({
-      statusCode: 200,
-      body: { message: "success" },
-    });
+    const message: OneMacSink = body;
+    const makoBody = transformOnemac(body.id).safeParse(message);
+    if (makoBody.success === false) {
+      // handle
+      console.log(
+        "MAKO Validation Error. The following record failed to parse: ",
+        JSON.stringify(message),
+        "Because of the following Reason(s): ",
+        makoBody.error.message
+      );
+    } else {
+      console.log(message);
+      await produceMessage(
+        process.env.topicName,
+        body.id,
+        JSON.stringify(message)
+      );
+
+      return response({
+        statusCode: 200,
+        body: { message: "success" },
+      });
+    }
   } catch (error) {
     console.error({ error });
     return response({
@@ -63,4 +112,30 @@ export const submit = async (event: APIGatewayEvent) => {
   }
 };
 
+async function produceMessage(topic, key, value) {
+  console.log("about to connect");
+  await producer.connect();
+  console.log("connected");
+
+  const message: KafkaMessage = {
+    key: key,
+    value: value,
+    partition: 0,
+    headers: { source: "mako" },
+  };
+  console.log(message);
+
+  try {
+    await producer.send({
+      topic,
+      messages: [message],
+    });
+    console.log("Message sent successfully");
+  } catch (error) {
+    console.error("Error sending message:", error);
+  } finally {
+    await producer.disconnect();
+  }
+}
+
 export const handler = submit;

src/services/data/handlers/sink.ts

@@ -21,7 +21,7 @@
   const seaToolRecords: (SeaToolTransform | SeaToolRecordsToDelete)[] = [];
   const docObject: Record<string, SeaToolTransform | SeaToolRecordsToDelete> =
     {};
   const rawArr: any[] = [];
 
   for (const recordKey of Object.keys(event.records)) {
     for (const seatoolRecord of event.records[recordKey] as {
@@ -105,11 +105,13 @@
       if (value) {
         const id: string = decode(key);
         const record = { id, ...JSON.parse(decode(value)) };
+        console.log(record);
         if (
-          record &&
-          record.sk === "Package" &&
-          record.submitterName &&
-          record.submitterName !== "-- --" // these records did not originate from onemac, thus we ignore them
+          record && // testing if we have a record
+          (record.origin === "micro" || // testing if this is a micro record
+            (record.sk === "Package" && // testing if this is a legacy onemac package record
+              record.submitterName &&
+              record.submitterName !== "-- --"))
         ) {
           const result = transformOnemac(id).safeParse(record);
           if (result.success === false) {

src/services/ui/package.json

@@ -18,9 +18,10 @@
     "@aws-amplify/auth": "^5.4.0",
     "@emotion/react": "^11.11.1",
     "@emotion/styled": "^11.11.0",
+    "@fontsource/open-sans": "^5.0.17",
     "@heroicons/react": "^2.0.17",
     "@hookform/error-message": "^2.0.1",
-    "@hookform/resolvers": "^3.3.1",
+    "@hookform/resolvers": "^3.3.2",
     "@mui/lab": "^5.0.0-alpha.136",
     "@mui/material": "^5.14.1",
     "@mui/styled-engine": "^5.13.2",
@@ -43,6 +44,7 @@
     "@tanstack/react-query-devtools": "^4.29.5",
     "@types/file-saver": "^2.0.5",
     "aws-amplify": "^5.2.5",
+    "axios": "^1.6.0",
     "class-variance-authority": "^0.7.0",
     "clsx": "^2.0.0",
     "date-fns": "^2.30.0",
@@ -55,6 +57,7 @@
     "react": "^18.2.0",
     "react-day-picker": "^8.8.1",
     "react-dom": "^18.2.0",
+    "react-dropzone": "^14.2.3",
     "react-hook-form": "^7.46.2",
     "react-loader-spinner": "^5.3.4",
     "react-router-dom": "^6.10.0",

src/services/ui/src/api/getAttachmentUrl.ts

@@ -3,13 +3,15 @@ import { API } from "aws-amplify";
 export const getAttachmentUrl = async (
   id: string,
   bucket: string,
-  key: string
+  key: string,
+  filename: string
 ) => {
   const response = await API.post("os", "/getAttachmentUrl", {
     body: {
       id,
       bucket,
       key,
+      filename,
     },
   });
   return response.url as string;

src/services/ui/src/components/AttachmentsList/index.tsx

@@ -44,7 +44,8 @@ const handleDownloadAll = async (data: AttachmentList) => {
         const url = await getAttachmentUrl(
           data.id,
           attachment.bucket,
-          attachment.key
+          attachment.key,
+          attachment.filename
         );
         return { ...attachment, url };
       });
@@ -84,7 +85,8 @@ export const Attachmentslist = (data: AttachmentList) => {
                           const url = await getAttachmentUrl(
                             data.id,
                             attachment.bucket,
-                            attachment.key
+                            attachment.key,
+                            attachment.filename
                           );
                           console.log(url);
                           window.open(url);

src/services/ui/src/components/BreadCrumb/bread-crumb-config.ts

@@ -44,6 +44,11 @@ export const BREAD_CRUMB_CONFIG_NEW_SUBMISSION: BreadCrumbConfig[] = [
     to: ROUTES.CHIP_SPA_SUB_OPTIONS,
     order: 4,
   },
+  {
+    displayText: "New Submission",
+    to: ROUTES.MEDICAID_NEW,
+    order: 5,
+  },
   {
     displayText: "CHIP Eligibility SPAs",
     to: ROUTES.CHIP_ELIGIBILITY_LANDING,

src/services/ui/src/components/Inputs/calendar.tsx

@@ -18,7 +18,7 @@ function Calendar({
 }: CalendarProps) {
   return (
     <DayPicker
-      fromYear={1960}
+      fromDate={new Date()}
       toYear={2050}
       showOutsideDays={showOutsideDays}
       className={cn("p-3", className)}

src/services/ui/src/components/Inputs/date-picker.tsx

@@ -0,0 +1,47 @@
+"use client";
+
+import * as React from "react";
+import { format } from "date-fns";
+import { Calendar as CalendarIcon } from "lucide-react";
+
+import { cn } from "@/lib/utils";
+import { Button } from "@/components/Inputs/button";
+import { Calendar } from "@/components/Inputs/calendar";
+import { Popover, PopoverContent, PopoverTrigger } from "@/components/Popover";
+
+type DatePickerProps = {
+  date: Date | undefined;
+  onChange: (date: Date | undefined) => void;
+};
+
+export const DatePicker = ({ date, onChange }: DatePickerProps) => {
+  const [isCalendarOpen, setIsCalendarOpen] = React.useState<boolean>(false);
+
+  return (
+    <Popover open={isCalendarOpen} onOpenChange={setIsCalendarOpen}>
+      <PopoverTrigger asChild>
+        <Button
+          variant={"outline"}
+          className={cn(
+            "w-[280px] justify-start text-left font-normal",
+            !date && "text-muted-foreground"
+          )}
+        >
+          <CalendarIcon className="mr-2 h-4 w-4" />
+          {date ? format(date, "PPP") : <span>Pick a date</span>}
+        </Button>
+      </PopoverTrigger>
+      <PopoverContent className="w-auto p-0">
+        <Calendar
+          mode="single"
+          selected={date}
+          onSelect={(date) => {
+            onChange(date);
+            setIsCalendarOpen(false);
+          }}
+          initialFocus
+        />
+      </PopoverContent>
+    </Popover>
+  );
+};

src/services/ui/src/components/Inputs/form.tsx

@@ -95,7 +95,7 @@ const FormLabel = React.forwardRef<
   return (
     <Label
       ref={ref}
-      className={cn(error && "text-destructive", className)}
+      className={cn(error && "text-destructive", "font-bold", className)}
       htmlFor={formItemId}
       {...props}
     />

src/services/ui/src/components/Inputs/index.tsx

@@ -2,10 +2,12 @@ export * from "./button";
 export * from "./calendar";
 export * from "./checkbox";
 export * from "./form";
+export * from "./upload";
 export * from "./input";
 export * from "./label";
 export * from "./radio-group";
 export * from "./select";
 export * from "./switch";
 export * from "./textarea";
 export * from "./toggle";
+export * from "./date-picker";