package ru.fromchat.ui.chat

import androidx.compose.animation.AnimatedContent
import androidx.compose.animation.fadeIn
import androidx.compose.animation.fadeOut
import androidx.compose.animation.togetherWith
import androidx.compose.foundation.gestures.detectTapGestures
import androidx.compose.foundation.layout.Arrangement
import androidx.compose.foundation.layout.Box
import androidx.compose.foundation.layout.Column
import androidx.compose.foundation.layout.Spacer
import androidx.compose.foundation.layout.WindowInsets
import androidx.compose.foundation.layout.fillMaxSize
import androidx.compose.foundation.layout.fillMaxWidth
import androidx.compose.foundation.layout.height
import androidx.compose.foundation.layout.ime
import androidx.compose.foundation.layout.padding
import androidx.compose.foundation.layout.windowInsetsPadding
import androidx.compose.foundation.lazy.LazyColumn
import androidx.compose.foundation.lazy.items
import androidx.compose.foundation.lazy.rememberLazyListState
import androidx.compose.material.icons.Icons
import androidx.compose.material.icons.automirrored.filled.ArrowBack
import androidx.compose.material.icons.filled.Call
import androidx.compose.material3.CircularProgressIndicator
import androidx.compose.material3.ExperimentalMaterial3Api
import androidx.compose.material3.Icon
import androidx.compose.material3.IconButton
import androidx.compose.material3.MaterialTheme
import androidx.compose.material3.Scaffold
import androidx.compose.material3.Text
import androidx.compose.material3.TopAppBar
import androidx.compose.material3.TopAppBarDefaults
import androidx.compose.runtime.Composable
import androidx.compose.runtime.LaunchedEffect
import androidx.compose.runtime.getValue
import androidx.compose.runtime.mutableStateOf
import androidx.compose.runtime.remember
import androidx.compose.runtime.rememberCoroutineScope
import androidx.compose.runtime.saveable.rememberSaveable
import androidx.compose.runtime.setValue
import androidx.compose.ui.Alignment
import androidx.compose.ui.Modifier
import androidx.compose.ui.geometry.Offset
import androidx.compose.ui.graphics.Color
import androidx.compose.ui.input.nestedscroll.nestedScroll
import androidx.compose.ui.input.pointer.pointerInput
import androidx.compose.ui.layout.onGloballyPositioned
import androidx.compose.ui.layout.positionInRoot
import androidx.compose.ui.unit.IntOffset
import androidx.compose.ui.unit.dp
import dev.chrisbanes.haze.HazeProgressive
import dev.chrisbanes.haze.hazeEffect
import dev.chrisbanes.haze.hazeSource
import dev.chrisbanes.haze.materials.ExperimentalHazeMaterialsApi
import dev.chrisbanes.haze.materials.HazeMaterials
import dev.chrisbanes.haze.rememberHazeState
import kotlinx.coroutines.launch
import kotlinx.serialization.json.decodeFromJsonElement
import org.jetbrains.compose.resources.stringResource
import ru.fromchat.Res
import ru.fromchat.api.ApiClient
import ru.fromchat.api.Message
import ru.fromchat.api.TypingData
import ru.fromchat.api.WebSocketManager
import ru.fromchat.api.WebSocketMessage
import ru.fromchat.back
import ru.fromchat.core.Logger
import ru.fromchat.ui.LocalNavController

