aboutsummaryrefslogtreecommitdiff
path: root/FrontEnd/src/app/services/timeline.ts
diff options
context:
space:
mode:
authorcrupest <crupest@outlook.com>2021-06-15 14:14:28 +0800
committercrupest <crupest@outlook.com>2021-06-15 14:14:28 +0800
commit47587812b809fee2a95c76266d9d0e42fc4ac1ca (patch)
treebfaa7320c838e21edf88b5a037263f89a8012222 /FrontEnd/src/app/services/timeline.ts
parentda26373c7fc13cded47428b27638b349b0432437 (diff)
downloadtimeline-47587812b809fee2a95c76266d9d0e42fc4ac1ca.tar.gz
timeline-47587812b809fee2a95c76266d9d0e42fc4ac1ca.tar.bz2
timeline-47587812b809fee2a95c76266d9d0e42fc4ac1ca.zip
...
Diffstat (limited to 'FrontEnd/src/app/services/timeline.ts')
-rw-r--r--FrontEnd/src/app/services/timeline.ts85
1 files changed, 0 insertions, 85 deletions
diff --git a/FrontEnd/src/app/services/timeline.ts b/FrontEnd/src/app/services/timeline.ts
deleted file mode 100644
index d8c0ae00..00000000
--- a/FrontEnd/src/app/services/timeline.ts
+++ /dev/null
@@ -1,85 +0,0 @@
-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());
- }
- };
- });
-}