diff --git a/src/ContentRepositoryReadModelAdapter.php b/src/ContentRepositoryReadModelAdapter.php index 528b38d..71bbb24 100644 --- a/src/ContentRepositoryReadModelAdapter.php +++ b/src/ContentRepositoryReadModelAdapter.php @@ -101,6 +101,7 @@ public function findContentStreamById(ContentStreamId $contentStreamId): ?Conten {$this->tableNames->contentStream()} WHERE id = :contentStreamId + AND removed = FALSE LIMIT 1 SQL; try { @@ -123,6 +124,8 @@ public function findContentStreams(): ContentStreams id, sourceContentStreamId, status, version FROM {$this->tableNames->contentStream()} + WHERE + removed = FALSE SQL; try { $rows = $this->dbal->fetchAllAssociative($contentStreamsStatement);