feat: update add permit flow

src/permit/permit.service.ts

@@ -18,6 +18,7 @@ import mongoose from "mongoose";
 import { getUser } from "../user/user.service";
 import { createNote } from "../note/note.service";
 import { createAlert } from "../alert/alert.service";
+import { processedModel } from "../processed/processed.schema";
 
 export async function createPermit(
   input: CreatePermitInput,
@@ -30,27 +31,51 @@ export async function createPermit(
     };
   }
 
-  const permit = await permitModel.create({
-    tenantId: user.tenantId,
-    pid: generateId(),
-    createdAt: new Date(),
-    createdBy: user.userId,
-    ...input,
-  });
-
-  dbEvents.emit(
-    "change",
-    {
+  if (input.issued) {
+    const permit = await processedModel.create({
       tenantId: user.tenantId,
-      type: "insert",
-      collection: "permits",
-      orgId: permit.client.toString(),
-      document: permit,
-    } as ChangeEvent,
-    ["permit:read"]
-  );
+      pid: generateId(),
+      createdAt: new Date(),
+      createdBy: user.userId,
+      ...input,
+    });
 
-  return permit;
+    dbEvents.emit(
+      "change",
+      {
+        tenantId: user.tenantId,
+        type: "insert",
+        collection: "processed",
+        orgId: permit.client.toString(),
+        document: permit,
+      } as ChangeEvent,
+      ["permit:read"]
+    );
+
+    return permit;
+  } else {
+    const permit = await permitModel.create({
+      tenantId: user.tenantId,
+      pid: generateId(),
+      createdAt: new Date(),
+      createdBy: user.userId,
+      ...input,
+    });
+
+    dbEvents.emit(
+      "change",
+      {
+        tenantId: user.tenantId,
+        type: "insert",
+        collection: "permits",
+        orgId: permit.client.toString(),
+        document: permit,
+      } as ChangeEvent,
+      ["permit:read"]
+    );
+
+    return permit;
+  }
 }
 
 export async function getPermit(permitId: string, tenantId: string) {