aboutsummaryrefslogtreecommitdiff
path: root/FrontEnd/src/app/services/timeline.ts
diff options
context:
space:
mode:
authorcrupest <crupest@outlook.com>2021-06-15 18:25:17 +0800
committerGitHub <noreply@github.com>2021-06-15 18:25:17 +0800
commit4645761c2090aeaf8c26789155b342c048f44535 (patch)
tree1aab5ce94549f3f8b3fd1a31c84fb2dd8b6b2511 /FrontEnd/src/app/services/timeline.ts
parent485ef185153890b7c6ac4ed9798a3f2db80c8845 (diff)
parentb6afd5e8161126522bdfff876f5483fa97e94797 (diff)
downloadtimeline-4645761c2090aeaf8c26789155b342c048f44535.tar.gz
timeline-4645761c2090aeaf8c26789155b342c048f44535.tar.bz2
timeline-4645761c2090aeaf8c26789155b342c048f44535.zip
Merge pull request #620 from crupest/vite
Migrate to vite!
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());
- }
- };
- });
-}