feat: implement http client, config load, and schema examples

Author: Jonathan D.A. Jewell

crates/opm-cli/Cargo.toml

@@ -11,6 +11,7 @@ anyhow = "1"
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 toml = "0.8"
+reqwest = { version = "0.12", features = ["json", "rustls-tls"] }
 
 [dev-dependencies]
 assert_cmd = "2"

crates/opm-cli/src/clients/http.rs

@@ -1,8 +1,30 @@
 // SPDX-License-Identifier: PMPL-1.0
 
-use anyhow::Result;
+use anyhow::{Context, Result};
+use reqwest::blocking::Client;
+use reqwest::header::{HeaderMap, HeaderValue, AUTHORIZATION, CONTENT_TYPE};
+
+pub fn post_json(base: &str, path: &str, token: Option<&str>, body: &str) -> Result<()> {
+    let client = Client::new();
+    let mut headers = HeaderMap::new();
+    headers.insert(CONTENT_TYPE, HeaderValue::from_static("application/json"));
+
+    if let Some(token) = token {
+        let value = format!("Bearer {token}");
+        headers.insert(AUTHORIZATION, HeaderValue::from_str(&value)?);
+    }
+
+    let url = format!("{}{}", base.trim_end_matches('/'), path);
+    let resp = client
+        .post(url)
+        .headers(headers)
+        .body(body.to_string())
+        .send()
+        .context("opm http post")?;
+
+    if !resp.status().is_success() {
+        return Err(anyhow::anyhow!("http error: {}", resp.status()));
+    }
 
-pub fn post_json(_base: &str, _path: &str, _token: Option<&str>, _body: &str) -> Result<()> {
-    // TODO: implement HTTP POST for service calls
     Ok(())
 }

crates/opm-cli/src/config.rs

@@ -1,6 +1,8 @@
 // SPDX-License-Identifier: PMPL-1.0
 
 use serde::Deserialize;
+use std::fs;
+use std::path::Path;
 
 #[derive(Debug, Deserialize, Clone)]
 pub struct ServiceConfig {
@@ -42,4 +44,10 @@ impl OpmConfig {
             },
         }
     }
+
+    pub fn load_from(path: impl AsRef<Path>) -> anyhow::Result<Self> {
+        let data = fs::read_to_string(path)?;
+        let cfg = toml::from_str(&data)?;
+        Ok(cfg)
+    }
 }

crates/opm-cli/src/wiring.rs

@@ -7,7 +7,7 @@ use crate::config::OpmConfig;
 
 pub fn publish(path: &str) -> Result<()> {
     println!("opm publish (stub) for {path}");
-    let cfg = OpmConfig::example();
+    let cfg = OpmConfig::load_from("opm.toml").unwrap_or_else(|_| OpmConfig::example());
     clients::claim_forge::attest(path, &cfg.claim_forge.base_url, cfg.claim_forge.token.as_deref())?;
     clients::checky_monkey::analyze(path, &cfg.checky_monkey.base_url, cfg.checky_monkey.token.as_deref())?;
     clients::palimpsest_license::audit(path, &cfg.palimpsest_license.base_url, cfg.palimpsest_license.token.as_deref())?;
@@ -17,7 +17,7 @@ pub fn publish(path: &str) -> Result<()> {
 
 pub fn audit(package: &str) -> Result<()> {
     println!("opm audit (stub) for {package}");
-    let cfg = OpmConfig::example();
+    let cfg = OpmConfig::load_from("opm.toml").unwrap_or_else(|_| OpmConfig::example());
     clients::claim_forge::attest(package, &cfg.claim_forge.base_url, cfg.claim_forge.token.as_deref())?;
     clients::checky_monkey::analyze(package, &cfg.checky_monkey.base_url, cfg.checky_monkey.token.as_deref())?;
     clients::oikos::score(package, &cfg.oikos.base_url, cfg.oikos.token.as_deref())?;

opm-registry-hub/schemas/audit-request.example.json

@@ -0,0 +1,4 @@
+{
+  "package": "example-lib",
+  "version": "1.2.3"
+}

opm-registry-hub/schemas/publish-request.example.json

@@ -0,0 +1,8 @@
+{
+  "path": "./dist/example-lib",
+  "manifest": {
+    "name": "example-lib",
+    "version": "1.2.3",
+    "license": "MIT"
+  }
+}