Update event RSVPs

Author: KrisBraun

sources/google-calendar/src/google-calendar.ts

@@ -2,13 +2,16 @@ import GoogleContacts from "@plotday/source-google-contacts";
 import {
   ActionType,
   type Action,
+  type ActorId,
+  type Actor,
   ConferencingProvider,
   type NewLinkWithNotes,
   type NewContact,
-  type NewNote,
   Source,
+  type Thread,
   type ToolBuilder,
 } from "@plotday/twister";
+import type { ScheduleContactStatus } from "@plotday/twister/schedule";
 import type {
   NewScheduleContact,
   NewScheduleOccurrence,
@@ -1096,6 +1099,44 @@ export class GoogleCalendar extends Source<GoogleCalendar> {
     }
   }
 
+  /**
+   * Called when a user changes their RSVP status in Plot.
+   * Syncs the change back to Google Calendar via actAs().
+   */
+  async onScheduleContactUpdated(
+    thread: Thread,
+    _scheduleId: string,
+    _contactId: ActorId,
+    status: ScheduleContactStatus | null,
+    actor: Actor
+  ): Promise<void> {
+    const meta = thread.meta as Record<string, unknown> | null;
+    const linkSource = meta?.linkSource as string | null;
+    const calendarId = meta?.syncableId as string | null;
+
+    if (!linkSource || !calendarId) return;
+
+    // Extract event ID from source format "google-calendar:<eventId>"
+    const eventId = linkSource.replace(/^google-calendar:/, "");
+    if (!eventId || eventId === linkSource) return;
+
+    // Map Plot status to Google Calendar status
+    const googleStatus = status === "attend" ? "accepted" as const
+      : status === "skip" ? "declined" as const
+      : "needsAction" as const;
+
+    await this.tools.integrations.actAs(
+      AuthProvider.Google,
+      actor.id,
+      thread.id,
+      this.syncActorRSVP,
+      calendarId,
+      eventId,
+      googleStatus,
+      actor.id as string
+    );
+  }
+
   /**
    * Update RSVP status for the authenticated user on a Google Calendar event.
    * Looks up the user's email from the calendar API to find the correct attendee.

sources/outlook-calendar/src/outlook-calendar.ts

@@ -1,14 +1,17 @@
 import {
   type Action,
   ActionType,
+  type Actor,
   type ActorId,
   ConferencingProvider,
   type ContentType,
   type NewLinkWithNotes,
   type NewContact,
   Source,
+  type Thread,
   type ToolBuilder,
 } from "@plotday/twister";
+import type { ScheduleContactStatus } from "@plotday/twister/schedule";
 import type {
   NewScheduleContact,
   NewScheduleOccurrence,
@@ -726,6 +729,44 @@ export class OutlookCalendar extends Source<OutlookCalendar> {
     await this.runTask(callback);
   }
 
+  /**
+   * Called when a user changes their RSVP status in Plot.
+   * Syncs the change back to Outlook Calendar via actAs().
+   */
+  async onScheduleContactUpdated(
+    thread: Thread,
+    _scheduleId: string,
+    _contactId: ActorId,
+    status: ScheduleContactStatus | null,
+    actor: Actor
+  ): Promise<void> {
+    const meta = thread.meta as Record<string, unknown> | null;
+    const linkSource = meta?.linkSource as string | null;
+    const calendarId = meta?.syncableId as string | null;
+
+    if (!linkSource || !calendarId) return;
+
+    // Extract event ID from source format "outlook-calendar:<eventId>"
+    const eventId = linkSource.replace(/^outlook-calendar:/, "");
+    if (!eventId || eventId === linkSource) return;
+
+    // Map Plot status to Outlook Calendar status
+    const outlookStatus = status === "attend" ? "accepted" as const
+      : status === "skip" ? "declined" as const
+      : "tentativelyAccepted" as const;
+
+    await this.tools.integrations.actAs(
+      AuthProvider.Microsoft,
+      actor.id,
+      thread.id,
+      this.syncActorRSVP,
+      calendarId,
+      eventId,
+      outlookStatus,
+      actor.id as string
+    );
+  }
+
   /**
    * Sync a schedule contact RSVP change back to Outlook Calendar.
    * Called via actAs() which provides the actor's auth token.

twister/src/source.ts

@@ -1,4 +1,5 @@
-import { type Actor, type Link, type Note, type Thread } from "./plot";
+import { type Actor, type ActorId, type Link, type Note, type Thread } from "./plot";
+import type { ScheduleContactStatus } from "./schedule";
 import {
   type AuthProvider,
   type AuthToken,
@@ -164,6 +165,21 @@ export abstract class Source<TSelf> extends Twist<TSelf> {
     return Promise.resolve();
   }
 
+  /**
+   * Called when a schedule contact's RSVP status changes on a thread owned by this source.
+   * Override to sync RSVP changes back to the external calendar.
+   *
+   * @param thread - The thread (includes thread.meta with source-specific data)
+   * @param scheduleId - The schedule ID
+   * @param contactId - The contact whose status changed
+   * @param status - The new RSVP status ('attend', 'skip', or null)
+   * @param actor - The user who changed the status
+   */
+  // eslint-disable-next-line @typescript-eslint/no-unused-vars
+  onScheduleContactUpdated(thread: Thread, scheduleId: string, contactId: ActorId, status: ScheduleContactStatus | null, actor: Actor): Promise<void> {
+    return Promise.resolve();
+  }
+
   // ---- Activation ----
 
   /**