X-Git-Url: https://git.r.bdr.sh/rbdr/forum/blobdiff_plain/862a5f9cdbbda522c608ea63c1e296e81f44de10..bd8e98d7e24c4dbaee7db6ec7955f7c2f6d396a6:/app/stores/forums.js?ds=sidebyside diff --git a/app/stores/forums.js b/app/stores/forums.js deleted file mode 100644 index e826163..0000000 --- a/app/stores/forums.js +++ /dev/null @@ -1,45 +0,0 @@ -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) { - - // No old value == add - if (!data.old_val) { - 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); - - if (index > -1) { - 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); - } - }); -});