First pass at integration tests

Some rough edges still exist:

- Issues with running tests in parallel on GH Actions
- Over reliance on magic delays rather than waiting on a condition
- Are the assertions for segment archiving robust enough?

.github/workflows/ci.yml

@@ -33,9 +33,12 @@ jobs:
       - name: Clippy
         run: nix develop --command cargo clippy --all-targets -- -D warnings
 
-      - name: Test
+      - name: Tests
         run: nix develop --command cargo test
 
+      - name: Integration tests
+        run: nix develop --command cargo test integration_tests -- --ignored --test-threads=1
+
   build:
     name: Build
     needs:

Cargo.toml

@@ -10,6 +10,8 @@ members = [
   "archiver",
   "ctl",
   "event-processor",
+
+  "integration-tests",
 ]
 
 [workspace.package]
@@ -31,6 +33,7 @@ crossterm = "0.27"
 futures = "0.3.25"
 hex = "0.4.3"
 hpke = { version = "0.11.0", features = ["std", "serde_impls"] }
+indoc = "2.0.4"
 lazy_static = "1.4.0"
 m3u8-rs = "5.0.3"
 mqtt-channel-client = { version = "0.6.0", features = ["metrics"] }
@@ -42,6 +45,7 @@ ratatui = { version = "0.23.0", features = ["all-widgets"]}
 rayon = "1.7.0"
 regex = "1.7.1"
 reqwest = "0.11.13"
+rumqttc = "0.23.0"
 rust-s3 = "0.34.0-rc4"
 satori-common = { path = "./common" }
 satori-storage = { path = "./storage" }
@@ -51,7 +55,7 @@ serde_with = "3.0"
 serde_json = "1.0.91"
 tempfile = "3.3.0"
 thiserror = "1.0.38"
-tokio = { version = "1.26", features = ["macros", "rt-multi-thread", "signal"] }
+tokio = { version = "1.26", features = ["macros", "rt-multi-thread", "signal", "process"] }
 toml = "0.8"
 tower-http = { version = "0.5.0", features = ["fs"] }
 tracing = "0.1"

agent/Cargo.toml

@@ -15,7 +15,7 @@ satori-common.workspace = true
 serde.workspace = true
 serde_with.workspace = true
 tempfile.workspace = true
-tokio = { workspace = true, features = ["process"] }
+tokio.workspace = true
 tower-http.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true

event-processor/src/config.rs

@@ -28,6 +28,7 @@ pub(crate) struct Config {
 #[derive(Debug, Deserialize)]
 pub(crate) struct TriggersConfig {
     /// Trigger configs that are used when a trigger with a specific ID are issued
+    #[serde(default)]
     pub(crate) templates: HashMap<String, TriggerTemplate>,
 
     /// Trigger defaults that are used when no matching template is found

integration-tests/Cargo.toml

@@ -0,0 +1,15 @@
+[package]
+name = "satori-integration-tests"
+license.workspace = true
+version.workspace = true
+edition.workspace = true
+
+[dev-dependencies]
+ctor.workspace = true
+indoc.workspace = true
+rumqttc.workspace = true
+satori-testing-utils.workspace = true
+tempfile.workspace = true
+tokio.workspace = true
+tracing.workspace = true
+tracing-subscriber.workspace = true

integration-tests/src/integration_tests/mod.rs

@@ -0,0 +1,10 @@
+#[ctor::ctor]
+fn init() {
+    tracing_subscriber::fmt()
+        .with_test_writer()
+        .with_max_level(tracing::Level::DEBUG)
+        .init();
+}
+
+mod one;
+mod two;