Debug flaky test TestClientTakeoverRoomSession

This commit is contained in:
Joachim Bauch 2021-10-28 10:54:37 +02:00
parent fb12b359e0
commit 6dd4c5ebeb
No known key found for this signature in database
GPG Key ID: 77C1D22D53E15F02
2 changed files with 7 additions and 2 deletions

View File

@ -857,6 +857,7 @@ func (s *ClientSession) processNatsMessage(msg *NatsMessage) *ServerMessage {
} else if msg.Message.Event.Target == "room" {
// Can happen mostly during tests where an older room NATS message
// could be received by a subscriber that joined after it was sent.
log.Printf("Message %+v was sent at %s, room joined at %s", msg.Message, msg.SendTime, s.getRoomJoinTime())
if msg.SendTime.Before(s.getRoomJoinTime()) {
log.Printf("Message %+v was sent before room was joined, ignoring", msg.Message)
return nil

View File

@ -175,8 +175,10 @@ func (c *LoopbackNatsClient) PublishNats(subject string, message *NatsMessage) e
}
func (c *LoopbackNatsClient) PublishMessage(subject string, message *ServerMessage) error {
now := time.Now()
log.Printf("Send message at %s: %+v", now, message)
msg := &NatsMessage{
SendTime: time.Now(),
SendTime: now,
Type: "message",
Message: message,
}
@ -184,8 +186,10 @@ func (c *LoopbackNatsClient) PublishMessage(subject string, message *ServerMessa
}
func (c *LoopbackNatsClient) PublishBackendServerRoomRequest(subject string, message *BackendServerRoomRequest) error {
now := time.Now()
log.Printf("Send message at %s: %+v", now, message)
msg := &NatsMessage{
SendTime: time.Now(),
SendTime: now,
Type: "room",
Room: message,
}