Add subscription code

Author: Jake-Shadle

.github/workflows/ci.yml

@@ -74,7 +74,7 @@ jobs:
         run: curl -LsSf https://get.nexte.st/latest/linux | tar zxf - -C ${CARGO_HOME:-~/.cargo}/bin
       - name: Build
         run: cargo build -p qt -p quilkin -p quilkin-xds --tests
-      - run: cargo nextest run --no-tests=pass -p qt -p quilkin -p quilkin-xds -p corrosion
+      - run: cargo nextest run --no-tests=pass -p qt -p quilkin -p quilkin-xds -p corrosion-tests
       - name: Validate Quilkin's clap arguments
         run: |
           set +e # don't fail on error, we expect the command to fail since we aren't providing arguments

Cargo.lock

@@ -191,7 +191,7 @@ members = [
     ".",
     "crates/agones",
     "crates/corrosion",
-    "crates/corrosion-utils",
+    "crates/corrosion-tests",
     "crates/macros",
     #"crates/nmap-service-probes",
     "crates/proto-gen",
@@ -215,7 +215,6 @@ base64 = "0.22.1"
 bytes = { version = "1.10.1", features = ["serde"] }
 cached = { version = "0.54", default-features = false }
 corrosion = { path = "crates/corrosion" }
-corrosion-utils = { path = "crates/corrosion-utils" }
 eyre = "0.6.12"
 enum-map = "2.7.3"
 futures = "0.3.31"
@@ -279,6 +278,7 @@ corro-client = { git = "https://github.com/EmbarkStudios/corrosion", branch = "m
 corro-types = { git = "https://github.com/EmbarkStudios/corrosion", branch = "misc" }
 rusqlite = "0.33"
 spawn = { git = "https://github.com/EmbarkStudios/corrosion", branch = "misc" }
+sqlite-pool = { git = "https://github.com/EmbarkStudios/corrosion", branch = "misc" }
 tripwire = { git = "https://github.com/EmbarkStudios/corrosion", branch = "misc" }
 uhlc = "0.7"
 

Cargo.toml

@@ -1,18 +1,28 @@
 [package]
-name = "corrosion-utils"
+name = "corrosion-tests"
 license.workspace = true
 edition.workspace = true
 version.workspace = true
 publish = false
 
 [dependencies]
+async-trait.workspace = true
+bytes.workspace = true
 camino.workspace = true
 corro-api-types.workspace = true
 corro-types.workspace = true
+corrosion.workspace = true
+insta = "1.43"
 prettytable = { version = "0.10", default-features = false }
+qt = { path = "../test" }
+quilkin-types.workspace = true
 rusqlite.workspace = true
+serde_json.workspace = true
+smallvec = "1.15"
 spawn.workspace = true
+sqlite-pool.workspace = true
 tempfile.workspace = true
+time.workspace = true
 tokio.workspace = true
 tokio-stream.workspace = true
 tripwire.workspace = true