Commit c61bbbf9 authored by Andrei Mihu's avatar Andrei Mihu
Browse files

Clean up realtime protocol message flag.

parent acffaf09

rtapi/realtime.pb.go

+147 −147

File changed.

Preview size limit exceeded, changes collapsed.

rtapi/realtime.proto

+1 −1
Original line number Diff line number Diff line
@@ -272,7 +272,7 @@ message MatchDataSend { 
  // List of presences in the match to deliver to, if filtering is required. Otherwise deliver to everyone in the match.

  repeated UserPresence presences = 4;

  // True if the data should be sent reliably, false otherwise.

  google.protobuf.BoolValue reliable = 5;

  bool reliable = 5;

}



// Join an existing realtime match.

server/pipeline_match.go

+3 −3
Original line number Diff line number Diff line
@@ -315,7 +315,7 @@ func (p *Pipeline) matchDataSend(logger *zap.Logger, session Session, envelope * 
			return

		}



		p.matchRegistry.SendData(matchID, matchIDComponents[1], session.UserID(), session.ID(), session.Username(), p.node, incoming.OpCode, incoming.Data, incoming.Reliable == nil || incoming.Reliable.Value, time.Now().UTC().UnixNano()/int64(time.Millisecond))

		p.matchRegistry.SendData(matchID, matchIDComponents[1], session.UserID(), session.ID(), session.Username(), p.node, incoming.OpCode, incoming.Data, incoming.Reliable, time.Now().UTC().UnixNano()/int64(time.Millisecond))

		return

	}
@@ -396,8 +396,8 @@ func (p *Pipeline) matchDataSend(logger *zap.Logger, session Session, envelope * 
		},

		OpCode:   incoming.OpCode,

		Data:     incoming.Data,

		Reliable: incoming.Reliable == nil || incoming.Reliable.Value,

		Reliable: incoming.Reliable,

	}}}



	p.router.SendToPresenceIDs(logger, presenceIDs, outgoing, incoming.Reliable == nil || incoming.Reliable.Value)

	p.router.SendToPresenceIDs(logger, presenceIDs, outgoing, incoming.Reliable)

}