Typescript Bun Knex Sqlite3 Repository Start

knex-sqlite3-repository.ts

import knex from "knex";
import fs from 'fs';

if (!fs.existsSync('./local.db')) {
    fs.appendFileSync('./local.db', '');
}

export const localDb = knex({
    client: 'sqlite3',
    connection: {
        filename: './local.db',
    },
});


const migrations = [
    {
        name: 'create-table-kv',
        async migrationFn() {
            await localDb.schema.createTableIfNotExists('kv', (table: any) => {
                table.string('kv_key');
                table.string('kv_val');
                table.index('kv_key', 'kv_kv_key_index');
            });
        }
    }

    // More migrations here
];


const MIGRATIONS_TABLE = '__migrations'; 
localDb.schema
  .createTableIfNotExists(MIGRATIONS_TABLE, (table: any) => {
    table.increments();
    table.string('name');
  }).finally(() => {
    (async () => {
        const migrated = async (migration: string) => {
            const exists = await localDb(MIGRATIONS_TABLE).select('name').where('name', migration);
            return exists.length;
        }
    
        const checkAndRunMigration = async (migration: string, migrationFn: () => Promise<void>) => {
            const done = await migrated(migration);
            if (!done) {
                await migrationFn();
                await localDb(MIGRATIONS_TABLE).insert({ name: migration });
            }
        }
    
        for (const migration of migrations) {
            await checkAndRunMigration(migration.name, migration.migrationFn);
        }
    })().catch(err => {
        console.error(err);
        process.exit(1);
    });
  });