@@ -127,7 +127,7 @@ const (
127
127
128
128
type BulkSubscribeResponseEntry struct {
129
129
// The id of the bulk subscribe entry
130
- EntryId string `json:"entryId"`
130
+ EntryId string `json:"entryId"` //nolint:stylecheck
131
131
132
132
// The response status of the bulk subscribe entry
133
133
Status AppResponseStatus `json:"status"`
@@ -367,14 +367,14 @@ func (s *Server) AddBulkTopicEventHandler(sub *common.Subscription, fn common.To
367
367
statuses := make ([]BulkSubscribeResponseEntry , 0 , len (ins .Entries ))
368
368
369
369
for _ , entry := range ins .Entries {
370
- itemJSON , err := json .Marshal (entry .Event )
371
- if err != nil {
372
- http .Error (w , err .Error (), PubSubHandlerDropStatusCode )
370
+ itemJSON , entryErr := json .Marshal (entry .Event )
371
+ if entryErr != nil {
372
+ http .Error (w , entryErr .Error (), PubSubHandlerDropStatusCode )
373
373
return
374
374
}
375
375
var in topicEventJSON
376
376
377
- if err : = json .Unmarshal (itemJSON , & in ); err != nil {
377
+ if err = json .Unmarshal (itemJSON , & in ); err != nil {
378
378
http .Error (w , err .Error (), PubSubHandlerDropStatusCode )
379
379
return
380
380
}
@@ -400,8 +400,8 @@ func (s *Server) AddBulkTopicEventHandler(sub *common.Subscription, fn common.To
400
400
Topic : in .Topic ,
401
401
}
402
402
403
- retry , err := fn (r .Context (), & te )
404
- if err == nil {
403
+ retry , funcErr := fn (r .Context (), & te )
404
+ if funcErr == nil {
405
405
statuses = append (statuses , BulkSubscribeResponseEntry {
406
406
EntryId : entry .EntryId ,
407
407
Status : Success ,
0 commit comments