wasm-pkg-client 0.15.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

use std::collections::BTreeMap;

use oci_client::{Reference, RegistryOperation};
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,
    ) -> 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, layer) = oci_wasm::WasmConfig::from_raw_component(buf, None)
            .map_err(crate::Error::InvalidComponent)?;
        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?;
        self.client
            .push(&reference, &auth, layer, config, Some(annotations))
            .await
            .map_err(crate::Error::RegistryError)?;
        Ok(())
    }
}