ensure ShardManager and Runner get fresh versions of the rpc protocol (#5505)

tim-smart · web-flow · commit 1c4b6ae81daf · 2025-09-16T09:32:41.000+12:00
diff --git a/.changeset/shaky-doodles-march.md b/.changeset/shaky-doodles-march.md
@@ -0,0 +1,5 @@
+---
+"@effect/cluster": patch
+---
+
+ensure ShardManager and Runner get fresh versions of the rpc protocol
diff --git a/packages/cluster/src/SocketRunner.ts b/packages/cluster/src/SocketRunner.ts
@@ -40,7 +40,7 @@ export const layer: Layer.Layer<
   | ShardStorage.ShardStorage
 > = RunnerServer.layerWithClients.pipe(
   withLogAddress,
-  Layer.provide(RpcServer.layerProtocolSocketServer)
+  Layer.provide(Layer.fresh(RpcServer.layerProtocolSocketServer))
 )
 
 /**
diff --git a/packages/cluster/src/SocketShardManager.ts b/packages/cluster/src/SocketShardManager.ts
@@ -41,7 +41,7 @@ export const layer: Layer.Layer<
   | ShardingConfig
 > = ShardManager.layerServer.pipe(
   withLogAddress,
-  Layer.provide(RpcServer.layerProtocolSocketServer),
+  Layer.provide(Layer.fresh(RpcServer.layerProtocolSocketServer)),
   Layer.provideMerge(ShardManager.layer),
   Layer.provide(Runners.layerRpc),
   Layer.provide(MessageStorage.layerNoop)

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +---
 +"@effect/cluster": patch
 +---
++
 +ensure ShardManager and Runner get fresh versions of the rpc protocol
Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ export const layer: Layer.Layer<`
`40`	`40`	`\| ShardStorage.ShardStorage`
`41`	`41`	`> = RunnerServer.layerWithClients.pipe(`
`42`	`42`	`withLogAddress,`
`43`		`- Layer.provide(RpcServer.layerProtocolSocketServer)`
	`43`	`+ Layer.provide(Layer.fresh(RpcServer.layerProtocolSocketServer))`
`44`	`44`	`)`
`45`	`45`
`46`	`46`	`/**`