blob: afced4c70a5bea4d51a7e28dfbe22ce48b1fb26f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
import { writable } from 'svelte/store';
import { browser } from '$app/environment';
import { Channels, ChannelsMeta } from '$lib/store/channels.svelte.js';
import { Messages } from '$lib/store/messages.svelte.js';
import { Logins } from '$lib/store/logins';
import { STORE_KEY_CHANNELS_DATA } from '$lib/constants';
// Get channelsList content from the local storage
const channelsMetaData = (
browser && JSON.parse(localStorage.getItem(STORE_KEY_CHANNELS_DATA))
) || {};
export const currentUser = writable(null);
export const logins = writable(new Logins());
export const channelsMetaList = writable(new ChannelsMeta({ channelsMetaData }));
export const channelsList = writable(new Channels({ channelsMetaList }));
export const messages = writable(new Messages());
export function onEvent(event) {
switch (event.type) {
case 'login':
onLoginEvent(event);
break;
case 'channel':
onChannelEvent(event);
break;
case 'message':
onMessageEvent(event);
break;
}
}
onEvent.fromJson = (event) => {
const parsed = JSON.parse(event);
return onEvent(parsed);
};
onEvent.fromMessage = (message) => {
const data = message.data;
return onEvent.fromJson(data);
};
function onLoginEvent(event) {
switch (event.event) {
case 'created':
logins.update((value) => value.addLogin(event.id, event.name));
break;
}
}
function onChannelEvent(event) {
switch (event.event) {
case 'created':
channelsList.update((value) => value.addChannel(event.id, event.name));
break;
case 'deleted':
channelsList.update((value) => value.deleteChannel(event.id));
messages.update((value) => value.deleteChannel(event.id));
break;
}
}
function onMessageEvent(event) {
switch (event.event) {
case 'sent':
messages.update((value) =>
value.addMessage(event.channel, event.id, {
at: event.at,
sender: event.sender,
body: event.body
})
);
break;
case 'deleted':
messages.update((value) => value.deleteMessage(event.id));
break;
}
}
|
