use dashmap::DashMap;
use serde::de::{DeserializeSeed, MapAccess, SeqAccess, Visitor};
use std::collections::HashMap;
use uuid::Uuid;

use super::{notification::NotificationMethodConverter, request::RequestMethod, result::SnapcastResult};
use crate::Message;

pub type SentRequests = DashMap<Uuid, RequestMethod>;
pub struct SnapcastDeserializer<'a>(&'a SentRequests);

impl<'a> SnapcastDeserializer<'a> {
  pub fn de(message: &str, state: &'a SentRequests) -> Result<Vec<Message>, DeserializationError> {
    let mut deserializer = serde_json::Deserializer::from_str(message);

    Ok(SnapcastDeserializer(state).deserialize(&mut deserializer)?)
  }
}

impl<'de, 'a> DeserializeSeed<'de> for SnapcastDeserializer<'a> {
  type Value = Vec<Message>;

  fn deserialize<D>(self, d: D) -> Result<Self::Value, D::Error>
  where
    D: serde::de::Deserializer<'de>,
  {
    d.deserialize_any(SnapcastDeserializerVisitor(self.0))
  }
}

struct SnapcastDeserializerVisitor<'a>(&'a SentRequests);

impl SnapcastDeserializerVisitor<'_> {
  fn parse_single_message(&self, value: &serde_json::Value) -> Result<Message, String> {
    let obj = value.as_object().ok_or("batch item must be an object")?;
    let response: HashMap<String, serde_json::Value> = obj.clone().into_iter().collect();
    self.parse_message_from_map(response)
  }

  fn parse_message_from_map(&self, mut response: HashMap<String, serde_json::Value>) -> Result<Message, String> {
    use serde_json::Value;

    let jsonrpc = response
      .get("jsonrpc")
      .unwrap_or(&Value::String("2.0".to_string()))
      .as_str()
      .unwrap_or("2.0")
      .to_string();

    if response.contains_key("method") {
      Ok(Message::Notification {
        jsonrpc,
        method: Box::new(
          NotificationMethodConverter(
            serde_json::from_value(response.remove("method").expect("this should never fail"))
              .map_err(|e| e.to_string())?,
            response.remove("params").ok_or("no params found")?,
          )
          .try_into()
          .map_err(|e: serde_json::Error| e.to_string())?,
        ),
      })
    } else if response.contains_key("result") {
      let id: Uuid = serde_json::from_value(response.remove("id").ok_or("could not associate result with request")?)
        .map_err(|e| e.to_string())?;
      let result = response.remove("result").expect("this should never fail");
      let result = if let Some(mapped_type) = self.0.remove(&id) {
        SnapcastResult::try_from((mapped_type.1, result)).map_err(|e| e.to_string())?
      } else {
        serde_json::from_value(result).map_err(|e| e.to_string())?
      };

      Ok(Message::Result {
        id,
        jsonrpc,
        result: Box::new(result),
      })
    } else if response.contains_key("error") {
      let id: Uuid = serde_json::from_value(response.remove("id").ok_or("could not associate result with request")?)
        .map_err(|e| e.to_string())?;
      Ok(Message::Error {
        id,
        jsonrpc,
        error: serde_json::from_value(response.remove("error").expect("this should never fail"))
          .map_err(|e| e.to_string())?,
      })
    } else {
      Err("invalid snapcast message".to_string())
    }
  }
}

impl<'de> Visitor<'de> for SnapcastDeserializerVisitor<'_> {
  type Value = Vec<Message>;

  fn expecting(&self, formatter: &mut std::fmt::Formatter) -> std::fmt::Result {
    write!(formatter, "a valid snapcast jsonrpc message or array of messages")
  }

  fn visit_seq<A>(self, mut seq: A) -> Result<Self::Value, A::Error>
  where
    A: SeqAccess<'de>,
  {
    use serde::de::Error;
    use serde_json::Value;

    let mut messages = Vec::with_capacity(seq.size_hint().unwrap_or(0));

    while let Some(item) = seq.next_element::<Value>()? {
      let msg = self.parse_single_message(&item).map_err(Error::custom)?;
      messages.push(msg);
    }

    Ok(messages)
  }

  fn visit_map<A>(self, mut access: A) -> Result<Self::Value, A::Error>
  where
    A: MapAccess<'de>,
  {
    use serde::de::Error;
    use serde_json::Value;

    let mut response: HashMap<String, Value> = HashMap::new();

    while let Some((key, value)) = access.next_entry()? {
      tracing::trace!("map key {:?} => {:?}", key, value);
      response.insert(key, value);
    }

    let msg = self.parse_message_from_map(response).map_err(Error::custom)?;
    Ok(vec![msg])
  }
}

