import { and, eq, isNull, sql } from "drizzle-orm";
import db from "../../database";
import { labelTable } from "../../database/schema";
import { syncLabelToGitea } from "../../plugins/gitea/utils/sync-label-to-gitea";
import { syncLabelToGitHub } from "../../plugins/github/utils/sync-label-to-github";

async function createLabel(
  name: string,
  color: string,
  taskId: string | undefined,
  workspaceId: string,
) {
  if (taskId) {
    const [inserted] = await db
      .insert(labelTable)
      .values({ name, color, taskId, workspaceId })
      .onConflictDoNothing({
        target: [labelTable.taskId, labelTable.name],
      })
      .returning();

    const label =
      inserted ??
      (await db.query.labelTable.findFirst({
        where: and(eq(labelTable.taskId, taskId), eq(labelTable.name, name)),
      }));

    if (!label) {
      throw new Error("Failed to create or resolve label");
    }

    if (inserted) {
      syncLabelToGitHub(taskId, name, color).catch((error) => {
        console.error("Failed to sync label to GitHub:", error);
      });
      syncLabelToGitea(taskId, name, color).catch((error) => {
        console.error("Failed to sync label to Gitea:", error);
      });
    }

    return label;
  }

  const [inserted] = await db
    .insert(labelTable)
    .values({ name, color, taskId: null, workspaceId })
    .onConflictDoNothing({
      target: [labelTable.workspaceId, labelTable.name],
      where: sql`${labelTable.taskId} is null`,
    })
    .returning();

  const label =
    inserted ??
    (await db.query.labelTable.findFirst({
      where: and(
        eq(labelTable.workspaceId, workspaceId),
        eq(labelTable.name, name),
        isNull(labelTable.taskId),
      ),
    }));

  if (!label) {
    throw new Error("Failed to create or resolve label");
  }

  return label;
}

export default createLabel;