X-Git-Url: https://git.r.bdr.sh/rbdr/forum/blobdiff_plain/41247723b2940efe89648749b90e56d582bdfb89..e749c95bf63e22ce81f8d0f933d44e0f56c24618:/app/stores/forums.js?ds=inline

diff --git a/app/stores/forums.js b/app/stores/forums.js
index c473124..5c7c6e6 100644
--- a/app/stores/forums.js
+++ b/app/stores/forums.js
@@ -1,86 +1,50 @@
-import { writable } from 'svelte/store';
-
-const internals = {};
-
-internals.forums = [
-  {
-    id: 'life',
-    glyph: '☆',
-    label: 'Life'
-  },
-  {
-    id: 'the-world',
-    glyph: '◯',
-    label: 'The World'
-  },
-  {
-    id: 'online',
-    glyph: '⏀',
-    label: 'Online'
-  },
-  {
-    id: 'experience',
-    glyph: '♢',
-    label: 'Experience'
-  },
-  {
-    id: 'belief',
-    glyph: '⏃',
-    label: 'Belief'
-  },
-  {
-    id: 'movement',
-    glyph: '▷',
-    label: 'Movement'
-  },
-  {
-    id: 'emotion',
-    glyph: '☽',
-    label: 'Emotion'
-  },
-  {
-    id: 'interaction',
-    glyph: '〒',
-    label: 'Interaction'
-  },
-  {
-    id: 'structure',
-    glyph: '▢',
-    label: 'Structure'
-  },
-  {
-    id: 'sound',
-    glyph: '〰',
-    label: 'Sound'
-  },
-  {
-    id: 'words',
-    glyph: '╳',
-    label: 'Words'
-  },
-  {
-    id: 'us',
-    glyph: '╱',
-    label: 'Us'
-  },
-  {
-    id: 'everything',
-    glyph: '♡',
-    label: 'Everything'
-  }
-];
+import { readable } from 'svelte/store';
+import { onMessage } from '../socket_coordinator';
+
+const internals = {
+
+  // Constants
+
+  kChangeFeedEventName: 'changefeed:forums',
+
+  // The exported data structure
+
+  forums: [],
+
+  // Handles messages from the event
+
+  handleChangeFeed(data) {
 
-export const forums = writable(internals.forums);
+    console.log(data);
 
-export const addForum = function addForum() {
+    // No old value == add
+    if (!data.old_val) {
+      console.log('Adding new data');
+      return internals.forums.push(data.new_val);
+    }
+
+    // We have an old value, let's find it.
+    const index = internals.forums.findIndex((element) => element.id === data.old_val.id);
 
-  const id = Math.random();
+    if (index > -1) {
+      console.log(`Found old data at index ${index}`);
 
-  forums.update((originalForums) => ([...originalForums,
-    {
-      id,
-      glyph: 'の',
-      label: `Woah ${id}`
+      if (data.new_val) {
+        return internals.forums.splice(index, 1, data.new_val || undefined);
+      }
+
+      return internals.forums.splice(index, 1);
     }
-  ]));
+  }
 };
+
+export const forums = readable(internals.forums, (set) => {
+
+  onMessage((message) => {
+
+    if (message.name === internals.kChangeFeedEventName) {
+      internals.handleChangeFeed(message.data);
+      set(internals.forums);
+    }
+  });
+});