ditto/src/db/migrations/007_unattached_media.ts

import { Kysely } from 'kysely';

export async function up(db: Kysely<any>): Promise<void> {
  await db.schema
    .createTable('unattached_media')
    .addColumn('id', 'text', (c) => c.primaryKey())
    .addColumn('pubkey', 'text', (c) => c.notNull())
    .addColumn('url', 'text', (c) => c.notNull())
    .addColumn('data', 'text', (c) => c.notNull())
    .addColumn('uploaded_at', 'bigint', (c) => c.notNull())
    .execute();

  await db.schema
    .createIndex('unattached_media_id')
    .on('unattached_media')
    .column('id')
    .execute();

  await db.schema
    .createIndex('unattached_media_pubkey')
    .on('unattached_media')
    .column('pubkey')
    .execute();

  await db.schema
    .createIndex('unattached_media_url')
    .on('unattached_media')
    .column('url')
    .execute();
}

export async function down(db: Kysely<any>): Promise<void> {
  await db.schema.dropTable('unattached_media').execute();
}