src/pages/Protocol.jsx

+import React, { useCallback, useState } from "react";
+import { Helmet } from "react-helmet-async";
+import useInterval from "@rooks/use-interval";
+
+import { loadProtocol } from "actions/global-info";
+import Button from "components/Button";
+import ErrorMessage from "components/ErrorMessage";
+import { useActionState } from "hooks";
+import { GlobalInfoStore } from "stores";
+
+const Protocol = () => {
+  const { protocolUrl, protocol } = GlobalInfoStore.useState();
+  const [protocolLoading, protocolLoadError] = useActionState(loadProtocol);
+  const [progressPercent, setProgressPercent] = useState(0);
+  const [paused, setPaused] = useState(false);
+
+  const forceLoad = useCallback(async () => {
+    try {
+      setPaused(true);
+      setProgressPercent(1);
+      await loadProtocol.run();
+    } finally {
+      setPaused(false);
+    }
+  }, [setPaused, setProgressPercent]);
+
+  const tick = useCallback(async () => {
+    if (paused) {
+      return;
+    }
+
+    if (progressPercent % 100 === 0) {
+      forceLoad();
+    } else {
+      setProgressPercent(progressPercent + 1);
+    }
+  }, [forceLoad, paused, progressPercent, setProgressPercent]);
+
+  useInterval(tick, 100, true);
+
+  const htmlContent = protocol
+    ? {
+        __html: protocol,
+      }
+    : null;
+
+  const progressStyle = {
+    position: "absolute",
+    width: `${progressPercent}%`,
+    height: "100%",
+    left: "0",
+    background:
+      "linear-gradient(142deg, rgba(2,0,36,1) 0%, rgba(51,51,51,1) 0%, rgba(255,255,255,1) 100%)",
+    opacity: "0.4",
+  };
+
+  return (
+    <>
+      <Helmet>
+        <title>Zápis ze zasedání | CF 2024 | Pirátská strana</title>
+        <meta
+          name="description"
+          content="Interaktivní zápis z on-line zasedání Celostátního fóra České pirátské strany, 13. 1. 2024."
+        />
+        <meta
+          property="og:title"
+          content="Zápis ze zasedání | CF 2024 | Pirátská strana"
+        />
+        <meta
+          property="og:description"
+          content="Interaktivní zápis z on-line zasedání Celostátního fóra České pirátské strany, 13. 1. 2024."
+        />
+      </Helmet>
+      <article className="container container--default py-8 lg:py-24">
+        <h1 className="head-alt-md lg:head-alt-lg mb-8">Zápis z jednání</h1>
+
+        <div className="flex items-start">
+          <div className="lg:w-2/3">
+            {!protocolUrl && (
+              <ErrorMessage>Zápis momentálně není k dispozici.</ErrorMessage>
+            )}
+            {protocolLoadError && (
+              <ErrorMessage>
+                Při stahování záznamu z jednání došlo k problému:{" "}
+                {protocolLoadError.toString()}
+              </ErrorMessage>
+            )}
+            {protocolUrl && <></>}
+            {htmlContent && (
+              <div
+                className="leading-tight text-sm lg:text-base content-block"
+                dangerouslySetInnerHTML={htmlContent}
+              ></div>
+            )}
+          </div>
+          <div className="hidden lg:block card elevation-10 w-1/3">
+            <div className="lg:card__body content-block">
+              <h2>Jak to funguje?</h2>
+              <p>
+                Zápis se aktualizuje automaticky každých 10 sekund. Pokud chceš
+                aktualizaci vynutit ručně, můžeš využít tlačítko níže.
+              </p>
+              <Button
+                icon="ico--refresh"
+                loading={protocolLoading}
+                className="btn--fullwidth"
+                onClick={forceLoad}
+                color="black"
+                bodyProps={{
+                  style: {
+                    position: "relative",
+                  },
+                }}
+              >
+                <span style={progressStyle}></span>
+                <span style={{ position: "relative" }}>
+                  {protocolLoading ? "Aktualizace..." : "Aktualizovat"}
+                </span>
+              </Button>
+            </div>
+          </div>
+        </div>
+      </article>
+    </>
+  );
+};
+
+export default Protocol;

src/serviceWorker.js

