Add last processed remote message id when adding to cache also as the… (#1144)

* Add last processed remote message id when adding to cache also as the returned message could be sent on the wire

* generated protobuf

* clean up

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>

Author: boks1971

signalling/signalcache.go

@@ -72,7 +72,7 @@ func (s *SignalCache) SetLastProcessedRemoteMessageId(lastProcessedRemoteMessage
 	s.lastProcessedRemoteMessageId = lastProcessedRemoteMessageId
 }
 
-func (s *SignalCache) Add(msg proto.Message, messageId uint32) {
+func (s *SignalCache) Add(msg proto.Message, messageId uint32) uint32 {
 	s.lock.Lock()
 	defer s.lock.Unlock()
 
@@ -85,6 +85,8 @@ func (s *SignalCache) Add(msg proto.Message, messageId uint32) {
 		})
 	}
 	s.messages.Insert(rindex+1, elem)
+
+	return s.lastProcessedRemoteMessageId
 }
 
 func (s *SignalCache) Clear(till uint32) {

signalling/signalv2clientmessagecache.go

@@ -35,7 +35,7 @@ func (s *Signalv2ClientMessageCache) Add(msg *livekit.Signalv2ClientMessage) *li
 	msg.Sequencer = &livekit.Sequencer{
 		MessageId: messageId,
 	}
-	s.SignalCache.Add(msg, messageId)
+	msg.Sequencer.LastProcessedRemoteMessageId = s.SignalCache.Add(msg, messageId)
 	return msg
 }
 

signalling/signalv2servermessagecache.go

@@ -35,7 +35,7 @@ func (s *Signalv2ServerMessageCache) Add(msg *livekit.Signalv2ServerMessage) *li
 	msg.Sequencer = &livekit.Sequencer{
 		MessageId: messageId,
 	}
-	s.SignalCache.Add(msg, messageId)
+	msg.Sequencer.LastProcessedRemoteMessageId = s.SignalCache.Add(msg, messageId)
 	return msg
 }