@OptIn(ExperimentalMaterial3Api::class, ExperimentalHazeMaterialsApi::class)
@Composable
fun ChatScreen(
    panel: ChatPanel,
    currentUserId: Int?,
    modifier: Modifier = Modifier
) {
    var panelState by remember(panel) { mutableStateOf(panel.getState()) }
    
    // Observe state changes
    LaunchedEffect(panel) {
        panel.setOnStateChange { newState ->
            Logger.d("ChatScreen", "State change callback received: messages=${newState.messages.size}")
            // Force state update to trigger recomposition
            panelState = newState.copy() // Ensure new instance
            Logger.d("ChatScreen", "panelState updated: messages=${panelState.messages.size}")
        }
        // Initial state
        panelState = panel.getState()
    }
    
    // Debug: Log state changes
    LaunchedEffect(panelState.messages.size) {
        Logger.d("ChatScreen", "Messages count changed: ${panelState.messages.size}")
    }

    val scrollBehavior = TopAppBarDefaults.pinnedScrollBehavior()
    val listState = rememberLazyListState()
    val scope = rememberCoroutineScope()
    val navController = LocalNavController.current
    val hazeState = rememberHazeState(blurEnabled = true)

    // UI state
    var inputText by rememberSaveable { mutableStateOf("") }
    var replyTo by rememberSaveable { mutableStateOf<Message?>(null) }
    var editingMessage by rememberSaveable { mutableStateOf<Message?>(null) }
    var contextMenuState by remember { 
        mutableStateOf(
            ContextMenuState(
                isOpen = false,
                message = null,
                position = IntOffset(0, 0)
            )
        )
    }
    var typingUsers by remember { mutableStateOf<Map<Int, String>>(emptyMap()) }

    // Collect WebSocket messages
    LaunchedEffect(Unit) {
        WebSocketManager.messages.collect { message ->
            Logger.d("ChatScreen", "Received WebSocket message: type=${message.type}, data=${message.data != null}")
            when (message.type) {
                "updates" -> {
                    // Handle batched updates
                    Logger.d("ChatScreen", "Processing updates message")
                    val data = message.data
                    if (data == null) {
                        Logger.w("ChatScreen", "Updates message has no data, skipping")
                        return@collect
                    }
                    Logger.d("ChatScreen", "Updates message has data, parsing...")
                    val json = ApiClient.json
                    try {
                        Logger.d("ChatScreen", "Parsing updates message")
                        val updatesMessage = json.decodeFromJsonElement<ru.fromchat.api.UpdatesMessage>(data)
                        Logger.d("ChatScreen", "Updates message parsed: ${updatesMessage.updates.size} updates")
                        // Process each update in the batch
                        updatesMessage.updates.forEach { update ->
                            Logger.d("ChatScreen", "Processing update: type=${update.type}, data=${update.data != null}")
                            val wsMessage = WebSocketMessage(
                                type = update.type,
                                data = update.data
                            )
                            when (update.type) {
                                "newMessage", "messageEdited", "messageDeleted" -> {
                                    Logger.d("ChatScreen", "Launching handleWebSocketMessage for ${update.type}")
                                    scope.launch {
                                        try {
                                            panel.handleWebSocketMessage(wsMessage)
                                        } catch (e: Exception) {
                                            Logger.e("ChatScreen", "Error handling WebSocket message: ${e.message}", e)
                                        }
                                    }
                                }
                                "typing" -> {
                                    val updateData = update.data ?: return@forEach
                                    val typingData = json.decodeFromJsonElement<TypingData>(updateData)
                                    if (typingData.userId != currentUserId) {
                                        typingUsers = typingUsers + (typingData.userId to typingData.username)
                                        // Remove after timeout
                                        scope.launch {
                                            kotlinx.coroutines.delay(3000)
                                            typingUsers = typingUsers - typingData.userId
                                        }
                                    }
                                }
                                "stopTyping" -> {
                                    val updateData = update.data ?: return@forEach
                                    val typingData = json.decodeFromJsonElement<TypingData>(updateData)
                                    typingUsers = typingUsers - typingData.userId
                                }
                            }
                        }
                    } catch (e: Exception) {
                        Logger.e("ChatScreen", "Error parsing updates message: ${e.message}", e)
                        e.printStackTrace()
                    }
                }
                "newMessage", "messageEdited", "messageDeleted" -> {
                    scope.launch {
                        panel.handleWebSocketMessage(message)
                    }
                }
                "typing" -> {
                    val data = message.data ?: return@collect
                    val json = ApiClient.json
                    val typingData = json.decodeFromJsonElement<TypingData>(data)
                    if (typingData.userId != currentUserId) {
                        typingUsers = typingUsers + (typingData.userId to typingData.username)
                        // Remove after timeout
                        scope.launch {
                            kotlinx.coroutines.delay(3000)
                            typingUsers = typingUsers - typingData.userId
                        }
                    }
                }
            }
        }
    }

    // Scroll to bottom when new messages arrive
    LaunchedEffect(panelState.messages.size) {
        if (panelState.messages.isNotEmpty()) {
            scope.launch {
                listState.animateScrollToItem(panelState.messages.size - 1)
            }
        }
    }

    Scaffold(
        modifier = modifier.nestedScroll(scrollBehavior.nestedScrollConnection),
        topBar = {
            TopAppBar(
                title = {
                    Column(
                        horizontalAlignment = Alignment.CenterHorizontally
                    ) {
                        Text(
                            text = panelState.title,
                            style = MaterialTheme.typography.titleLarge
                        )
                        AnimatedContent(
                            targetState = typingUsers.isNotEmpty(),
                            transitionSpec = {
                                fadeIn() togetherWith fadeOut()
                            },
                            label = "typing_status"
                        ) { hasTyping ->
                            if (hasTyping) {
                                TypingIndicator(
                                    typingUsers = typingUsers.values.toList(),
                                    modifier = Modifier.padding(top = 2.dp)
                                )
                            } else {
                                // Empty space to maintain height
                                Box(modifier = Modifier.height(0.dp))
                            }
                        }
                    }
                },
                navigationIcon = {
                    IconButton(onClick = { navController.navigateUp() }) {
                        Icon(
                            imageVector = Icons.AutoMirrored.Filled.ArrowBack,
                            contentDescription = stringResource(Res.string.back)
                        )
                    }
                },
                actions = {
                    if (panel.showCallButton()) {
                        IconButton(onClick = { /* TODO: Handle call */ }) {
                            Icon(
                                imageVector = Icons.Default.Call,
                                contentDescription = "Call"
                            )
                        }
                    }
                },
                scrollBehavior = scrollBehavior,
                modifier = Modifier.hazeEffect(
                    state = hazeState,
                    style = HazeMaterials.thin()
                ),
                colors = TopAppBarDefaults.topAppBarColors(
                    containerColor = Color.Transparent,
                    scrolledContainerColor = Color.Transparent
                )
            )
        },
        bottomBar = {
            Column( // New Column to hold ChatInput below the LazyColumn
                modifier = Modifier
                    .windowInsetsPadding(WindowInsets.ime)
                    .fillMaxWidth()
                    .hazeEffect(
                        state = hazeState,
                        style = HazeMaterials.thin()
                    ) {
                        progressive = HazeProgressive.verticalGradient(
                            startIntensity = 0f,
                            endIntensity = 1f
                        )
                    }
            ) {
                ChatInput(
                    text = inputText,
                    onTextChange = { inputText = it },
                    onSend = { text ->
                        if (editingMessage != null) {
                            scope.launch {
                                panel.handleEditMessage(editingMessage!!.id, text)
                                editingMessage = null
                            }
                        } else {
                            scope.launch {
                                panel.sendMessageWithImmediateDisplay(text, replyTo?.id)
                                replyTo = null
                            }
                        }
                        inputText = ""
                    },
                    typingHandler = panel.getTypingHandler(),
                    replyTo = replyTo,
                    editingMessage = editingMessage,
                    onClearReply = { replyTo = null },
                    onClearEdit = { editingMessage = null },
                    hazeState = hazeState
                )
            }
        }
    ) { innerPadding ->
        Box(
            modifier = Modifier
                .fillMaxSize()
                .pointerInput(Unit) {
                    detectTapGestures {
                        // Close context menu on outside tap
                        if (contextMenuState.isOpen) {
                            contextMenuState = contextMenuState.copy(isOpen = false)
                        }
                    }
                }
        ) {
            if (panelState.isLoading) {
                Box(
                    modifier = Modifier.fillMaxSize(),
                    contentAlignment = Alignment.Center
                ) {
                    CircularProgressIndicator()
                }
            } else {
                LazyColumn(
                    state = listState,
                    modifier = Modifier.fillMaxSize(), // Fill the entire space of the Box
                    verticalArrangement = Arrangement.spacedBy(4.dp, alignment = Alignment.Bottom)
                ) {
                    item { Spacer(Modifier.height(innerPadding.calculateTopPadding())) } // Spacer for TopAppBar

                    items(
                        items = panelState.messages,
                        key = { it.id }
                    ) { message ->
                        val isAuthor = message.user_id == currentUserId
                        var messagePosition by remember { mutableStateOf(IntOffset(0, 0)) }
                        var tapOffset by remember { mutableStateOf(Offset(0f, 0f)) }

                        Box(
                            modifier = Modifier
                                .hazeSource(hazeState)
                                .onGloballyPositioned { coordinates ->
                                    messagePosition = IntOffset(
                                        coordinates.positionInRoot().x.toInt(),
                                        coordinates.positionInRoot().y.toInt()
                                    )
                                }
                        ) {
                            MessageItem(
                                message = message,
                                isAuthor = isAuthor,
                                onLongPress = {
                                    contextMenuState = ContextMenuState(
                                        isOpen = true,
                                        message = message,
                                        position = IntOffset(
                                            messagePosition.x + tapOffset.x.toInt(),
                                            messagePosition.y + tapOffset.y.toInt()
                                        )
                                    )
                                },
                                onTapPosition = { offset ->
                                    tapOffset = offset
                                }
                            )
                        }
                    }

                    item { Spacer(Modifier.height(innerPadding.calculateBottomPadding())) } // Spacer for chat input
                }
            }

            // Context menu
            MessageContextMenu(
                state = contextMenuState,
                isAuthor = contextMenuState.message?.user_id == currentUserId,
                onDismiss = { contextMenuState = contextMenuState.copy(isOpen = false) },
                onReply = { message ->
                    replyTo = message
                    editingMessage = null
                },
                onEdit = { message ->
                    editingMessage = message
                    inputText = message.content
                    replyTo = null
                },
                onDelete = { message ->
                    scope.launch {
                        panel.handleDeleteMessage(message.id)
                    }
                },
            )
        }
    }
}