-
Notifications
You must be signed in to change notification settings - Fork 29
/
message-selectors.js
61 lines (54 loc) · 2.01 KB
/
message-selectors.js
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
// @flow
import { createSelector } from 'reselect';
import { threadIsPending } from 'lib/shared/thread-utils.js';
import type { ThreadMessageInfo } from 'lib/types/message-types.js';
import { activeThreadSelector } from '../navigation/nav-selectors.js';
import type { AppState } from '../redux/state-types.js';
import type { NavPlusRedux } from '../types/selector-types.js';
const msInHour = 60 * 60 * 1000;
const nextMessagePruneTimeSelector: (state: AppState) => ?number =
createSelector(
(state: AppState) => state.messageStore.threads,
(threadMessageInfos: { +[id: string]: ThreadMessageInfo }): ?number => {
let nextTime;
for (const threadID in threadMessageInfos) {
const threadMessageInfo = threadMessageInfos[threadID];
const threadPruneTime = Math.max(
threadMessageInfo.lastNavigatedTo + msInHour,
threadMessageInfo.lastPruned + msInHour * 6,
);
if (nextTime === undefined || threadPruneTime < nextTime) {
nextTime = threadPruneTime;
}
}
return nextTime;
},
);
const pruneThreadIDsSelector: (
input: NavPlusRedux,
) => () => $ReadOnlyArray<string> = createSelector(
(input: NavPlusRedux) => input.redux.messageStore.threads,
(input: NavPlusRedux) => activeThreadSelector(input.navContext),
(
threadMessageInfos: { +[id: string]: ThreadMessageInfo },
activeThread: ?string,
) =>
(): $ReadOnlyArray<string> => {
const now = Date.now();
const threadIDsToPrune = [];
for (const threadID in threadMessageInfos) {
if (threadID === activeThread || threadIsPending(threadID)) {
continue;
}
const threadMessageInfo = threadMessageInfos[threadID];
if (
threadMessageInfo.lastNavigatedTo + msInHour < now &&
threadMessageInfo.lastPruned + msInHour * 6 < now
) {
threadIDsToPrune.push(threadID);
}
}
return threadIDsToPrune;
},
);
export { nextMessagePruneTimeSelector, pruneThreadIDsSelector };