feat(launch darkly perform intake): add launch darkly logic to label mappers

src/libs/opensearch-lib.ts

@@ -58,10 +58,17 @@ export async function bulkUpdateData(
 
   client = client || (await getClient(host));
 
-  const body: any[] = arrayOfDocuments.flatMap((doc) => [
-    { update: { _index: index, _id: doc.id } }, // Action and metadata
-    { doc: doc, doc_as_upsert: true }, // Document to update or upsert
-  ]);
+  const body: any[] = [];
+  for (const doc of arrayOfDocuments) {
+    if (doc.delete) {
+      body.push({ delete: { _index: index, _id: doc.id } });
+    } else {
+      body.push(
+        { update: { _index: index, _id: doc.id } },
+        { doc: doc, doc_as_upsert: true },
+      );
+    }
+  }
 
   async function attemptBulkUpdate(
     retries: number = 5,

src/packages/shared-types/action-types/index.ts

@@ -9,3 +9,5 @@ export * from "./legacy-package-view";
 export * from "./legacy-admin-change";
 export * from "./seatool";
 export * from "./remove-appk-child";
+export * from "./update-id";
+export * from "./perform-intake";

src/packages/shared-types/action-types/perform-intake.ts

@@ -0,0 +1,17 @@
+import { z } from "zod";
+
+// This is the event schema for intake performed from our system
+export const performIntakeSchema = z.object({
+  id: z.string(),
+  authority: z.string(),
+  origin: z.string(),
+  submitterName: z.string(),
+  submitterEmail: z.string(),
+  subject: z.string(),
+  description: z.string(),
+  typeIds: z.array(z.number()),
+  subTypeIds: z.array(z.number()),
+  cpoc: z.number(),
+});
+
+export type PerformIntake = z.infer<typeof performIntakeSchema>;

src/packages/shared-types/action-types/update-id.ts

@@ -0,0 +1,15 @@
+import { z } from "zod";
+import { attachmentSchema } from "../attachments";
+
+// This is the event schema for ne submissions from our system
+export const updateIdSchema = z.object({
+  newId: z.string(),
+  timestamp: z.string().optional(), // Used by waivers and chip spas
+  origin: z.string(),
+  additionalInformation: z.string().nullable().default(null),
+  submitterName: z.string(),
+  submitterEmail: z.string(),
+  attachments: z.array(attachmentSchema).nullish(),
+});
+
+export type UpdateId = z.infer<typeof updateIdSchema>;

src/packages/shared-types/actions.ts

@@ -10,8 +10,10 @@ export enum Action {
   WITHDRAW_PACKAGE = "withdraw-package",
   REMOVE_APPK_CHILD = "remove-appk-child",
   TEMP_EXTENSION = "temporary-extension",
+  UPDATE_ID = "update-id",
+  PERFORM_INTAKE = "perform-intake",
   LEGACY_ADMIN_CHANGE = "legacy-admin-change",
-  LEGACY_WITHDRAW_RAI_REQUEST = "legacy-withdraw-rai-request"
+  LEGACY_WITHDRAW_RAI_REQUEST = "legacy-withdraw-rai-request",
 }
 
 export type ActionRule = {

src/packages/shared-types/opensearch/_.ts

@@ -91,4 +91,5 @@ export type Index =
   | "changelog"
   | "types"
   | "subtypes"
-  | "legacyinsights";
+  | "legacyinsights"
+  | "cpocs"

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

@@ -14,6 +14,7 @@ import {
   RaiWithdraw,
   WithdrawPackage,
   ToggleWithdrawRaiEnabled,
+  UpdateId,
 } from "../../action-types";
 import { legacyAdminChange, legacyEvent } from "./transforms";
 
@@ -22,11 +23,14 @@ export type Document = OneMac &
   RaiResponse &
   RaiIssue &
   RaiWithdraw &
-  ToggleWithdrawRaiEnabled & {
+  ToggleWithdrawRaiEnabled &
+  UpdateId & {
     actionType: string;
     timestamp: string;
     packageId: string;
     appkChildId: string;
+    oldPackageId: string;
+    newPackageId: string;
   } & z.infer<legacyEvent.Schema> &
   z.infer<legacyAdminChange.Schema>;
 

src/packages/shared-types/opensearch/cpocs/index.ts

@@ -0,0 +1,23 @@
+import {
+  Response as Res,
+  Hit,
+  Filterable as FIL,
+  QueryState,
+  AggQuery,
+} from "./../_";
+import { z } from "zod";
+import { Officers } from "./transforms";
+
+export type Document = z.infer<Officers.Schema>;
+
+export type Response = Res<Document>;
+export type ItemResult = Hit<Document> & {
+  found: boolean;
+};
+
+export type Field = keyof Document | `${keyof Document}.keyword`;
+export type Filterable = FIL<Field>;
+export type State = QueryState<Field>;
+export type Aggs = AggQuery<Field>;
+
+export * from "./transforms";

src/packages/shared-types/opensearch/cpocs/transforms/Officers.ts

@@ -0,0 +1,15 @@
+import { seaOfficersSchema } from "../../..";
+
+export const transform = () => {
+  return seaOfficersSchema.transform((data) => {
+    const transformedData = {
+      id: data.Officer_ID,
+      firstName: data.First_Name,
+      lastName: data.Last_Name,
+      email: data.Email,
+    };
+    return transformedData;
+  });
+};
+
+export type Schema = ReturnType<typeof transform>;

src/packages/shared-types/opensearch/cpocs/transforms/index.ts

@@ -0,0 +1 @@
+export * as Officers from "./Officers";

src/packages/shared-types/opensearch/index.ts

@@ -2,4 +2,5 @@ export * as changelog from "./changelog";
 export * as main from "./main";
 export * as types from "./types";
 export * as subtypes from "./subtypes";
+export * as cpocs from "./cpocs";
 export * from "./_";

src/packages/shared-types/seatool-statics/Plan_Types.ts

@@ -1,14 +1,3 @@
-//
-//
-//
-//
-// Be advised:  This plan_types file holds the authorities; the authroity id and its corresponding name.
-// Be advised:  The seatool table is called Plan_Types, hence this file's name.
-//
-//
-//
-//
-
 export const SEATOOL_AUTHORITIES: { [key: string]: string } = {
   "121": "1115",
   "122": "1915(b)",
@@ -21,3 +10,16 @@ export const SEATOOL_AUTHORITIES: { [key: string]: string } = {
   "129": "ADM",
   "130": "UPL",
 };
+
+export const SEATOOL_AUTHORITIES_MAP_TO_ID: { [key: string]: number } = {
+  ["1115"]: 121,
+  ["1915(b)"]: 122,
+  ["1915(c)"]: 123,
+  ["CHIP SPA"]: 124,
+  ["Medicaid SPA"]: 125,
+  ["1115 Indep. Plus"]: 126,
+  ["1915(c) Indep. Plus"]: 127,
+  ["APD"]: 128,
+  ["ADM"]: 129,
+  ["UPL"]: 130,
+};

src/packages/shared-types/seatool-tables/Officers.ts

@@ -0,0 +1,9 @@
+import { z } from "zod";
+
+export const seaOfficersSchema = z.object({
+  Officer_ID: z.number(),
+  First_Name: z.string(),
+  Last_Name: z.string(),
+  Email: z.string().nullish(),
+});
+export type SeaOfficersSchema = z.infer<typeof seaOfficersSchema>;

src/packages/shared-types/seatool-tables/index.ts

@@ -1,3 +1,4 @@
 export * from "./Type";
 export * from "./SPA_Type";
-export * from "./State_Plan";
+export * from "./State_Plan";
+export * from "./Officers";

src/packages/shared-types/user.ts

@@ -3,6 +3,7 @@ export enum UserRoles {
   CMS_REVIEWER = "onemac-micro-reviewer",
   HELPDESK = "onemac-micro-helpdesk",
   STATE_SUBMITTER = "onemac-micro-statesubmitter",
+  CMS_SUPER_USER = "onemac-micro-super",
 }
 
 export type UserRolesString = `${UserRoles}${"," | ""}` | "";
@@ -22,9 +23,13 @@ export const CMS_ROLES = [
   UserRoles.CMS_READ_ONLY,
   UserRoles.CMS_REVIEWER,
   UserRoles.HELPDESK,
+  UserRoles.CMS_SUPER_USER,
 ];
 
-export const CMS_WRITE_ROLES = [UserRoles.CMS_REVIEWER];
+export const CMS_WRITE_ROLES = [
+  UserRoles.CMS_REVIEWER,
+  UserRoles.CMS_SUPER_USER,
+];
 
 export const CMS_READ_ONLY_ROLES = [
   UserRoles.CMS_READ_ONLY,
@@ -38,4 +43,5 @@ export const RoleDescriptionStrings: { [key: string]: string } = {
   [UserRoles.CMS_REVIEWER]: "Reviewer",
   [UserRoles.HELPDESK]: "Helpdesk",
   [UserRoles.STATE_SUBMITTER]: "State Submitter",
+  [UserRoles.CMS_SUPER_USER]: "Super User",
 };

src/packages/shared-utils/feature-flags.ts

@@ -19,4 +19,12 @@ export const featureFlags = {
     flag: "clear-data-button",
     defaultValue: false,
   },
+
+  /**
+   * Toggles Performance Intake
+   */
+  PERFORM_INTAKE: {
+    flag: "perform-intake",
+    defaultValue: false,
+  },
 } as const;

src/packages/shared-utils/package-actions/rules.ts

@@ -5,7 +5,12 @@ import {
   SEATOOL_STATUS,
   finalDispositionStatuses,
 } from "shared-types";
-import { isStateUser, isCmsWriteUser, isIDM } from "../user-helper";
+import {
+  isStateUser,
+  isCmsWriteUser,
+  isIDM,
+  isCmsSuperUser,
+} from "../user-helper";
 
 const arIssueRai: ActionRule = {
   action: Action.ISSUE_RAI,
@@ -84,6 +89,15 @@ const arWithdrawPackage: ActionRule = {
     !checker.hasStatus(finalDispositionStatuses) &&
     isStateUser(user),
 };
+const arUpdateId: ActionRule = {
+  action: Action.UPDATE_ID,
+  check: (checker, user) =>
+    isCmsSuperUser(user) && !checker.hasStatus(finalDispositionStatuses),
+};
+const arPerformIntake: ActionRule = {
+  action: Action.PERFORM_INTAKE,
+  check: (checker, user) => isCmsWriteUser(user) && checker.needsIntake,
+};
 
 // TODO: Add rule for remove-appk-child
 
@@ -95,4 +109,6 @@ export default [
   arWithdrawRaiResponse,
   arWithdrawPackage,
   arTempExtension,
+  arUpdateId,
+  arPerformIntake,
 ];

src/packages/shared-utils/package-check.ts

@@ -30,6 +30,7 @@ export const PackageCheck = ({
   authority,
   actionType,
   appkParentId,
+  initialIntakeNeeded,
 }: opensearch.main.Document) => {
   const planChecks = {
     isSpa: checkAuthority(authority, [Authority.MED_SPA, Authority.CHIP_SPA]),
@@ -62,6 +63,10 @@ export const PackageCheck = ({
     hasStatus: (authorizedStatuses: string | string[]) =>
       checkStatus(seatoolStatus, authorizedStatuses),
   };
+  const subStatusChecks = {
+    /** Is in any of our pending statuses, sans Pending-RAI **/
+    needsIntake: initialIntakeNeeded,
+  };
   const raiChecks = {
     /** There is an RAI and it does not have a response **/
     hasRequestedRai: !!raiRequestedDate && !raiReceivedDate,
@@ -86,6 +91,7 @@ export const PackageCheck = ({
   return {
     ...planChecks,
     ...statusChecks,
+    ...subStatusChecks,
     ...raiChecks,
     ...actionTypeChecks,
   };

src/packages/shared-utils/user-helper.ts

@@ -31,6 +31,9 @@ export const isCmsReadonlyUser = (user: CognitoUserAttributes) =>
 /** Confirms user is a State user */
 export const isStateUser = (user: CognitoUserAttributes | null) =>
   userHasAuthorizedRole(user, STATE_ROLES);
+/** Confirms user is a State user */
+export const isCmsSuperUser = (user: CognitoUserAttributes | null) =>
+  userHasAuthorizedRole(user, [UserRoles.CMS_SUPER_USER]);
 /** Confirms user is an IDM user */
 export const isIDM = (user: CognitoUserAttributes | null) =>
   user?.username.startsWith("IDM_");

src/services/api/handlers/action.ts

@@ -13,8 +13,10 @@ import {
   removeAppkChild,
   respondToRai,
   toggleRaiResponseWithdraw,
+  updateId,
   withdrawPackage,
   withdrawRai,
+  performIntake,
 } from "./packageActions";
 
 export const handler = async (event: APIGatewayEvent) => {
@@ -53,7 +55,7 @@ export const handler = async (event: APIGatewayEvent) => {
     const authDetails = getAuthDetails(event);
     const userAttr = await lookupUserAttributes(
       authDetails.userId,
-      authDetails.poolId
+      authDetails.poolId,
     );
 
     if (actionType === Action.REMOVE_APPK_CHILD) {
@@ -74,7 +76,7 @@ export const handler = async (event: APIGatewayEvent) => {
         },
       });
     }
-
+    console.log(actionType);
     // Call package action
     switch (actionType) {
       case Action.WITHDRAW_PACKAGE:
@@ -95,6 +97,12 @@ export const handler = async (event: APIGatewayEvent) => {
       case Action.WITHDRAW_RAI:
         await withdrawRai(body, result._source);
         break;
+      case Action.UPDATE_ID:
+        await updateId(body);
+        break;
+      case Action.PERFORM_INTAKE:
+        await performIntake(body);
+        break;
       default:
         throw `No ${actionType} action available`;
     }