juiz_core 0.0.9

Core library for JUIZ application. This package is not required if you want to build juiz functional module.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use crate::{brokers::broker_proxy::SystemBrokerProxy, prelude::*};
use juiz_sdk::anyhow::anyhow;

pub(super) fn setup_subsystems(system: &System, manifest: &Value) -> JuizResult<()> {
    log::info!("setup_subsystems(manifest:{manifest:?}) called");
    match manifest.as_array() {
        Some(arr) => {
            for v in arr.iter() {
                setup_subsystem(system, v).or_else(|e| {
                    log::error!("setup_subsystem(manifest={v}) failed. Error: {e:?}");
                    Err(e)
                })?
            }
        }
        None => {
            log::error!("setup_subsystem failed. Record 'subsystems' must be array type.");
            return Err(anyhow!(JuizError::InvalidValueError {
                message: "setup_subsystem failed. Record 'subsystems' must be array type."
                    .to_owned()
            }));
        }
    }
    log::info!("setup_subsystems() successfully exit");
    Ok(())
}

fn setup_subsystem(system: &System, manifest: &Value) -> JuizResult<()> {
    log::info!("setup_subsystem(manifest:{manifest:?}) called");
    system
        .core_broker()
        .lock_mut()?
        .system_add_subsystem(manifest.clone())
        .or_else(|e| {
            log::error!("system.add_subsystem(manifest={manifest}) failed. Error: {e:?}");
            Err(e)
        })?;
    log::info!("setup_subsystem() successfully exit");
    Ok(())
}

pub(super) fn setup_mastersystem(system: &System, manifest: &Value) -> JuizResult<()> {
    log::info!("setup_mastersystem({manifest}) called");
    // let broker_proxy = system.create_broker_proxy(manifest)?;
    // broker_proxy.lock().or_else(|e| { Err(anyhow!(JuizError::ObjectLockError { target: "core_broker".to_owned() }))})?
    //     .system_add_subsystem(manifest)
    let info = jvalue!({
        "subsystem": manifest
    });
    system.core_broker().lock_mut()?.system_add_mastersystem(info).or_else(|e| {
        log::error!("In setup_mastersystem(subsystem.rs), system.add_mastersystem(manifest={manifest}) failed. Error: {e:?}");
        Err(e)
    })?;
    log::info!("setup_mastersystem() successfully exit");
    Ok(())
}