From ca556d16ae0eb4ba69ce4137d45a27b17a3497eb Mon Sep 17 00:00:00 2001
From: DanConwayDev <DanConwayDev@protonmail.com>
Date: Fri, 1 Mar 2024 10:26:45 +0000
Subject: [PATCH] fix: stop fetching recent repos on homepage load

fetch them on first load of homepage and listen for new repo events
---
 src/lib/stores/repos.ts             | 76 +++++++++++++++++++++++++
 src/lib/wrappers/ReposRecent.svelte | 87 +++--------------------------
 2 files changed, 85 insertions(+), 78 deletions(-)

diff --git a/src/lib/stores/repos.ts b/src/lib/stores/repos.ts
index 011c385..a67e620 100644
--- a/src/lib/stores/repos.ts
+++ b/src/lib/stores/repos.ts
@@ -333,3 +333,79 @@ const addEventsWithMatchingIdentifiers = (exisiting_events: RepoEvent[]) => {
       )
     })
 }
+
+export const recent_repo_summaries: Writable<RepoSummary[]> = writable([])
+
+export const recent_repo_summaries_loading = writable(false)
+
+let began_fetching_repo_events = false
+
+export const ensureRecentReposEvents = () => {
+  if (began_fetching_repo_events) return
+  began_fetching_repo_events = true
+  recent_repo_summaries_loading.set(true)
+  const sub = ndk.subscribe(
+    {
+      kinds: [repo_kind],
+      limit: 100,
+    },
+    {
+      closeOnEose: false,
+    }
+  )
+  const events: RepoEvent[] = []
+  sub.on('event', (event: NDKEvent) => {
+    const repo_event = eventToRepoEvent(event)
+    if (repo_event) events.push(repo_event)
+  })
+  sub.on('eose', () => {
+    const unique_commits = [
+      ...new Set(events.map((e) => e.unique_commit).filter((s) => !!s)),
+    ] as string[]
+    const identifers_not_linked_to_unique_commit = [
+      ...new Set(events.map((e) => e.identifier)),
+    ].filter(
+      (identifier) =>
+        !events.some((e) => e.identifier == identifier && e.unique_commit)
+    )
+    unique_commits
+      .concat(identifers_not_linked_to_unique_commit)
+      .forEach((c) => {
+        ensureRepoCollection(c).subscribe((repo_collection) => {
+          const summary = repoCollectionToSummary(repo_collection)
+          if (!summary) return
+          recent_repo_summaries.update((repos) => {
+            // if duplicate
+            if (
+              repos.some(
+                (repo) =>
+                  (repo.unique_commit &&
+                    repo.unique_commit === repo_collection.unique_commit) ||
+                  (!repo.unique_commit &&
+                    repo.identifier === repo_collection.identifier)
+              )
+            ) {
+              return [
+                // update summary
+                ...repos.map((repo) => {
+                  if (
+                    summary &&
+                    ((repo.unique_commit &&
+                      repo.unique_commit === repo_collection.unique_commit) ||
+                      (!repo.unique_commit &&
+                        repo.identifier === repo_collection.identifier))
+                  )
+                    return summary
+                  return { ...repo }
+                }),
+              ]
+            }
+            // if not duplicate - add summary
+            else if (summary) return [...repos, summary]
+            return [...repos]
+          })
+        })
+      })
+    recent_repo_summaries_loading.set(false)
+  })
+}
diff --git a/src/lib/wrappers/ReposRecent.svelte b/src/lib/wrappers/ReposRecent.svelte
index aab5f09..12b854e 100644
--- a/src/lib/wrappers/ReposRecent.svelte
+++ b/src/lib/wrappers/ReposRecent.svelte
@@ -1,85 +1,16 @@
 <script lang="ts">
   import ReposSummaryList from '$lib/components/ReposSummaryList.svelte'
-  import type { RepoEvent, RepoSummary } from '$lib/components/repo/type'
-  import { repo_kind } from '$lib/kinds'
-  import { ndk } from '$lib/stores/ndk'
   import {
-    ensureRepoCollection,
-    eventToRepoEvent,
-    repoCollectionToSummary,
+    ensureRecentReposEvents,
+    recent_repo_summaries,
+    recent_repo_summaries_loading,
   } from '$lib/stores/repos'
-  import type { NDKEvent } from '@nostr-dev-kit/ndk'
-  import { onDestroy } from 'svelte'
-  import { writable, type Writable } from 'svelte/store'
 
-  export let limit: number = 100
-
-  let repos: Writable<RepoSummary[]> = writable([])
-
-  let loading: boolean = true
-  let sub = ndk.subscribe({
-    kinds: [repo_kind],
-    limit,
-  })
-  let events: RepoEvent[] = []
-  sub.on('event', (event: NDKEvent) => {
-    let repo_event = eventToRepoEvent(event)
-    if (repo_event) events.push(repo_event)
-  })
-  sub.on('eose', () => {
-    let unique_commits = [
-      ...new Set(events.map((e) => e.unique_commit).filter((s) => !!s)),
-    ] as string[]
-    let identifers_not_linked_to_unique_commit = [
-      ...new Set(events.map((e) => e.identifier)),
-    ].filter(
-      (identifier) =>
-        !events.some((e) => e.identifier == identifier && e.unique_commit)
-    )
-    unique_commits
-      .concat(identifers_not_linked_to_unique_commit)
-      .forEach((c) => {
-        ensureRepoCollection(c).subscribe((repo_collection) => {
-          let summary = repoCollectionToSummary(repo_collection)
-          if (!summary) return
-          repos.update((repos) => {
-            // if duplicate
-            if (
-              repos.some(
-                (repo) =>
-                  (repo.unique_commit &&
-                    repo.unique_commit === repo_collection.unique_commit) ||
-                  (!repo.unique_commit &&
-                    repo.identifier === repo_collection.identifier)
-              )
-            ) {
-              return [
-                // update summary
-                ...repos.map((repo) => {
-                  if (
-                    summary &&
-                    ((repo.unique_commit &&
-                      repo.unique_commit === repo_collection.unique_commit) ||
-                      (!repo.unique_commit &&
-                        repo.identifier === repo_collection.identifier))
-                  )
-                    return summary
-                  return { ...repo }
-                }),
-              ]
-            }
-            // if not duplicate - add summary
-            else if (summary) return [...repos, summary]
-            return [...repos]
-          })
-        })
-      })
-    if (loading == true) loading = false
-  })
-
-  onDestroy(() => {
-    sub.stop()
-  })
+  ensureRecentReposEvents()
 </script>
 
-<ReposSummaryList title="Latest Repositories" repos={$repos} {loading} />
+<ReposSummaryList
+  title="Latest Repositories"
+  repos={$recent_repo_summaries}
+  loading={$recent_repo_summaries_loading}
+/>