update dependencies (#244)

Author: tim-smart

packages/discord-bot/package.json

@@ -10,14 +10,14 @@
     "@chat/discord": "workspace:*",
     "@chat/domain": "workspace:*",
     "@chat/shared": "workspace:*",
-    "@effect/ai": "^0.18.9",
-    "@effect/ai-openai": "^0.21.9",
-    "@effect/cluster": "^0.38.5",
-    "@effect/experimental": "^0.48.8",
+    "@effect/ai": "^0.18.10",
+    "@effect/ai-openai": "^0.21.10",
+    "@effect/cluster": "^0.38.7",
+    "@effect/experimental": "^0.48.9",
     "@effect/language-service": "^0.19.0",
-    "@effect/opentelemetry": "^0.50.7",
-    "@effect/platform": "^0.84.7",
-    "@effect/platform-node": "^0.85.5",
+    "@effect/opentelemetry": "^0.50.8",
+    "@effect/platform": "^0.84.8",
+    "@effect/platform-node": "^0.85.7",
     "@octokit/plugin-rest-endpoint-methods": "^16.0.0",
     "@octokit/types": "^14.1.0",
     "@types/node": "^22.15.30",
@@ -28,6 +28,6 @@
     "octokit": "^5.0.3"
   },
   "dependencies": {
-    "@effect/workflow": "^0.1.4"
+    "@effect/workflow": "^0.1.5"
   }
 }

packages/discord-bot/src/Cluster.ts

@@ -1,6 +1,6 @@
 import { SqlClientLayer } from "@chat/shared/Sql"
 import type { Runners, Sharding } from "@effect/cluster"
-import { RunnerAddress } from "@effect/cluster"
+import { ClusterWorkflowEngine, RunnerAddress } from "@effect/cluster"
 import { NodeClusterRunnerSocket } from "@effect/platform-node"
 import type { WorkflowEngine } from "@effect/workflow"
 import { Config, Effect, Layer } from "effect"
@@ -26,4 +26,6 @@ const ShardingLayer = Layer.unwrapEffect(
 
 export const ClusterLayer: Layer.Layer<
   Sharding.Sharding | Runners.Runners | WorkflowEngine.WorkflowEngine
-> = ShardingLayer as any
+> = ClusterWorkflowEngine.layer.pipe(
+  Layer.provideMerge(ShardingLayer)
+)

packages/discord-bot/src/MessageLogger.ts

@@ -1,5 +1,6 @@
 import { DiscordGatewayLayer } from "@chat/discord/DiscordGateway"
 import { MessageLogger } from "@chat/domain/MessageLogger"
+import { MessageWorkflow } from "@chat/domain/MessageWorkflow"
 import { DiscordGateway } from "dfx/DiscordGateway"
 import { Effect, Layer } from "effect"
 import { ChannelsCache } from "./ChannelsCache.ts"
@@ -30,11 +31,11 @@ const make = Effect.gen(function*() {
           message: message.content
         })
 
-        // yield* MessageWorkflow.execute({
-        //   id: message.id,
-        //   message: message.content,
-        //   author: message.author.username
-        // }, { discard: true })
+        yield* MessageWorkflow.execute({
+          id: message.id,
+          message: message.content,
+          author: message.author.username
+        }, { discard: true })
       },
       (effect, message) =>
         Effect.withSpan(effect, "MessageLogger.handle", {

packages/discord/package.json

@@ -9,8 +9,8 @@
     "./*": "./src/*.ts"
   },
   "dependencies": {
-    "@effect/platform": "^0.84.7",
-    "@effect/platform-node": "^0.85.5",
+    "@effect/platform": "^0.84.8",
+    "@effect/platform-node": "^0.85.7",
     "dfx": "^0.120.0",
     "effect": "^3.16.4"
   }

packages/domain/package.json

@@ -9,11 +9,11 @@
     "./*": "./src/*.ts"
   },
   "dependencies": {
-    "@effect/ai": "^0.18.9",
-    "@effect/cluster": "^0.38.5",
-    "@effect/rpc": "^0.61.7",
-    "@effect/sql": "^0.37.8",
-    "@effect/workflow": "^0.1.4",
+    "@effect/ai": "^0.18.10",
+    "@effect/cluster": "^0.38.7",
+    "@effect/rpc": "^0.61.8",
+    "@effect/sql": "^0.37.9",
+    "@effect/workflow": "^0.1.5",
     "effect": "^3.16.4"
   }
 }

packages/runner/package.json

@@ -10,18 +10,18 @@
     "@chat/discord": "workspace:*",
     "@chat/domain": "workspace:*",
     "@chat/shared": "workspace:*",
-    "@effect/ai": "^0.18.9",
-    "@effect/ai-openai": "^0.21.9",
-    "@effect/cluster": "^0.38.5",
-    "@effect/platform": "^0.84.7",
-    "@effect/platform-node": "^0.85.5",
-    "@effect/rpc": "^0.61.7",
-    "@effect/sql": "^0.37.8",
-    "@effect/sql-pg": "^0.38.8",
+    "@effect/ai": "^0.18.10",
+    "@effect/ai-openai": "^0.21.10",
+    "@effect/cluster": "^0.38.7",
+    "@effect/platform": "^0.84.8",
+    "@effect/platform-node": "^0.85.7",
+    "@effect/rpc": "^0.61.8",
+    "@effect/sql": "^0.37.9",
+    "@effect/sql-pg": "^0.38.9",
     "dfx": "^0.120.0",
     "effect": "^3.16.4"
   },
   "dependencies": {
-    "@effect/workflow": "^0.1.4"
+    "@effect/workflow": "^0.1.5"
   }
 }

packages/runner/src/MessageWorkflow.ts

@@ -7,6 +7,13 @@ export const MessageWorkflowLayer = MessageWorkflow.toLayer(
     function*({ author }, _executionId) {
       yield* Effect.log("Running")
 
+      yield* DurableClock.sleep({
+        name: "Wait 2 minutes",
+        duration: "2 minutes"
+      })
+
+      yield* Effect.log("Starting big sleep")
+
       yield* DurableClock.sleep({
         name: "Wait 1 day",
         duration: "1 day"

packages/shard-manager/package.json

@@ -14,10 +14,10 @@
   },
   "devDependencies": {
     "@chat/shared": "workspace:*",
-    "@effect/cluster": "^0.38.5",
-    "@effect/platform-node": "^0.85.5",
-    "@effect/sql": "^0.37.8",
-    "@effect/sql-pg": "^0.38.8",
+    "@effect/cluster": "^0.38.7",
+    "@effect/platform-node": "^0.85.7",
+    "@effect/sql": "^0.37.9",
+    "@effect/sql-pg": "^0.38.9",
     "effect": "^3.16.4"
   }
 }

packages/shared/package.json

@@ -9,10 +9,10 @@
     "./*": "./src/*.ts"
   },
   "dependencies": {
-    "@effect/opentelemetry": "^0.50.7",
-    "@effect/platform-node": "^0.85.5",
-    "@effect/sql": "^0.37.8",
-    "@effect/sql-pg": "^0.38.8",
+    "@effect/opentelemetry": "^0.50.8",
+    "@effect/platform-node": "^0.85.7",
+    "@effect/sql": "^0.37.9",
+    "@effect/sql-pg": "^0.38.9",
     "effect": "^3.16.4"
   }
 }