From 15cbf8b11a60dbad18ec2967690c2fa9df164a94 Mon Sep 17 00:00:00 2001
From: Tom Molesworth <tom@deriv.com>
Date: Wed, 15 May 2024 06:02:14 +0800
Subject: [PATCH] Record RPC groups

---
 lib/Myriad/RPC/Implementation/Redis.pm | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/lib/Myriad/RPC/Implementation/Redis.pm b/lib/Myriad/RPC/Implementation/Redis.pm
index 84f5bda7..696eae32 100644
--- a/lib/Myriad/RPC/Implementation/Redis.pm
+++ b/lib/Myriad/RPC/Implementation/Redis.pm
@@ -93,6 +93,11 @@ async method create_group ($rpc) {
             '0',
             1
         );
+        await $redis->hset(
+            'rpc.group',
+            $rpc->{stream},
+            $self->group_name,
+        );
         $rpc->{group} = 1;
     }
 }