]> git.r.bdr.sh - rbdr/forum/blame_incremental - app/stores/forums.js
Connect forum store to changefeed
[rbdr/forum] / app / stores / forums.js
... / ...
CommitLineData
1import { readable } from 'svelte/store';
2import { onMessage } from '../socket_coordinator';
3
4const internals = {
5
6 // Constants
7
8 kChangeFeedEventName: 'changefeed:forums',
9
10 // The exported data structure
11
12 forums: [],
13
14 // Handles messages from the event
15
16 handleChangeFeed(data) {
17
18 console.log(data);
19
20 // No old value == add
21 if (!data.old_val) {
22 console.log('Adding new data');
23 return internals.forums.push(data.new_val);
24 }
25
26 // We have an old value, let's find it.
27 const index = internals.forums.findIndex((element) => element.id === data.old_val.id);
28
29 if (index > -1) {
30 console.log(`Found old data at index ${index}`);
31
32 if (data.new_val) {
33 return internals.forums.splice(index, 1, data.new_val || undefined);
34 }
35
36 return internals.forums.splice(index, 1);
37 }
38 }
39};
40
41export const forums = readable(internals.forums, (set) => {
42
43 onMessage((message) => {
44
45 if (message.name === internals.kChangeFeedEventName) {
46 internals.handleChangeFeed(message.data);
47 set(internals.forums);
48 }
49 });
50});