From 769e0936635f9998a342ace24652605c2bd23d97 Mon Sep 17 00:00:00 2001
From: Kieran <kieran@harkin.me>
Date: Sun, 18 Jun 2023 14:14:34 +0100
Subject: [PATCH] Live event page

---
 packages/app/src/Element/LiveChat.css        | 11 ++++
 packages/app/src/Element/LiveChat.tsx        | 63 ++++++++++++++++++++
 packages/app/src/Element/LiveEvent.tsx       | 30 +++++++---
 packages/app/src/Element/LiveVideoPlayer.tsx | 10 ++--
 packages/app/src/Element/MediaElement.tsx    |  2 +-
 packages/app/src/Feed/LiveChatFeed.tsx       | 19 ++++++
 packages/app/src/Pages/Layout.tsx            |  7 ++-
 packages/app/src/Pages/LivePage.css          |  8 +++
 packages/app/src/Pages/LivePage.tsx          | 29 +++++++++
 packages/app/src/index.css                   |  2 +-
 packages/app/src/index.tsx                   |  5 ++
 11 files changed, 168 insertions(+), 18 deletions(-)
 create mode 100644 packages/app/src/Element/LiveChat.css
 create mode 100644 packages/app/src/Element/LiveChat.tsx
 create mode 100644 packages/app/src/Feed/LiveChatFeed.tsx
 create mode 100644 packages/app/src/Pages/LivePage.css
 create mode 100644 packages/app/src/Pages/LivePage.tsx

diff --git a/packages/app/src/Element/LiveChat.css b/packages/app/src/Element/LiveChat.css
new file mode 100644
index 0000000..5423adf
--- /dev/null
+++ b/packages/app/src/Element/LiveChat.css
@@ -0,0 +1,11 @@
+.live-chat {
+  height: calc(100vh - 73px);
+  display: flex;
+  flex-direction: column;
+}
+
+.live-chat > div:nth-child(1) {
+  flex-grow: 1;
+  display: flex;
+  flex-direction: column-reverse;
+}
diff --git a/packages/app/src/Element/LiveChat.tsx b/packages/app/src/Element/LiveChat.tsx
new file mode 100644
index 0000000..306dc9c
--- /dev/null
+++ b/packages/app/src/Element/LiveChat.tsx
@@ -0,0 +1,63 @@
+import "./LiveChat.css";
+import { NostrLink, TaggedRawEvent } from "@snort/system";
+import { useUserProfile } from "@snort/system-react";
+import { useState } from "react";
+import Textarea from "./Textarea";
+import { useLiveChatFeed } from "Feed/LiveChatFeed";
+import useEventPublisher from "Feed/EventPublisher";
+import { System } from "index";
+import { getDisplayName } from "Element/ProfileImage";
+
+export function LiveChat({ ev, link }: { ev: TaggedRawEvent; link: NostrLink }) {
+  const [chat, setChat] = useState("");
+  const messages = useLiveChatFeed(link);
+  const pub = useEventPublisher();
+
+  async function sendChatMessage() {
+    const reply = await pub?.note(chat, eb => {
+      return eb.tag(["a", `${link.kind}:${link.author}:${link.id}`]);
+    });
+    if (reply) {
+      console.debug(reply);
+      System.BroadcastEvent(reply);
+    }
+    setChat("");
+  }
+  return (
+    <div className="live-chat">
+      <div>
+        {[...(messages.data ?? [])]
+          .sort((a, b) => b.created_at - a.created_at)
+          .map(a => (
+            <ChatMessage ev={a} key={a.id} />
+          ))}
+      </div>
+      <div>
+        <Textarea
+          autoFocus={false}
+          className=""
+          onChange={v => setChat(v.target.value)}
+          value={chat}
+          onFocus={() => {}}
+          placeholder=""
+          onKeyDown={async e => {
+            if (e.code === "Enter") {
+              await sendChatMessage();
+            }
+          }}
+        />
+      </div>
+    </div>
+  );
+}
+
+function ChatMessage({ ev }: { ev: TaggedRawEvent }) {
+  const profile = useUserProfile(System, ev.pubkey);
+  return (
+    <div>
+      <b>{getDisplayName(profile, ev.pubkey)}</b>
+      :&nbsp;
+      {ev.content}
+    </div>
+  );
+}
diff --git a/packages/app/src/Element/LiveEvent.tsx b/packages/app/src/Element/LiveEvent.tsx
index 576c9a6..5c134e5 100644
--- a/packages/app/src/Element/LiveEvent.tsx
+++ b/packages/app/src/Element/LiveEvent.tsx
@@ -1,11 +1,25 @@
-import { NostrEvent } from "@snort/system";
-import { findTag } from "SnortUtils";
-import { LiveVideoPlayer } from "Element/LiveVideoPlayer";
+import { NostrEvent, NostrPrefix, encodeTLV } from "@snort/system";
+import { findTag, unwrap } from "SnortUtils";
+import { FormattedMessage } from "react-intl";
+import { Link } from "react-router-dom";
 
 export function LiveEvent({ ev }: { ev: NostrEvent }) {
-  const stream = findTag(ev, "streaming");
-  if (stream) {
-    return <LiveVideoPlayer src={stream} />;
-  }
-  return null;
+  const title = findTag(ev, "title");
+  const d = unwrap(findTag(ev, "d"));
+  return (
+    <div className="text">
+      <div className="flex card">
+        <div className="f-grow">
+          <h3>{title}</h3>
+        </div>
+        <div>
+          <Link to={`/live/${encodeTLV(NostrPrefix.Address, d, undefined, ev.kind, ev.pubkey)}`}>
+            <button className="primary" type="button">
+              <FormattedMessage defaultMessage="Watch Live!" />
+            </button>
+          </Link>
+        </div>
+      </div>
+    </div>
+  );
 }
