import { TimelineVisibility } from "@/http/timeline";
import XRegExp from "xregexp";
import { Observable } from "rxjs";
import { HubConnectionBuilder } 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);

      void connection
        .invoke("UnsubscribeTimelinePostChange", timelineName)
        .then(() => connection.stop());
    };
  });
}