use std::collections::HashMap;
use std::sync::Arc;
use devtools_traits::CssDatabaseProperty;
use malloc_size_of_derive::MallocSizeOf;
use serde::Serialize;
use serde_json::{Map, Value};
use crate::StreamId;
use crate::actor::{Actor, ActorError, ActorRegistry, new_actor_name};
use crate::protocol::ClientRequest;
#[derive(MallocSizeOf)]
pub(crate) struct CssPropertiesActor {
name: String,
properties: HashMap<String, CssDatabaseProperty>,
}
#[derive(Serialize)]
struct GetCssDatabaseReply<'a> {
from: String,
properties: &'a HashMap<String, CssDatabaseProperty>,
}
impl Actor for CssPropertiesActor {
fn name(&self) -> &str {
&self.name
}
fn handle_message(
&self,
request: ClientRequest,
_registry: &ActorRegistry,
msg_type: &str,
_msg: &Map<String, Value>,
_id: StreamId,
) -> Result<(), ActorError> {
match msg_type {
"getCSSDatabase" => request.reply_final(&GetCssDatabaseReply {
from: self.name().into(),
properties: &self.properties,
})?,
_ => return Err(ActorError::UnrecognizedPacketType),
};
Ok(())
}
}
impl CssPropertiesActor {
pub fn register(
registry: &ActorRegistry,
properties: HashMap<String, CssDatabaseProperty>,
) -> Arc<Self> {
let name = new_actor_name::<Self>();
let actor = Self { name, properties };
registry.register::<Self>(actor)
}
}