import { query } from '../db';

/** Append an audit row for a user (subject of the event). */
export async function logUserActivity(
  userId: string,
  action: string,
  metadata: Record<string, unknown> = {},
  ip?: string | null
): Promise<void> {
  await query(
    `INSERT INTO user_activity_log (user_id, action, metadata, ip_address)
     VALUES ($1, $2, $3::jsonb, $4)`,
    [userId, action, JSON.stringify(metadata), ip ?? null]
  );
}