MessageHandler.lua 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273
  1. -------------------------------------------------
  2. -- 本文件由代码生成器自动生成,
  3. -- 千万不要修改本文件的任何代码,
  4. -- 修改的的任何代码都会被覆盖掉!
  5. ----------------------------------------------------
  6. local Socket = require "Xmds.Pomelo.LuaGameSocket"
  7. require "base64"
  8. require "messageHandler_pb"
  9. --------------------------------Pomelo-------------------------------
  10. Pomelo = Pomelo or {}
  11. --------------------------------MessageHandler-------------------------------
  12. Pomelo.MessageHandler = {}
  13. local function handleMessageRequestEncoder(msg)
  14. local input = messageHandler_pb.HandleMessageRequest()
  15. protobuf.FromMessage(input,msg)
  16. return (input:SerializeToString())
  17. end
  18. local function handleMessageRequestDecoder(stream)
  19. local res = messageHandler_pb.HandleMessageResponse()
  20. res:ParseFromString(stream)
  21. return res
  22. end
  23. function Pomelo.MessageHandler.handleMessageRequest(c2s_id,c2s_type,c2s_operate,cb,option)
  24. local msg = {}
  25. msg.c2s_id = c2s_id
  26. msg.c2s_type = c2s_type
  27. msg.c2s_operate = c2s_operate
  28. Socket.OnRequestStart("area.messageHandler.handleMessageRequest", option)
  29. Socket.Request("area.messageHandler.handleMessageRequest", msg, function(res)
  30. if(res.s2c_code == 200) then
  31. Pomelo.MessageHandler.lastHandleMessageResponse = res
  32. Socket.OnRequestEnd("area.messageHandler.handleMessageRequest", true)
  33. cb(nil,res)
  34. else
  35. local ex = {}
  36. if(res.s2c_code) then
  37. ex.Code = res.s2c_code
  38. ex.Message = res.s2c_msg
  39. else
  40. ex.Code = 501
  41. ex.Message = "[LuaXmdsNetClient] area.messageHandler.handleMessageRequest decode error!!"
  42. end
  43. Socket.OnRequestEnd("area.messageHandler.handleMessageRequest", false,ex.Code,ex.Message)
  44. cb(ex,nil)
  45. end
  46. end, handleMessageRequestEncoder, handleMessageRequestDecoder)
  47. end
  48. local function onMessageAddPushDecoder(stream)
  49. local res = messageHandler_pb.OnMessageAddPush()
  50. res:ParseFromString(stream)
  51. return res
  52. end
  53. function Pomelo.MessageHandler.onMessageAddPush(cb)
  54. Socket.On("area.messagePush.onMessageAddPush", function(res)
  55. Pomelo.MessageHandler.lastOnMessageAddPush = res
  56. cb(nil,res)
  57. end, onMessageAddPushDecoder)
  58. end
  59. --------------------------------Pomelo-------------------------------
  60. return Pomelo