feat: add systemd service and user creation

Author: d-perl

Cargo.toml

@@ -12,7 +12,11 @@ edition = "2024"
 [package.metadata.generate-rpm]
 assets = [
     { source = "target/release/bec_log_ingestor", dest = "/usr/local/bin/bec_log_ingestor", mode = "755" },
+    { source = "install/bec_log_ingestor.service", dest = "/lib/systemd/system/bec_log_ingestor.service", mode = "755" },
 ]
+pre_install_script = "install/setup_user"
+pre_install_script_prog = ["/bin/bash"]
+pre_install_script_flags = 0b100
 
 [dependencies]
 chrono = "0.4.41"

README.md

@@ -4,6 +4,8 @@
 
 Tiny service to pull BEC logs from Redis and push them to Elastic.
 
+To use the systemd service as-is, a config should be created at `/etc/bec_log_ingestor.toml`, following the example in `install/example_config.toml`.
+
 Published RPM packages are signed by PGP, the corresponding public key is:
 
 ```

install/bec_log_ingestor.service

@@ -0,0 +1,15 @@
+[Unit]
+Description=bec-log-ingestor service
+
+[Service]
+Type=oneshot
+RemainAfterExit=yes
+User=bec_log_ingestor
+ExecStart=/usr/local/bin/bec_log_ingestor -c /etc/bec_log_ingestor.toml
+Restart=on-failure
+RestartSec=5
+StartLimitBurst=3
+StartLimitIntervalSec=120
+
+[Install]
+WantedBy=multi-user.target

src/example_config.toml install/example_config.tomlsrc/example_config.toml renamed to install/example_config.toml

@@ -0,0 +1,7 @@
+# Create the user 'bec_log_ingestor' if it does not exist
+if id "bec_log_ingestor" &>/dev/null; then
+    echo "User 'bec_log_ingestor' already exists."
+else
+    useradd --system --create-home --shell /bin/bash bec_log_ingestor
+    echo "User 'bec_log_ingestor' created."
+fi

install/setup_user

@@ -21,8 +21,7 @@ fn json_from_logmsg(
     msg: &LogMsg,
     config: &ElasticConfig,
 ) -> Result<serde_json::Value, serde_json::Error> {
-    // dbg!(serde_json::to_value(record))
-    dbg!(Ok(serde_json::json!({
+    Ok(serde_json::json!({
         "@timestamp": msg.record.time.as_rfc3339(),
         "file": msg.record.file,
         "function": msg.record.function,
@@ -34,7 +33,7 @@ fn json_from_logmsg(
         "beamline_name": config.beamline_name,
         "proc_id": msg.record.process.id,
         "exception": msg.record.exception,
-    })))
+    }))
 }
 
 fn make_json_body(