ax 2.18.2

ax distributed event databank and command line tool
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

use crate::cmd::AxCliCommand;
use ax_core::{
    certs::{AppDomain, DeveloperCertificateInput, ManifestDeveloperCertificate},
    crypto::{PrivateKey, PublicKey},
    util::formats::{ActyxOSCode, ActyxOSResult, ActyxOSResultExt},
};
use futures::{stream::once, FutureExt, Stream};

#[derive(clap::Parser, Clone, Debug)]
pub struct DevCertOpts {
    /// The secret key used to sign the certificate
    /// (this must match the AX_PUBLIC_KEY your `actyx` binary has been compiled with).
    #[arg(long, short = 'A', env, hide_env_values = true)]
    ax_secret_key: PrivateKey,

    /// The developer's public key.
    #[arg(long, short)]
    dev_public_key: PublicKey,

    /// The app id domains for which to certify the developer.
    #[arg(long, short)]
    app_domains: Vec<AppDomain>,
}

pub struct UsersDevCert;

impl AxCliCommand for UsersDevCert {
    type Opt = DevCertOpts;
    type Output = String;

    fn run(opts: Self::Opt) -> Box<dyn Stream<Item = ActyxOSResult<Self::Output>> + Unpin> {
        Box::new(once(
            async move {
                let input = DeveloperCertificateInput::new(opts.dev_public_key, opts.app_domains);
                let dev_cert = ManifestDeveloperCertificate::new(input, opts.ax_secret_key)
                    .ax_err(ActyxOSCode::ERR_INTERNAL_ERROR)?;
                serde_json::to_string(&dev_cert).ax_err(ActyxOSCode::ERR_INTERNAL_ERROR)
            }
            .boxed(),
        ))
    }

    fn pretty(result: Self::Output) -> String {
        result
    }
}