iccicci/sedentary

import { strictEqual as eq } from "assert";
import { PoolClient } from "pg";

import { EntryBase, TransactionPG } from "..";
import { helper } from "./helper";
import { transactions } from "./local";

describe("coverage", () => {
  describe("DB.release", function() {
    helper([], true, { autoSync: false }, async db => {
      await db.connect();
      // eslint-disable-next-line @typescript-eslint/no-explicit-any
      (db as any).log("Syncing...");
      // eslint-disable-next-line @typescript-eslint/no-explicit-any
      (db as any).log("Synced");
    });
  });

  describe("Transaction.release", function() {
    helper(transactions.commit, async db => {
      const test2 = db.model("test2", { a: db.Int, b: db.VarChar });
      await db.connect();
      const r1 = new test2({ a: 1, b: "1" });
      await r1.save();
      const r2 = new test2({ a: 2, b: "2" });
      await r2.save();
      const tx = await db.begin();
      const r3 = new test2({ a: 3, b: "3" }, tx);
      const l1 = await test2.load({}, tx);
      l1[0].a = 11;
      l1[0].b = "11";
      await l1[0].save();
      await l1[1].remove();
      await r3.save();
      await tx.commit();
      await test2.load({ id: [">", 0] }, ["id"]);
      await tx.commit();
      await tx.rollback();
    });
  });

  it("EntryBase", () => eq(new EntryBase() instanceof EntryBase, true));
  // eslint-disable-next-line no-console
  it("TransactionPG", () => eq(new TransactionPG(console.log, null as unknown as PoolClient) instanceof TransactionPG, true));
});