diff --git a/go.mod b/go.mod index f45065249..56c64c670 100644 --- a/go.mod +++ b/go.mod @@ -18,7 +18,7 @@ require ( github.com/jxskiss/base62 v1.1.0 github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1 github.com/livekit/mediatransportutil v0.0.0-20230612070454-d5299b956135 - github.com/livekit/protocol v1.5.8-0.20230619005042-089430752e03 + github.com/livekit/protocol v1.5.8-0.20230620161627-ce9e603cfda8 github.com/livekit/psrpc v0.3.1 github.com/mackerelio/go-osstat v0.2.4 github.com/magefile/mage v1.15.0 diff --git a/go.sum b/go.sum index 886ed55c3..966bd9126 100644 --- a/go.sum +++ b/go.sum @@ -124,8 +124,8 @@ github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1 h1:jm09419p0lqTkD github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1/go.mod h1:Rs3MhFwutWhGwmY1VQsygw28z5bWcnEYmS1OG9OxjOQ= github.com/livekit/mediatransportutil v0.0.0-20230612070454-d5299b956135 h1:lWYbsondvqG69czxoACDwaJ/BoyD57BahCo70ZH+m4U= github.com/livekit/mediatransportutil v0.0.0-20230612070454-d5299b956135/go.mod h1:MRc0zSOSzXuFt0X218SgabzlaKevkvCckPgBEoHYc34= -github.com/livekit/protocol v1.5.8-0.20230619005042-089430752e03 h1:Ma+BKzQHCZhXeklDN72ahkERSixANOwlargLT4mrsPo= -github.com/livekit/protocol v1.5.8-0.20230619005042-089430752e03/go.mod h1:B6hJiuXT84dHsUgaKHBo+ZLPX4XhklptYA2UbANSiNg= +github.com/livekit/protocol v1.5.8-0.20230620161627-ce9e603cfda8 h1:pri2aylzPrDDTjBKQQdcYsYqwjv9J7W8CnEkrbnF0lU= +github.com/livekit/protocol v1.5.8-0.20230620161627-ce9e603cfda8/go.mod h1:B6hJiuXT84dHsUgaKHBo+ZLPX4XhklptYA2UbANSiNg= github.com/livekit/psrpc v0.3.1 h1:KfylgJHvoLQcc22t/oflwMOeSnx0c14G7cWsS+9MYS4= github.com/livekit/psrpc v0.3.1/go.mod h1:n6JntEg+zT6Ji8InoyTpV7wusPNwGqqtxmHlkNhDN0U= github.com/mackerelio/go-osstat v0.2.4 h1:qxGbdPkFo65PXOb/F/nhDKpF2nGmGaCFDLXoZjJTtUs= diff --git a/pkg/service/ioinfo.go b/pkg/service/ioinfo.go index f3bd6cac7..612020916 100644 --- a/pkg/service/ioinfo.go +++ b/pkg/service/ioinfo.go @@ -143,6 +143,13 @@ func (s *IOInfoService) UpdateIngressState(ctx context.Context, req *rpc.UpdateI logger.Infow("ingress buffering", "ingressID", req.IngressId) } + } else { + // Status didn't change, send Updated event + info.State = req.State + + s.telemetry.IngressUpdated(ctx, info) + + logger.Infow("ingress updated", "ingressID", req.IngressId) } return &emptypb.Empty{}, nil