fix: get new actors working on docker compose

Author: MasterPtato

Cargo.lock

@@ -8,7 +8,7 @@
 				"cluster_id": "11ca8960-acab-4963-909c-99d72af3e1cb",
 				"datacenter_id": "f288913c-735d-4188-bf9b-2fcf6eac7b9c",
 				"server_id": "174aca2a-98b7-462c-9ad9-3835094a9a10",
-				"intercom_endpoint": "http://rivet-server:8081"
+				"intercom_address": "http://rivet-server:8081"
 			},
 			"guard": {
 				// TLS not configured for local development

docker/dev-full/rivet-edge-server/config.jsonc

@@ -20,7 +20,7 @@
 				"cluster_id": "11ca8960-acab-4963-909c-99d72af3e1cb",
 				"datacenter_id": "f288913c-735d-4188-bf9b-2fcf6eac7b9c",
 				"server_id": "174aca2a-98b7-462c-9ad9-3835094a9a10",
-				"intercom_endpoint": "http://rivet-server:8081"
+				"intercom_address": "http://rivet-server:8081"
 			},
 			"guard": {
 				// TLS not configured for local development

docker/dev-full/rivet-guard/config.jsonc

@@ -67,7 +67,9 @@ RUN apt-get update -y && \
     redis-tools  \
     postgresql-client \
     gpg \
-    dirmngr && \
+    dirmngr \
+    gcc \
+    wget && \
     curl -fsSL 'https://packages.clickhouse.com/rpm/lts/repodata/repomd.xml.key' | gpg --dearmor -o /usr/share/keyrings/clickhouse-keyring.gpg && \
     echo "deb [signed-by=/usr/share/keyrings/clickhouse-keyring.gpg] https://packages.clickhouse.com/deb stable main" | tee /etc/apt/sources.list.d/clickhouse.list && \
     apt-get update -y && \
@@ -76,7 +78,13 @@ RUN apt-get update -y && \
     mv migrate /usr/local/bin/migrate && \
     apt-get clean && \
     rm -rf /var/lib/apt/lists/* && \
-    curl -Lf -o /lib/libfdb_c.so "https://github.com/apple/foundationdb/releases/download/7.1.60/libfdb_c.x86_64.so"
+    curl -Lf -o /lib/libfdb_c.so "https://github.com/apple/foundationdb/releases/download/7.1.60/libfdb_c.x86_64.so" && \
+    # Install go and usql
+    wget https://go.dev/dl/go1.24.4.linux-amd64.tar.gz && \
+    tar -C /usr/local -xzf go1.24.4.linux-amd64.tar.gz && \
+    export PATH=$PATH:/usr/local/go/bin && \
+    export PATH="$PATH:$(go env GOPATH)/bin" && \
+    go install github.com/xo/usql@latest
 
 # MARK: Server (Full)
 FROM server-full-base AS server-full

docker/universal/Dockerfile

@@ -44,13 +44,13 @@ async function run() {
 								guard: {},
 							},
 						},
-						udp: {
-							protocol: "udp",
-							// internalPort: 80,
-							routing: {
-								host: {},
-							},
-						},
+						// udp: {
+						// 	protocol: "udp",
+						// 	// internalPort: 80,
+						// 	routing: {
+						// 		host: {},
+						// 	},
+						// },
 					},
 				},
 				runtime: {

examples/system-test-actor/tests/client.ts

@@ -28,4 +28,4 @@
 		"react": "^19",
 		"react-dom": "^19"
 	}
-}
+}

package.json

@@ -841,7 +841,8 @@ pub struct Edge {
 	pub cluster_id: Uuid,
 	pub datacenter_id: Uuid,
 	pub server_id: Uuid,
-	pub intercom_endpoint: Url,
+	/// Url of the core cluster.
+	pub intercom_address: Url,
 	/// This API address will be used if there are no worker servers listed in the cluster package
 	#[serde(default)]
 	pub api_lan_address: Option<(String, u16)>,

packages/common/config/src/config/server/rivet/mod.rs

@@ -36,8 +36,6 @@ pub enum Id {
 	V1([u8; 18]),
 }
 
-
-
 impl Id {
 	/// Construct V0 from uuid.
 	pub fn new_v0() -> Self {
@@ -241,20 +239,41 @@ impl TuplePack for Id {
 		w: &mut W,
 		tuple_depth: TupleDepth,
 	) -> std::io::Result<VersionstampOffset> {
+		let mut size = 1;
+
 		w.write_all(&[fdb_util::codes::ID])?;
+		
+		// IMPORTANT: While the normal bytes representation of a v0 ID doesn't include the version, we write
+		// it here so that we can unpack without a terminating NIL.
+		if let Id::V0(_) = self {
+			w.write_all(&[0])?;
+			size += 1;
+		}
+
 		let bytes = self.as_bytes();
+
 		let len = u32::try_from(bytes.len())
 			.map_err(|err| std::io::Error::new(std::io::ErrorKind::InvalidData, err))?;
+		size += len;
+
 		w.write_all(&bytes)?;
 
-		Ok(VersionstampOffset::None { size: 1 + len })
+		Ok(VersionstampOffset::None { size })
 	}
 }
 
 impl<'de> TupleUnpack<'de> for Id {
 	fn unpack(input: &[u8], tuple_depth: TupleDepth) -> PackResult<(&[u8], Self)> {
 		let input = fdb_util::parse_code(input, fdb_util::codes::ID)?;
-		let (input, slice) = fdb_util::parse_bytes(input, 16)?;
+		let (input2, version) = fdb_util::parse_byte(input)?;
+
+		let (input, slice) = if version == 0 {
+			// Parse 16 bytes after version
+			fdb_util::parse_bytes(input2, 16)?
+		} else {
+			// Parse 19 bytes including version
+			fdb_util::parse_bytes(input, 19)?
+		};
 
 		let v = Id::from_bytes(slice)
 			.map_err(|err| PackError::Message(format!("bad id format: {err}").into()))?;

packages/common/util/id/src/lib.rs

@@ -227,6 +227,13 @@ pub fn config(rivet_config: rivet_config::Config) -> Result<RunConfigData> {
 			),
 			db_name: "db_pegboard_runner_log",
 		},
+		SqlService {
+			kind: SqlServiceKind::ClickHouse,
+			migrations: include_dir!(
+				"$CARGO_MANIFEST_DIR/../../../edge/services/pegboard/db/runner"
+			),
+			db_name: "db_pegboard_runner",
+		},
 		SqlService {
 			kind: SqlServiceKind::CockroachDB,
 			migrations: include_dir!(

packages/core/infra/server/src/run_config.rs

@@ -58,7 +58,7 @@ pub fn configure(config: &rivet_config::Config) -> GlobalResult<String> {
 					datacenter_id: Uuid::nil(),
 					server_id: Uuid::nil(),
 					api_lan_address: None,
-					intercom_endpoint: Url::parse(&format!("http://127.0.0.1:{TUNNEL_API_EDGE_PORT}"))?,
+					intercom_address: Url::parse(&format!("http://127.0.0.1:{TUNNEL_API_EDGE_PORT}"))?,
 					redirect_logs_dir: Some(PathBuf::from("/var/log/rivet-guard")),
 				}),
 				status: server_config.rivet.status.clone(),