wasm-pkg-client 0.16.0

Wasm package client
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

use std::collections::BTreeMap;

use oci_client::{
    Reference, RegistryOperation,
    annotations::{
        ORG_OPENCONTAINERS_IMAGE_AUTHORS, ORG_OPENCONTAINERS_IMAGE_DESCRIPTION,
        ORG_OPENCONTAINERS_IMAGE_LICENSES, ORG_OPENCONTAINERS_IMAGE_SOURCE,
        ORG_OPENCONTAINERS_IMAGE_TITLE, ORG_OPENCONTAINERS_IMAGE_URL,
        ORG_OPENCONTAINERS_IMAGE_VERSION,
    },
};
use tokio::io::AsyncReadExt;

use crate::publisher::PackagePublisher;
use crate::{PackageRef, PublishingSource, Version};

use super::OciBackend;

#[async_trait::async_trait]
impl PackagePublisher for OciBackend {
    async fn publish(
        &self,
        package: &PackageRef,
        version: &Version,
        mut data: PublishingSource,
        dry_run: bool,
    ) -> Result<(), crate::Error> {
        // NOTE(thomastaylor312): oci-client doesn't support publishing from a stream or reader, so
        // we have to read all the data in for now. Once we can address that upstream, we'll be able
        // to remove this and use the stream directly.
        let mut buf = Vec::new();
        data.read_to_end(&mut buf).await?;
        let payload = wasm_metadata::Payload::from_binary(&buf).map_err(|e| {
            crate::Error::InvalidComponent(anyhow::anyhow!("Unable to parse WASM: {e}"))
        })?;
        let meta = payload.metadata();
        let (config, mut layer) = oci_wasm::WasmConfig::from_raw_component(buf, None)
            .map_err(crate::Error::InvalidComponent)?;
        // Set the layer title so OCI tools can name the file on disk
        layer.annotations = Some(BTreeMap::from_iter([(
            ORG_OPENCONTAINERS_IMAGE_TITLE.to_string(),
            format!("{}.wasm", package.name()),
        )]));
        let mut annotations = BTreeMap::from_iter([(
            ORG_OPENCONTAINERS_IMAGE_VERSION.to_string(),
            version.to_string(),
        )]);
        if let Some(desc) = &meta.description {
            annotations.insert(
                ORG_OPENCONTAINERS_IMAGE_DESCRIPTION.to_string(),
                desc.to_string(),
            );
        }
        if let Some(licenses) = &meta.licenses {
            annotations.insert(
                ORG_OPENCONTAINERS_IMAGE_LICENSES.to_string(),
                licenses.to_string(),
            );
        }
        if let Some(source) = &meta.source {
            annotations.insert(
                ORG_OPENCONTAINERS_IMAGE_SOURCE.to_string(),
                source.to_string(),
            );
        }
        if let Some(homepage) = &meta.homepage {
            annotations.insert(
                ORG_OPENCONTAINERS_IMAGE_URL.to_string(),
                homepage.to_string(),
            );
        }
        if let Some(authors) = &meta.authors {
            annotations.insert(
                ORG_OPENCONTAINERS_IMAGE_AUTHORS.to_string(),
                authors.to_string(),
            );
        }

        let reference: Reference = self.make_reference(package, Some(version));
        let auth = self.auth(&reference, RegistryOperation::Push).await?;
        if !dry_run {
            self.client
                .push(&reference, &auth, layer, config, Some(annotations))
                .await
                .map_err(crate::Error::RegistryError)?;
        }
        Ok(())
    }
}