Skip to content

Commit 7cc5d6c

Browse files
committed
fix: lint errors
1 parent c900aaf commit 7cc5d6c

2 files changed

Lines changed: 17 additions & 2 deletions

File tree

cl/member/member_test.go

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,19 @@ func TestMemberClientRun(t *testing.T) {
124124
relayerServer := &fakeRelayerServer{}
125125
pb.RegisterRelayerServer(s, relayerServer)
126126

127-
go s.Serve(lis)
127+
errChan := make(chan error, 1)
128+
go func() {
129+
errChan <- s.Serve(lis)
130+
}()
131+
132+
select {
133+
case err := <-errChan:
134+
if err != nil {
135+
t.Fatalf("failed to serve: %v", err)
136+
}
137+
case <-time.After(time.Millisecond * 100):
138+
// Server started successfully
139+
}
128140

129141
clientID := "test-client-id"
130142
relayerAddr := lis.Addr().String()

cl/relayer/relayer.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,10 @@ func (r *Relayer) handleBidirectionalStream(stream pb.Relayer_SubscribeServer, c
133133
if !ok || !okPayload || !okSenderID {
134134
r.logger.Error("Invalid message format", "clientID", clientID)
135135
// Acknowledge malformed messages to prevent reprocessing
136-
r.ackMessage(ctx, field.ID, groupName)
136+
err = r.ackMessage(ctx, field.ID, groupName)
137+
if err != nil {
138+
r.logger.Error("Failed to acknowledge malformed message", "clientID", clientID, "error", err)
139+
}
137140
pendingMessageID = ""
138141
continue
139142
}

0 commit comments

Comments
 (0)