/// Errors that can occur during deserialization
#[derive(Debug, thiserror::Error)]
pub enum DeserializationError {
  /// general deserialization error
  #[error("Deserialization error: {0}")]
  DeserializationError(#[from] serde::de::value::Error),
  /// json deserialization error
  #[error("JSON Deserialization error: {0}")]
  SerdeJsonError(#[from] serde_json::Error),
  /// top-level JSON was not an object or array
  #[error("invalid top-level snapcast message: {0}")]
  InvalidTopLevelMessage(String),
}

#[cfg(test)]
mod tests {
  use crate::protocol::{client, group, Method, Notification, Request, SnapcastResult};

  use super::*;

  #[test]
  fn deserialize_error() {
    let map = DashMap::new();

    let message = r#"{"id": "00000000-0000-0000-0000-000000000000", "jsonrpc": "2.0", "error": {"code": -32603, "message": "Internal error"}}"#;
    let snapcast_messages = SnapcastDeserializer::de(message, &map).unwrap();

    assert_eq!(snapcast_messages.len(), 1);
    assert_eq!(
      snapcast_messages[0],
      Message::Error {
        id: "00000000-0000-0000-0000-000000000000".try_into().unwrap(),
        jsonrpc: "2.0".to_string(),
        error: serde_json::from_str(r#"{"code": -32603, "message": "Internal error"}"#).unwrap()
      }
    );
  }

  #[test]
  fn serialize_client_get_status() {
    let message = r#"{"id":"00000000-0000-0000-0000-000000000000","jsonrpc":"2.0","method":"Client.GetStatus","params":{"id":"00:21:6a:7d:74:fc"}}"#;
    let composed = Request {
      id: "00000000-0000-0000-0000-000000000000".try_into().unwrap(),
      jsonrpc: "2.0".to_string(),
      method: Method::ClientGetStatus {
        params: client::GetStatusParams {
          id: "00:21:6a:7d:74:fc".to_string(),
        },
      },
    };

    assert_eq!(serde_json::to_string(&composed).unwrap(), message);
  }

  #[test]
  fn deserialize_client_get_status() {
    let map = DashMap::from_iter([(
      "00000000-0000-0000-0000-000000000000".try_into().unwrap(),
      RequestMethod::ClientGetStatus,
    )]);

    let message = r#"{"id":"00000000-0000-0000-0000-000000000000","jsonrpc":"2.0","result":{"client":{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":74}},"connected":true,"host":{"arch":"x86_64","ip":"127.0.0.1","mac":"00:21:6a:7d:74:fc","name":"T400","os":"Linux Mint 17.3 Rosa"},"id":"00:21:6a:7d:74:fc","lastSeen":{"sec":1488026416,"usec":135973},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.10.0"}}}}"#;
    let snapcast_messages = SnapcastDeserializer::de(message, &map).unwrap();

    assert_eq!(snapcast_messages.len(), 1);
    assert_eq!(
      snapcast_messages[0],
      Message::Result {
        id: "00000000-0000-0000-0000-000000000000".try_into().unwrap(),
        jsonrpc: "2.0".to_string(),
        result: Box::new(SnapcastResult::ClientGetStatus(client::GetStatusResult {
          client: client::Client {
            id: "00:21:6a:7d:74:fc".to_string(),
            connected: true,
            config: client::ClientConfig {
              instance: 1,
              latency: 0,
              name: "".to_string(),
              volume: client::ClientVolume {
                muted: false,
                percent: 74
              }
            },
            host: client::Host {
              arch: "x86_64".to_string(),
              ip: "127.0.0.1".to_string(),
              mac: "00:21:6a:7d:74:fc".to_string(),
              name: "T400".to_string(),
              os: "Linux Mint 17.3 Rosa".to_string()
            },
            last_seen: client::LastSeen {
              sec: 1488026416,
              usec: 135973
            },
            snapclient: client::Snapclient {
              name: "Snapclient".to_string(),
              protocol_version: 2,
              version: "0.10.0".to_string()
            }
          }
        }))
      }
    );
  }

  #[test]
  fn serialize_group_get_status() {
    let message = r#"{"id":"00000000-0000-0000-0000-000000000000","jsonrpc":"2.0","method":"Group.GetStatus","params":{"id":"4dcc4e3b-c699-a04b-7f0c-8260d23c43e1"}}"#;
    let composed = Request {
      id: "00000000-0000-0000-0000-000000000000".try_into().unwrap(),
      jsonrpc: "2.0".to_string(),
      method: Method::GroupGetStatus {
        params: group::GetStatusParams {
          id: "4dcc4e3b-c699-a04b-7f0c-8260d23c43e1".to_string(),
        },
      },
    };

    assert_eq!(serde_json::to_string(&composed).unwrap(), message);
  }

  #[test]
  fn deserialize_group_get_status() {
    let map = DashMap::new();

    let message = r#"{"id":"00000000-0000-0000-0000-000000000000","jsonrpc":"2.0","result":{"group":{"clients":[{"config":{"instance":2,"latency":10,"name":"Laptop","volume":{"muted":false,"percent":48}},"connected":true,"host":{"arch":"x86_64","ip":"127.0.0.1","mac":"00:21:6a:7d:74:fc","name":"T400","os":"Linux Mint 17.3 Rosa"},"id":"00:21:6a:7d:74:fc#2","lastSeen":{"sec":1488026485,"usec":644997},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.10.0"}},{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":74}},"connected":true,"host":{"arch":"x86_64","ip":"127.0.0.1","mac":"00:21:6a:7d:74:fc","name":"T400","os":"Linux Mint 17.3 Rosa"},"id":"00:21:6a:7d:74:fc","lastSeen":{"sec":1488026481,"usec":223747},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.10.0"}}],"id":"4dcc4e3b-c699-a04b-7f0c-8260d23c43e1","muted":true,"name":"","stream_id":"stream 1"}}}"#;
    let snapcast_messages = SnapcastDeserializer::de(message, &map).unwrap();

    assert_eq!(snapcast_messages.len(), 1);
    assert_eq!(
      snapcast_messages[0],
      Message::Result {
        id: "00000000-0000-0000-0000-000000000000".try_into().unwrap(),
        jsonrpc: "2.0".to_string(),
        result: Box::new(SnapcastResult::GroupGetStatus(group::GetStatusResult {
          group: group::Group {
            id: "4dcc4e3b-c699-a04b-7f0c-8260d23c43e1".to_string(),
            muted: true,
            name: "".to_string(),
            stream_id: "stream 1".to_string(),
            clients: vec![
              client::Client {
                id: "00:21:6a:7d:74:fc#2".to_string(),
                connected: true,
                config: client::ClientConfig {
                  instance: 2,
                  latency: 10,
                  name: "Laptop".to_string(),
                  volume: client::ClientVolume {
                    muted: false,
                    percent: 48
                  }
                },
                host: client::Host {
                  arch: "x86_64".to_string(),
                  ip: "127.0.0.1".to_string(),
                  mac: "00:21:6a:7d:74:fc".to_string(),
                  name: "T400".to_string(),
                  os: "Linux Mint 17.3 Rosa".to_string()
                },
                last_seen: client::LastSeen {
                  sec: 1488026485,
                  usec: 644997
                },
                snapclient: client::Snapclient {
                  name: "Snapclient".to_string(),
                  protocol_version: 2,
                  version: "0.10.0".to_string()
                }
              },
              client::Client {
                id: "00:21:6a:7d:74:fc".to_string(),
                connected: true,
                config: client::ClientConfig {
                  instance: 1,
                  latency: 0,
                  name: "".to_string(),
                  volume: client::ClientVolume {
                    muted: false,
                    percent: 74
                  }
                },
                host: client::Host {
                  arch: "x86_64".to_string(),
                  ip: "127.0.0.1".to_string(),
                  mac: "00:21:6a:7d:74:fc".to_string(),
                  name: "T400".to_string(),
                  os: "Linux Mint 17.3 Rosa".to_string()
                },
                last_seen: client::LastSeen {
                  sec: 1488026481,
                  usec: 223747
                },
                snapclient: client::Snapclient {
                  name: "Snapclient".to_string(),
                  protocol_version: 2,
                  version: "0.10.0".to_string()
                }
              }
            ]
          }
        }))
      }
    )
  }

  #[test]
  fn serialize_server_get_status() {
    let message = r#"{"id":"00000000-0000-0000-0000-000000000000","jsonrpc":"2.0","method":"Server.GetStatus"}"#;
    let composed = Request {
      id: "00000000-0000-0000-0000-000000000000".try_into().unwrap(),
      jsonrpc: "2.0".to_string(),
      method: Method::ServerGetStatus,
    };

    assert_eq!(serde_json::to_string(&composed).unwrap(), message);
  }

  #[test]
  fn deserialize_server_get_status() {
    let map = DashMap::new();

    let message = r#"{"id":"00000000-0000-0000-0000-000000000000","jsonrpc":"2.0","result":{"server":{"groups":[{"clients":[{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":100}},"connected":true,"host":{"arch":"aarch64","ip":"172.16.3.109","mac":"2c:cf:67:47:cd:4a","name":"porch-musical-pi","os":"Debian GNU/Linux 12 (bookworm)"},"id":"Porches Pi","lastSeen":{"sec":1718314437,"usec":278423},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.28.0"}}],"id":"960ead7d-101a-88e9-1bee-b1c5f25efa9f","muted":false,"name":"","stream_id":"Porches Spotify"},{"clients":[{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":100}},"connected":true,"host":{"arch":"aarch64","ip":"172.16.2.171","mac":"d8:3a:dd:80:a0:87","name":"family-musical-pi","os":"Debian GNU/Linux 12 (bookworm)"},"id":"Family Pi","lastSeen":{"sec":1718314437,"usec":461576},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.28.0"}}],"id":"22a54ef3-54f6-949b-2eed-2ad83d1dab56","muted":false,"name":"","stream_id":"Kitchen Spotify"},{"clients":[{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":100}},"connected":true,"host":{"arch":"aarch64","ip":"172.16.3.38","mac":"2c:cf:67:47:cd:03","name":"bonus-musical-pi","os":"Debian GNU/Linux 12 (bookworm)"},"id":"Bonus Pi","lastSeen":{"sec":1718060095,"usec":922290},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.28.0"}}],"id":"a67bfc41-9286-48b9-a48c-383fcc16070f","muted":false,"name":"","stream_id":"Porches Spotify"},{"clients":[{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":100}},"connected":false,"host":{"arch":"aarch64","ip":"172.16.2.242","mac":"2c:cf:67:47:ca:ca","name":"bonus-sub-musical-pi","os":"Debian GNU/Linux 12 (bookworm)"},"id":"Bonus Sub Pi","lastSeen":{"sec":1718062516,"usec":632403},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.28.0"}}],"id":"46a2b853-5f6e-37a1-00e0-445c98e5826a","muted":false,"name":"","stream_id":"Porches Spotify"},{"clients":[{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":100}},"connected":true,"host":{"arch":"aarch64","ip":"172.16.2.240","mac":"d8:3a:dd:80:a0:cc","name":"family-sub-musical-pi","os":"Debian GNU/Linux 12 (bookworm)"},"id":"Family Sub Pi","lastSeen":{"sec":1718314437,"usec":344666},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.28.0"}}],"id":"28025fcd-1435-67f1-6fed-eb5117aa436c","muted":false,"name":"","stream_id":"Kitchen Spotify"},{"clients":[{"config":{"instance":1,"latency":0,"name":"","volume":{"muted":false,"percent":100}},"connected":true,"host":{"arch":"armv6l","ip":"172.16.1.56","mac":"b8:27:eb:62:a0:01","name":"joey-room-musical-pi","os":"Raspbian GNU/Linux 12 (bookworm)"},"id":"Joey Room Pi","lastSeen":{"sec":1718314437,"usec":51860},"snapclient":{"name":"Snapclient","protocolVersion":2,"version":"0.28.0"}}],"id":"47d70477-d74d-38e1-b949-7a637b34ee27","muted":false,"name":"","stream_id":"Joey Room Spotify"}],"server":{"host":{"arch":"x86_64","ip":"","mac":"","name":"9960edc046a3","os":"Alpine Linux v3.19"},"snapserver":{"controlProtocolVersion":1,"name":"Snapserver","protocolVersion":1,"version":"0.28.0"}},"streams":[{"id":"Porches Spotify","properties":{"canControl":false,"canGoNext":false,"canGoPrevious":false,"canPause":false,"canPlay":false,"canSeek":false,"metadata":{"artData":{"data":"PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIiBoZWlnaHQ9IjE2OHB4IiB3aWR0aD0iMTY4cHgiIHZlcnNpb249IjEuMSIgdmlld0JveD0iMCAwIDE2OCAxNjgiPgogPHBhdGggZmlsbD0iIzFFRDc2MCIgZD0ibTgzLjk5NiAwLjI3N2MtNDYuMjQ5IDAtODMuNzQzIDM3LjQ5My04My43NDMgODMuNzQyIDAgNDYuMjUxIDM3LjQ5NCA4My43NDEgODMuNzQzIDgzLjc0MSA0Ni4yNTQgMCA4My43NDQtMzcuNDkgODMuNzQ0LTgzLjc0MSAwLTQ2LjI0Ni0zNy40OS04My43MzgtODMuNzQ1LTgzLjczOGwwLjAwMS0wLjAwNHptMzguNDA0IDEyMC43OGMtMS41IDIuNDYtNC43MiAzLjI0LTcuMTggMS43My0xOS42NjItMTIuMDEtNDQuNDE0LTE0LjczLTczLjU2NC04LjA3LTIuODA5IDAuNjQtNS42MDktMS4xMi02LjI0OS0zLjkzLTAuNjQzLTIuODEgMS4xMS01LjYxIDMuOTI2LTYuMjUgMzEuOS03LjI5MSA1OS4yNjMtNC4xNSA4MS4zMzcgOS4zNCAyLjQ2IDEuNTEgMy4yNCA0LjcyIDEuNzMgNy4xOHptMTAuMjUtMjIuODA1Yy0xLjg5IDMuMDc1LTUuOTEgNC4wNDUtOC45OCAyLjE1NS0yMi41MS0xMy44MzktNTYuODIzLTE3Ljg0Ni04My40NDgtOS43NjQtMy40NTMgMS4wNDMtNy4xLTAuOTAzLTguMTQ4LTQuMzUtMS4wNC0zLjQ1MyAwLjkwNy03LjA5MyA0LjM1NC04LjE0MyAzMC40MTMtOS4yMjggNjguMjIyLTQuNzU4IDk0LjA3MiAxMS4xMjcgMy4wNyAxLjg5IDQuMDQgNS45MSAyLjE1IDguOTc2di0wLjAwMXptMC44OC0yMy43NDRjLTI2Ljk5LTE2LjAzMS03MS41Mi0xNy41MDUtOTcuMjg5LTkuNjg0LTQuMTM4IDEuMjU1LTguNTE0LTEuMDgxLTkuNzY4LTUuMjE5LTEuMjU0LTQuMTQgMS4wOC04LjUxMyA1LjIyMS05Ljc3MSAyOS41ODEtOC45OCA3OC43NTYtNy4yNDUgMTA5LjgzIDExLjIwMiAzLjczIDIuMjA5IDQuOTUgNy4wMTYgMi43NCAxMC43MzMtMi4yIDMuNzIyLTcuMDIgNC45NDktMTAuNzMgMi43Mzl6Ii8+Cjwvc3ZnPgo=","extension":"svg"},"artUrl":"http://9960edc046a3:1780/__image_cache?name=cd91d51d70227e57d35950777b3d1aac.svg","duration":217.94500732421875,"title":"leave in five"}},"status":"idle","uri":{"fragment":"","host":"","path":"/usr/bin/librespot","query":{"autoplay":"true","bitrate":"320","chunk_ms":"20","codec":"flac","devicename":"Porches","name":"Porches Spotify","sampleformat":"44100:16:2","volume":"50"},"raw":"librespot:////usr/bin/librespot?autoplay=true&bitrate=320&chunk_ms=20&codec=flac&devicename=Porches&name=Porches Spotify&sampleformat=44100:16:2&volume=50","scheme":"librespot"}},{"id":"Kitchen Spotify","properties":{"canControl":false,"canGoNext":false,"canGoPrevious":false,"canPause":false,"canPlay":false,"canSeek":false,"metadata":{"artData":{"data":"PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIiBoZWlnaHQ9IjE2OHB4IiB3aWR0aD0iMTY4cHgiIHZlcnNpb249IjEuMSIgdmlld0JveD0iMCAwIDE2OCAxNjgiPgogPHBhdGggZmlsbD0iIzFFRDc2MCIgZD0ibTgzLjk5NiAwLjI3N2MtNDYuMjQ5IDAtODMuNzQzIDM3LjQ5My04My43NDMgODMuNzQyIDAgNDYuMjUxIDM3LjQ5NCA4My43NDEgODMuNzQzIDgzLjc0MSA0Ni4yNTQgMCA4My43NDQtMzcuNDkgODMuNzQ0LTgzLjc0MSAwLTQ2LjI0Ni0zNy40OS04My43MzgtODMuNzQ1LTgzLjczOGwwLjAwMS0wLjAwNHptMzguNDA0IDEyMC43OGMtMS41IDIuNDYtNC43MiAzLjI0LTcuMTggMS43My0xOS42NjItMTIuMDEtNDQuNDE0LTE0LjczLTczLjU2NC04LjA3LTIuODA5IDAuNjQtNS42MDktMS4xMi02LjI0OS0zLjkzLTAuNjQzLTIuODEgMS4xMS01LjYxIDMuOTI2LTYuMjUgMzEuOS03LjI5MSA1OS4yNjMtNC4xNSA4MS4zMzcgOS4zNCAyLjQ2IDEuNTEgMy4yNCA0LjcyIDEuNzMgNy4xOHptMTAuMjUtMjIuODA1Yy0xLjg5IDMuMDc1LTUuOTEgNC4wNDUtOC45OCAyLjE1NS0yMi41MS0xMy44MzktNTYuODIzLTE3Ljg0Ni04My40NDgtOS43NjQtMy40NTMgMS4wNDMtNy4xLTAuOTAzLTguMTQ4LTQuMzUtMS4wNC0zLjQ1MyAwLjkwNy03LjA5MyA0LjM1NC04LjE0MyAzMC40MTMtOS4yMjggNjguMjIyLTQuNzU4IDk0LjA3MiAxMS4xMjcgMy4wNyAxLjg5IDQuMDQgNS45MSAyLjE1IDguOTc2di0wLjAwMXptMC44OC0yMy43NDRjLTI2Ljk5LTE2LjAzMS03MS41Mi0xNy41MDUtOTcuMjg5LTkuNjg0LTQuMTM4IDEuMjU1LTguNTE0LTEuMDgxLTkuNzY4LTUuMjE5LTEuMjU0LTQuMTQgMS4wOC04LjUxMyA1LjIyMS05Ljc3MSAyOS41ODEtOC45OCA3OC43NTYtNy4yNDUgMTA5LjgzIDExLjIwMiAzLjczIDIuMjA5IDQuOTUgNy4wMTYgMi43NCAxMC43MzMtMi4yIDMuNzIyLTcuMDIgNC45NDktMTAuNzMgMi43Mzl6Ii8+Cjwvc3ZnPgo=","extension":"svg"},"artUrl":"http://9960edc046a3:1780/__image_cache?name=efc69e1ab3519570d890ee4f551bd908.svg","duration":169.99000549316406,"title":"BLEED"}},"status":"idle","uri":{"fragment":"","host":"","path":"/usr/bin/librespot","query":{"autoplay":"true","bitrate":"320","chunk_ms":"20","codec":"flac","devicename":"Kitchen","name":"Kitchen Spotify","sampleformat":"44100:16:2","volume":"50"},"raw":"librespot:////usr/bin/librespot?autoplay=true&bitrate=320&chunk_ms=20&codec=flac&devicename=Kitchen&name=Kitchen Spotify&sampleformat=44100:16:2&volume=50","scheme":"librespot"}},{"id":"Joey Room Spotify","properties":{"canControl":false,"canGoNext":false,"canGoPrevious":false,"canPause":false,"canPlay":false,"canSeek":false,"metadata":{"artData":{"data":"PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjxzdmcgeG1sbnM9Imh0dHA6Ly93d3cudzMub3JnLzIwMDAvc3ZnIiBoZWlnaHQ9IjE2OHB4IiB3aWR0aD0iMTY4cHgiIHZlcnNpb249IjEuMSIgdmlld0JveD0iMCAwIDE2OCAxNjgiPgogPHBhdGggZmlsbD0iIzFFRDc2MCIgZD0ibTgzLjk5NiAwLjI3N2MtNDYuMjQ5IDAtODMuNzQzIDM3LjQ5My04My43NDMgODMuNzQyIDAgNDYuMjUxIDM3LjQ5NCA4My43NDEgODMuNzQzIDgzLjc0MSA0Ni4yNTQgMCA4My43NDQtMzcuNDkgODMuNzQ0LTgzLjc0MSAwLTQ2LjI0Ni0zNy40OS04My43MzgtODMuNzQ1LTgzLjczOGwwLjAwMS0wLjAwNHptMzguNDA0IDEyMC43OGMtMS41IDIuNDYtNC43MiAzLjI0LTcuMTggMS43My0xOS42NjItMTIuMDEtNDQuNDE0LTE0LjczLTczLjU2NC04LjA3LTIuODA5IDAuNjQtNS42MDktMS4xMi02LjI0OS0zLjkzLTAuNjQzLTIuODEgMS4xMS01LjYxIDMuOTI2LTYuMjUgMzEuOS03LjI5MSA1OS4yNjMtNC4xNSA4MS4zMzcgOS4zNCAyLjQ2IDEuNTEgMy4yNCA0LjcyIDEuNzMgNy4xOHptMTAuMjUtMjIuODA1Yy0xLjg5IDMuMDc1LTUuOTEgNC4wNDUtOC45OCAyLjE1NS0yMi41MS0xMy44MzktNTYuODIzLTE3Ljg0Ni04My40NDgtOS43NjQtMy40NTMgMS4wNDMtNy4xLTAuOTAzLTguMTQ4LTQuMzUtMS4wNC0zLjQ1MyAwLjkwNy03LjA5MyA0LjM1NC04LjE0MyAzMC40MTMtOS4yMjggNjguMjIyLTQuNzU4IDk0LjA3MiAxMS4xMjcgMy4wNyAxLjg5IDQuMDQgNS45MSAyLjE1IDguOTc2di0wLjAwMXptMC44OC0yMy43NDRjLTI2Ljk5LTE2LjAzMS03MS41Mi0xNy41MDUtOTcuMjg5LTkuNjg0LTQuMTM4IDEuMjU1LTguNTE0LTEuMDgxLTkuNzY4LTUuMjE5LTEuMjU0LTQuMTQgMS4wOC04LjUxMyA1LjIyMS05Ljc3MSAyOS41ODEtOC45OCA3OC43NTYtNy4yNDUgMTA5LjgzIDExLjIwMiAzLjczIDIuMjA5IDQuOTUgNy4wMTYgMi43NCAxMC43MzMtMi4yIDMuNzIyLTcuMDIgNC45NDktMTAuNzMgMi43Mzl6Ii8+Cjwvc3ZnPgo=","extension":"svg"},"artUrl":"http://9960edc046a3:1780/__image_cache?name=db1b174342c6589a1b1786848c88176d.svg","duration":188.20799255371094,"title":"Endeavor"}},"status":"idle","uri":{"fragment":"","host":"","path":"/usr/bin/librespot","query":{"autoplay":"true","bitrate":"320","chunk_ms":"20","codec":"flac","devicename":"Joey%s Room","name":"Joey Room Spotify","sampleformat":"44100:16:2","volume":"50"},"raw":"librespot:////usr/bin/librespot?autoplay=true&bitrate=320&chunk_ms=20&codec=flac&devicename=Joey%s Room&name=Joey Room Spotify&sampleformat=44100:16:2&volume=50","scheme":"librespot"}}]}}}"#;
    let snapcast_messages = SnapcastDeserializer::de(message, &map).unwrap();

    assert_eq!(snapcast_messages.len(), 1);
    println!("{:?}", snapcast_messages[0]);
  }

  #[test]
  fn deserialize_notification() {
    let map = DashMap::new();

    let message = r#"{"jsonrpc":"2.0","method":"Client.OnVolumeChanged","params":{"id":"test","volume":{"muted":false,"percent":50}}}"#;
    let snapcast_messages = SnapcastDeserializer::de(message, &map).unwrap();

    assert_eq!(snapcast_messages.len(), 1);
    assert_eq!(
      snapcast_messages[0],
      Message::Notification {
        jsonrpc: "2.0".to_string(),
        method: Box::new(Notification::ClientOnVolumeChanged {
          params: Box::new(client::OnVolumeChangedParams {
            id: "test".to_string(),
            volume: client::ClientVolume {
              muted: false,
              percent: 50
            }
          })
        })
      }
    );
  }

  #[test]
  fn deserialize_notification_array() {
    let map = DashMap::new();

    let message = r#"[{"jsonrpc":"2.0","method":"Client.OnVolumeChanged","params":{"id":"e4:5f:01:41:53:4b","volume":{"muted":false,"percent":20}}},{"jsonrpc":"2.0","method":"Client.OnVolumeChanged","params":{"id":"b8:27:eb:19:34:8a","volume":{"muted":false,"percent":21}}},{"jsonrpc":"2.0","method":"Client.OnVolumeChanged","params":{"id":"b8:27:eb:62:26:ab","volume":{"muted":false,"percent":13}}}]"#;
    let snapcast_messages = SnapcastDeserializer::de(message, &map).unwrap();

    assert_eq!(snapcast_messages.len(), 3);
    assert_eq!(
      snapcast_messages[0],
      Message::Notification {
        jsonrpc: "2.0".to_string(),
        method: Box::new(Notification::ClientOnVolumeChanged {
          params: Box::new(client::OnVolumeChangedParams {
            id: "e4:5f:01:41:53:4b".to_string(),
            volume: client::ClientVolume {
              muted: false,
              percent: 20
            }
          })
        })
      }
    );
    assert_eq!(
      snapcast_messages[1],
      Message::Notification {
        jsonrpc: "2.0".to_string(),
        method: Box::new(Notification::ClientOnVolumeChanged {
          params: Box::new(client::OnVolumeChangedParams {
            id: "b8:27:eb:19:34:8a".to_string(),
            volume: client::ClientVolume {
              muted: false,
              percent: 21
            }
          })
        })
      }
    );
    assert_eq!(
      snapcast_messages[2],
      Message::Notification {
        jsonrpc: "2.0".to_string(),
        method: Box::new(Notification::ClientOnVolumeChanged {
          params: Box::new(client::OnVolumeChangedParams {
            id: "b8:27:eb:62:26:ab".to_string(),
            volume: client::ClientVolume {
              muted: false,
              percent: 13
            }
          })
        })
      }
    );
  }
}
