From 1a401ff20f548693d7e4b2e587b6f4905b800bee Mon Sep 17 00:00:00 2001
From: Jonathan Staab <shtaab@gmail.com>
Date: Tue, 4 Apr 2023 15:53:31 -0500
Subject: [PATCH] re-work note detail to keep listening for new data

---
 src/views/notes/Note.svelte       |  6 +--
 src/views/notes/NoteDetail.svelte | 70 +++++++++++++++++++------------
 2 files changed, 46 insertions(+), 30 deletions(-)

diff --git a/src/views/notes/Note.svelte b/src/views/notes/Note.svelte
index 16a64da7..c0dee664 100644
--- a/src/views/notes/Note.svelte
+++ b/src/views/notes/Note.svelte
@@ -544,11 +544,11 @@
     </div>
   {/if}
 
-  {#if visibleNotes.length > 0 && !showEntire && depth > 0 && !muted}
+  {#if !reply && visibleNotes.length > 0 && !showEntire && depth > 0 && !muted}
     <div class="relative -mt-4">
       <div
-        class="absolute top-0 right-0 z-10 -mt-4 -mr-2 flex h-6 w-6 cursor-pointer
-                 items-center justify-center rounded-full border border-solid border-gray-7 bg-gray-8"
+        class="absolute top-0 right-0 z-10 -mt-4 -mr-2 flex h-6 w-6 cursor-pointer items-center
+                 justify-center rounded-full border border-solid border-gray-7 bg-gray-8 text-gray-3"
         on:click={() => {
           collapsed = !collapsed
         }}>
diff --git a/src/views/notes/NoteDetail.svelte b/src/views/notes/NoteDetail.svelte
index 02a5c79f..0f0c5cda 100644
--- a/src/views/notes/NoteDetail.svelte
+++ b/src/views/notes/NoteDetail.svelte
@@ -1,14 +1,12 @@
 <script>
   import {onMount} from "svelte"
-  import {nip19} from "nostr-tools"
+  import {pluck, propEq} from "ramda"
   import {fly} from "svelte/transition"
   import {first} from "hurdak/lib/hurdak"
-  import {log} from "src/util/logger"
   import {asDisplayEvent} from "src/util/nostr"
   import Content from "src/partials/Content.svelte"
   import Spinner from "src/partials/Spinner.svelte"
   import Note from "src/views/notes/Note.svelte"
-  import user from "src/agent/user"
   import network from "src/agent/network"
   import {sampleRelays} from "src/agent/relays"
 
@@ -18,34 +16,52 @@
 
   let found = false
   let loading = true
+  let seen = new Set()
 
-  onMount(async () => {
-    if (note.pubkey) {
-      found = true
-    } else {
-      await network.load({
-        relays: sampleRelays(relays),
-        filter: {kinds: [1], ids: [note.id]},
-        onChunk: events => {
-          found = true
-          note = first(events)
-        },
-      })
-    }
+  onMount(() => {
+    const sub = network.listen({
+      relays: sampleRelays(relays),
+      filter: [
+        {kinds: [1], ids: [note.id]},
+        {kinds: [1, 7, 9735], "#e": [note.id]},
+      ],
+      onChunk: chunk => {
+        const children = chunk.filter(propEq("kind", 1))
 
-    if (note) {
-      log("NoteDetail", nip19.noteEncode(note.id), note)
+        // Recursively bring in context for children, since reactions etc don't
+        // contain the full chain of ancestors
+        network.streamContext({
+          depth: 5,
+          notes: children.filter(e => !seen.has(e.id)),
+          onChunk: childChunk => {
+            note = first(network.applyContext([note], childChunk))
+          },
+        })
 
-      network.streamContext({
-        depth: 6,
-        notes: [note],
-        onChunk: context => {
-          note = first(network.applyContext([note], user.applyMutes(context)))
-        },
-      })
-    }
+        // Keep track of the children we've seen, update latest version of our note
+        children.forEach(event => {
+          if (event.id === note.id) {
+            found = true
+            loading = false
+            note = {...note, ...event}
+          }
 
-    loading = false
+          seen.add(event.id)
+        })
+
+        // Load authors
+        network.loadPeople(pluck("pubkey", children))
+
+        // Apply context
+        note = first(network.applyContext([note], chunk))
+      },
+    })
+
+    setTimeout(() => {
+      loading = false
+    }, 3000)
+
+    return () => sub.then(s => s.unsub())
   })
 </script>