authorgravatar for julius0216@outlook.comJulius Marminge <julius0216@outlook.com> 2026-04-01 09:26:52-07:00
committergravatar for noreply@github.comGitHub <noreply@github.com> 2026-04-01 16:26:52+00:00
logb9c7ea0581e171d2d4aad716f8391c670d5e3276
tree3b1dab0c1f2f6419d89107f86f1738c5d4cf72ae
parent556a195c9de5554a6de978422a0160d01585a906
signature Signed by PGP key B5690EEEBB952194

[codex] migrate Effect.fn in apps/server/src/orchestration/Layers/ProviderCommandReactor.ts (#1629)

Co-authored-by: codex <codex@users.noreply.github.com>

1 files changed, 31 insertions(+), 30 deletions(-)

apps/server/src/orchestration/Layers/ProviderCommandReactor.ts+31-30
...@@ -724,39 +724,40 @@ const make = Effect.gen(function* () {...@@ -724,39 +724,40 @@ const make = Effect.gen(function* () {
724 });724 });
725 });725 });
726726
727 const processDomainEvent = (event: ProviderIntentEvent) =>727 const processDomainEvent = Effect.fn("processDomainEvent")(function* (
728 Effect.gen(function* () {728 event: ProviderIntentEvent,
729 switch (event.type) {729 ) {
730 case "thread.runtime-mode-set": {730 switch (event.type) {
731 const thread = yield* resolveThread(event.payload.threadId);731 case "thread.runtime-mode-set": {
732 if (!thread?.session || thread.session.status === "stopped") {732 const thread = yield* resolveThread(event.payload.threadId);
733 return;733 if (!thread?.session || thread.session.status === "stopped") {
734 }
735 const cachedModelSelection = threadModelSelections.get(event.payload.threadId);
736 yield* ensureSessionForThread(
737 event.payload.threadId,
738 event.occurredAt,
739 cachedModelSelection !== undefined ? { modelSelection: cachedModelSelection } : {},
740 );
741 return;734 return;
742 }735 }
743 case "thread.turn-start-requested":736 const cachedModelSelection = threadModelSelections.get(event.payload.threadId);
744 yield* processTurnStartRequested(event);737 yield* ensureSessionForThread(
745 return;738 event.payload.threadId,
746 case "thread.turn-interrupt-requested":739 event.occurredAt,
747 yield* processTurnInterruptRequested(event);740 cachedModelSelection !== undefined ? { modelSelection: cachedModelSelection } : {},
748 return;741 );
749 case "thread.approval-response-requested":742 return;
750 yield* processApprovalResponseRequested(event);
751 return;
752 case "thread.user-input-response-requested":
753 yield* processUserInputResponseRequested(event);
754 return;
755 case "thread.session-stop-requested":
756 yield* processSessionStopRequested(event);
757 return;
758 }743 }
759 });744 case "thread.turn-start-requested":
745 yield* processTurnStartRequested(event);
746 return;
747 case "thread.turn-interrupt-requested":
748 yield* processTurnInterruptRequested(event);
749 return;
750 case "thread.approval-response-requested":
751 yield* processApprovalResponseRequested(event);
752 return;
753 case "thread.user-input-response-requested":
754 yield* processUserInputResponseRequested(event);
755 return;
756 case "thread.session-stop-requested":
757 yield* processSessionStopRequested(event);
758 return;
759 }
760 });
760761
761 const processDomainEventSafely = (event: ProviderIntentEvent) =>762 const processDomainEventSafely = (event: ProviderIntentEvent) =>
762 processDomainEvent(event).pipe(763 processDomainEvent(event).pipe(