/
emitters.ts
96 lines (90 loc) · 2.68 KB
/
emitters.ts
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
import { Source } from 'react-declarative';
import { CC_SECONDS_TO_VERIFY } from '../../config/params';
import recorder from './recorder';
export const messageEmitter = Source.multicast(() =>
Source.create<{
type: "facewasm-msg";
text: string;
color: string;
}>((next) => {
const handler = (e: any) => {
if (e.origin === origin) {
const { data } = e;
const { type } = data;
if (data.type === 'facewasm-msg') {
const { text, color } = data;
next({
type,
text,
color,
});
}
}
};
window.addEventListener("message", handler);
return () => window.removeEventListener("message", handler);
})
);
export const cordEmitter = Source.multicast(() =>
Source.create<{
type: "facewasm-cord";
x: number;
y: number;
w: number;
h: number;
}>((next) => {
const handler = (e: any) => {
if (e.origin === origin) {
const { data } = e;
const { type } = data;
if (data.type === 'facewasm-cord') {
const { x, y, w, h } = data;
next({ type, x, y, w, h });
}
}
};
window.addEventListener("message", handler);
return () => window.removeEventListener("message", handler);
})
);
export const stateEmitter = Source.multicast(() =>
Source.create<{
type: "facewasm-state";
state: boolean;
}>((next) => {
const handler = (e: any) => {
if (e.origin === origin) {
const { data } = e;
const { type } = data;
if (data.type === 'facewasm-state') {
const { state } = data;
next({ type, state });
}
}
};
window.addEventListener("message", handler);
return () => window.removeEventListener("message", handler);
})
);
export const verifyCompleteEmitter = Source.multicast(() =>
Source
.join([
stateEmitter,
Source.fromInterval(1_000),
])
.reduce((acm, [{ state: isValid }]) => {
if (isValid) {
return acm + 1;
}
return 0;
}, 0)
.tap((ticker) => {
if (ticker === 1) {
recorder.beginRecord();
}
})
.filter((ticker) => ticker === CC_SECONDS_TO_VERIFY)
.tap(() => {
recorder.endRecord();
})
);