diff --git a/packages/app/src/Element/LiveVideoPlayer.tsx b/packages/app/src/Element/LiveVideoPlayer.tsx
index c7e58bf..19bf767 100644
--- a/packages/app/src/Element/LiveVideoPlayer.tsx
+++ b/packages/app/src/Element/LiveVideoPlayer.tsx
@@ -1,19 +1,19 @@
 import Hls from "hls.js";
 import { HTMLProps, useEffect, useRef } from "react";
 
-export function LiveVideoPlayer(props: HTMLProps<HTMLVideoElement>) {
+export function LiveVideoPlayer(props: HTMLProps<HTMLVideoElement> & { stream: string }) {
   const video = useRef<HTMLVideoElement>(null);
   useEffect(() => {
-    if (props.src && video.current && !video.current.src && Hls.isSupported()) {
+    if (props.stream && video.current && !video.current.src && Hls.isSupported()) {
       const hls = new Hls();
-      hls.loadSource(props.src);
+      hls.loadSource(props.stream);
       hls.attachMedia(video.current);
       return () => hls.destroy();
     }
   }, [video, props]);
   return (
-    <div className="w-max">
-      <video className="w-max" ref={video} controls={true} />
+    <div>
+      <video ref={video} {...props} controls={true} />
     </div>
   );
 }
diff --git a/packages/app/src/Element/MediaElement.tsx b/packages/app/src/Element/MediaElement.tsx
index 2f50b04..73f2300 100644
--- a/packages/app/src/Element/MediaElement.tsx
+++ b/packages/app/src/Element/MediaElement.tsx
@@ -174,7 +174,7 @@ export function MediaElement(props: MediaElementProps) {
     return <audio key={props.url} src={url} controls onError={() => probeFor402()} />;
   } else if (props.mime.startsWith("video/")) {
     if (props.url.endsWith(".m3u8")) {
-      return <LiveVideoPlayer src={props.url} />;
+      return <LiveVideoPlayer stream={props.url} />;
     }
     return <video key={props.url} src={url} controls onError={() => probeFor402()} />;
   } else {
diff --git a/packages/app/src/Feed/LiveChatFeed.tsx b/packages/app/src/Feed/LiveChatFeed.tsx
new file mode 100644
index 0000000..3bb40a8
--- /dev/null
+++ b/packages/app/src/Feed/LiveChatFeed.tsx
@@ -0,0 +1,19 @@
+import { FlatNoteStore, NostrLink, RequestBuilder } from "@snort/system";
+import { useRequestBuilder } from "@snort/system-react";
+import { System } from "index";
+import { useMemo } from "react";
+
+export function useLiveChatFeed(link: NostrLink) {
+  const sub = useMemo(() => {
+    const rb = new RequestBuilder(`live:${link.id}:${link.author}`);
+    rb.withOptions({
+      leaveOpen: true,
+    });
+    rb.withFilter()
+      .tag("a", [`${link.kind}:${link.author}:${link.id}`])
+      .limit(100);
+    return rb;
+  }, [link]);
+
+  return useRequestBuilder<FlatNoteStore>(System, FlatNoteStore, sub);
+}
diff --git a/packages/app/src/Pages/Layout.tsx b/packages/app/src/Pages/Layout.tsx
index 7f267a2..82e59d4 100644
--- a/packages/app/src/Pages/Layout.tsx
+++ b/packages/app/src/Pages/Layout.tsx
@@ -43,7 +43,7 @@ export default function Layout() {
   };
 
   const shouldHideNoteCreator = useMemo(() => {
-    const hideOn = ["/settings", "/messages", "/new", "/login", "/donate", "/p/", "/e", "/subscribe"];
+    const hideOn = ["/settings", "/messages", "/new", "/login", "/donate", "/p/", "/e", "/subscribe", "/live"];
     return isReplyNoteCreatorShowing || hideOn.some(a => location.pathname.startsWith(a));
   }, [location, isReplyNoteCreatorShowing]);
 
@@ -53,9 +53,10 @@ export default function Layout() {
   }, [location]);
 
   useEffect(() => {
-    const widePage = ["/login", "/messages"];
+    const widePage = ["/login", "/messages", "/live"];
+    const noScroll = ["/messages", "/live"];
     if (widePage.some(a => location.pathname.startsWith(a))) {
-      setPageClass("");
+      setPageClass(noScroll.some(a => location.pathname.startsWith(a)) ? "scroll-lock" : "");
     } else {
       setPageClass("page");
     }
diff --git a/packages/app/src/Pages/LivePage.css b/packages/app/src/Pages/LivePage.css
new file mode 100644
index 0000000..3b98989
--- /dev/null
+++ b/packages/app/src/Pages/LivePage.css
@@ -0,0 +1,8 @@
+.live-page {
+  display: grid;
+  grid-template-columns: auto 250px;
+}
+
+.live-page video {
+  width: 100%;
+}
diff --git a/packages/app/src/Pages/LivePage.tsx b/packages/app/src/Pages/LivePage.tsx
new file mode 100644
index 0000000..0b94c9b
--- /dev/null
+++ b/packages/app/src/Pages/LivePage.tsx
@@ -0,0 +1,29 @@
+import "./LivePage.css";
+import { parseNostrLink } from "@snort/system";
+import { useParams } from "react-router-dom";
+
+import { LiveVideoPlayer } from "Element/LiveVideoPlayer";
+import { findTag, unwrap } from "SnortUtils";
+import PageSpinner from "Element/PageSpinner";
+import { LiveChat } from "Element/LiveChat";
+import useEventFeed from "Feed/EventFeed";
+
+export function LivePage() {
+  const params = useParams();
+  const link = parseNostrLink(unwrap(params.id));
+  const thisEvent = useEventFeed(link);
+
+  if (!thisEvent.data) {
+    return <PageSpinner />;
+  }
+
+  return (
+    <div className="live-page main-content">
+      <div>
+        <h3>{findTag(thisEvent.data, "title")}</h3>
+        <LiveVideoPlayer stream={unwrap(findTag(thisEvent.data, "streaming"))} autoPlay={true} />
+      </div>
+      <LiveChat ev={thisEvent.data} link={link} />
+    </div>
+  );
+}
diff --git a/packages/app/src/index.css b/packages/app/src/index.css
index 6d6c7fb..3b67e18 100644
--- a/packages/app/src/index.css
+++ b/packages/app/src/index.css
@@ -445,7 +445,7 @@ div.form-col {
   grid-template-columns: auto;
 }
 
-body.scroll-lock {
+.scroll-lock {
   overflow: hidden;
   height: 100vh;
 }
diff --git a/packages/app/src/index.tsx b/packages/app/src/index.tsx
index 9ffc3fc..348ad87 100644
--- a/packages/app/src/index.tsx
+++ b/packages/app/src/index.tsx
@@ -36,6 +36,7 @@ import DebugPage from "Pages/Debug";
 import { db } from "Db";
 import { preload, RelayMetrics, UserCache, UserRelays } from "Cache";
 import { LoginStore } from "Login";
+import { LivePage } from "Pages/LivePage";
 
 /**
  * Singleton nostr system
@@ -145,6 +146,10 @@ export const router = createBrowserRouter([
         path: "/zap-pool",
         element: <ZapPoolPage />,
       },
+      {
+        path: "/live/:id",
+        element: <LivePage />,
+      },
       ...NewUserRoutes,
       ...WalletRoutes,
       ...SubscribeRoutes,