Read schedule from Pretalx

Resolves #62

Author: AndrewKvalheim

README.md

@@ -17,8 +17,8 @@ Populate environment variables:
     - `MATRIX_BASE_URL`: Homeserver base URL
     - `MATRIX_RATE_LIMIT`: Rate limit in hertz
     - `ISSUE_8895_COOLDOWN`: Seconds to wait before room creation ([matrix-org/synapse#8895])
-  - [OSEM]:
-    - `OSEM_RATE_LIMIT`: Rate limit in hertz
+  - [Pretalx]:
+    - `PRETALX_RATE_LIMIT`: Rate limit in hertz
   - [Sentry]:
     - `SENTRY_DSN` (Optional): Data Source Name of Sentry project. If unset, error reporting is not enabled.
 
@@ -38,7 +38,7 @@ yarn start
 [this Stack Exchange question]: https://webapps.stackexchange.com/q/131056/19769
 [matrix-org/synapse#8895]: https://github.com/matrix-org/synapse/issues/8895
 [Node.js]: https://nodejs.org/
-[OSEM]: https://osem.seagl.org/
+[Pretalx]: https://pretalx.seagl.org/
 [SeaGL]: https://seagl.org/
 [SeaGL Matrix space]: https://seagl.org/meet
 [Sentry]: https://sentry.io/

src/lib/Osem.ts

@@ -27,8 +27,8 @@ export namespace Plan {
   export type Rooms = Record<string, Room>;
 
   export interface Sessions {
-    conference: string;
     demo?: string;
+    event: string;
     ignore?: string[];
     intro?: string;
     openEarly: number;

src/lib/Plan.ts

@@ -0,0 +1,68 @@
+import Bottleneck from "bottleneck";
+import { DateTime } from "luxon";
+import { env, fetch as unlimited } from "./utilities.js";
+
+const origin = "https://pretalx.seagl.org";
+const minTime = 1000 / Number(env("PRETALX_RATE_LIMIT"));
+
+const limiter = new Bottleneck({ maxConcurrent: 1, minTime });
+const fetch = limiter.wrap(unlimited);
+
+// Reference: https://docs.pretalx.org/api/fundamentals/#pagination
+interface PaginatedResponse<T = {}> {
+  next: string | null;
+  results: T[];
+}
+
+export interface Talk {
+  beginning: DateTime;
+  end: DateTime;
+  id: string;
+  roomId: string;
+  roomName: string;
+  title: string;
+  url: string;
+}
+
+// Reference: https://docs.pretalx.org/api/resources/talks/
+type TalksResponse = PaginatedResponse<{
+  code: string;
+  slot?: {
+    end: string;
+    room: { en: string };
+    room_id: number;
+    start: string;
+  };
+  title: string;
+}>;
+
+export const getTalks = async (event: string): Promise<Talk[]> => {
+  const talks: Talk[] = [];
+
+  const url = `${origin}/api/events/${event}/talks/?limit=100&state=confirmed`;
+  for await (const page of pages<TalksResponse>(url))
+    for (const { code, slot, title } of page)
+      if (slot)
+        talks.push({
+          beginning: DateTime.fromISO(slot.start),
+          end: DateTime.fromISO(slot.end),
+          id: code,
+          roomId: slot.room_id.toString(),
+          roomName: slot.room.en,
+          title,
+          url: `${origin}/${event}/talk/${code}/`,
+        });
+
+  return talks;
+};
+
+async function* pages<Response extends PaginatedResponse>(
+  url: string,
+): AsyncGenerator<Response["results"]> {
+  let next: string | null = url;
+  do {
+    const response = (await (await fetch(next)).json()) as Response;
+    next = response.next;
+    yield response.results;
+  } while (next);
+}

src/lib/Pretalx.ts

@@ -23,10 +23,10 @@ import {
   StateEventInput,
 } from "../lib/matrix.js";
 import Module from "../lib/Module.js";
-import * as OSEM from "../lib/Osem.js";
 import type { Plan, SessionGroupId } from "../lib/Plan.js";
+import * as Pretalx from "../lib/Pretalx.js";
 import type { Scheduled } from "../lib/scheduling.js";
-import { expect, maxDelay, optional, populate, unimplemented } from "../lib/utilities.js";
+import { expect, maxDelay, populate, unimplemented } from "../lib/utilities.js";
 import type Patch from "../Patch.js";
 
 const md = new MarkdownIt();
@@ -42,7 +42,7 @@ interface ListedSpace extends Space {
   local: string;
 }
 
-interface Session extends OSEM.Event {
+interface Session extends Pretalx.Talk {
   day: number;
   open: DateTime;
 }
@@ -704,11 +704,10 @@ export default class extends Module {
   ) {
     const ignore = new Set(plan.ignore ?? []);
 
-    this.debug("📅 Get sessions", { conference: plan.conference });
-    const osemRooms = await OSEM.getRooms(plan.conference);
-    const osemEvents = await OSEM.getEvents(plan.conference);
-    const startOfDay = DateTime.min(...osemEvents.map((e) => e.beginning)).startOf("day");
-    const sessions = osemEvents
+    this.debug("📅 Get sessions", { event: plan.event });
+    const talks = await Pretalx.getTalks(plan.event);
+    const startOfDay = DateTime.min(...talks.map((e) => e.beginning)).startOf("day");
+    const sessions = talks
       .filter((e) => !ignore.has(e.id))
       .map((event) => ({
         ...event,
@@ -730,21 +729,20 @@ export default class extends Module {
     for (const [index, session] of sessions.entries()) {
       const suffix = plan.suffixes?.[session.id] ?? `session-${session.id}`;
       const redirect = plan.redirects?.[session.id];
-      const venueRoom = osemRooms[session.room]?.name;
-      const values = { room: venueRoom, title: session.title, url: session.url };
+      const values = { room: session.roomName, title: session.title, url: session.url };
       const intro = populate(values, plan.intro);
       const topic = populate(values, plan.topic);
-      const widget = redirect ? undefined : plan.widgets?.[session.room]?.[session.day];
+      const widget = redirect ? undefined : plan.widgets?.[session.roomId]?.[session.day];
 
       const local = `${plan.prefix}${suffix}`;
       const room = await this.reconcileRoom(inheritedUsers, local, sortKey(index), {
         name: [
           session.beginning.toFormat("EEE HH:mm"),
-          ...optional(venueRoom?.replace(/Room (?=\d+)/, "R")),
+          session.roomName.replace(/Room (?=\d+)/, "R"),
           "·",
           session.title,
         ].join(" "),
-        tag: `osem-event-${session.id}`,
+        tag: `pretalx-talk-${session.id}`,
         ...(intro ? { intro } : {}),
         ...(redirect ? { redirect } : {}),
         ...(topic ? { topic } : {}),