ditto/src/db/migrations/020_pgfts.ts

import { Kysely, sql } from 'kysely';

import { Conf } from '@/config.ts';

export async function up(db: Kysely<any>): Promise<void> {
  if (['postgres:', 'postgresql:'].includes(Conf.databaseUrl.protocol!)) {
    await db.schema.createTable('nostr_pgfts')
      .ifNotExists()
      .addColumn('event_id', 'text', (c) => c.primaryKey().references('nostr_events.id').onDelete('cascade'))
      .addColumn('search_vec', sql`tsvector`, (c) => c.notNull())
      .execute();
  }
}

export async function down(db: Kysely<any>): Promise<void> {
  if (['postgres:', 'postgresql:'].includes(Conf.databaseUrl.protocol!)) {
    await db.schema.dropTable('nostr_pgfts').ifExists().execute();
  }
}