@@ -16,8 +16,8 @@ const isLocalhost = Boolean(
     window.location.hostname === "[::1]" ||
     // 127.0.0.0/8 are considered localhost for IPv4.
     window.location.hostname.match(
-      /^127(?:\.(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)){3}$/
-    )
+      /^127(?:\.(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)){3}$/,
+    ),
 );
 
 export function register(config) {
@@ -43,7 +43,7 @@ export function register(config) {
         navigator.serviceWorker.ready.then(() => {
           console.log(
             "This web app is being served cache-first by a service " +
-              "worker. To learn more, visit https://bit.ly/CRA-PWA"
+              "worker. To learn more, visit https://bit.ly/CRA-PWA",
           );
         });
       } else {
@@ -71,7 +71,7 @@ function registerValidSW(swUrl, config) {
               // content until all client tabs are closed.
               console.log(
                 "New content is available and will be used when all " +
-                  "tabs for this page are closed. See https://bit.ly/CRA-PWA."
+                  "tabs for this page are closed. See https://bit.ly/CRA-PWA.",
               );
 
               // Execute callback
@@ -123,7 +123,7 @@ function checkValidServiceWorker(swUrl, config) {
     })
     .catch(() => {
       console.log(
-        "No internet connection found. App is running in offline mode."
+        "No internet connection found. App is running in offline mode.",
       );
     });
 }

src/stores.js

@@ -6,8 +6,11 @@ const globalInfoStoreInitial = {
   connectionState: "connecting",
   onlineMembers: 0,
   onlineUsers: 0,
+  groupSizeHalf: null,
   websocketUrl: null,
   streamUrl: null,
+  protocolUrl: null,
+  protocol: null,
 };
 
 export const GlobalInfoStore = new Store(globalInfoStoreInitial);
@@ -45,12 +48,10 @@ const postStoreInitial = {
   window: {
     items: [],
     itemCount: 0,
-    page: 1,
-    perPage: 20,
   },
   filters: {
-    flags: "all",
-    sort: "byDate",
+    flags: "active",
+    sort: "byScore",
     type: "all",
     showPendingProposals: false,
   },
@@ -62,7 +63,7 @@ export const getGroupByCode = memoize(
   (groupMappings, groupCode) => {
     return groupMappings.find((gm) => gm.code === groupCode);
   },
-  (groupMappings, groupCode) => [groupMappings, groupCode]
+  (groupMappings, groupCode) => [groupMappings, groupCode],
 );
 
 export const getGroupsByCode = memoize((groupMappings, groupCodes) => {

src/utils.js

@@ -7,7 +7,8 @@ import WaitQueue from "wait-queue";
 
 import { markdownConverter } from "markdown";
 
-export const urlRegex = /^(?:(?:(?:https?|ftp):)?\/\/)(?:\S+(?::\S*)?@)?(?:(?!(?:10|127)(?:\.\d{1,3}){3})(?!(?:169\.254|192\.168)(?:\.\d{1,3}){2})(?!172\.(?:1[6-9]|2\d|3[0-1])(?:\.\d{1,3}){2})(?:[1-9]\d?|1\d\d|2[01]\d|22[0-3])(?:\.(?:1?\d{1,2}|2[0-4]\d|25[0-5])){2}(?:\.(?:[1-9]\d?|1\d\d|2[0-4]\d|25[0-4]))|(?:(?:[a-z0-9\u00a1-\uffff][a-z0-9\u00a1-\uffff_-]{0,62})?[a-z0-9\u00a1-\uffff]\.)+(?:[a-z\u00a1-\uffff]{2,}\.?))(?::\d{2,5})?(?:[/?#]\S*)?$/i;
+export const urlRegex =
+  /^(?:(?:(?:https?|ftp):)?\/\/)(?:\S+(?::\S*)?@)?(?:(?!(?:10|127)(?:\.\d{1,3}){3})(?!(?:169\.254|192\.168)(?:\.\d{1,3}){2})(?!172\.(?:1[6-9]|2\d|3[0-1])(?:\.\d{1,3}){2})(?:[1-9]\d?|1\d\d|2[01]\d|22[0-3])(?:\.(?:1?\d{1,2}|2[0-4]\d|25[0-5])){2}(?:\.(?:[1-9]\d?|1\d\d|2[0-4]\d|25[0-4]))|(?:(?:[a-z0-9\u00a1-\uffff][a-z0-9\u00a1-\uffff_-]{0,62})?[a-z0-9\u00a1-\uffff]\.)+(?:[a-z\u00a1-\uffff]{2,}\.?))(?::\d{2,5})?(?:[/?#]\S*)?$/i;
 export const seenPostsLSKey = "cf2021_seen_posts";
 export const seenAnnouncementsLSKey = "cf2021_seen_announcements";
 
@@ -38,7 +39,7 @@ export const filterPosts = (filters, allItems) => {
 
   if (!filters.showPendingProposals) {
     filteredItems = filteredItems.filter(
-      (item) => item.type === "post" || item.state !== "pending"
+      (item) => item.type === "post" || item.state !== "pending",
     );
   }
 
@@ -55,7 +56,7 @@ export const filterPosts = (filters, allItems) => {
  */
 export const updateWindowPosts = (state) => {
   state.window.items = filterPosts(state.filters, values(state.items)).map(
-    property("id")
+    property("id"),
   );
 };
 
@@ -168,7 +169,7 @@ export const parseRawAnnouncement = (rawAnnouncement) => {
     datetime: parse(
       rawAnnouncement.datetime,
       "yyyy-MM-dd HH:mm:ss",
-      new Date()
+      new Date(),
     ),
     type: announcementTypeMapping[rawAnnouncement.type],
     seen: isSeen(seenAnnouncementsLSKey, rawAnnouncement.id),
@@ -183,7 +184,7 @@ export const createSeenWriter = (localStorageKey) => {
   const seenWriterWorker = async () => {
     const id = await queue.shift();
     const seen = new Set(
-      (localStorage.getItem(localStorageKey) || "").split(",")
+      (localStorage.getItem(localStorageKey) || "").split(","),
     );
 
     seen.add(id);

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;
   }