rest of the tests implemented

Author: alxsabo

src/Documents/Indexes/IndexDefinitionHelper.php

@@ -5,7 +5,6 @@
 use RavenDB\Exceptions\IllegalArgumentException;
 use RavenDB\Utils\StringUtils;
 
-// !status: DONE
 class IndexDefinitionHelper
 {
   public static function detectStaticIndexType(string $map, ?string $reduce): IndexType
@@ -61,7 +60,6 @@ public static function detectStaticIndexSourceType(?string $map): IndexSourceTyp
         if (str_starts_with($map, "from")) {
             // detect `from ts in timeseries` or `from ts in timeseries.Users.HeartRate`
 
-            // @todo: following five lines of code should be tested
             $tokens = [];
             foreach (explode(' ', $mapLower) as $item) {
                 if (StringUtils::isNotEmpty($item)) {
@@ -83,17 +81,13 @@ public static function detectStaticIndexSourceType(?string $map): IndexSourceTyp
         return IndexSourceType::documents();
     }
 
-    // @todo: implement and this code should be tested
     private static function stripComments(string $input): string
     {
-        return $input;
-//        return trim(preg_replace("(?:/\\*(?:[^*]|(?:\\*+[^*/]))*\\*+/)|(?://.*)","", $input));
+        return trim(preg_replace('~(?:/\\*(?:[^*]|(?:\\*+[^*/]))*\\*+/)|(?://.*)~',"", $input));
     }
 
-    // @todo: implement and this code should be tested
     private static function unifyWhiteSpace(string $input): string
     {
-        return $input;
-//        return preg_replace("\\s+", " ", $input);
+        return preg_replace("/\s+/", " ", $input);
     }
 }

src/Documents/Operations/TimeSeries/ConfigureRawTimeSeriesPolicyOperation.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace RavenDB\Documents\Operations\TimeSeries;
+
+class ConfigureRawTimeSeriesPolicyOperation extends ConfigureTimeSeriesPolicyOperation
+{
+    public function __construct(?string $collection, ?RawTimeSeriesPolicy $config) {
+        parent::__construct($collection, $config);
+    }
+}

src/Documents/Operations/TimeSeries/ConfigureTimeSeriesPolicyCommand.php

@@ -0,0 +1,69 @@
+<?php
+
+namespace RavenDB\Documents\Operations\TimeSeries;
+
+use RavenDB\Exceptions\IllegalArgumentException;
+use RavenDB\Http\HttpRequest;
+use RavenDB\Http\HttpRequestInterface;
+use RavenDB\Http\RaftCommandInterface;
+use RavenDB\Http\RavenCommand;
+use RavenDB\Http\ServerNode;
+use RavenDB\Utils\RaftIdGenerator;
+
+class ConfigureTimeSeriesPolicyCommand extends RavenCommand implements RaftCommandInterface
+{
+    private ?string $collection = null;
+    private ?TimeSeriesPolicy $configuration = null;
+
+    public function __construct(?string $collection, ?TimeSeriesPolicy $configuration)
+    {
+        parent::__construct(ConfigureTimeSeriesOperationResult::class);
+
+        if ($configuration == null) {
+            throw new IllegalArgumentException("Configuration cannot be null");
+        }
+
+        if ($collection == null) {
+            throw new IllegalArgumentException("Collection cannot be null");
+        }
+
+        $this->collection = $collection;
+        $this->configuration = $configuration;
+    }
+
+    public function getRaftUniqueRequestId(): string
+    {
+        return RaftIdGenerator::newId();
+    }
+
+    public function isReadRequest(): bool
+    {
+        return false;
+    }
+
+    public function createUrl(ServerNode $serverNode): string
+    {
+        return $serverNode->getUrl() . "/databases/" . $serverNode->getDatabase() . "/admin/timeseries/policy?collection=" . urlEncode($this->collection);
+    }
+
+    public function createRequest(ServerNode $serverNode): HttpRequestInterface
+    {
+        $options = [
+            'json' => $this->getMapper()->normalize($this->configuration),
+            'headers' => [
+                'Content-Type' => 'application/json'
+            ]
+        ];
+
+        return new HttpRequest($this->createUrl($serverNode), HttpRequest::PUT, $options);
+    }
+
+    public function setResponse(?string $response, bool $fromCache): void
+    {
+        if ($response == null) {
+            $this->throwInvalidResponse();
+        }
+
+        $this->result = $this->getMapper()->deserialize($response, $this->resultClass, 'json');
+    }
+}

src/Documents/Operations/TimeSeries/ConfigureTimeSeriesPolicyOperation.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace RavenDB\Documents\Operations\TimeSeries;
+
+use RavenDB\Documents\Conventions\DocumentConventions;
+use RavenDB\Documents\Operations\MaintenanceOperationInterface;
+use RavenDB\Http\RavenCommand;
+
+class ConfigureTimeSeriesPolicyOperation implements MaintenanceOperationInterface
+{
+    private ?string $collection = null;
+    private ?TimeSeriesPolicy $config = null;
+
+    public function __construct(?string $collection, ?TimeSeriesPolicy $config)
+    {
+        $this->collection = $collection;
+        $this->config = $config;
+    }
+
+    public function getCommand(DocumentConventions $conventions): RavenCommand
+    {
+        return new ConfigureTimeSeriesPolicyCommand($this->collection, $this->config);
+    }
+}

src/Documents/Operations/TimeSeries/ConfigureTimeSeriesValueNamesParameters.php

@@ -59,9 +59,9 @@ public function getValueNames(): ?StringArray
         return $this->valueNames;
     }
 
-    public function setValueNames(?StringArray $valueNames): void
+    public function setValueNames(null|array|StringArray $valueNames): void
     {
-        $this->valueNames = $valueNames;
+        $this->valueNames = is_array($valueNames) ? StringArray::fromArray($valueNames) : $valueNames;
     }
 
     public function isUpdate(): bool

src/Documents/Operations/TimeSeries/GetMultipleTimeSeriesCommand.php

@@ -21,7 +21,7 @@ class GetMultipleTimeSeriesCommand extends RavenCommand
     private ?int $pageSize = null;
     private ?Closure $includes = null;
 
-    public function __construct(?string $docId, ?TimeSeriesRangeList $ranges, int $start, int $pageSize, ?Closure $includes = null)
+    public function __construct(?string $docId, null|TimeSeriesRangeList|array $ranges, int $start, int $pageSize, ?Closure $includes = null)
     {
         parent::__construct(TimeSeriesDetails::class);
 
@@ -30,7 +30,9 @@ public function __construct(?string $docId, ?TimeSeriesRangeList $ranges, int $s
         }
 
         $this->docId = $docId;
-        $this->ranges = $ranges;
+        if ($ranges != null) {
+            $this->ranges = TimeSeriesRangeList::ensure($ranges);
+        }
         $this->start = $start;
         $this->pageSize = $pageSize;
         $this->includes = $includes;

src/Documents/Operations/TimeSeries/RemoveTimeSeriesPolicyCommand.php

@@ -0,0 +1,53 @@
+<?php
+
+namespace RavenDB\Documents\Operations\TimeSeries;
+
+use RavenDB\Http\HttpRequest;
+use RavenDB\Http\HttpRequestInterface;
+use RavenDB\Http\RaftCommandInterface;
+use RavenDB\Http\RavenCommand;
+use RavenDB\Http\ServerNode;
+use RavenDB\Utils\RaftIdGenerator;
+
+class RemoveTimeSeriesPolicyCommand extends RavenCommand implements RaftCommandInterface
+{
+    private ?string $collection = null;
+    private ?string $name = null;
+
+    public function __construct(?string $collection, ?string $name)
+    {
+        parent::__construct(ConfigureTimeSeriesOperationResult::class);
+
+        $this->collection = $collection;
+        $this->name = $name;
+    }
+    public function getRaftUniqueRequestId(): string
+    {
+        return RaftIdGenerator::newId();
+    }
+
+    public function isReadRequest(): bool
+    {
+        return false;
+    }
+
+    public function createUrl(ServerNode $serverNode): string
+    {
+        return $serverNode->getUrl() . "/databases/" . $serverNode->getDatabase()
+            . "/admin/timeseries/policy?collection=" . urlEncode($this->collection) . "&name=" . urlEncode($this->name);
+    }
+
+    public function createRequest(ServerNode $serverNode): HttpRequestInterface
+    {
+        return new HttpRequest($this->createUrl($serverNode), HttpRequest::DELETE);
+    }
+
+    public function setResponse(?string $response, bool $fromCache): void
+    {
+        if ($response == null) {
+            $this->throwInvalidResponse();
+        }
+
+        $this->result = $this->getMapper()->deserialize($response,$this->resultClass, 'json');
+    }
+}

src/Documents/Operations/TimeSeries/RemoveTimeSeriesPolicyOperation.php

@@ -0,0 +1,32 @@
+<?php
+
+namespace RavenDB\Documents\Operations\TimeSeries;
+
+use RavenDB\Documents\Conventions\DocumentConventions;
+use RavenDB\Documents\Operations\MaintenanceOperationInterface;
+use RavenDB\Exceptions\IllegalArgumentException;
+use RavenDB\Http\RavenCommand;
+
+class RemoveTimeSeriesPolicyOperation implements MaintenanceOperationInterface
+{
+    private ?string $collection = null;
+    private ?string $name = null;
+
+    public function __construct(?string $collection, ?string $name)
+    {
+        if ($collection == null) {
+            throw new IllegalArgumentException("Collection cannot be null");
+        }
+        if ($name == null) {
+            throw new IllegalArgumentException("Name cannot be null");
+        }
+
+        $this->collection = $collection;
+        $this->name = $name;
+    }
+
+    public function getCommand(DocumentConventions $conventions): RavenCommand
+    {
+        return new RemoveTimeSeriesPolicyCommand($this->collection, $this->name);
+    }
+}

src/Documents/Operations/TimeSeries/TimeSeriesConfiguration.php

@@ -81,12 +81,13 @@ public function getNames(string $collection, string $timeSeries): ?array
         if (!$this->namedValues->offsetExists($collection)) {
             return null;
         }
-        $timeSeriesHolder = $this->namedValues[$collection];
+        $timeSeriesHolder = array_change_key_case($this->namedValues[$collection], CASE_LOWER);
 
-        if (!array_key_exists($timeSeries, $timeSeriesHolder)) {
+        $timeSeriesLowerCase = strtolower($timeSeries);
+        if (!array_key_exists($timeSeriesLowerCase, $timeSeriesHolder)) {
             return null;
         }
-        return $timeSeriesHolder[$timeSeries];
+        return $timeSeriesHolder[$timeSeriesLowerCase];
     }
 
     private function internalPostJsonDeserialization(): void