link-stack/apps/link/app/_lib/utils.ts

import { createLogger } from "@link-stack/logger";

const logger = createLogger('link-utils');

export const fetchLeafcutter = async (url: string, options: any) => {
  /*

    const headers = {
      'X-Opensearch-Username': process.env.OPENSEARCH_USER!,
      'X-Opensearch-Password': process.env.OPENSEARCH_PASSWORD!,
      'X-Leafcutter-User': token.email.toLowerCase()
    };
    */
  const fetchData = async (url: string, options: any) => {
    try {
      const res = await fetch(url, options);
      const json = await res.json();
      return json;
    } catch (error) {
      logger.error({ error }, "Error occurred");
      return null;
    }
  };

  const data = await fetchData(url, options);

  if (!data) {
    const csrfURL = `${process.env.NEXT_PUBLIC_LEAFCUTTER_URL}/api/auth/csrf`;
    const csrfData = await fetchData(csrfURL, {});
    const authURL = `${process.env.NEXT_PUBLIC_LEAFCUTTER_URL}/api/auth/callback/credentials`;
    const authData = await fetchData(authURL, { method: "POST" });
    if (!authData) {
      return null;
    } else {
      return await fetchData(url, options);
    }
  } else {
    return data;
  }
};