import { NextRequest, NextResponse } from 'next/server'
import { insertMessage, updateRoom } from 'lib/persistence'
import { logEvent } from 'lib/logger'

export async function POST(request: NextRequest) {
  try {
    const body = await request.json()
    const messages = Array.isArray(body?.messages) ? body.messages : []

    let inserted = 0
    for (const msg of messages) {
      const res = await insertMessage({
        id: msg.id,
        room_id: msg.room_id,
        code_id: msg.code_id,
        user_id: msg.user_id || null,
        content: msg.content,
        image_url: msg.image_url || null,
        created_at: msg.created_at || new Date().toISOString()
      })
      if (res) {
        inserted++
        await updateRoom(msg.room_id, { date_last_message: new Date().toISOString() })
      }
    }

    if (inserted > 0) {
      await logEvent({
        module: 'sync',
        operation: 'push_messages',
        data: { inserted },
        ip: (request as any).headers?.get?.('x-forwarded-for') || null,
        userAgent: (request as any).headers?.get?.('user-agent') || null
      })
    }

    return NextResponse.json({ success: true, inserted })
  } catch (error) {
    console.error('Sync push error:', error)
    return NextResponse.json({ error: 'Vnitřní chyba serveru' }, { status: 500 })
  }
}