livekit-protocol 0.7.5

package observability

import "time"

type SessionTimer struct {
	lastMilli int64
	lastMin   int64
}

func NewSessionTimer(startTime time.Time) *SessionTimer {
	ts := startTime.UnixMilli()
	return &SessionTimer{ts, ts}
}

func (h *SessionTimer) Advance(now time.Time) (millis, mins int64) {
	ts := now.UnixMilli()
	if ts > h.lastMilli {
		millis = ts - h.lastMilli
		h.lastMilli = ts
	}
	if ts > h.lastMin {
		n := (ts - h.lastMin + 59999) / 60000
		mins += n
		h.lastMin += n * 60000
	}
	return
}