Get and pass all events from event store to node-cqrs-eventdenormalizer about node-eventstore HOT 4 CLOSED

It depends on your system but basically you need to wrap for example es.getEvents() with a rest service or a dedicated channel on the messageBus.
Then when you want to rebuild you can ask that service to return your events by streaming or I would recommend to implement some sort of pagination...

from node-eventstore.

Thanks.
Basically, I could do:
client ---Rest (rebuild request)--> Host Server: rebuild-readmodel method (request events) ---MessageBus--> EventStore (es.getEvents()) ---MessageBus--> Host Server: rebuild-readmodel method (eventdenormalizer.clear();eventdenormalizer.replay())

The rebuild-readmodel method would be accessible via a Rest request to the Host Server and would send a messages to the EventStore to get the events before requesting the Eventdenormalizer to perform a replay.
Does it sound right? ...

from node-eventstore.

There is no correct or incorrect... just do what best fits in your system.
Usually in my systems I do not request for a replay from client side. I do it on the operations side (i.e. while deploying a new release) => so each time a new ReadModel have to be (re)created the denormalizer processes are started with a special environment variable or flag and then they will request all events (in pages) via REST from a "replay-service" that queries the events from the eventstore.

from node-eventstore.

Thank you for the explanation.

from node-eventstore.