query-handler-example.ts

interface GetUserEnrolledDecksQueryHandlerDependencies {
  enrolledDeckRepository: EnrolledDeckRepository;
  deckElasticView: ElasticView<Deck>;
  storageClient: StorageClient;
}

export class GetUserEnrolledDecksQueryHandler extends QueryHandler<
  GetUserEnrolledDecks,
  GetUserEnrolledDecksQueryResult
> {
  constructor(
    private readonly dependencies: GetUserEnrolledDecksQueryHandlerDependencies,
  ) {
    super(GET_USER_ENROLLED_DECKS_QUERY_TYPE);
  }

  public async execute({ payload: { userId } }: GetUserEnrolledDecks) {
    const {
      enrolledDeckRepository,
      deckElasticView,
      storageClient,
    } = this.dependencies;

    const enrolledDecks = await enrolledDeckRepository.getAllByUser(userId);

    const { items } = await deckElasticView.findMany({
      ids: enrolledDecks.map(enrolledDeck => enrolledDeck.getDeckId()),
    });

    return new GetUserEnrolledDecksQueryResult(
      items.map(item => ({
        ...item,
        imgUrl: item.imgUrl
          ? storageClient.getPublicUrlResolver(item.imgUrl)
          : '',
      })),
    );
  }
}