adminFront/src/api/tickets.ts

import makeRequest from "@root/kitUI/makeRequest";
import {
  GetMessagesRequest,
  GetMessagesResponse,
  GetTicketsRequest,
  GetTicketsResponse,
  SendTicketMessageRequest,
} from "@root/model/ticket";
import { authStore } from "@root/stores/auth";
import ReconnectingEventSource from "reconnecting-eventsource";

// const { makeRequest } = authStore();

const supportApiUrl = "https://admin.pena.digital/heruvym";

export function subscribeToAllTickets({
  onMessage,
  onError,
  accessToken,
}: {
  accessToken: string;
  onMessage: (e: MessageEvent) => void;
  onError: (e: Event) => void;
}) {
  const url = `${supportApiUrl}/subscribe?Authorization=${accessToken}`;

  const eventSource = createEventSource(onMessage, onError, url);

  return () => {
    eventSource.close();
  };
}

export function subscribeToTicketMessages({
  onMessage,
  onError,
  accessToken,
  ticketId,
}: {
  accessToken: string;
  ticketId: string;
  onMessage: (e: MessageEvent) => void;
  onError: (e: Event) => void;
}) {
  const url = `${supportApiUrl}/ticket?ticket=${ticketId}&Authorization=${accessToken}`;

  const eventSource = createEventSource(onMessage, onError, url);

  return () => {
    eventSource.close();
  };
}

export async function getTickets({
  body,
  signal,
}: {
  body: GetTicketsRequest;
  signal: AbortSignal;
}): Promise<GetTicketsResponse> {
  return makeRequest({
    url: `${supportApiUrl}/getTickets`,
    method: "POST",
    useToken: true,
    body,
    signal,
  }).then((response) => {
    const result = (response as any).data as GetTicketsResponse;
    return result;
  });
}

export async function getTicketMessages({
  body,
  signal,
}: {
  body: GetMessagesRequest;
  signal: AbortSignal;
}): Promise<GetMessagesResponse> {
  return makeRequest({
    url: `${supportApiUrl}/getMessages`,
    method: "POST",
    useToken: true,
    body,
    signal,
  }).then((response) => {
    const result = (response as any).data as GetMessagesResponse;
    return result;
  });
}

export async function sendTicketMessage({ body }: { body: SendTicketMessageRequest }) {
  return makeRequest({
    url: `${supportApiUrl}/send`,
    method: "POST",
    useToken: true,
    body,
  });
}

function createEventSource(onMessage: (e: MessageEvent) => void, onError: (e: Event) => void, url: string) {
  const eventSource = new ReconnectingEventSource(url);

  eventSource.addEventListener("open", () => console.log(`EventSource connected with ${url}`));
  eventSource.addEventListener("close", () => console.log(`EventSource closed with ${url}`));
  eventSource.addEventListener("message", onMessage);
  eventSource.addEventListener("error", onError);

  return eventSource;
}