use std::collections::HashMap;
use embedder_traits::Theme;
use log::warn;
use malloc_size_of_derive::MallocSizeOf;
use serde::Serialize;
use serde_json::{Map, Value};
use crate::actor::{Actor, ActorEncode, ActorError, ActorRegistry};
use crate::actors::browsing_context::BrowsingContextActor;
use crate::actors::tab::TabDescriptorActor;
use crate::protocol::ClientRequest;
use crate::{EmptyReplyMsg, RootActor, StreamId};
#[derive(Serialize)]
#[serde(rename_all = "camelCase")]
pub(crate) struct TargetConfigurationTraits {
supported_options: HashMap<&'static str, bool>,
}
#[derive(Serialize)]
pub(crate) struct TargetConfigurationActorMsg {
actor: String,
configuration: HashMap<&'static str, bool>,
traits: TargetConfigurationTraits,
}
#[derive(MallocSizeOf)]
pub(crate) struct TargetConfigurationActor {
name: String,
configuration: HashMap<&'static str, bool>,
supported_options: HashMap<&'static str, bool>,
}
#[derive(Serialize)]
#[serde(rename_all = "camelCase")]
struct JavascriptEnabledReply {
from: String,
javascript_enabled: bool,
}
impl Actor for TargetConfigurationActor {
fn name(&self) -> String {
self.name.clone()
}
fn handle_message(
&self,
request: ClientRequest,
registry: &ActorRegistry,
msg_type: &str,
msg: &Map<String, Value>,
_id: StreamId,
) -> Result<(), ActorError> {
match msg_type {
"updateConfiguration" => {
let config = msg
.get("configuration")
.ok_or(ActorError::MissingParameter)?
.as_object()
.ok_or(ActorError::BadParameterType)?;
if let Some(scheme) = config.get("colorSchemeSimulation").and_then(|v| v.as_str()) {
let theme = match scheme {
"dark" => Theme::Dark,
"light" => Theme::Light,
_ => Theme::Light,
};
let root_actor = registry.find::<RootActor>("root");
if let Some(tab_name) = root_actor.active_tab() {
let tab_descriptor_actor = registry.find::<TabDescriptorActor>(&tab_name);
let browsing_context_actor = registry.find::<BrowsingContextActor>(
&tab_descriptor_actor.browsing_context_name,
);
browsing_context_actor
.simulate_color_scheme(theme)
.map_err(|_| ActorError::Internal)?;
} else {
warn!("No active tab for updateConfiguration");
}
}
let msg = EmptyReplyMsg { from: self.name() };
request.reply_final(&msg)?
},
"isJavascriptEnabled" => {
let msg = JavascriptEnabledReply {
from: self.name(),
javascript_enabled: true,
};
request.reply_final(&msg)?
},
_ => return Err(ActorError::UnrecognizedPacketType),
};
Ok(())
}
}
impl TargetConfigurationActor {
pub fn register(registry: &ActorRegistry) -> String {
let name = registry.new_name::<Self>();
let actor = Self {
name: name.clone(),
configuration: HashMap::new(),
supported_options: HashMap::from([
("cacheDisabled", false),
("colorSchemeSimulation", true),
("customFormatters", false),
("customUserAgent", false),
("javascriptEnabled", false),
("overrideDPPX", false),
("printSimulationEnabled", false),
("rdmPaneMaxTouchPoints", false),
("rdmPaneOrientation", false),
("recordAllocations", false),
("reloadOnTouchSimulationToggle", false),
("restoreFocus", false),
("serviceWorkersTestingEnabled", false),
("setTabOffline", false),
("touchEventsOverride", false),
("tracerOptions", false),
("useSimpleHighlightersForReducedMotion", false),
]),
};
registry.register::<Self>(actor);
name
}
}
impl ActorEncode<TargetConfigurationActorMsg> for TargetConfigurationActor {
fn encode(&self, _: &ActorRegistry) -> TargetConfigurationActorMsg {
TargetConfigurationActorMsg {
actor: self.name(),
configuration: self.configuration.clone(),
traits: TargetConfigurationTraits {
supported_options: self.supported_options.clone(),
},
}
}
}