createCollection time series support

Create collection time series support doctrine#2533
cyildirim · Jul 3, 2023 · 9733bad · 9733bad
1 parent a66e407
commit 9733bad
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/lib/Doctrine/ODM/MongoDB/SchemaManager.php b/lib/Doctrine/ODM/MongoDB/SchemaManager.php
@@ -65,7 +65,7 @@ public function __construct(protected DocumentManager $dm, protected ClassMetada
     public function ensureIndexes(?int $maxTimeMs = null, ?WriteConcern $writeConcern = null, bool $background = false): void
     {
         foreach ($this->metadataFactory->getAllMetadata() as $class) {
-            if ($class->isMappedSuperclass || $class->isEmbeddedDocument || $class->isQueryResultDocument || $class->isView()) {
+            if ($class->isMappedSuperclass || $class->isEmbeddedDocument || $class->isQueryResultDocument || $class->isView() || $class->isTimeSeriesDocument) {
                 continue;
             }
 
@@ -339,7 +339,7 @@ public function updateValidators(?int $maxTimeMs = null, ?WriteConcern $writeCon
     public function updateDocumentValidator(string $documentName, ?int $maxTimeMs = null, ?WriteConcern $writeConcern = null): void
     {
         $class = $this->dm->getClassMetadata($documentName);
-        if ($class->isMappedSuperclass || $class->isEmbeddedDocument || $class->isQueryResultDocument || $class->isView() || $class->isFile) {
+        if ($class->isMappedSuperclass || $class->isEmbeddedDocument || $class->isQueryResultDocument || $class->isView() || $class->isFile || $class->isTimeSeriesDocument) {
             throw new InvalidArgumentException('Cannot update validators for files, views, mapped super classes, embedded documents or aggregation result documents.');
         }
 
@@ -447,6 +447,8 @@ public function createDocumentCollection(string $documentName, ?int $maxTimeMs =
         }
 
         $options = [
+            'timeseries' => $class->getCollectionTimeseries(),
+            'expireAfterSeconds' => $class->getCollectionExpireAfterSeconds(),
             'capped' => $class->getCollectionCapped(),
             'size' => $class->getCollectionSize(),
             'max' => $class->getCollectionMax(),