use chrono::{DateTime, Utc};
use jid::JID;
use rusqlite::{
    ToSql,
    types::{FromSql, ToSqlOutput, Value},
};
use uuid::Uuid;

#[derive(Debug, Clone)]
pub struct Message {
    pub id: Uuid,
    // does not contain full user information
    // bare jid (for now)
    pub from: JID,
    pub delivery: Option<Delivery>,
    pub timestamp: DateTime<Utc>,
    // TODO: originally_from
    // TODO: message edits
    // TODO: message timestamp
    pub body: Body,
}

#[derive(Debug, Clone, Copy)]
pub enum Delivery {
    Sending,
    Written,
    Sent,
    Delivered,
    Read,
    Failed,
    Queued,
}

impl ToSql for Delivery {
    fn to_sql(&self) -> rusqlite::Result<rusqlite::types::ToSqlOutput<'_>> {
        Ok(match self {
            Delivery::Sending => ToSqlOutput::Owned(Value::Text("sending".to_string())),
            Delivery::Written => ToSqlOutput::Owned(Value::Text("written".to_string())),
            Delivery::Sent => ToSqlOutput::Owned(Value::Text("sent".to_string())),
            Delivery::Delivered => ToSqlOutput::Owned(Value::Text("delivered".to_string())),
            Delivery::Read => ToSqlOutput::Owned(Value::Text("read".to_string())),
            Delivery::Failed => ToSqlOutput::Owned(Value::Text("failed".to_string())),
            Delivery::Queued => ToSqlOutput::Owned(Value::Text("queued".to_string())),
        })
    }
}

impl FromSql for Delivery {
    fn column_result(value: rusqlite::types::ValueRef<'_>) -> rusqlite::types::FromSqlResult<Self> {
        Ok(match value.as_str()? {
            "sending" => Self::Sending,
            "written" => Self::Written,
            "sent" => Self::Sent,
            "delivered" => Self::Delivered,
            "read" => Self::Read,
            "failed" => Self::Failed,
            "queued" => Self::Queued,
            // TODO: don't have these lol
            value => panic!("unexpected subscription `{value}`"),
        })
    }
}

// TODO: user migrations
// pub enum Migrated {
//     Jabber(User),
//     Outside,
// }

#[derive(Debug, Clone)]
pub struct Body {
    // TODO: rich text, other contents, threads
    pub body: String,
}

#[derive(Debug, Clone)]
pub struct Chat {
    pub correspondent: JID,
    pub have_chatted: bool,
    // pub unread_messages: i32,
    // pub latest_message: Message,
    // when a new message is received, the chat should be updated, and the new message should be delivered too.
    // message history is not stored in chat, retreived separately.
    // pub message_history: Vec<Message>,
}

pub enum ChatUpdate {}

impl Chat {
    pub fn new(correspondent: JID, have_chatted: bool) -> Self {
        Self {
            correspondent,
            have_chatted,
        }
    }
    pub fn correspondent(&self) -> &JID {
        &self.correspondent
    }
}

// TODO: group chats
// pub enum Chat {
//     Direct(DirectChat),
//     Channel(Channel),
// }
// pub struct Channel {}