Add communityId to Slack notifications and update email sending function

Author: probablyangg

src/app/api/upsert/convo/route.ts

@@ -81,6 +81,7 @@ const sendWithRateLimit = async (
 // Helper function to send emails asynchronously without blocking the response
 const sendEmailsAsync = async (
   event: ServerEvent,
+  community: { id: string }, // Add community parameter for slack notifications
   goingAttendees: (Rsvp & { attendee: User })[] = [],
   maybeAttendees: (Rsvp & { attendee: User })[] = [],
   isUpdate = false,
@@ -183,6 +184,7 @@ const sendEmailsAsync = async (
         eventId: event.id,
         host,
         type: isUpdate ? "updated" : "new", // "new" | "reminder" | "updated"
+        communityId: community.id,
       });
 
       console.log(
@@ -471,6 +473,7 @@ export async function POST(req: NextRequest) {
     // Error handling is now inside the sendEmailsAsync function
     void sendEmailsAsync(
       updated,
+      community,
       goingAttendees,
       maybeAttendees,
       true,
@@ -636,9 +639,11 @@ export async function POST(req: NextRequest) {
   // Start sending emails asynchronously without awaiting
   // Don't await or use catch - start this fully asynchronously to improve response time
   // Fire and forget approach
-  sendEmailsAsync(created, [], [], false, undefined, userId).catch((error) => {
-    console.error("Background email sending failed:", error);
-  });
+  sendEmailsAsync(created, community, [], [], false, undefined, userId).catch(
+    (error) => {
+      console.error("Background email sending failed:", error);
+    }
+  );
 
   // Queue reminder scheduling in parallel - fully asynchronous
   // This significantly improves API response time

src/lib/queue/slack.ts

@@ -6,6 +6,7 @@ export interface SlackJobData {
   eventId: string;
   host: string;
   type: "new" | "reminder" | "updated";
+  communityId: string;
 }
 
 // Create the slack notification queue

src/lib/queue/workers/slack.ts

@@ -1,20 +1,16 @@
 import { slackQueue, type SlackJobData } from "../slack";
 import { sendMessage } from "src/utils/slack/sendMessage";
 import { prisma } from "src/utils/db";
-import { getCommunityFromSubdomain } from "src/utils/getCommunityFromSubdomain";
 
 // Process a slack notification job
 async function processSlackJob(job: { data: SlackJobData }): Promise<void> {
-  const { eventId, host, type } = job.data;
+  const { eventId, host, type, communityId } = job.data;
 
   console.log(
-    `Processing Slack notification job for event ${eventId} with type ${type}`
+    `Processing Slack notification job for event ${eventId} with type ${type} in community ${communityId}`
   );
 
   try {
-    // Get the community for community-specific profiles
-    const community = await getCommunityFromSubdomain();
-
     // Fetch the event with all needed relationships
     const event = await prisma.event.findUnique({
       where: { id: eventId },
@@ -24,7 +20,7 @@ async function processSlackJob(job: { data: SlackJobData }): Promise<void> {
             user: {
               include: {
                 profiles: {
-                  where: { communityId: community.id },
+                  where: { communityId },
                   take: 1,
                 },
               },
@@ -36,7 +32,7 @@ async function processSlackJob(job: { data: SlackJobData }): Promise<void> {
             attendee: {
               include: {
                 profiles: {
-                  where: { communityId: community.id },
+                  where: { communityId },
                   take: 1,
                 },
               },