/**
 * Execute a raw SQL query against Supabase/PostgreSQL
 * This is a server-only endpoint for internal API use
 */
export default defineEventHandler(async (event) => {
  const body = await readBody(event)
  const { query, params = [] } = body

  if (!query) {
    throw createError({
      statusCode: 400,
      statusMessage: 'Query is required'
    })
  }

  try {
    // Execute query using MCP postgres tool
    const result = await $fetch('/__mcp/mcp__postgres__query', {
      method: 'POST',
      body: {
        query,
        params
      }
    })

    return result
  } catch (error: any) {
    console.error('[Postgres] Query failed:', error)
    throw createError({
      statusCode: error.statusCode || 500,
      statusMessage: error.statusMessage || 'Database query failed'
    })
  }
})