src/ws/connection.js

@@ -103,7 +103,7 @@ export const connect = ({ url, onConnect }) => {
       });
       console.log(
         "[ws] Socket is closed. Reconnect will be attempted in 1 second.",
-        event.reason
+        event.reason,
       );
 
       clearInterval(keepAliveInterval);
@@ -114,7 +114,7 @@ export const connect = ({ url, onConnect }) => {
       console.error(
         "[ws] Socket encountered error: ",
         err.message,
-        "Closing socket"
+        "Closing socket",
       );
       ws.close();
       reject(err);

src/ws/handlers/announcements.js

@@ -10,7 +10,7 @@ export const handleAnnouncementChanged = (payload) => {
       if (has(payload, "content")) {
         state.items[payload.id].content = payload.content;
         state.items[payload.id].contentHtml = markdownConverter.makeHtml(
-          payload.content
+          payload.content,
         );
       }
       if (has(payload, "link")) {

src/ws/handlers/global.js

@@ -6,5 +6,8 @@ export const handleOnlineUsersUpdated = (payload) => {
   GlobalInfoStore.update((state) => {
     state.onlineUsers = isNumber(payload.all) ? payload.all : 0;
     state.onlineMembers = isNumber(payload.members) ? payload.members : 0;
+    state.groupSizeHalf = isNumber(payload.group_size_half)
+      ? payload.group_size_half
+      : null;
   });
 };

src/ws/handlers/posts.js

 import has from "lodash/has";
+import throttle from "lodash/throttle";
 
 import { markdownConverter } from "markdown";
 import { PostStore } from "stores";
 import { parseRawPost, postsStateMapping, updateWindowPosts } from "utils";
 
+/**
+ * Re-apply sorting by rank but no more than once every 3 seconds.
+ */
+const sortOnRankThrottled = throttle(() => {
+  PostStore.update((state) => {
+    if (state.filters.sort === "byScore") {
+      updateWindowPosts(state);
+    }
+  });
+}, 5000);
+
 export const handlePostRanked = (payload) => {
   PostStore.update((state) => {
     if (state.items[payload.id]) {
@@ -12,12 +24,11 @@ export const handlePostRanked = (payload) => {
       state.items[payload.id].ranking.score =
         state.items[payload.id].ranking.likes -
         state.items[payload.id].ranking.dislikes;
-
-      if (state.filters.sort === "byScore") {
-        updateWindowPosts(state);
-      }
     }
   });
+
+  // Run sorting in a throttled manner.
+  sortOnRankThrottled();
 };
 
 export const handlePostChanged = (payload) => {
@@ -26,21 +37,21 @@ export const handlePostChanged = (payload) => {
       if (has(payload, "content")) {
         state.items[payload.id].content = payload.content;
         state.items[payload.id].contentHtml = markdownConverter.makeHtml(
-          payload.content
+          payload.content,
         );
         state.items[payload.id].modified = true;
       }
 
       if (has(payload, "state")) {
         state.items[payload.id].state = postsStateMapping[payload.state];
+        updateWindowPosts(state);
       }
 
       if (has(payload, "is_archived")) {
         state.items[payload.id].archived = payload.is_archived;
-      }
-
         updateWindowPosts(state);
       }
+    }
   });
 };
 

src/ws/handlers/program.js

 import has from "lodash/has";
 
+import { loadPosts } from "actions/posts";
+import { markdownConverter } from "markdown";
 import { ProgramStore } from "stores";
 
 export const handleProgramEntryChanged = (payload) => {
   ProgramStore.update((state) => {
-    if (state.items[payload.id]) {
+    const entry = state.items[payload.id];
+
+    if (entry) {
       if (has(payload, "discussion_opened")) {
         state.items[payload.id].discussionOpened = payload.discussion_opened;
       }
       if (has(payload, "title")) {
         state.items[payload.id].title = payload.title;
+        state.items[payload.id].fullTitle =
+          entry.number !== "" ? `${entry.number}. ${entry.title}` : entry.title;
+      }
+      if (has(payload, "description")) {
+        state.items[payload.id].description = payload.description;
+        state.items[payload.id].htmlContent = markdownConverter.makeHtml(
+          payload.description,
+        );
+      }
+
+      if (has(payload, "is_live") && payload.is_live) {
+        state.currentId = payload.id;
       }
     }
   });
+
+  if (has(payload, "is_live") && payload.is_live) {
+    // Re-load posts - these are bound directly to the program schedule entry.
+    loadPosts.run({}, { respectCache: false });
+  }
 };

typings/cf2021.d.ts

 declare namespace CF2021 {
   export interface GlobalInfoStorePayload {
     connectionState: "connected" | "offline" | "connecting";
+    onlineMembers: number;
     onlineUsers: number;
     websocketUrl: string;
+    groupSizeHalf?: number;
     streamUrl?: string;
+    protocolUrl?: string;
+    protocol?: string;
   }
 
   interface ProgramScheduleEntry {
     id: number;
     number: string;
     title: string;
+    fullTitle: string;
     proposer: string;
+    speakers: string;
     discussionOpened: boolean;
     description?: string;
+    htmlContent?: string;
     expectedStartAt: Date;
     expectedFinishAt?: Date;
   }
@@ -151,8 +158,6 @@ declare namespace CF2021 {
     window: {
       items: string[];
       itemCount: number;
-      page: number;
-      perPage: number;
     };
     filters: PostStoreFilters;
   }