File tree Expand file tree Collapse file tree 2 files changed +7
-10
lines changed Expand file tree Collapse file tree 2 files changed +7
-10
lines changed Original file line number Diff line number Diff line change 11import { SqlClientLayer } from "@chat/shared/Sql"
22import type { Runners , Sharding } from "@effect/cluster"
3- import { ClusterWorkflowEngine , RunnerAddress } from "@effect/cluster"
3+ import { RunnerAddress } from "@effect/cluster"
44import { NodeClusterRunnerSocket } from "@effect/platform-node"
55import type { WorkflowEngine } from "@effect/workflow"
66import { Config , Effect , Layer } from "effect"
@@ -26,6 +26,4 @@ const ShardingLayer = Layer.unwrapEffect(
2626
2727export const ClusterLayer : Layer . Layer <
2828 Sharding . Sharding | Runners . Runners | WorkflowEngine . WorkflowEngine
29- > = ClusterWorkflowEngine . layer . pipe (
30- Layer . provideMerge ( ShardingLayer )
31- ) as any
29+ > = ShardingLayer as any
Original file line number Diff line number Diff line change 11import { DiscordGatewayLayer } from "@chat/discord/DiscordGateway"
22import { MessageLogger } from "@chat/domain/MessageLogger"
3- import { MessageWorkflow } from "@chat/domain/MessageWorkflow"
43import { DiscordGateway } from "dfx/DiscordGateway"
54import { Effect , Layer } from "effect"
65import { ChannelsCache } from "./ChannelsCache.ts"
@@ -31,11 +30,11 @@ const make = Effect.gen(function*() {
3130 message : message . content
3231 } )
3332
34- yield * MessageWorkflow . execute ( {
35- id : message . id ,
36- message : message . content ,
37- author : message . author . username
38- } , { discard : true } )
33+ // yield* MessageWorkflow.execute({
34+ // id: message.id,
35+ // message: message.content,
36+ // author: message.author.username
37+ // }, { discard: true })
3938 } ,
4039 ( effect , message ) =>
4140 Effect . withSpan ( effect , "MessageLogger.handle" , {
You can’t perform that action at this time.
0 commit comments