From d0d96dd1d93d1fa84b559546c9684a8921ba545b Mon Sep 17 00:00:00 2001 From: Rob Watson Date: Sun, 11 May 2025 06:15:20 +0200 Subject: [PATCH] fixup! wip: refactor: API --- internal/client/clientapp.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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) } })