Add new thread on create event

HACC-2023 · Nov 10, 2023 · 765593c · 765593c
1 parent 477853c
commit 765593c
Show file tree

Hide file tree

Showing 4 changed files with 19 additions and 2 deletions.
diff --git a/my-app/src/models/threads/thread.js b/my-app/src/models/threads/thread.js
@@ -11,6 +11,7 @@ const threadSchema = new Schema({
   messages: {
     type: [Message],
     required: true,
+    default: [],
   },
 });
 

diff --git a/my-app/src/pages/api/mongo/event/add-dev.js b/my-app/src/pages/api/mongo/event/add-dev.js
@@ -1,7 +1,8 @@
 import connectDB from '@/lib/mongodb';
 import Event from '@/models/event';
-import { findCloseIsland } from "@/utils/findCloseIsland";
 import Organization from "@/models/organization";
+import Thread from "@/models/threads/thread";
+import { findCloseIsland } from "@/utils/findCloseIsland";
 
 /*
 
@@ -41,7 +42,7 @@ export default async function handler(req, res) {
 
             const matchingOrgs = await Organization.find({ location: derivedClosetIsland });
 
-            await Event.create({
+            const newEvent = await Event.create({
                 status,
                 publicType,
                 publicTypeDesc,
@@ -68,6 +69,11 @@ export default async function handler(req, res) {
                     phoneNumber,
                 },
             });
+
+            await Thread.create({
+                eventId: newEvent._id,
+            });
+
             res.status(201).json({msg: 'Event reported'});
         } catch (error) {
             console.log(error);

diff --git a/my-app/src/pages/api/mongo/event/add-dialogflow.js b/my-app/src/pages/api/mongo/event/add-dialogflow.js
@@ -1,6 +1,7 @@
 import connectDB from '@/lib/mongodb';
 import Event from '@/models/event';
 import { sendEmail } from '@/server/mailService';
+import Thread from "@/models/threads/thread";
 
 export default async function handler(req, res) {
   if (req.method === 'POST') {
@@ -66,6 +67,10 @@ export default async function handler(req, res) {
 
       const created = await Event.create(eventDetails);
 
+      await Thread.create({
+        eventId: created._id,
+      });
+
       const containerFullness = publicContainerFullness ? `<b>Container Fullness:</b> ${publicContainerFullness}<br/>` : '';
       const claimBoat = publicClaimBoat ? `<b>Intend to Claim Boat:</b> ${publicClaimBoat}<br/>` : '';
       const latLongOrPositionDescription = publicLatLongOrPositionDesc ? `<b>Position Description:</b> ${publicLatLongOrPositionDesc}<br/>` : '';

diff --git a/my-app/src/pages/api/mongo/event/add-form.js b/my-app/src/pages/api/mongo/event/add-form.js
@@ -2,6 +2,7 @@ import connectDB from '@/lib/mongodb';
 import Event from '@/models/event';
 import { sendEmail } from '@/server/mailService';
 import { findCloseIsland } from "@/utils/findCloseIsland";
+import Thread from "@/models/threads/thread";
 
 export default async function handler(req, res) {
   if (req.method === 'POST') {
@@ -57,6 +58,10 @@ export default async function handler(req, res) {
         },
       });
 
+      await Thread.create({
+        eventId: created._id,
+      });
+
       const containerFullness = publicContainerFullness ? `<b>Container Fullness:</b> ${publicContainerFullness}<br/>` : '';
       const claimBoat = publicClaimBoat ? `<b>Intend to Claim Boat:</b> ${publicClaimBoat}<br/>` : '';
       const latLongOrPositionDescription = publicLatLongOrPositionDesc ? `<b>Position Description:</b> ${publicLatLongOrPositionDesc}<br/>` : '';