Get ready to use the query

Refs #2089
PREreview · Nov 18, 2024 · db7a8a4 · db7a8a4
1 parent c3e8fd8
commit db7a8a4
Show file tree

Hide file tree

Showing 3 changed files with 33 additions and 0 deletions.
diff --git a/src/Comments/Context.ts b/src/Comments/Context.ts
@@ -12,6 +12,16 @@ export class CommentEvents extends Context.Tag('CommentEvents')<
   PubSub.PubSub<{ readonly commentId: Uuid.Uuid; readonly event: CommentEvent }>
 >() {}
 
+export class GetNextExpectedCommandForUserOnAComment extends Context.Tag('GetNextExpectedCommandForUserOnAComment')<
+  GetNextExpectedCommandForUserOnAComment,
+  (
+    ...params: Parameters<ReturnType<ReturnType<typeof Queries.GetNextExpectedCommandForUserOnAComment>>>
+  ) => Effect.Effect<
+    ReturnType<ReturnType<ReturnType<typeof Queries.GetNextExpectedCommandForUserOnAComment>>>,
+    UnableToQuery
+  >
+>() {}
+
 export class GetNextExpectedCommandForUser extends Context.Tag('GetNextExpectedCommandForUser')<
   GetNextExpectedCommandForUser,
   (

diff --git a/src/Comments/index.ts b/src/Comments/index.ts
@@ -7,6 +7,7 @@ import {
   CommentEvents,
   type GetComment,
   type GetNextExpectedCommandForUser,
+  type GetNextExpectedCommandForUserOnAComment,
   type HandleCommentCommand,
   type PublishCommentWithADoi,
   UnableToHandleCommand,
@@ -98,6 +99,22 @@ export const makeGetNextExpectedCommandForUser: Effect.Effect<
     }).pipe(Effect.catchTag('FailedToGetEvents', cause => new UnableToQuery({ cause })))
 })
 
+export const makeGetNextExpectedCommandForUserOnAComment: Effect.Effect<
+  typeof GetNextExpectedCommandForUserOnAComment.Service,
+  never,
+  EventStore | RequiresAVerifiedEmailAddress
+> = Effect.gen(function* () {
+  const eventStore = yield* EventStore
+  const requiresAVerifiedEmailAddress = yield* RequiresAVerifiedEmailAddress
+
+  return commentId =>
+    Effect.gen(function* () {
+      const events = yield* eventStore.getAllEvents
+
+      return Queries.GetNextExpectedCommandForUserOnAComment(requiresAVerifiedEmailAddress)(events)(commentId)
+    }).pipe(Effect.catchTag('FailedToGetEvents', cause => new UnableToQuery({ cause })))
+})
+
 export const ReactToCommentEvents: Layer.Layer<
   never,
   never,

diff --git a/src/Program.ts b/src/Program.ts
@@ -229,6 +229,12 @@ export const Program = pipe(
   Layer.provide(getPreprint),
   Layer.provide(Layer.effect(Comments.HandleCommentCommand, Comments.makeHandleCommentCommand)),
   Layer.provide(Layer.effect(Comments.GetNextExpectedCommandForUser, Comments.makeGetNextExpectedCommandForUser)),
+  Layer.provide(
+    Layer.effect(
+      Comments.GetNextExpectedCommandForUserOnAComment,
+      Comments.makeGetNextExpectedCommandForUserOnAComment,
+    ),
+  ),
   Layer.provide(Layer.effect(Comments.GetComment, Comments.makeGetComment)),
   Layer.provide(
     Layer.scoped(