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
|
import { TimelineVisibility } from "@/http/timeline";
import XRegExp from "xregexp";
import { Observable } from "rxjs";
import { HubConnectionBuilder, HubConnectionState } from "@microsoft/signalr";
import { getHttpToken } from "@/http/common";
const timelineNameReg = XRegExp("^[-_\\p{L}]*$", "u");
export function validateTimelineName(name: string): boolean {
return timelineNameReg.test(name);
}
export const timelineVisibilityTooltipTranslationMap: Record<
TimelineVisibility,
string
> = {
Public: "timeline.visibilityTooltip.public",
Register: "timeline.visibilityTooltip.register",
Private: "timeline.visibilityTooltip.private",
};
export function getTimelinePostUpdate$(
timelineName: string
): Observable<{ update: boolean; state: HubConnectionState }> {
return new Observable((subscriber) => {
subscriber.next({
update: false,
state: HubConnectionState.Connecting,
});
const token = getHttpToken();
const connection = new HubConnectionBuilder()
.withUrl("/api/hub/timeline", {
accessTokenFactory: token == null ? undefined : () => token,
})
.withAutomaticReconnect()
.build();
const handler = (tn: string): void => {
if (timelineName === tn) {
subscriber.next({ update: true, state: connection.state });
}
};
connection.onclose(() => {
subscriber.next({
update: false,
state: HubConnectionState.Disconnected,
});
});
connection.onreconnecting(() => {
subscriber.next({
update: false,
state: HubConnectionState.Reconnecting,
});
});
connection.onreconnected(() => {
subscriber.next({
update: false,
state: HubConnectionState.Connected,
});
});
connection.on("OnTimelinePostChanged", handler);
void connection.start().then(() => {
subscriber.next({ update: false, state: HubConnectionState.Connected });
return connection.invoke("SubscribeTimelinePostChange", timelineName);
});
return () => {
connection.off("OnTimelinePostChanged", handler);
if (connection.state === HubConnectionState.Connected) {
void connection
.invoke("UnsubscribeTimelinePostChange", timelineName)
.then(() => connection.stop());
}
};
});
}
|
