Create chimp controller service

backend/Cargo.toml

@@ -1,6 +1,7 @@
 [workspace]
 members = [
     "chimp_chomp",
+    "chimp_controller",
     "chimp_protocol",
     "graphql_endpoints",
     "graphql_event_broker",

backend/chimp_controller/Cargo.toml

@@ -0,0 +1,24 @@
+[package]
+name = "chimp_controller"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+anyhow = { workspace = true }
+async-tungstenite = { version = "0.22.0", features = ["tokio-runtime"] }
+chimp_protocol = { path = "../chimp_protocol" }
+clap = { workspace = true }
+cynic = { version = "3.2.2", features = ["http-reqwest"] }
+dotenvy = { workspace = true }
+futures-util = { version = "0.3.28" }
+graphql-ws-client = { version = "0.5.0", features = ["cynic"] }
+lapin = { version = "2.2.1", default-features = false, features = ["rustls"] }
+reqwest = "0.11.20"
+serde_json = "1.0.107"
+tokio = { workspace = true, features = ["sync"] }
+url = { workspace = true }
+uuid = { workspace = true }
+
+[build-dependencies]
+cynic-codegen = { version = "3.2.2" }
+targeting = { path = "../targeting" }

backend/chimp_controller/README.md

@@ -0,0 +1,3 @@
+# Chimp Controller
+
+A small shim service which is designed to listen to the `imageCreated` subscription endpoint of the `targeting` service and generate jobs for `chimp_chomp`. When `chimp_chomp` completes the job this service will format the response and send it to the `targeting` service.

backend/chimp_controller/build.rs

@@ -0,0 +1,8 @@
+use targeting::root_schema_builder;
+
+fn main() {
+    let schema = root_schema_builder().finish();
+    cynic_codegen::register_schema("targeting")
+        .from_sdl(&schema.sdl())
+        .unwrap();
+}