import type { Database } from '@/db/connection.js';
import { systemSettings } from '@/db/schema.js';

export async function getSettings(db: Database) {
  let [settings] = await db.select().from(systemSettings).limit(1);
  
  if (!settings) {
    [settings] = await db.insert(systemSettings).values({ allowRequesterChat: true }).returning();
  }
  
  return settings;
}

export async function updateSettings(db: Database, data: { allowRequesterChat: boolean }) {
  let [settings] = await db.select().from(systemSettings).limit(1);

  if (!settings) {
    [settings] = await db.insert(systemSettings).values(data).returning();
  } else {
    [settings] = await db.update(systemSettings)
      .set({ allowRequesterChat: data.allowRequesterChat, updatedAt: new Date().toISOString() })
      .returning();
  }

  return settings;
}