import type { Kysely } from "kysely";
import { sql } from "kysely";
import type { DB } from "../db";

export async function up(db: Kysely<DB>): Promise<void> {
  await sql`ALTER TABLE admin_activity_log ADD COLUMN IF NOT EXISTS response_payload jsonb`.execute(db);
  await sql`ALTER TABLE admin_activity_log ADD COLUMN IF NOT EXISTS query_params jsonb`.execute(db);
  await sql`ALTER TABLE admin_activity_log ADD COLUMN IF NOT EXISTS origin_page text`.execute(db);
}

export async function down(db: Kysely<DB>): Promise<void> {
  await db.schema
    .alterTable("admin_activity_log")
    .dropColumn("response_payload")
    .dropColumn("query_params")
    .dropColumn("origin_page")
    .execute();
}