db-seafowl.test.ts

import { describe, it, expect } from "vitest";
import { makeDb } from "./db-seafowl";
import { SeafowlImportFilePlugin } from "./plugins/importers/seafowl-import-file-plugin";

import { shouldSkipSeafowlTests } from "@madatdata/test-helpers/env-config";

describe("importData", () => {
  it("returns false for unknown plugin", async () => {
    const examplePlugins = [
      {
        __name: "csv",
        importData: () =>
          Promise.resolve({ response: "import-ok", error: null, info: null }),
      },
      {
        __name: "export-something", // NOTE: duplicate names intentional, they implement different interfaces
        exportData: (_args: { foo?: string }) =>
          Promise.resolve({ response: "export-ok", error: null, info: null }),
      },
      {
        __name: "mongo",
        importData: () =>
          Promise.resolve({ response: "import-ok", error: null, info: null }),
      },
    ];

    const db = makeDb({
      plugins: examplePlugins,
    });

    await expect(async () =>
      // @ts-expect-error not a valid plugin
      db.importData("unknown-doesnotexist", {}, {}).catch((err) => {
        throw err;
      })
    ).rejects.toThrowErrorMatchingInlineSnapshot(
      '"plugin not found: unknown-doesnotexist"'
    );
  });
});

const createDb = () => {
  // const transformRequestHeaders = vi.fn((headers) => ({
  //   ...headers,
  //   foobar: "fizzbuzz",
  // }));

  const db = makeDb({
    database: {
      dbname: "default",
    },
    authenticatedCredential: {
      // @ts-expect-error https://stackoverflow.com/a/70711231
      token: import.meta.env.VITE_TEST_SEAFOWL_SECRET,
      anonymous: false,
    },
    host: {
      // temporary hacky mess
      dataHost: "127.0.0.1:8080",
      apexDomain: "bogus",
      apiHost: "bogus",
      baseUrls: {
        gql: "bogus",
        sql: "http://127.0.0.1:8080",
        auth: "bogus",
      },
      postgres: {
        host: "127.0.0.1",
        port: 6432,
        ssl: false,
      },
    },
    plugins: [new SeafowlImportFilePlugin({})],
  });

  return db;
};

describe.skipIf(shouldSkipSeafowlTests())("seafowl stub test", () => {
  it("can fingerprint with sha256 by default", async () => {
    const db = createDb();

    const fingerprint = await db.fingerprintQuery("select 1");

    expect(fingerprint).toMatchInlineSnapshot(`
      {
        "fingerprint": "822ae07d4783158bc1912bb623e5107cc9002d519e1143a9c200ed6ee18b6d0f",
        "normalized": "select 1",
      }
    `);
  });
});