Move towards using queries to inform sagas

Refs #2100
PREreview · Nov 21, 2024 · 4d1a2ad · 4d1a2ad
1 parent 7d83519
commit 4d1a2ad
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/Comments/index.ts b/src/Comments/index.ts
@@ -120,6 +120,7 @@ export const ReactToCommentEvents: Layer.Layer<
   never,
   never,
   | CommentEvents
+  | EventStore
   | GetComment
   | HandleCommentCommand
   | DoesUserHaveAVerifiedEmailAddress
@@ -128,6 +129,7 @@ export const ReactToCommentEvents: Layer.Layer<
 > = Layer.scopedDiscard(
   Effect.gen(function* () {
     const commentEvents = yield* CommentEvents
+    const eventStore = yield* EventStore
     const dequeue = yield* PubSub.subscribe(commentEvents)
 
     yield* pipe(
@@ -143,7 +145,9 @@ export const ReactToCommentEvents: Layer.Layer<
           ),
           Match.when({ event: { _tag: 'CommentPublicationWasRequested' } }, ({ commentId }) =>
             pipe(
-              React.AssignCommentADoiWhenPublicationWasRequested(commentId),
+              eventStore.getAllEvents,
+              Effect.andThen(events => Queries.GetACommentInNeedOfADoi(events)),
+              Effect.andThen(React.AssignCommentADoiWhenPublicationWasRequested),
               Effect.tapError(() => Effect.annotateLogs(Effect.logError('ReactToCommentEvents failed'), { commentId })),
             ),
           ),