Add EndedAt field to Ingress State (#40)

Set ended_at on ingress end
livekit · Jan 9, 2024 · 4440158 · 4440158
1 parent da9ac82
commit 4440158
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/pkg/params/params.go b/pkg/params/params.go
@@ -270,6 +270,15 @@ func (p *Params) SetStatus(status livekit.IngressState_Status, errString string)
 
 	p.State.Status = status
 	p.State.Error = errString
+
+	switch status {
+	case livekit.IngressState_ENDPOINT_COMPLETE,
+		livekit.IngressState_ENDPOINT_INACTIVE,
+		livekit.IngressState_ENDPOINT_ERROR:
+		if p.State.EndedAt == 0 {
+			p.State.EndedAt = time.Now().UnixNano()
+		}
+	}
 }
 
 func (p *Params) SetRoomId(roomId string) {