coa.ts

import "dotenv/config";

import {
  inducks_issuequotation,
  PrismaClient as PrismaCoa,
} from "~prisma-clients/client_coa";

export const prismaCoa = new PrismaCoa();

const cachedCoaIssues: Record<string, string[]> = {};

export const createQuotations = async (
  data: Omit<inducks_issuequotation, "id" | "shortIssuecode">[]
) => {
  console.log(`Adding ${data.length} quotations`);
  return await prismaCoa.inducks_issuequotation.createMany({
    data,
  });
};

export const truncateQuotations = async () =>
  await prismaCoa.$executeRawUnsafe(`TRUNCATE TABLE inducks_issuequotation`);

export const isInducksIssueExisting = async (
  publicationcode: string,
  issuenumber: string
) =>
  (await getInducksIssuesBetween(publicationcode, issuenumber, issuenumber))
    .length;

export const getInducksIssuesBetween = async (
  publicationcode: string,
  issuenumberStart: string,
  issuenumberEnd = issuenumberStart
) => {
  cachedCoaIssues[publicationcode] =
    cachedCoaIssues[publicationcode] ||
    (
      await prismaCoa.inducks_issue.findMany({
        where: { publicationcode },
        select: { issuenumber: true },
      })
    ).map(({ issuenumber }) => issuenumber);

  if (!cachedCoaIssues[publicationcode].length) {
    console.warn(
      ` No issue found in COA for publication code ${publicationcode}`
    );
    return [];
  }

  const startIssueIndex =
    cachedCoaIssues[publicationcode].indexOf(issuenumberStart);
  if (startIssueIndex === -1) {
    console.warn(
      ` No issue found in COA for publication code ${publicationcode} and issue number ${issuenumberStart}`
    );
    return [];
  }
  const endIssueIndex =
    cachedCoaIssues[publicationcode].indexOf(issuenumberEnd);
  if (endIssueIndex === -1) {
    console.warn(
      ` No issue found in COA for publication code ${publicationcode} and issue number ${issuenumberEnd}`
    );
    return [];
  }
  return cachedCoaIssues[publicationcode].filter(
    (_, index) => index >= startIssueIndex && index <= endIssueIndex
  );
};

export const getAll = async () =>
  await prismaCoa.inducks_issuequotation.findMany({
    orderBy: [
      {
        publicationcode: "asc",
      },
      { issuenumber: "asc" },
    ],
  });