feat(pegboard): outbound runners

Author: MasterPtato

Cargo.lock

@@ -1,7 +1,7 @@
 
 [workspace]
 resolver = "2"
-members = ["packages/common/api-builder","packages/common/api-client","packages/common/api-types","packages/common/api-util","packages/common/cache/build","packages/common/cache/result","packages/common/clickhouse-inserter","packages/common/clickhouse-user-query","packages/common/config","packages/common/env","packages/common/error/core","packages/common/error/macros","packages/common/gasoline/core","packages/common/gasoline/macros","packages/common/logs","packages/common/metrics","packages/common/pools","packages/common/runtime","packages/common/service-manager","packages/common/test-deps","packages/common/test-deps-docker","packages/common/types","packages/common/udb-util","packages/common/universaldb","packages/common/universalpubsub","packages/common/util/core","packages/common/util/id","packages/common/versioned-data-util","packages/core/actor-kv","packages/core/api-peer","packages/core/api-public","packages/core/bootstrap","packages/core/dump-openapi","packages/core/guard/core","packages/core/guard/server","packages/core/pegboard-gateway","packages/core/pegboard-runner-ws","packages/core/pegboard-tunnel","packages/core/workflow-worker","packages/infra/engine","packages/services/epoxy","packages/services/namespace","packages/services/pegboard","sdks/rust/api-full","sdks/rust/api-runtime","sdks/rust/bare_gen","sdks/rust/epoxy-protocol","sdks/rust/key-data","sdks/rust/runner-protocol","sdks/rust/tunnel-protocol"]
+members = ["packages/common/api-builder","packages/common/api-client","packages/common/api-types","packages/common/api-util","packages/common/cache/build","packages/common/cache/result","packages/common/clickhouse-inserter","packages/common/clickhouse-user-query","packages/common/config","packages/common/env","packages/common/error/core","packages/common/error/macros","packages/common/gasoline/core","packages/common/gasoline/macros","packages/common/logs","packages/common/metrics","packages/common/pools","packages/common/runtime","packages/common/service-manager","packages/common/test-deps","packages/common/test-deps-docker","packages/common/types","packages/common/udb-util","packages/common/universaldb","packages/common/universalpubsub","packages/common/util/core","packages/common/util/id","packages/common/versioned-data-util","packages/core/actor-kv","packages/core/api-peer","packages/core/api-public","packages/core/bootstrap","packages/core/dump-openapi","packages/core/guard/core","packages/core/guard/server","packages/core/pegboard-gateway","packages/core/pegboard-outbound","packages/core/pegboard-runner-ws","packages/core/pegboard-tunnel","packages/core/workflow-worker","packages/infra/engine","packages/services/epoxy","packages/services/namespace","packages/services/pegboard","sdks/rust/api-full","sdks/rust/api-runtime","sdks/rust/bare_gen","sdks/rust/epoxy-protocol","sdks/rust/key-data","sdks/rust/runner-protocol","sdks/rust/tunnel-protocol"]
 
 [workspace.package]
 version = "0.0.1"
@@ -79,17 +79,11 @@ tracing-core = "0.1"
 tracing-opentelemetry = "0.29"
 tracing-slog = "0.2"
 vergen = "9.0.4"
+reqwest-eventsource = "0.6.0"
 
 [workspace.dependencies.windows]
 version = "0.58"
-features = [
-	"Win32",
-	"Win32_Storage",
-	"Win32_Storage_FileSystem",
-	"Win32_System",
-	"Win32_System_Console",
-	"Win32_Security",
-]
+features = ["Win32","Win32_Storage","Win32_Storage_FileSystem","Win32_System","Win32_System_Console","Win32_Security"]
 
 [workspace.dependencies.pest]
 version = "2.7"
@@ -105,12 +99,12 @@ features = ["full"]
 [workspace.dependencies.rustls]
 version = "0.23.25"
 default-features = false
-features = ["ring", "std", "logging"] 
+features = ["ring","std","logging"]
 
 [workspace.dependencies.tokio-rustls]
 version = "0.26.2"
 default-features = false
-features = ["ring", "logging"] 
+features = ["ring","logging"]
 
 [workspace.dependencies.utoipa]
 version = "5.4.0"
@@ -358,6 +352,9 @@ path = "packages/core/guard/server"
 [workspace.dependencies.pegboard-gateway]
 path = "packages/core/pegboard-gateway"
 
+[workspace.dependencies.pegboard-outbound]
+path = "packages/core/pegboard-outbound"
+
 [workspace.dependencies.pegboard-runner-ws]
 path = "packages/core/pegboard-runner-ws"
 

Cargo.toml

@@ -187,6 +187,7 @@ services:
     environment:
       - RIVET_ENDPOINT=http://rivet-engine:6420
       - RUNNER_HOST=runner
+      # - NO_AUTOSTART=1
     stop_grace_period: 4s
     ports:
       - '5050:5050'

docker/dev/docker-compose.yml

@@ -61,6 +61,16 @@ impl AsTags for serde_json::Value {
 	}
 }
 
+impl AsTags for () {
+	fn as_tags(&self) -> WorkflowResult<serde_json::Value> {
+		Ok(serde_json::Value::Object(serde_json::Map::new()))
+	}
+
+	fn as_cjson_tags(&self) -> WorkflowResult<String> {
+		Ok(String::new())
+	}
+}
+
 impl<T: AsTags> AsTags for &T {
 	fn as_tags(&self) -> WorkflowResult<serde_json::Value> {
 		(*self).as_tags()

packages/common/gasoline/core/src/utils/tags.rs

@@ -13,3 +13,10 @@ pub async fn client() -> Result<Client, reqwest::Error> {
 		.await
 		.cloned()
 }
+
+pub async fn client_no_timeout() -> Result<Client, reqwest::Error> {
+	CLIENT
+		.get_or_try_init(|| async { Client::builder().build() })
+		.await
+		.cloned()
+}

packages/common/pools/src/reqwest.rs

@@ -0,0 +1,17 @@
+[package]
+name = "pegboard-outbound"
+version.workspace = true
+authors.workspace = true
+license.workspace = true
+edition.workspace = true
+
+[dependencies]
+anyhow.workspace = true
+epoxy.workspace = true
+gas.workspace = true
+reqwest-eventsource.workspace = true
+rivet-config.workspace = true
+rivet-runner-protocol.workspace = true
+tracing.workspace = true
+
+pegboard.workspace = true