From c2df46bdc1d580f386c697fa7d8da86e4de31036 Mon Sep 17 00:00:00 2001
From: Akhil Meka <akhil.reddy@qualyval.com>
Date: Tue, 29 Apr 2025 13:46:11 +0530
Subject: [PATCH] permit and processed collection updates

---
 src/permit/permit.route.ts         |  9 ++-------
 src/permit/permit.schema.ts        |  5 ++++-
 src/processed/processed.route.ts   | 29 ++++++++++++++++++++++++++++-
 src/processed/processed.schema.ts  | 15 +++++++++++++++
 src/processed/processed.service.ts | 26 +++++++++++++++++++++++++-
 src/utils/roles.ts                 |  2 ++
 6 files changed, 76 insertions(+), 10 deletions(-)

diff --git a/src/permit/permit.route.ts b/src/permit/permit.route.ts
index c426716..2a708d1 100644
--- a/src/permit/permit.route.ts
+++ b/src/permit/permit.route.ts
@@ -10,15 +10,10 @@ import {
 } from "./permit.controller";
 import { $permit } from "./permit.schema";
 import { hideFields } from "../auth";
-import {
-  createNoteHandler,
-  deleteNoteHandler,
-  listNotesHandler,
-} from "../note/note.controller";
 import { noteRoutes } from "../note/note.route";
 
 export async function permitRoutes(fastify: FastifyInstance) {
-  fastify.post(
+  /*   fastify.post(
     "/",
     {
       schema: {
@@ -28,7 +23,7 @@ export async function permitRoutes(fastify: FastifyInstance) {
       preHandler: [fastify.authorize],
     },
     createPermitHandler
-  );
+  ); */
 
   fastify.get(
     "/:permitId",
diff --git a/src/permit/permit.schema.ts b/src/permit/permit.schema.ts
index 58ca518..c2f1245 100644
--- a/src/permit/permit.schema.ts
+++ b/src/permit/permit.schema.ts
@@ -133,7 +133,10 @@ const updatePermitInput = z.object({
     .enum(["Ready To Issue", "Issued", "Invoiced", "Paid", "Closed"])
     .nullable()
     .optional(),
-  utility: z.string().optional(),
+  utility: z
+    .enum(["Submitted", "Pending", "Applied", "Rejected", "Paid"])
+    .nullable()
+    .optional(),
   assignedTo: z.string().optional(),
   newPayment: z.array(z.any()).optional(),
 });
diff --git a/src/processed/processed.route.ts b/src/processed/processed.route.ts
index 7ec4763..f68b5a1 100644
--- a/src/processed/processed.route.ts
+++ b/src/processed/processed.route.ts
@@ -4,8 +4,9 @@ import {
   getProcessedPermit,
   getUniqueValuesProcessed,
   listProcessedPermits,
+  updateProcessed,
 } from "./processed.service";
-import { $processed } from "./processed.schema";
+import { $processed, UpdateProcessedInput } from "./processed.schema";
 
 export async function processedRoutes(fastify: FastifyInstance) {
   fastify.get(
@@ -74,6 +75,32 @@ export async function processedRoutes(fastify: FastifyInstance) {
     }
   );
 
+  fastify.patch(
+    "/:permitId",
+    {
+      schema: {
+        params: {
+          type: "object",
+          properties: { permitId: { type: "string" } },
+        },
+        body: $processed("updateProcessedInput"),
+      },
+      config: { requiredClaims: ["permit:write"] },
+      preHandler: [fastify.authorize],
+    },
+    async (req: FastifyRequest, res: FastifyReply) => {
+      const { permitId } = req.params as { permitId: string };
+      const input = req.body as UpdateProcessedInput;
+
+      try {
+        const permit = await updateProcessed(input, permitId, req.user);
+        return res.code(200).send(permit);
+      } catch (err) {
+        return err;
+      }
+    }
+  );
+
   fastify.get(
     "/fields/:field",
     {
diff --git a/src/processed/processed.schema.ts b/src/processed/processed.schema.ts
index ee5e8c9..b676c3f 100644
--- a/src/processed/processed.schema.ts
+++ b/src/processed/processed.schema.ts
@@ -1,3 +1,4 @@
+import z from "zod";
 import mongoose from "mongoose";
 import { pageQueryParams } from "../pagination";
 import { buildJsonSchemas } from "fastify-zod";
@@ -74,9 +75,23 @@ export const processedModel = mongoose.model(
   "processed"
 );
 
+const updateProcessedInput = z.object({
+  manualStatus: z
+    .enum(["Ready To Issue", "Issued", "Invoiced", "Paid", "Closed"])
+    .nullable()
+    .optional(),
+  utility: z
+    .enum(["Submitted", "Pending", "Applied", "Rejected", "Paid"])
+    .nullable()
+    .optional(),
+});
+
+export type UpdateProcessedInput = z.infer<typeof updateProcessedInput>;
+
 export const { schemas: processedSchemas, $ref: $processed } = buildJsonSchemas(
   {
     pageQueryParams,
+    updateProcessedInput,
   },
   { $id: "processed" }
 );
diff --git a/src/processed/processed.service.ts b/src/processed/processed.service.ts
index d70e706..f55c6ea 100644
--- a/src/processed/processed.service.ts
+++ b/src/processed/processed.service.ts
@@ -1,7 +1,12 @@
+import { AuthenticatedUser } from "../auth";
 import { orgModel } from "../organization/organization.schema";
 import { getFilterObject, getSortObject, PageQueryParams } from "../pagination";
 import { userModel } from "../user/user.schema";
-import { processedFields, processedModel } from "./processed.schema";
+import {
+  processedFields,
+  processedModel,
+  UpdateProcessedInput,
+} from "./processed.schema";
 
 export async function getProcessedPermit(permitId: String, tenantId: String) {
   return await processedModel.findOne({
@@ -9,6 +14,25 @@ export async function getProcessedPermit(permitId: String, tenantId: String) {
   });
 }
 
+export async function updateProcessed(
+  input: UpdateProcessedInput,
+  permitId: string,
+  user: AuthenticatedUser
+) {
+  return await processedModel
+    .findOneAndUpdate(
+      {
+        $and: [{ tenantId: user.tenantId }, { pid: permitId }],
+      },
+      { ...input, lastUpdateDate: new Date() },
+      { new: true }
+    )
+    .populate({ path: "county", select: "pid name avatar" })
+    .populate({ path: "client", select: "pid name avatar" })
+    .populate({ path: "assignedTo", select: "pid name avatar" })
+    .populate({ path: "createdBy", select: "pid name avatar" });
+}
+
 export async function listProcessedPermits(
   params: PageQueryParams,
   tenantId: string
diff --git a/src/utils/roles.ts b/src/utils/roles.ts
index e3f9bb1..e7165ba 100644
--- a/src/utils/roles.ts
+++ b/src/utils/roles.ts
@@ -48,6 +48,7 @@ export const rules: Record<
       "user:write",
       "org:read",
       "permit:read",
+      "permit:write",
       "file:upload",
       "file:download",
       "file:delete",
@@ -78,6 +79,7 @@ export const rules: Record<
     claims: [
       "org:read",
       "permit:read",
+      "permit:write",
       "file:upload",
       "file:download",
       "rts:read",