actrpc-orchestrator 0.1.0

Configuration and orchestration utilities for ActRPC.
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

use actrpc_core::{DescribeValue, json_rpc::JsonRpcMessage, participant::Participant};
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
pub struct TranscriptEntry {
    pub from: Participant,
    pub to: Participant,
    pub seq: u64,
    pub ts: f64,
    pub message: JsonRpcMessage,
}

#[derive(Debug, Clone, PartialEq, Serialize, Deserialize, DescribeValue)]
pub struct TranscriptEntryView {
    pub from: String,
    pub to: String,
    pub seq: u64,
    pub ts: f64,
    pub message: serde_json::Value,
}

impl From<TranscriptEntry> for TranscriptEntryView {
    fn from(value: TranscriptEntry) -> Self {
        Self {
            from: value.from.to_string(),
            to: value.to.to_string(),
            seq: value.seq,
            ts: value.ts,
            message: serde_json::to_value(value.message).expect("JsonRpcMessage should serialize"),
        }
    }
}