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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
import _ from 'lodash'
import * as websocketActions from '../websocket'
export const SET = 'LIST_SET'
export const CLEAR = 'LIST_CLEAR'
export const UNKNOWN_CMD = 'LIST_UNKNOWN_CMD'
export const REQUEST = 'LIST_REQUEST'
export const RECEIVE = 'LIST_RECEIVE'
const defaultState = {
data: {},
pendingActions: null,
}
export default function reduce(state = defaultState, action) {
if (state.pendingActions && action.type !== RECEIVE) {
return {
...state,
pendingActions: [...state.pendingActions, action]
}
}
switch (action.type) {
case SET:
return {
...state,
data: { ...state.data, [action.id]: null, [action.item.id]: action.item }
}
case CLEAR:
return {
...state,
data: { ...state.data, [action.id]: null }
}
case REQUEST:
return {
...state,
pendingActions: []
}
case RECEIVE:
return state.pendingActions.reduce(reduce, {
...state,
pendingActions: null,
data: _.fromPairs(action.list.map(item => [item.id, item])),
})
default:
return state
}
}
/**
* @public
*/
export function add(item) {
return { type: SET, id: item.id, item }
}
/**
* @public
*/
export function update(id, item) {
return { type: SET, id, item }
}
/**
* @public
*/
export function remove(id) {
return { type: CLEAR, id }
}
/**
* @public
*/
export function request() {
return { type: REQUEST }
}
/**
* @public
*/
export function receive(list) {
return { type: RECEIVE, list }
}
/**
* @public websocket
*/
export function handleWsMsg(msg) {
switch (msg.cmd) {
case websocketActions.CMD_ADD:
return add(msg.data)
case websocketActions.CMD_UPDATE:
return update(msg.data.id, msg.data)
case websocketActions.CMD_REMOVE:
return remove(msg.data.id)
default:
return { type: UNKNOWN_CMD, msg }
}
}
|
