Feat/logging local (#2103)

* wip: Working on sockets, but can't connect?

* simplify unix socket connection

* wip: Get responses back from the server at least once.

* WIP: Get the sockets working'

* feat: Sockets can start/ stop/ config/ properites/ uninstall

* fix: Restart services

* Fix: Sockets work and can stop main and not kill client

* chore: Add logging to service

Co-authored-by: Aiden McClelland <me@drbonez.dev>

libs/embassy_container_init/src/lib.rs

@@ -56,6 +56,49 @@ impl RpcMethod for RunCommand {
     }
 }
 
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub enum LogLevel {
+    Trace(String),
+    Warn(String),
+    Error(String),
+    Info(String),
+    Debug(String),
+}
+impl LogLevel {
+    pub fn trace(&self) {
+        match self {
+            LogLevel::Trace(x) => tracing::trace!("{}", x),
+            LogLevel::Warn(x) => tracing::warn!("{}", x),
+            LogLevel::Error(x) => tracing::error!("{}", x),
+            LogLevel::Info(x) => tracing::info!("{}", x),
+            LogLevel::Debug(x) => tracing::debug!("{}", x),
+        }
+    }
+}
+
+#[derive(Debug, Clone, Copy)]
+pub struct Log;
+impl Serialize for Log {
+    fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
+    where
+        S: Serializer,
+    {
+        Serialize::serialize(Self.as_str(), serializer)
+    }
+}
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct LogParams {
+    pub gid: Option<ProcessGroupId>,
+    pub level: LogLevel,
+}
+impl RpcMethod for Log {
+    type Params = LogParams;
+    type Response = ();
+    fn as_str<'a>(&'a self) -> &'a str {
+        "log"
+    }
+}
+
 #[derive(Debug, Clone, Copy)]
 pub struct ReadLineStdout;
 impl Serialize for ReadLineStdout {

libs/embassy_container_init/src/main.rs

@@ -6,7 +6,7 @@ use std::sync::Arc;
 
 use embassy_container_init::{
     OutputParams, OutputStrategy, ProcessGroupId, ProcessId, ReadLineStderrParams,
-    ReadLineStdoutParams, RunCommandParams, SendSignalParams, SignalGroupParams,
+    ReadLineStdoutParams, RunCommandParams, SendSignalParams, SignalGroupParams, LogParams,
 };
 use futures::StreamExt;
 use helpers::NonDetachingJoinHandle;
@@ -28,6 +28,7 @@ enum Output {
     ReadLineStdout(String),
     ReadLineStderr(String),
     Output(String),
+    Log,
     Signal,
     SignalGroup,
 }
@@ -37,6 +38,8 @@ enum Output {
 enum Input {
     /// Run a new command, with the args
     Command(RunCommandParams),
+    /// Want to log locall on the service rather than the eos
+    Log(LogParams),
     // /// Get a line of stdout from the command
     // ReadLineStdout(ReadLineStdoutParams),
     // /// Get a line of stderr from the command
@@ -100,6 +103,10 @@ impl Handler {
             // Input::ReadLineStderr(ReadLineStderrParams { pid }) => {
             //     Output::ReadLineStderr(self.read_line_stderr(pid).await?)
             // }
+            Input::Log(LogParams { gid, level }) => {
+                level.trace();
+                Output::Log
+            }
             Input::Output(OutputParams { pid }) => Output::Output(self.output(pid).await?),
             Input::Signal(SendSignalParams { pid, signal }) => {
                 self.signal(pid, signal).await?;