acts-channel 0.8.0

acts client channel for acts-server
Documentation 
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

# acts-channel


[![Build](https://github.com/yaojianpin/acts-channel/actions/workflows/build.yml/badge.svg)](https://github.com/yaojianpin/acts-channel/actions?workflow=build)

provides an acts client channel for workflow engine server [`acts-server`](https://github.com/yaojianpin/acts-server)

The crate is called acts-channel and you can depend on it via cargo:

```toml
[dependencies]
acts-channel = "*"
```

If you want to use the git version:

```toml
[dependencies]
acts-channel = { git = "https://github.com/yaojianpin/acts-channel.git" }
```

# Usage


Before connecting, please download [`acts-server`](https://github.com/yaojianpin/acts-server) and start it

## Message


Listening to the message from [`acts-server`](https://github.com/yaojianpin/acts-server)

```rust,ignore
use acts_channel::{ActsChannel, ActsOptions};

let url = format!("http://{hostname}:{port}");

// connect to server
let mut client = ActsChannel::connect(&url).await?;

// subscribe the messages
client
    .subscribe(
        "client-1",
        move |message| {
            println!("{message:?}");
        },
        &ActsOptions::default(),
    )
    .await;

```

## Action


Executes action to interact with acts-server, such as `deploy`, `start`, `ack`, `send`, etc. For more information, please see [`acts-server`](https://github.com/yaojianpin/acts-server)

### Publish


```rust,ignore
let yml = r"
    id: test
    name: model test
    steps:
        - name: step 1
    ";
let resp = client
    .deploy(yml, Some("custom_model_id")).await?;
assert_eq!(resp.data.unwrap(), true);
```

### Start


```rust,ignore
let mut vars = Vars::new();
vars.set("var1", true);
client
    .submit("pid", "tid", vars).await?;

```

### do act


```rust,ignore
    // set some other vars
    let vars = Vars::new();

    // combine with pid and tid
    let options = Vars::new().with("pid", pid).with("tid", tid).extend(&vars);

    // name should be one of complete, submit, back, cancel, error, abort, push and remove
    let name = "complete";
    client
        .send::<()>(name, options)
        .await
        .map_err(|err| err.message().to_string())?;
```

### Ack a message


```rust,ignore
    let resp = client
        // id is message id
        .ack(id)
        .await
        .map_err(|err| err.message().to_string())?;
```