handle error with GetContextFromRequest(), response should be init

topfreegames · May 24, 2021 · 54d2ae3 · 54d2ae3
1 parent fac48bf
commit 54d2ae3
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/cluster/nats_rpc_server.go b/cluster/nats_rpc_server.go
@@ -260,11 +260,12 @@ func (ns *NatsRPCServer) processMessages(threadID int) {
 		logger.Log.Debugf("(%d) processing message %v", threadID, ns.requests[threadID].GetMsg().GetId())
 		ctx, err := util.GetContextFromRequest(ns.requests[threadID], ns.server.ID)
 		if err != nil {
-			ns.responses[threadID].Error = &protos.Error{
-				Code: e.ErrInternalCode,
-				Msg:  err.Error(),
+			ns.responses[threadID] = &protos.Response{
+				Error: &protos.Error{
+					Code: e.ErrInternalCode,
+					Msg:  err.Error(),
+				},
 			}
-			ns.responses[threadID].Data = nil
 		} else {
 			ns.responses[threadID], _ = ns.pitayaServer.Call(ctx, ns.requests[threadID])
 		}