batching signals push by 50 to avoid exeeding request length

src/Configuration/Watcher.php

@@ -33,6 +33,7 @@ class Watcher extends AbstractConfiguration
         'scenarios',
         'api_timeout',
         'api_connect_timeout',
+        'signals_batch_size',
         'metrics',
     ];
 
@@ -108,6 +109,15 @@ public function getConfigTreeBuilder(): TreeBuilder
             ->end()
             ->integerNode('api_timeout')->defaultValue(Constants::API_TIMEOUT)->end()
             ->integerNode('api_connect_timeout')->defaultValue(Constants::API_CONNECT_TIMEOUT)->end()
+            ->integerNode('signals_batch_size')
+                ->defaultValue(Constants::SIGNALS_BATCH_SIZE)
+                ->validate()
+                ->ifTrue(function (int $value) {
+                    return $value < 1;
+                })
+                ->thenInvalid('Invalid signals batch size. Must be greater than 0')
+                ->end()
+            ->end()
         ->end()
         ;
         $this->addMetricsNodes($rootNode);

src/Constants.php

@@ -62,6 +62,10 @@ class Constants extends CommonConstants
      * @var int The number of register retry attempts in case of 500
      */
     public const REGISTER_RETRY = 1;
+    /**
+     * @var int The default maximum number of signals per push request
+     */
+    public const SIGNALS_BATCH_SIZE = 50;
     /**
      * @var string The signals push endpoint
      */

src/Watcher.php

@@ -249,8 +249,14 @@ public function getStreamDecisions(): array
     public function pushSignals(array $signals): array
     {
         $indexedSignals = array_values($signals);
+        $batchSize = $this->getConfig('signals_batch_size') ?? Constants::SIGNALS_BATCH_SIZE;
+        $chunks = array_chunk($indexedSignals, $batchSize);
+        $result = [];
+        foreach ($chunks as $chunk) {
+            $result = $this->manageRequest('POST', Constants::SIGNALS_ENDPOINT, $chunk);
+        }
 
-        return $this->manageRequest('POST', Constants::SIGNALS_ENDPOINT, $indexedSignals);
+        return $result;
     }
 
     /**