Fix redis stream editing with same id

Author: RobiNN1

src/Dashboards/Redis/RedisTrait.php

@@ -382,7 +382,7 @@ private function form(): string {
         }
 
         if (isset($_GET['key']) && $_GET['form'] === 'edit' && $this->redis->exists($key)) {
-            [$value, $index, $score, $hash_key] = $this->getKeyValue($type, $key);
+            [$value, $index, $score, $hash_key, $stream_id] = $this->getKeyValue($type, $key);
         }
 
         $value = Value::converter($value, $encoder, 'view');

src/Dashboards/Redis/RedisTypes.php

@@ -72,6 +72,7 @@ private function getKeyValue(string $type, string $key): array {
         $index = null;
         $score = 0;
         $hash_key = '';
+        $stream_id = '*';
 
         switch ($type) {
             case 'string':
@@ -99,7 +100,8 @@ private function getKeyValue(string $type, string $key): array {
                 break;
             case 'stream':
                 $ranges = $this->redis->xRange($key, '-', '+');
-                $value = $ranges[Http::get('stream_id', '')] ?? [];
+                $stream_id = Http::get('stream_id', '');
+                $value = $ranges[$stream_id] ?? [];
                 $value = json_encode($value, JSON_THROW_ON_ERROR | JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
                 break;
             case 'rejson':
@@ -109,7 +111,7 @@ private function getKeyValue(string $type, string $key): array {
                 $value = '';
         }
 
-        return [$value, $index, $score, $hash_key];
+        return [$value, $index, $score, $hash_key, $stream_id];
     }
 
     /**
@@ -183,6 +185,11 @@ public function store(string $type, string $key, string $value, string $old_valu
                 $this->redis->hSet($key, $options['hash_key'], $value);
                 break;
             case 'stream':
+                if ($options['stream_id'] === Http::get('stream_id', '')) {
+                    [$timestamp, $sequence] = array_pad(explode('-', Http::get('stream_id', '')), 2, 0);
+                    $options['stream_id'] = $timestamp.'-'.((int) $sequence + 1);
+                }
+
                 if (Http::get('stream_id', '') !== '') {
                     $this->redis->xDel($key, [Http::get('stream_id', '')]);
                 }