Marble.js 3.0 - CQRS example

cqrs.ts

// 📄 postOfferFile.effect.ts

const postOffersFile$ = r.pipe(
  r.matchPath('/offers/:id/file'),
  r.matchType('POST'),
  r.useEffect((req$, ctx) => {
    const eventBusClient = useContext(EventBusClientToken)(ctx.ask);

    return req$.pipe(
      validateRequest,
      map(req => req.params.id),
      tap(id => eventBusClient.emit(OfferCommand.generateOfferFile(id)),
      mapTo({ status: HttpStatus.ACCEPTED }),
    );
  }));

// 📄 generateOfferFile.effect.ts

const generateOfferFile$: MsgEffect = (event$, ctx) =>
  event$.pipe(
    matchEvent(GenerateOfferFileCommand),
    act(eventValidator$(GenerateOfferFileCommand)),
    act(event => of(event).pipe(
      map(event => event.payload.offerId),
      // ...
      map(id => OfferFileCreatedEvent.create(id)),
    )),
  );
    
// 📄 sendOffer.effect.ts    

const sendOffer$: MsgEffect = (event$, ctx) =>
  event$.pipe(
    matchEvent(OfferFileCreatedEvent),
    act(eventValidator$(OfferFileCreatedEvent)),
    act(event => of(event).pipe(
      map(event => event.payload.offerId),
      // ...
      map(id => OfferSentEvent.create(id)),
    )),
  );