juiz_core 0.0.13

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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

//! System を起動して BrokerProxy の API を叩くテスト用の共通部品
//!
//! Rust / Python / C++ のプロセスとコンテナを読み込んだ System を作る。
//! C++ の例は CI の "Build C++ examples" で ../target にビルドされ、
//! Rust の例は cargo build で ../target/debug にビルドされている前提。

#![allow(dead_code)]

use juiz_core::prelude::*;
use juiz_sdk::process_identifier::ProcessIdentifier;

pub fn system_manifest(name: &str, port: i64) -> Value {
    jvalue!({
        "name": name,
        "option": {
            "http_broker": { "start": true, "port": port },
            // Python プラグインの位置からの相対パス (tests/python -> リポジトリルート)
            "pythonpath": ["../../../bindings/pyjuiz"]
        },
        "plugins": {
            "process_factories": {
                "increment_process": { "path": "../target/debug" },
                "py_increment": { "language": "python", "path": "tests/python" },
                "increment_process_cpp": { "language": "c++", "path": "../target" }
            },
            "container_factories": {
                "example_container": {
                    "path": "../target/debug",
                    "processes": {
                        "example_container_increment": { "path": "../target/debug" },
                        "example_container_get": { "path": "../target/debug" }
                    }
                },
                "py_counter": {
                    "language": "python",
                    "path": "tests/python",
                    "processes": {
                        "py_counter_add": { "path": "tests/python" },
                        "py_counter_get": { "path": "tests/python" }
                    }
                },
                "example_container_cpp": {
                    "language": "c++",
                    "path": "../target",
                    "processes": {
                        "example_container_cpp_increment": { "path": "../target" },
                        "example_container_cpp_get": { "path": "../target" }
                    }
                }
            },
            "ec_factories": {
                "timer_ec": { "path": "../target/debug" }
            }
        },
        "processes": [
            { "type_name": "increment_process", "name": "inc0" },
            { "type_name": "py_increment", "name": "pyinc0" },
            { "type_name": "increment_process_cpp", "name": "cppinc0" }
        ],
        "containers": [
            { "type_name": "example_container", "name": "c0",
              "processes": [
                  { "type_name": "example_container_increment", "name": "c0inc" },
                  { "type_name": "example_container_get", "name": "c0get" } ] },
            { "type_name": "py_counter", "name": "pyc0",
              "processes": [
                  { "type_name": "py_counter_add", "name": "pyc0add" },
                  { "type_name": "py_counter_get", "name": "pyc0get" } ] },
            { "type_name": "example_container_cpp", "name": "cppc0",
              "processes": [
                  { "type_name": "example_container_cpp_increment", "name": "cppc0inc" },
                  { "type_name": "example_container_cpp_get", "name": "cppc0get" } ] }
        ],
        "ecs": [
            { "type_name": "TimerEC", "name": "timer0", "rate": 0.01 }
        ]
    })
}

/// 各言語のプロセス (名前, 型名)
pub const PROCESSES: [(&str, &str); 3] = [
    ("inc0", "increment_process"),
    ("pyinc0", "py_increment"),
    ("cppinc0", "increment_process_cpp"),
];

/// 各言語のコンテナ (コンテナ名, 加算プロセス名, 加算の引数名, 取得プロセス名)
pub const CONTAINERS: [(&str, &str, &str, &str); 3] = [
    ("c0", "c0inc", "arg1", "c0get"),
    ("pyc0", "pyc0add", "arg1", "pyc0get"),
    ("cppc0", "cppc0inc", "arg0", "cppc0get"),
];

pub fn find_process<'a>(ids: &'a [ProcessIdentifier], name: &str) -> &'a ProcessIdentifier {
    ids.iter()
        .find(|id| id.name == name)
        .unwrap_or_else(|| panic!("process {name} not found in {ids:?}"))
}

pub fn int_of(c: JuizResult<CapsulePtr>) -> i64 {
    c.expect("call failed")
        .lock_as_value(|v| v.as_i64().expect("not an integer"))
        .unwrap()
}

/// get_output などでカプセルが Value でない場合も考えて、整数として取り出す
pub fn try_int_of(c: &CapsulePtr) -> Option<i64> {
    c.lock_as_value(|v| v.as_i64()).ok().flatten()
}