blob: b19dcbe9cee3aae81cd9a7007dc92fff800a7a24 (
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
|
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<string> {
return new Observable((subscriber) => {
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(tn);
}
};
connection.on("OnTimelinePostChanged", handler);
void connection
.start()
.then(() =>
connection.invoke("SubscribeTimelinePostChange", timelineName)
);
return () => {
connection.off("OnTimelinePostChanged", handler);
if (connection.state === HubConnectionState.Connected) {
void connection
.invoke("UnsubscribeTimelinePostChange", timelineName)
.then(() => connection.stop());
}
};
});
}
|
