Post Luma sync status updates to Discord.

Send a new channel message after each imported Luma event with key event details and review setup status so admins can quickly follow up in Discord.

Author: andrelandgraf

app/src/lib/discord/review-bot.tsx

@@ -27,6 +27,19 @@ type ReviewCardInput = {
   isDraft: boolean;
 };
 
+type LumaSyncStatusUpdateInput = {
+  eventId: string;
+  name: string;
+  slug: string;
+  lumaEventId: string | null;
+  isDraft: boolean;
+  startDate: Date;
+  endDate: Date;
+  reviewMessageId: string | null;
+  reviewSessionCreated: boolean;
+  reviewSetupError: string | null;
+};
+
 type RecentMessageContext = {
   author: string;
   text: string;
@@ -273,3 +286,41 @@ export async function postEventReviewCard(
     rootMessageId: sentMessage.id,
   };
 }
+
+export async function postLumaSyncStatusUpdate(
+  input: LumaSyncStatusUpdateInput,
+): Promise<void> {
+  const { guildId, reviewChannelId } = requireDiscordConfig();
+  const bot = getDiscordReviewBot();
+  const channel = bot.channel(toReviewChannelId(guildId, reviewChannelId));
+
+  const startIso = new Date(input.startDate).toISOString();
+  const endIso = new Date(input.endDate).toISOString();
+  const eventUrl = `${mainConfig.instance.origin}/${input.slug}`;
+  const reviewCardStatus = input.reviewMessageId
+    ? `posted (message id: ${input.reviewMessageId})`
+    : "not posted";
+  const reviewSessionStatus = input.reviewSessionCreated
+    ? "created (pending approval)"
+    : "not created";
+  const reviewError = input.reviewSetupError
+    ? `\n- Review setup error: ${input.reviewSetupError}`
+    : "";
+
+  await channel.post(
+    [
+      "Luma sync status update",
+      `- Event: ${input.name}`,
+      `- Event ID: ${input.eventId}`,
+      `- Slug: ${input.slug}`,
+      `- Luma Event ID: ${input.lumaEventId ?? "n/a"}`,
+      `- Draft: ${input.isDraft ? "true" : "false"}`,
+      `- Start: ${startIso}`,
+      `- End: ${endIso}`,
+      `- Event URL: ${eventUrl}`,
+      `- Review card: ${reviewCardStatus}`,
+      `- Review session: ${reviewSessionStatus}${reviewError}`,
+      "- Follow-up: reply in this channel with any edits or approval actions.",
+    ].join("\n"),
+  );
+}

app/src/workflows/luma-sync/index.ts

@@ -1,6 +1,9 @@
 import type { LumaEvent } from "@/lib/luma";
 import { generateEventDraftWithAI } from "./steps/ai";
-import { createDiscordReviewThreadForEvent } from "./steps/discord";
+import {
+  createDiscordReviewThreadForEvent,
+  postDiscordLumaSyncStatusUpdate,
+} from "./steps/discord";
 import {
   createDiscordReviewSession,
   createEventFromDraft,
@@ -201,18 +204,24 @@ export async function syncLumaEventsWorkflow(
       const createdEvent = await createEventFromDraft(eventDraft);
       if (createdEvent) {
         createdEvents.push(createdEvent);
+        let reviewMessageId: string | null = null;
+        let reviewSessionCreated = false;
+        let reviewSetupErrorMessage: string | null = null;
 
         try {
           const reviewThread =
             await createDiscordReviewThreadForEvent(createdEvent);
+          reviewMessageId = reviewThread.rootMessageId;
           await createDiscordReviewSession({
             eventId: createdEvent.id,
             channelId: reviewThread.channelId,
             rootMessageId: reviewThread.rootMessageId,
             threadId: reviewThread.threadId,
             lastSeenMessageId: reviewThread.lastSeenMessageId,
           });
+          reviewSessionCreated = true;
         } catch (reviewSetupError) {
+          reviewSetupErrorMessage = toErrorMessage(reviewSetupError);
           errors.push({
             scope: "review",
             reference: createdEvent.id,
@@ -221,6 +230,23 @@ export async function syncLumaEventsWorkflow(
             )}`,
           });
         }
+
+        try {
+          await postDiscordLumaSyncStatusUpdate({
+            event: createdEvent,
+            reviewMessageId,
+            reviewSessionCreated,
+            reviewSetupError: reviewSetupErrorMessage,
+          });
+        } catch (statusUpdateError) {
+          errors.push({
+            scope: "review",
+            reference: createdEvent.id,
+            error: `Failed to post Discord status update: ${toErrorMessage(
+              statusUpdateError,
+            )}`,
+          });
+        }
       }
     } catch (error) {
       errors.push({

app/src/workflows/luma-sync/steps/discord.ts

@@ -31,3 +31,28 @@ export async function createDiscordReviewThreadForEvent(
     lastSeenMessageId: null,
   };
 }
+
+export async function postDiscordLumaSyncStatusUpdate(input: {
+  event: LumaSyncCreatedEvent;
+  reviewMessageId: string | null;
+  reviewSessionCreated: boolean;
+  reviewSetupError: string | null;
+}): Promise<void> {
+  "use step";
+  const { postLumaSyncStatusUpdate } = await import("@/lib/discord/review-bot");
+  const { event, reviewMessageId, reviewSessionCreated, reviewSetupError } =
+    input;
+
+  await postLumaSyncStatusUpdate({
+    eventId: event.id,
+    name: event.name,
+    slug: event.slug,
+    lumaEventId: event.lumaEventId,
+    isDraft: event.isDraft,
+    startDate: event.startDate,
+    endDate: event.endDate,
+    reviewMessageId,
+    reviewSessionCreated,
+    reviewSetupError,
+  });
+}