Ensure Graceful Shutdown for SQS Consumer During Deployment

export const EventsProcessor = Layer.scopedDiscard(
  Effect.gen(function* () {
    const eventService = yield* EventService;
    const messageHandles = yield* eventservice.processevents();
    if (messageHandles) {
      yield* Effect.forEach(messageHandles, (receiptHandle) =>
        Effect.gen(function* () {
          yield* eventService
            .deleteEvents(receiptHandle)
            .pipe(
              Effect.catchTag("DeleteMessageError", (e) =>
                Effect.logError(e.message, e.cause)
              )
            );
        })
      );
    }
  }).pipe(Effect.repeat(Schedule.spaced(Duration.seconds(1))))
);

export const EventsProcessor = Layer.scopedDiscard(
  Effect.gen(function* () {
    const eventService = yield* EventService;
    const messageHandles = yield* eventservice.processevents();
    if (messageHandles) {
      yield* Effect.forEach(messageHandles, (receiptHandle) =>
        Effect.gen(function* () {
          yield* eventService
            .deleteEvents(receiptHandle)
            .pipe(
              Effect.catchTag("DeleteMessageError", (e) =>
                Effect.logError(e.message, e.cause)
              )
            );
        })
      );
    }
  }).pipe(Effect.repeat(Schedule.spaced(Duration.seconds(1))))
);