Start creating launcher binary

Author: fintelia

Cargo.lock

@@ -3,14 +3,15 @@ resolver = "2"
 default-members = ["crates/trident"]
 
 members = [
-    "crates/trident",
-    "crates/trident_api",
-    "crates/osutils",
     "crates/docbuilder",
-    "crates/pytest",
+    "crates/launcher",
+    "crates/osutils",
     "crates/pytest_gen",
+    "crates/pytest",
     "crates/sysdefs",
+    "crates/trident_api",
     "crates/trident-proto",
+    "crates/trident",
 ]
 
 [workspace.dependencies]

Cargo.toml

@@ -0,0 +1,38 @@
+[package]
+name = "launcher"
+version = "0.1.0"
+edition = "2021"
+publish = false
+
+[dependencies]
+anyhow = { version = "1.0.82", features = ["backtrace"] }
+log = "0.4.21"
+quick-xml = { version = "0.37.1", features = ["serialize"] }
+reqwest = { version = "0.12.4", default-features = false, features = [
+    "blocking",
+    "default-tls",
+    "charset",
+] } # "http2" is enabled by default but causes a (false positive) CG alert
+semver = "1.0.23"
+serde = { version = "1.0.200", features = ["derive"] }
+serde_path_to_error = "0.1"
+sha2 = "0.10.8"
+thiserror = "1.0.59"
+url = { version = "2.5.0", features = ["serde"] }
+uuid = { version = "1.8.0", features = ["v4", "serde"] }
+clap = { workspace = true, features = ["derive"] }
+systemd-journal-logger = {workspace = true}
+env_logger = { workspace = true}
+tokio = { workspace = true }
+
+sysdefs = { path = "../sysdefs" }
+osutils = { path = "../osutils" }
+trident-proto = { path = "../trident-proto" }
+tonic.workspace = true
+futures = "0.3.32"
+
+[dev-dependencies]
+indoc = "2"
+maplit = "1.0.2"
+mockito = "1.6.0"
+serde_json = "1.0"

crates/launcher/Cargo.toml

@@ -0,0 +1,48 @@
+use serde::{Deserialize, Serialize};
+
+use crate::omaha::event::{EventResult, OmahaEventType};
+
+#[derive(Debug, Eq, thiserror::Error, Serialize, Deserialize, PartialEq)]
+#[serde(rename_all = "kebab-case")]
+pub enum HarpoonError {
+    #[error("Failed to initialize the Harpoon client: {0}")]
+    InitializationError(String),
+
+    #[error("The version provided '{version}' is not valid semver: {inner}")]
+    InvalidVersion { version: String, inner: String },
+
+    #[error("Failed to read machine-id: {0}")]
+    MachineIdRead(String),
+
+    #[error("Failed to read hostname: {0}")]
+    HostnameRead(String),
+
+    #[error("Internal error: {0}")]
+    Internal(String),
+
+    #[error("Failed to send request: {0}")]
+    SendRequest(String),
+
+    #[error("Received an HTTP error: {0}")]
+    HttpError(String),
+
+    #[error("Failed to parse response: {0}")]
+    ParseResponse(String),
+
+    #[error("Received an invalid response from the server: {0}")]
+    InvalidResponse(String),
+
+    #[error("Failed to query for updates: {0}")]
+    QueryError(String),
+
+    #[error("Failed to fetch the updated document: {0}")]
+    FetchError(String),
+
+    #[error(
+        "Expected a yaml document, but the provided URL does not have a .yaml extension '{0}'"
+    )]
+    ExpectedYamlDocument(String),
+
+    #[error("Event '{0:?}:{1:?}' was not acknowledged by server.")]
+    EventNotAcknowledged(OmahaEventType, EventResult),
+}

crates/launcher/src/error.rs

@@ -0,0 +1,39 @@
+use std::fmt::Display;
+
+use osutils::{hostname, machine_id::MachineId};
+
+use crate::error::HarpoonError;
+
+#[derive(Debug, PartialEq, Eq, Clone, Copy)]
+pub enum IdSource {
+    MachineIdHashed,
+    MachineIdRaw,
+    Hostname,
+}
+
+impl Display for IdSource {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        match self {
+            IdSource::MachineIdHashed => write!(f, "machin-id-hashed"),
+            IdSource::MachineIdRaw => write!(f, "machine-id-raw"),
+            IdSource::Hostname => write!(f, "hostname"),
+        }
+    }
+}
+
+impl IdSource {
+    pub(super) fn produce_id(&self) -> Result<String, HarpoonError> {
+        Ok(match self {
+            IdSource::MachineIdHashed => MachineId::read()
+                .map_err(|err| HarpoonError::MachineIdRead(err.to_string()))?
+                .hashed_uuid()
+                .to_string(),
+            IdSource::MachineIdRaw => MachineId::read()
+                .map_err(|err| HarpoonError::MachineIdRead(err.to_string()))?
+                .as_string(),
+            IdSource::Hostname => {
+                hostname::read().map_err(|err| HarpoonError::HostnameRead(err.to_string()))?
+            }
+        })
+    }
+}