extract apple-calender sync logic under sevices (#2505)

Author: yujonglee

apps/desktop/src/components/main/sidebar/timeline/task.ts

@@ -8,8 +8,8 @@ import {
 import { Button } from "@hypr/ui/components/ui/button";
 import { Spinner } from "@hypr/ui/components/ui/spinner";
 
+import { CALENDAR_SYNC_TASK_ID } from "../../../services/apple-calendar";
 import * as main from "../../../store/tinybase/main";
-import { CALENDAR_SYNC_TASK_ID } from "../../main/sidebar/timeline/task";
 
 export function CalendarStatus() {
   const calendars = main.UI.useTable("calendars", main.STORE_ID);

apps/desktop/src/components/settings/calendar/status.tsx

@@ -1,19 +1,24 @@
+import type { Queries } from "tinybase/with-schemas";
 import { useScheduleTaskRun, useSetTask } from "tinytick/ui-react";
 
-import * as main from "../store/tinybase/main";
 import {
   CALENDAR_SYNC_TASK_ID,
   syncCalendarEvents,
-} from "./main/sidebar/timeline/task";
+} from "../services/apple-calendar";
+import * as main from "../store/tinybase/main";
 
 const CALENDAR_SYNC_INTERVAL = 60 * 1000; // 60 sec
 
 export function TaskManager() {
   const store = main.UI.useStore(main.STORE_ID);
+  const queries = main.UI.useQueries(main.STORE_ID);
 
   useSetTask(CALENDAR_SYNC_TASK_ID, async () => {
-    if (store) {
-      await syncCalendarEvents(store as main.Store);
+    if (store && queries) {
+      await syncCalendarEvents(
+        store as main.Store,
+        queries as Queries<main.Schemas>,
+      );
     }
   });
 

apps/desktop/src/components/task-manager.tsx

@@ -0,0 +1,45 @@
+import type { Queries } from "tinybase/with-schemas";
+
+import { QUERIES, type Schemas, type Store } from "../../store/tinybase/main";
+
+export interface Ctx {
+  store: Store;
+  userId: string;
+  from: Date;
+  to: Date;
+  calendarIds: string[];
+}
+
+export function createCtx(store: Store, queries: Queries<Schemas>): Ctx | null {
+  const resultTable = queries.getResultTable(QUERIES.enabledAppleCalendars);
+
+  const calendarIds = Object.keys(resultTable);
+
+  if (calendarIds.length === 0) {
+    return null;
+  }
+
+  const userId = store.getValue("user_id");
+  if (!userId) {
+    return null;
+  }
+
+  const { from, to } = getRange();
+
+  return {
+    store,
+    userId: String(userId),
+    from,
+    to,
+    calendarIds,
+  };
+}
+
+const getRange = () => {
+  const now = new Date();
+  const from = new Date(now);
+  from.setDate(from.getDate() - 7);
+  const to = new Date(now);
+  to.setDate(to.getDate() + 30);
+  return { from, to };
+};

apps/desktop/src/services/apple-calendar/ctx.ts

@@ -0,0 +1,40 @@
+import type { Ctx } from "../ctx";
+import type { ExistingEvent } from "./types";
+
+export function fetchExistingEvents(ctx: Ctx): Array<ExistingEvent> {
+  const enabledCalendarIds = new Set(ctx.calendarIds);
+  const events: Array<ExistingEvent> = [];
+
+  ctx.store.forEachRow("events", (rowId, _forEachCell) => {
+    const event = ctx.store.getRow("events", rowId);
+    if (!event) return;
+
+    const calendarId = event.calendar_id as string | undefined;
+    if (!calendarId || !enabledCalendarIds.has(calendarId)) {
+      return;
+    }
+
+    const startedAt = event.started_at as string | undefined;
+    if (!startedAt) return;
+
+    const eventDate = new Date(startedAt);
+    if (eventDate >= ctx.from && eventDate <= ctx.to) {
+      events.push({
+        id: rowId,
+        user_id: event.user_id as string | undefined,
+        created_at: event.created_at as string | undefined,
+        calendar_id: calendarId,
+        title: event.title as string | undefined,
+        started_at: startedAt,
+        ended_at: event.ended_at as string | undefined,
+        location: event.location as string | undefined,
+        meeting_link: event.meeting_link as string | undefined,
+        description: event.description as string | undefined,
+        note: event.note as string | undefined,
+        participants: event.participants as string | undefined,
+      });
+    }
+  });
+
+  return events;
+}

apps/desktop/src/services/apple-calendar/fetch/existing.ts

@@ -0,0 +1,82 @@
+import type { AppleEvent, Participant } from "@hypr/plugin-apple-calendar";
+import { commands as appleCalendarCommands } from "@hypr/plugin-apple-calendar";
+import { commands as miscCommands } from "@hypr/plugin-misc";
+import type { EventParticipant } from "@hypr/store";
+
+import type { Ctx } from "../ctx";
+import type { IncomingEvent } from "./types";
+
+export async function fetchIncomingEvents(
+  ctx: Ctx,
+): Promise<Array<IncomingEvent>> {
+  const results = await Promise.all(
+    ctx.calendarIds.map(async (calendarId) => {
+      const result = await appleCalendarCommands.listEvents({
+        calendar_tracking_id: calendarId,
+        from: ctx.from.toISOString(),
+        to: ctx.to.toISOString(),
+      });
+
+      if (result.status === "error") {
+        return [];
+      }
+
+      return result.data;
+    }),
+  );
+
+  const events = results.flat();
+
+  return Promise.all(events.map(normalizeAppleEvent));
+}
+
+async function normalizeAppleEvent(event: AppleEvent): Promise<IncomingEvent> {
+  const meetingLink =
+    event.url ?? (await extractMeetingLink(event.notes, event.location));
+
+  const participants: EventParticipant[] = [];
+
+  if (event.organizer) {
+    participants.push(normalizeParticipant(event.organizer, true));
+  }
+
+  for (const attendee of event.attendees) {
+    participants.push(normalizeParticipant(attendee, false));
+  }
+
+  return {
+    id: event.event_identifier,
+    calendar_id: event.calendar.id,
+    title: event.title,
+    started_at: event.start_date,
+    ended_at: event.end_date,
+    location: event.location ?? undefined,
+    meeting_link: meetingLink ?? undefined,
+    description: event.notes ?? undefined,
+    participants:
+      participants.length > 0 ? JSON.stringify(participants) : undefined,
+  };
+}
+
+async function extractMeetingLink(
+  ...texts: (string | undefined | null)[]
+): Promise<string | undefined> {
+  for (const text of texts) {
+    if (!text) continue;
+    const result = await miscCommands.parseMeetingLink(text);
+    if (result) return result;
+  }
+  return undefined;
+}
+
+function normalizeParticipant(
+  participant: Participant,
+  isOrganizer: boolean,
+): EventParticipant {
+  return {
+    name: participant.name ?? undefined,
+    email: participant.email ?? undefined,
+    is_organizer: isOrganizer,
+    is_current_user: participant.is_current_user,
+  };
+}

apps/desktop/src/services/apple-calendar/fetch/incoming.ts

@@ -0,0 +1,3 @@
+export { fetchExistingEvents } from "./existing";
+export { fetchIncomingEvents } from "./incoming";
+export type { ExistingEvent, IncomingEvent } from "./types";

apps/desktop/src/services/apple-calendar/fetch/index.ts

@@ -0,0 +1,8 @@
+import { EventStorage } from "@hypr/store";
+
+type EventBaseForSync = { id: string };
+
+export type IncomingEvent = EventBaseForSync &
+  Omit<EventStorage, "user_id" | "created_at">;
+
+export type ExistingEvent = EventBaseForSync & EventStorage;