export const journeys = pgTable("journey", {
  id: uuid("id").defaultRandom().primaryKey(),
  customer_firstName: text("customer_firstName").notNull(),
  customer_lastName: text("customer_lastName").notNull(),
  customer_emailAddress: text("customer_emailAddress").notNull(),
  currentstep: text("currentstep").notNull(),
});

export const journeys = pgTable("journey", {
  id: uuid("id").defaultRandom().primaryKey(),
  customer_firstName: text("customer_firstName").notNull(),
  customer_lastName: text("customer_lastName").notNull(),
  customer_emailAddress: text("customer_emailAddress").notNull(),
  currentstep: text("currentstep").notNull(),
});

export async function POST(req: Request) {
  const body = (await req.json()) as CreateJourneyRequest;

  const existingJourney = await db.transaction(async (tx) => {
    const result = await tx.query.journeys.findFirst({
      with: {
        products: {
          with: {
            product: true,
          },
        },
      },
      where: (journeys, { eq }) =>
        eq(journeys.customer_emailAddress, body.emailAddress),
    });

    return result;
  });

  if (existingJourney)
    return NextResponse.json(existingJourney);
  }

  const journeyId = uuidv4();

  const newJourney = {
    id: journeyId,
    customer_firstName: body.firstName,
    customer_lastName: body.lastName,
    customer_emailAddress: body.emailAddress,
    completed: false,
    currentstep: "review",
  };

  await db.transaction(async (tx) => {
    console.log(Date.now(), "Inserting New Journey");
    await tx.insert(journeys).values(newJourney);
    console.log(Date.now(), "Finished Inserting New Journey");

    const productsToLink = await tx.query.products.findMany({
      where: (products) => inArray(products.name, body.initialProducts),
    });

    const journeysProductsToInsert = productsToLink.map((product) => ({
      journeyId,
      productId: product.id,
    }));

    await tx.insert(journeysToProducts).values(journeysProductsToInsert);
  });
}

export async function POST(req: Request) {
  const body = (await req.json()) as CreateJourneyRequest;

  const existingJourney = await db.transaction(async (tx) => {
    const result = await tx.query.journeys.findFirst({
      with: {
        products: {
          with: {
            product: true,
          },
        },
      },
      where: (journeys, { eq }) =>
        eq(journeys.customer_emailAddress, body.emailAddress),
    });

    return result;
  });

  if (existingJourney)
    return NextResponse.json(existingJourney);
  }

  const journeyId = uuidv4();

  const newJourney = {
    id: journeyId,
    customer_firstName: body.firstName,
    customer_lastName: body.lastName,
    customer_emailAddress: body.emailAddress,
    completed: false,
    currentstep: "review",
  };

  await db.transaction(async (tx) => {
    console.log(Date.now(), "Inserting New Journey");
    await tx.insert(journeys).values(newJourney);
    console.log(Date.now(), "Finished Inserting New Journey");

    const productsToLink = await tx.query.products.findMany({
      where: (products) => inArray(products.name, body.initialProducts),
    });

    const journeysProductsToInsert = productsToLink.map((product) => ({
      journeyId,
      productId: product.id,
    }));

    await tx.insert(journeysToProducts).values(journeysProductsToInsert);
  });
}