juiz_core 0.0.5

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

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

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(())
}