diff --git a/internal/client/clientapp.go b/internal/client/clientapp.go index 6fbc7e7..eec1380 100644 --- a/internal/client/clientapp.go +++ b/internal/client/clientapp.go @@ -64,14 +64,15 @@ func (a *App) Run(ctx context.Context) error { return fmt.Errorf("receive envelope: %w", recErr) } - evt := envelope.GetEvent() - if evt == nil { + pbEvt := envelope.GetEvent() + if pbEvt == nil { a.logger.Error("Received envelope without event") continue } - a.logger.Debug("Received event") - a.bus.Send(protocol.EventFromProto(evt)) + evt := protocol.EventFromProto(pbEvt) + a.logger.Debug("Received event from gRPC stream", "event", evt) + a.bus.Send(evt) } })