From 7d6798b0f7d24912178e14d839a8d82ade816ee0 Mon Sep 17 00:00:00 2001 From: Rob Watson Date: Tue, 13 May 2025 07:25:25 +0200 Subject: [PATCH] fixup! wip: refactor: API --- internal/client/clientapp.go | 4 ++-- internal/server/grpc.go | 2 +- internal/server/serverapp.go | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/client/clientapp.go b/internal/client/clientapp.go index 3352506..8fe8faa 100644 --- a/internal/client/clientapp.go +++ b/internal/client/clientapp.go @@ -63,9 +63,9 @@ func (a *App) Run(ctx context.Context) error { ui, err := terminal.NewUI(ctx, terminal.Params{ EventBus: a.bus, Dispatcher: func(cmd event.Command) { - a.logger.Info("Command dispatched", "cmd", cmd.Name()) + a.logger.Debug("Command dispatched to gRPC stream", "cmd", cmd.Name()) if sendErr := stream.Send(&pb.Envelope{Payload: &pb.Envelope_Command{Command: protocol.CommandToProto(cmd)}}); sendErr != nil { - a.logger.Error("Error sending command to gRPC API", "err", sendErr) + a.logger.Error("Error dispatching command to gRPC stream", "err", sendErr) } }, ClipboardAvailable: a.clipboardAvailable, diff --git a/internal/server/grpc.go b/internal/server/grpc.go index bcc9dbf..55f8e1e 100644 --- a/internal/server/grpc.go +++ b/internal/server/grpc.go @@ -109,7 +109,7 @@ func (s *Server) Communicate(stream pb.InternalAPI_CommunicateServer) error { switch pbCmd := in.Payload.(type) { case *pb.Envelope_Command: cmd := protocol.CommandFromProto(pbCmd.Command) - s.logger.Info("Received command", "command", cmd.Name()) + s.logger.Debug("Received command from gRPC stream", "command", cmd.Name()) s.dispatcher(cmd) default: return fmt.Errorf("expected command but got: %T", pbCmd) diff --git a/internal/server/serverapp.go b/internal/server/serverapp.go index 675c241..6d37e84 100644 --- a/internal/server/serverapp.go +++ b/internal/server/serverapp.go @@ -265,7 +265,7 @@ func (a *App) handleCommand( containerClient *container.Client, startMediaServerC chan struct{}, ) (evt event.Event, _ error) { - a.logger.Debug("Command received", "cmd", cmd.Name()) + a.logger.Debug("Command received in handler", "cmd", cmd.Name()) defer func() { if evt != nil { a.eventBus.Send(evt)