Fix PSUBSCRIBE and EVALSHA

Author: willnode

.gitignore

@@ -1,3 +1,4 @@
 .vscode
 __debug*
 build
+/Gemfile

Gemfile.lock

@@ -0,0 +1,44 @@
+GEM
+  remote: https://rubygems.org/
+  specs:
+    connection_pool (2.5.0)
+    date (3.4.1)
+    debug (1.10.0)
+      irb (~> 1.10)
+      reline (>= 0.3.8)
+    io-console (0.8.0)
+    irb (1.15.1)
+      pp (>= 0.6.0)
+      rdoc (>= 4.0.0)
+      reline (>= 0.4.2)
+    message_bus (4.4.1)
+      rack (>= 1.1.3)
+    pp (0.6.2)
+      prettyprint
+    prettyprint (0.2.0)
+    psych (5.2.3)
+      date
+      stringio
+    rack (3.1.12)
+    rdbg (0.1.0)
+      debug (>= 1.2.2)
+    rdoc (6.13.0)
+      psych (>= 4.0.0)
+    redis (5.4.0)
+      redis-client (>= 0.22.0)
+    redis-client (0.24.0)
+      connection_pool
+    reline (0.6.0)
+      io-console (~> 0.5)
+    stringio (3.1.6)
+
+PLATFORMS
+  x86_64-linux
+
+DEPENDENCIES
+  message_bus
+  rdbg (~> 0.1.0)
+  redis
+
+BUNDLED WITH
+   2.6.2

handler.go

@@ -67,7 +67,7 @@ func (m *Handler) ServeRESP(conn redcon.Conn, cmd redcon.Command) {
 		if command == "AUTH" && len(cmd.Args) == 3 {
 			context.username = string(cmd.Args[1])
 			conn.SetContext(context)
-		} else if command == "SUBSCRIBE" || command == "PSUBSRIBE" {
+		} else if command == "SUBSCRIBE" || command == "PSUBSCRIBE" {
 			// this will detach connection from this loop
 			context.detached = true
 			conn.SetContext(context)

mod.go

@@ -154,9 +154,6 @@ func modSingleCommand(command, username string, args [][]byte) ([][]byte, revive
 		}
 	case ModifyEvalStyle, ModifyEvalShaStyle:
 		kpos := 2
-		if modType == ModifyEvalShaStyle {
-			kpos = 3
-		}
 		if len(args) < kpos {
 			return args, nil
 		}

test/bus_message/Gemfile

@@ -0,0 +1,4 @@
+source 'https://rubygems.org'
+
+gem 'message_bus'
+gem 'redis'

test/bus_message/Gemfile.lock

@@ -0,0 +1,22 @@
+GEM
+  remote: https://rubygems.org/
+  specs:
+    connection_pool (2.5.0)
+    message_bus (4.4.1)
+      rack (>= 1.1.3)
+    rack (3.1.12)
+    redis (5.4.0)
+      redis-client (>= 0.22.0)
+    redis-client (0.24.0)
+      connection_pool
+
+PLATFORMS
+  ruby
+  x86_64-linux
+
+DEPENDENCIES
+  message_bus
+  redis
+
+BUNDLED WITH
+   2.6.2

test/bus_message/main.rb

@@ -0,0 +1,26 @@
+require 'message_bus'
+require 'redis'
+
+# Configure MessageBus to use your custom Redis server
+MessageBus.configure(
+  backend: :redis,
+  redis_config: {
+    url: "redis://127.0.0.1:6479/0"
+  },
+)
+
+# Subscribe to a channel
+Thread.new do
+  MessageBus.subscribe('/test_channel') do |msg|
+    puts "[Subscriber] Received message: #{msg.data}"
+  end
+end
+
+# Give the subscriber some time to start
+sleep 1
+
+# Publish a message
+MessageBus.publish('/test_channel', 'Hello from MessageBus!')
+
+# Keep the script running to receive messages
+sleep 5

test/users.acl

@@ -0,0 +1,3 @@
+user default on nopass ~default:* &default:* +@all
+user root on > ~* &* +@all
+user foo on nopass ~foo:* &foo:* +@all