import { Alepha } from "alepha";
import { DateTimeProvider } from "alepha/datetime";
import { $repository } from "alepha/orm";
import { AlephaOrmPostgres } from "alepha/orm/postgres";
import { describe, it } from "vitest";
import {
  AlephaApiVerification,
  VerificationJobs,
  verifications,
} from "../index.ts";

class Db {
  verifications = $repository(verifications);
}

const alepha = Alepha.create()
  .with(AlephaOrmPostgres)
  .with(AlephaApiVerification);
const db = alepha.inject(Db);

describe("VerificationJobs", () => {
  it("it should clear old verifications", async ({ expect }) => {
    const time = alepha.inject(DateTimeProvider);
    const jobs = alepha.inject(VerificationJobs);

    await db.verifications.deleteMany({ target: { eq: "hello@mail.com" } });

    const entry = {
      type: "link",
      target: "hello@mail.com",
      code: "123456",
    } as const;

    await db.verifications.create({
      ...entry,
      createdAt: time.nowISOString(),
    });

    await db.verifications.create({
      ...entry,
      createdAt: time.now().subtract(2, "days").toISOString(),
    });

    await db.verifications.create({
      ...entry,
      createdAt: time.now().subtract(3, "days").toISOString(),
    });

    expect(await db.verifications.count()).toBe(3);

    await jobs.cleanExpired.trigger();

    expect(await db.verifications.count()).toBe(1);
  });
});