Fix invalid payload parsing

CHANGELOG.md

@@ -6,6 +6,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 
+### Fixed
+
+- Invalid payload parsing when the message is broken.
+
 ## [2.4.2] - 2024-01-18
 
 ### Added

membership/events.lua

@@ -84,11 +84,17 @@ end
 
 function events.unpack(event)
     checks('table')
+    local payload = event[4]
+    if payload == msgpack.NULL
+    or type(payload) ~= 'table'
+    then
+        payload = nil
+    end
     return {
-        uri = event[1],
-        status = event[2],
-        incarnation = event[3],
-        payload = (event[4] ~= msgpack.NULL) and event[4] or nil,
+        uri = tostring(event[1]),
+        status = tonumber(event[2]),
+        incarnation = tonumber(event[3]),
+        payload = payload,
         ttl = event[5],
     }
 end

test/test_dissemination.py

@@ -60,7 +60,7 @@ def test_discover_kill(servers, helpers):
     t1 = time.time()
 
     def check_public_opinion():
-        """ Cheack that all members consider URI has given STATUS """
+        """ Check that all members consider URI has given STATUS """
 
         for port, srv in list(servers_copy.items()):
             member = srv.get_member(uri)

test/test_payload.py

@@ -39,3 +39,19 @@ def test(servers, helpers):
             'foo2': 42
         }
     ])
+
+    assert servers[13301].conn.eval('''
+        local old_checks = package.loaded['checks']
+        package.loaded['checks'] = function() end
+
+        require('membership.events').generate(13301, 29, 31, 37)
+
+        package.loaded['checks'] = old_checks
+
+        return true
+    ''')[0]
+    helpers.wait_for(check_payload, [
+        servers[13302],
+        '13301',
+        None,
+    ])