From 408099ac29d406b423faf6140dc0f0ad4b39713f Mon Sep 17 00:00:00 2001
From: wryk <wryk@wryk.moe>
Date: Thu, 9 Jan 2020 02:26:13 +0100
Subject: [PATCH] big store uwu

---
 src/App.svelte           | 48 +++++++++++++--------------
 src/YoutubeViewer.svelte |  7 ++--
 src/main.js              | 11 +------
 src/store.js             | 71 ++++++++++++++++++++++++++++++++++++++++
 src/util.js              | 29 +++-------------
 5 files changed, 102 insertions(+), 64 deletions(-)
 create mode 100644 src/store.js

diff --git a/src/App.svelte b/src/App.svelte
index 782c0bf..304f475 100644
--- a/src/App.svelte
+++ b/src/App.svelte
@@ -15,23 +15,29 @@
     </section>
 
     <section class="queue">
-        {#await entriesPromise}
-            Loading radio please wait
-        {:then entries}
-            <ul>
-                {#each entries as entry}
-                    <li class="entry" class:active={entry === selectedEntry} on:click={selectEntry(entry)}>
-                        <b>{entry.status.account.acct}</b>
-                        <small>{entry.tags}</small>
-                    </li>
-                {/each}
-            </ul>
-        {:catch error}
-            Oops, something went wrong : {error}
-        {/await}
+        {#if $entries}
+            {#await $entries}
+                Loading radio please wait
+            {:then entries}
+                <ul>
+                    {#each entries as entry}
+                        <li class="entry" class:active={entry === selectedEntry} on:click={selectEntry(entry)}>
+                            <b>{entry.status.account.acct}</b>
+                            <small>{entry.tags}</small>
+                        </li>
+                    {/each}
+                </ul>
+            {:catch error}
+                Oops, something went wrong : {error}
+            {/await}
+        {:else}
+            Your queue
+        {/if}
 
         <header>
-            <a href="https://{domain}/">{domain}</a> - {@html hashtags.map(hashtag => `<a href="https://${domain}/tags/${hashtag}">#${hashtag}</a>`)}
+            <a href="https://{$domain}/">{$domain}</a> - {@html $hashtags.map(hashtag => `<a href="https://${$domain}/tags/${hashtag}">#${hashtag}</a>`)}
+
+            <button on:click={() => entries.load()}>LOAD MOAR</button>
         </header>
     </section>
 </main>
@@ -39,13 +45,9 @@
 
 <script>
     import { onMount } from 'svelte'
-    import { fetchEntries } from './util.js'
     import YoutubeViewer from './YoutubeViewer.svelte'
+    import { domain, hashtags, entries } from './store.js'
 
-    export let domain
-    export let hashtags
-
-    let entriesPromise = new Promise(() => {})
     let selectedEntry = null
 
     const selectEntry = entry => {
@@ -53,11 +55,7 @@
     }
 
     onMount(() => {
-        entriesPromise = fetchEntries(domain, hashtags)
-
-        entriesPromise.then(entries => {
-            [selectedEntry] = entries
-        })
+        entries.load()
     })
 </script>
 
diff --git a/src/YoutubeViewer.svelte b/src/YoutubeViewer.svelte
index 25787ab..cb47ddb 100644
--- a/src/YoutubeViewer.svelte
+++ b/src/YoutubeViewer.svelte
@@ -1,5 +1,7 @@
 <div>
     <div bind:this={element}></div>
+
+    <button on:click={player.play()}>PLAY UWU</button>
 </div>
 
 <script>
@@ -12,16 +14,13 @@
     let player
 
     $: if (player && videoId) {
-        console.log(`loada ${videoId}`)
         player.load(videoId, true)
     }
 
     onMount(() => {
         player = new YoutubePlayer(element, {
-            width: 200,
-            height: 200,
             autoplay: true,
-            controls: false, // debug only
+            controls: true, // debug only
             keyboard: false,
             fullscreen: false,
             modestBranding: true,
diff --git a/src/main.js b/src/main.js
index 4249964..f177c8d 100644
--- a/src/main.js
+++ b/src/main.js
@@ -1,16 +1,7 @@
 import App from './App.svelte'
 
 const app = new App({
-    target: document.body,
-    props: {
-        domain: 'eldritch.cafe',
-        hashtags: [
-            'np',
-            'nowplaying',
-            'tootradio',
-            'pouetradio'
-        ]
-    }
+    target: document.body
 })
 
 export default app
\ No newline at end of file
diff --git a/src/store.js b/src/store.js
new file mode 100644
index 0000000..524a26e
--- /dev/null
+++ b/src/store.js
@@ -0,0 +1,71 @@
+import { writable, get } from 'svelte/store'
+import { getUrls, getYoutubeId, isSupportedUrl, intersection } from './util.js'
+
+export const domain = writable('eldritch.cafe')
+
+export const hashtags = writable([
+    'np',
+    'nowplaying',
+    'tootradio',
+    'pouetradio'
+])
+
+export const entries = entriesStore()
+
+function entriesStore() {
+    let loading = false
+    let next = `https://eldritch.cafe/api/v1/timelines/tag/np`
+
+    const store = writable(null)
+    const { set, subscribe } = store
+
+    const load = async () => {
+        if (loading) {
+            return
+        }
+
+        loading = true
+
+        const responseP = fetch(next)
+
+        responseP.then(response => {
+            next = Array.from(getUrls(response.headers.get('link')))[0] // need to better parse that
+        })
+
+        const entriesP = responseP
+            .then(response => response.json())
+            .then(statuses => {
+                return statuses
+                    .map(status => {
+                        const [url] = Array.from(getUrls(status.content)).filter(isSupportedUrl)
+
+                        return { status, url }
+                    })
+                    .filter(entry => entry.url != null)
+                    .map(({ status, url }) => {
+                        const id = getYoutubeId(url)
+                        const tags = intersection(status.tags.map(tag => tag.name), [
+                            'np',
+                            'nowplaying',
+                            'tootradio',
+                            'pouetradio'
+                        ])
+
+                        return { status, url, id, tags }
+                    })
+            })
+
+        const previousEntriesP = get(store)
+
+        if (previousEntriesP) {
+            const [previousEntries, entries] = await Promise.all([previousEntriesP, entriesP])
+            set(Promise.resolve([...previousEntries, ...entries]))
+        } else {
+            set(entriesP)
+        }
+
+        loading = false
+    }
+
+    return { subscribe, load }
+}
\ No newline at end of file
diff --git a/src/util.js b/src/util.js
index 21378a9..4d34d8d 100644
--- a/src/util.js
+++ b/src/util.js
@@ -1,31 +1,10 @@
-import getUrls from 'get-urls'
-import getYoutubeId from 'get-youtube-id'
+export { default as getUrls } from 'get-urls'
+export { default as getYoutubeId } from 'get-youtube-id'
 
-export async function fetchEntries(domain, hashtags) {
-    const response = await fetch(`https://${domain}/api/v1/timelines/tag/${hashtags[0]}`)
-    const statuses = await response.json()
-
-    const entries = statuses
-        .map(status => {
-            const [url] = Array.from(getUrls(status.content)).filter(isSupportedUrl)
-
-            return { status, url }
-        })
-        .filter(entry => entry.url != null)
-        .map(({ status, url }) => {
-            const id = getYoutubeId(url)
-            const tags = intersection(status.tags.map(tag => tag.name), hashtags)
-
-            return { status, url, id, tags }
-        })
-
-    return entries
-}
-
-function isSupportedUrl(url) {
+export function isSupportedUrl(url) {
     return (new URL(url)).hostname === 'youtube.com'
 }
 
-function intersection(xs, ys) {
+export function intersection(xs, ys) {
     return xs.filter(x => ys.includes(x));
 }
\ No newline at end of file