Version 1.5 - bug fixes and small improvements

modules/gamelib/protocolgame.lua

@@ -1,5 +1,8 @@
 local opcodeCallbacks = {}
 local extendedCallbacks = {}
+local extendedJSONCallbacks = {}
+local extendedJSONData = {}
+local maxPacketSize = 65000
 
 function ProtocolGame:onOpcode(opcode, msg)
   for i, callback in pairs(opcodeCallbacks) do
@@ -16,6 +19,29 @@ function ProtocolGame:onExtendedOpcode(opcode, buffer)
   if callback then
     callback(self, opcode, buffer)
   end
+  
+  callback = extendedJSONCallbacks[opcode]
+  if callback then
+    local status = buffer:sub(1,1) -- O - just one message, S - start, P - part, E - end
+    local data = buffer:sub(2)
+    if status ~= "E" and status ~= "P" then
+      extendedJSONData[opcode] = ""
+    end
+    if status ~= "S" and status ~= "P" and status ~= "E" then
+      extendedJSONData[opcode] = buffer
+    else
+      extendedJSONData[opcode] = extendedJSONData[opcode] .. data
+    end
+    if status ~= "S" and status ~= "P" then
+      local json_status, json_data = pcall(function() return json.decode(extendedJSONData[opcode]) end)
+      extendedJSONData[opcode] = nil
+      if not json_status then
+        error("Invalid data in extended JSON opcode (" .. json_status .. "): " .. json_data)
+        return
+      end
+      callback(self, opcode, json_data)
+    end
+  end
 end
 
 function ProtocolGame.registerOpcode(opcode, callback)
@@ -57,3 +83,56 @@ function ProtocolGame.unregisterExtendedOpcode(opcode)
 
   extendedCallbacks[opcode] = nil
 end
+
+function ProtocolGame.registerExtendedJSONOpcode(opcode, callback)
+  if not callback or type(callback) ~= 'function' then
+    error('Invalid callback.')
+  end
+
+  if opcode < 0 or opcode > 255 then
+    error('Invalid opcode. Range: 0-255')
+  end
+
+  if extendedJSONCallbacks[opcode] then
+    error('Opcode is already taken.')
+  end
+
+  extendedJSONCallbacks[opcode] = callback
+end
+
+function ProtocolGame.unregisterExtendedJSONOpcode(opcode)
+  if opcode < 0 or opcode > 255 then
+    error('Invalid opcode. Range: 0-255')
+  end
+
+  if not extendedJSONCallbacks[opcode] then
+    error('Opcode is not registered.')
+  end
+
+  extendedJSONCallbacks[opcode] = nil
+end
+
+function ProtocolGame:sendExtendedJSONOpcode(opcode, data)
+  if opcode < 0 or opcode > 255 then
+    error('Invalid opcode. Range: 0-255')
+  end
+
+  if type(data) ~= "table" then
+    error('Invalid data type, should be table')
+  end
+  
+  local buffer = json.encode(data)  
+  local s = {}
+  for i=1, #buffer, maxPacketSize do
+     s[#s+1] = buffer:sub(i,i+maxPacketSize - 1)
+  end
+  if #s == 1 then
+    self:sendExtendedOpcode(opcode, s[1])
+    return
+  end
+  self:sendExtendedOpcode(opcode, "S" .. s[1])
+  for i=2,#s - 1 do
+    self:sendExtendedOpcode(opcode, "P" .. s[i])
+  end
+  self:sendExtendedOpcode(opcode, "E" .. s[#s])
+end