See prooph/proophessor-do#158

see https://github.com/prooph/snapshotter/blob/develop/src/SnapshotReadModel.php

just call $snapshotStore->removeAll($aggregateType); in there. The constructor of the readmodel might need adjustments, so this value is present.

@basz maybe?

and use after_success instead of after_script for it

Hi,

I see that the TakeSnapshot command is tightly bound to the SnapshotPlugin. I am looking for a way to run this async and wanted to add the AsyncMessage interface. This would require quote a bit of work extending classes. Would you have any objections to a config item to set the TakeSnapshot command, which defaults to what you already have?

Thank you
Guy

I have recreated an environment to reproduce this issue.
You will find it here: https://github.com/gquemener/prooph-snapshotter-issue-poc.

Basically, the snapshotter applies the events multiple times on aggregate root.

I haven't yet detected the root cause of this issue, but I'm suspecting something around the persistBlockSize of the PdoEventStoreProjector as the issue seems to appear only when the event stream contain more than 1000 events (1000 being the default persistBlockSize).

When a snapshot script is halted it could finish a batch and set its own state to idle before it would halt the process.

// user land code

if (function_exists('pcntl_signal')) {
            pcntl_signal(SIGTERM, [$this, 'onPCNTLSignal']);
            pcntl_signal(SIGINT, [$this, 'onPCNTLSignal']);
}

public function onPCNTLSignal() {
        $this->projectionManager->stopProjection($this->snapshotStreamName);
}

To have this work the run loop must include declare(ticks = 1);.