1 files changed, 0 insertions, 146 deletions
diff --git a/deno/mail-relay/db.ts b/deno/mail-relay/db.ts
deleted file mode 100644
index 062700b..0000000
--- a/deno/mail-relay/db.ts
+++ /dev/null
@@ -1,146 +0,0 @@
-import {
-  Generated,
-  Insertable,
-  Kysely,
-  Migration,
-  Migrator,
-  SqliteDatabase,
-  SqliteDialect,
-  SqliteStatement,
-} from "kysely";
-import * as sqlite from "@db/sqlite";
-
-class SqliteStatementAdapter implements SqliteStatement {
-  constructor(public readonly stmt: sqlite.Statement) {}
-
-  get reader(): boolean {
-    return this.stmt.columnNames().length >= 1;
-  }
-
-  all(parameters: readonly unknown[]): unknown[] {
-    return this.stmt.all(...(parameters as sqlite.BindValue[]));
-  }
-
-  iterate(parameters: readonly unknown[]): IterableIterator<unknown> {
-    return this.stmt.iter(...(parameters as sqlite.BindValue[]));
-  }
-
-  run(parameters: readonly unknown[]): {
-    changes: number | bigint;
-    lastInsertRowid: number | bigint;
-  } {
-    const { db } = this.stmt;
-    const totalChangesBefore = db.totalChanges;
-    const changes = this.stmt.run(...(parameters as sqlite.BindValue[]));
-    return {
-      changes: totalChangesBefore === db.totalChanges ? 0 : changes,
-      lastInsertRowid: db.lastInsertRowId,
-    };
-  }
-}
-
-class SqliteDatabaseAdapter implements SqliteDatabase {
-  constructor(public readonly db: sqlite.Database) {}
-
-  prepare(sql: string): SqliteStatementAdapter {
-    return new SqliteStatementAdapter(this.db.prepare(sql));
-  }
-
-  close(): void {
-    this.db.close();
-  }
-}
-
-export class DbError extends Error {}
-
-interface AwsMessageIdMapTable {
-  id: Generated<number>;
-  message_id: string;
-  aws_message_id: string;
-}
-
-interface Database {
-  aws_message_id_map: AwsMessageIdMapTable;
-}
-
-const migrations: Record<string, Migration> = {
-  "0001-init": {
-    // deno-lint-ignore no-explicit-any
-    async up(db: Kysely<any>): Promise<void> {
-      await db.schema
-        .createTable("aws_message_id_map")
-        .addColumn("id", "integer", (col) => col.primaryKey().autoIncrement())
-        .addColumn("message_id", "text", (col) => col.notNull().unique())
-        .addColumn("aws_message_id", "text", (col) => col.notNull().unique())
-        .execute();
-
-      for (const column of ["message_id", "aws_message_id"]) {
-        await db.schema
-          .createIndex(`aws_message_id_map_${column}`)
-          .on("aws_message_id_map")
-          .column(column)
-          .execute();
-      }
-    },
-
-    // deno-lint-ignore no-explicit-any
-    async down(db: Kysely<any>): Promise<void> {
-      await db.schema.dropTable("aws_message_id_map").execute();
-    },
-  },
-};
-
-export class DbService {
-  #db;
-  #kysely;
-  #migrator;
-
-  constructor(public readonly path: string) {
-    this.#db = new sqlite.Database(path);
-    this.#kysely = new Kysely<Database>({
-      dialect: new SqliteDialect({
-        database: new SqliteDatabaseAdapter(this.#db),
-      }),
-    });
-    this.#migrator = new Migrator({
-      db: this.#kysely,
-      provider: {
-        getMigrations(): Promise<Record<string, Migration>> {
-          return Promise.resolve(migrations);
-        },
-      },
-    });
-  }
-
-  async migrate(): Promise<void> {
-    await this.#migrator.migrateToLatest();
-  }
-
-  async addMessageIdMap(
-    mail: Insertable<AwsMessageIdMapTable>,
-  ): Promise<number> {
-    const inserted = await this.#kysely
-      .insertInto("aws_message_id_map")
-      .values(mail)
-      .executeTakeFirstOrThrow();
-    return Number(inserted.insertId!);
-  }
-
-  async messageIdToAws(messageId: string): Promise<string | null> {
-    const row = await this.#kysely
-      .selectFrom("aws_message_id_map")
-      .where("message_id", "=", messageId)
-      .select("aws_message_id")
-      .executeTakeFirst();
-    return row?.aws_message_id ?? null;
-  }
-
-  async messageIdFromAws(awsMessageId: string): Promise<string | null> {
-    const row = await this.#kysely
-      .selectFrom("aws_message_id_map")
-      .where("aws_message_id", "=", awsMessageId)
-      .select("message_id")
-      .executeTakeFirst();
-    return row?.message_id ?? null;
-  }
-}