use serde::{Deserialize, Serialize};
use serde_json::{json, Map, Value};
use super::js_trim;
use super::package::PackageIssue;
use crate::generated::catalog::ICON_NAMES;
pub const MAX_SCREENS: usize = 5;
pub const MAX_SCREEN_TITLE: usize = 32;
pub const NAVIGATE_FUNCTION: &str = "app.navigate";
pub const SCREEN_PARAMS_KEY: &str = "params";
const SCREEN_KEYS: &[&str] = &["template", "title", "icon", "params"];
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct ResolvedScreen {
pub screen: String,
pub title: String,
pub icon: Option<String>,
pub params: Map<String, Value>,
}
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
pub struct NavigateTarget {
pub screen: String,
pub params: Map<String, Value>,
}
fn issue(path: impl Into<String>, message: impl Into<String>) -> PackageIssue {
PackageIssue { path: path.into(), message: message.into() }
}
fn escape(k: &str) -> String {
k.replace('~', "~0").replace('/', "~1")
}
fn sorted_keys(o: &Map<String, Value>) -> Vec<&String> {
let mut keys: Vec<&String> = o.keys().collect();
keys.sort();
keys
}
pub fn validate_package_screens(pkg: &Map<String, Value>) -> Vec<PackageIssue> {
let Some(list) = pkg.get("screens") else { return Vec::new() };
let Some(list) = list.as_array().filter(|l| !l.is_empty()) else {
return vec![issue("/screens", "screens is a non-empty list of {template, title, icon?, params?}")];
};
let mut issues = Vec::new();
if list.len() > MAX_SCREENS {
issues.push(issue("/screens", format!("at most {MAX_SCREENS} screens, got {}", list.len())));
}
let empty = Map::new();
let templates = pkg.get("templates").and_then(Value::as_object).unwrap_or(&empty);
let mut seen: Vec<String> = Vec::new();
for (i, s) in list.iter().enumerate() {
let at = format!("/screens/{i}");
let Some(s) = s.as_object() else {
issues.push(issue(&at, "a screen is {template, title, icon?, params?}"));
continue;
};
for k in sorted_keys(s) {
if !SCREEN_KEYS.contains(&k.as_str()) {
issues.push(issue(format!("{at}/{}", escape(k)), format!("unknown screen key {k}")));
}
}
match s.get("template").and_then(Value::as_str).filter(|t| !t.is_empty()) {
None => issues.push(issue(format!("{at}/template"), "template is a required string")),
Some(t) if !templates.contains_key(t) => issues.push(issue(format!("{at}/template"), format!("template {t} names no package template"))),
Some(t) if seen.iter().any(|x| x == t) => issues.push(issue(format!("{at}/template"), format!("duplicate screen {t}"))),
Some(t) => seen.push(t.to_string()),
}
match s.get("title").and_then(Value::as_str) {
Some(t) if !js_trim(t).is_empty() => {
if t.chars().count() > MAX_SCREEN_TITLE {
issues.push(issue(format!("{at}/title"), format!("title is at most {MAX_SCREEN_TITLE} characters")));
}
}
_ => issues.push(issue(format!("{at}/title"), "title is a required string")),
}
if let Some(icon) = s.get("icon") {
if !icon.as_str().is_some_and(|n| ICON_NAMES.contains(&n)) {
let shown = icon.as_str().map(str::to_string).unwrap_or_else(|| icon.to_string());
issues.push(issue(format!("{at}/icon"), format!("icon {shown} is not an Exponential UI icon")));
}
}
if let Some(params) = s.get("params") {
match params.as_object() {
None => issues.push(issue(format!("{at}/params"), "params is an object of strings")),
Some(params) => {
for k in sorted_keys(params) {
if !params[k].is_string() {
issues.push(issue(format!("{at}/params/{}", escape(k)), format!("params.{k} is a string")));
}
}
}
}
}
}
issues.extend(navigate_issues(pkg, &seen));
issues
}
fn cel_string_literal(v: &Value) -> Option<String> {
let s = js_trim(v.as_str()?);
for q in ['\'', '"'] {
if s.len() >= 2 && s.starts_with(q) && s.ends_with(q) {
let inner = &s[1..s.len() - 1];
if !inner.contains(q) && !inner.contains('\\') {
return Some(inner.to_string());
}
}
}
None
}
fn navigate_issues(pkg: &Map<String, Value>, screens: &[String]) -> Vec<PackageIssue> {
let mut issues = Vec::new();
let check = |screen: Option<String>, at: String, issues: &mut Vec<PackageIssue>| {
if let Some(screen) = screen {
if !screens.iter().any(|s| *s == screen) {
issues.push(issue(at, format!("navigate: {screen} is not a screen")));
}
}
};
if let Some(templates) = pkg.get("templates").and_then(Value::as_object) {
for id in sorted_keys(templates) {
let Some(components) = templates[id].get("components").and_then(Value::as_array) else { continue };
for (i, c) in components.iter().enumerate() {
let Some(on) = c.get("on").and_then(Value::as_object) else { continue };
for event in sorted_keys(on) {
let Some(fc) = on[event].get("functionCall").filter(|f| f.is_object()) else { continue };
if fc.get("call").and_then(Value::as_str) != Some(NAVIGATE_FUNCTION) {
continue;
}
let at = format!("/templates/{}/components/{i}/on/{}/functionCall/args", escape(id), escape(event));
match fc.get("args").and_then(Value::as_object) {
None => issues.push(issue(at, "navigate takes {screen, params?}")),
Some(args) => check(args.get("screen").and_then(Value::as_str).map(str::to_string), format!("{at}/screen"), &mut issues),
}
}
}
}
}
if let Some(actions) = pkg.get("actions").and_then(Value::as_object) {
for name in sorted_keys(actions) {
let Some(steps) = actions[name].get("steps").and_then(Value::as_array) else { continue };
for (i, step) in steps.iter().enumerate() {
if !step.is_object() || step.get("call").and_then(Value::as_str) != Some(NAVIGATE_FUNCTION) {
continue;
}
let at = format!("/actions/{}/steps/{i}/args", escape(name));
match step.get("args").and_then(Value::as_object) {
None => issues.push(issue(at, "navigate takes {screen, params?}")),
Some(args) => check(args.get("screen").and_then(cel_string_literal), format!("{at}/screen"), &mut issues),
}
}
}
}
issues
}
pub fn package_screens(pkg: &Value) -> Vec<&Map<String, Value>> {
pkg.get("screens").and_then(Value::as_array).into_iter().flatten().filter_map(Value::as_object).filter(|s| s.get("template").is_some_and(Value::is_string)).collect()
}
pub fn resolve_screen(pkg: &Value, screen: Option<&str>, params: Option<&Value>) -> Option<ResolvedScreen> {
let screens = package_screens(pkg);
let picked = screens.iter().find(|s| s.get("template").and_then(Value::as_str) == screen).or(screens.first())?;
let mut merged = Map::new();
for source in [picked.get("params"), params] {
let Some(o) = source.and_then(Value::as_object) else { continue };
for k in sorted_keys(o) {
if o[k].is_string() {
merged.insert(k.clone(), o[k].clone());
}
}
}
Some(ResolvedScreen {
screen: picked["template"].as_str().unwrap_or_default().to_string(),
title: picked.get("title").and_then(Value::as_str).unwrap_or_default().to_string(),
icon: picked.get("icon").and_then(Value::as_str).map(str::to_string),
params: merged,
})
}
pub fn navigate_target(pkg: &Value, args: &Value) -> Result<NavigateTarget, String> {
let Some(args) = args.as_object() else { return Err("navigate takes {screen, params?}".into()) };
let Some(screen) = args.get("screen").and_then(Value::as_str).filter(|s| !s.is_empty()) else { return Err("navigate: screen is a required string".into()) };
if !package_screens(pkg).iter().any(|s| s.get("template").and_then(Value::as_str) == Some(screen)) {
return Err(format!("navigate: {screen} is not a screen"));
}
let mut params = Map::new();
match args.get("params") {
None | Some(Value::Null) => {}
Some(Value::Object(o)) => {
for k in sorted_keys(o) {
if !o[k].is_string() {
return Err(format!("navigate: params.{k} is a string"));
}
params.insert(k.clone(), o[k].clone());
}
}
Some(_) => return Err("navigate: params is an object of strings".into()),
}
Ok(NavigateTarget { screen: screen.to_string(), params })
}
pub fn navigate_target_value(pkg: &Value, args: &Value) -> Value {
match navigate_target(pkg, args) {
Ok(t) => json!({"screen": t.screen, "params": t.params}),
Err(error) => json!({"error": error}),
}
}
pub fn screen_data(screen: &ResolvedScreen) -> Value {
json!({ SCREEN_PARAMS_KEY: screen.params })
}
pub fn fill_screen_params(source: &str, params: Option<&Value>) -> String {
let Some(params) = params.and_then(Value::as_object) else { return source.to_string() };
if !source.contains("${params.") {
return source.to_string();
}
let mut out = String::with_capacity(source.len());
let mut rest = source;
while let Some(at) = rest.find("${params.") {
out.push_str(&rest[..at]);
let after = &rest[at + "${params.".len()..];
let key_len = after.bytes().take_while(|b| b.is_ascii_alphanumeric() || *b == b'_').count();
if key_len > 0 && after[key_len..].starts_with('}') {
if let Some(v) = params.get(&after[..key_len]).and_then(Value::as_str) {
out.push_str(&super::sources::encode_component(v));
}
rest = &after[key_len + 1..];
} else {
out.push_str("${params.");
rest = after;
}
}
out.push_str(rest);
out
}