harmos-operations 0.1.8

Portable Harmos built-in operations and optional execution.
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

/* ***
 *
 * Harmos
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * ***
 */

/* === Modules === */

/* === Re-Exports === */

/* === Imports === */

#[cfg(feature = "runtime")]
use harmos_sdk::operations::publication::PublicationAccess;

pub use harmos_domain::model::operations::publication::FollowingRow;

/* === Constants === */

/* === Macros === */

harmos_domain::builtin_payload! {
    #[harmos::operation(harmos_path = crate, id = "host.publish", policy = crate::host::POLICY,
        codec = manual, visibility = Shared, resources = [PublicationAccess])]
    Publish,
    stream: String => (1, Kind::String, Required),
    schema: u32 => (2, Kind::U32, Required),
    sequence: Option<u64> => (3, Kind::U64, Optional),
    published_unix_micros: Option<i64> => (4, Kind::I64, Optional),
    context: Option<String> => (5, Kind::String, Optional),
    payload: Vec<u8> => (6, Kind::Bytes, Required),
    following: Vec<FollowingRow> => (7, Kind::Message { definition: FollowingRow::DEFINITION }, Repeated),
}

/* === Type Aliases === */

/* === Structs === */

/* === Enums === */

/* === Traits === */

/* === Implementations === */

#[cfg(feature = "runtime")]
impl crate::Operation for Publish {
    type Error = crate::Error;

    async fn run(mut self, context: harmos_sdk::Context<'_, Self>) -> Result<crate::Response<()>, Self::Error> {
        let access = context.resource::<harmos_sdk::operations::publication::PublicationAccess>();

        let publication = harmos_sdk::operations::publication::Publication {
            stream: &self.stream,
            schema: self.schema,
            sequence: self.sequence,
            published_unix_micros: self.published_unix_micros,
            context: &mut self.context,
            payload: &mut self.payload,
            following: &mut self.following,
        };
        access.0.publish(context.call().clone(), publication).await.map_err(crate::Error::Access)?;
        Ok(().into())
    }
}

/* === Public Functions === */

/* === Private Functions === */

/* === Tests === */