fix: Fixed Event Syncing

app/api/slack/events/conversations/route.ts

@@ -34,19 +34,24 @@ export const POST = async (req: NextRequest) => {
     if (type === 'event_callback' && event?.type === 'reaction_added') {
       validateReactionSlackEvent(event);
       await updateSlackReaction(event);
+      return new Response(
+        JSON.stringify({
+          success: true,
+        }),
+        { status: 200 }
+      );
     }
 
     if (type === 'event_callback' && event?.type === 'message') {
       validateMessageSlackEvent(event);
       await updateSlackMessage(event);
+      return new Response(
+        JSON.stringify({
+          success: true,
+        }),
+        { status: 200 }
+      );
     }
-
-    return new Response(
-      JSON.stringify({
-        success: true,
-      }),
-      { status: 200 }
-    );
   } catch (error) {
     if (error instanceof Error) {
       console.log(error.message);

functions/src/index.ts

@@ -71,6 +71,8 @@ exports.clearRealtimeDatabase = functions.pubsub
       const ref = rtdb.ref(pathToClear);
       await ref.remove();
 
+      await initializeRealtimeDatabase();
+
       console.log(`Successfully cleared the path: ${pathToClear}`);
       return null;
     } catch (error) {
@@ -106,3 +108,16 @@ const takeScreenshotAndUpload = async (bucket: Bucket) => {
 
   return screenshotFileName;
 };
+
+const initializeRealtimeDatabase = async () => {
+  const ref = await firestore.collection("metrics").get();
+  const metrics = ref.docs.map((doc) => doc.data());
+  const dataRef = rtdb.ref("/data");
+  metrics.forEach((metric) => {
+    dataRef.child(metric.id).set({
+      title: metric.title,
+      description: metric.description,
+      sensors: {},
+    });
+  });
+};

server/slack/syncs.ts

@@ -42,7 +42,7 @@ export const validateReactionSlackEvent = (event: ReactionAddedEvent) => {
 export const updateSlackReaction = async (event: ReactionAddedEvent) => {
   const db = admin.database();
   const userRef = db.ref(
-    `data/team-communication/sensor-1/value/${event.user}`
+    `data/team-communication/sensors/slack/value/${event.user}`
   );
 
   const snapshot = await userRef.once('value');