this repo has no description
cleanup car handling
+4
-6
+4
-6
cmd/relay/bgs/validator.go
+4
-6
cmd/relay/bgs/validator.go
···
192
192
commit, repoFragment, err := atrepo.LoadFromCAR(ctx, bytes.NewReader([]byte(msg.Blocks)))
193
193
if err != nil {
194
194
commitVerifyErrors.WithLabelValues(hostname, "car").Inc()
195
-
if !val.Sync11ErrorsAreWarnings || commit == nil || repoFragment == nil {
196
-
return nil, err
197
-
} else {
195
+
if val.Sync11ErrorsAreWarnings {
198
196
logger.Warn("invalid car", "err", err)
199
197
}
198
+
return nil, fmt.Errorf("invalid car, %w", err)
200
199
}
201
200
202
201
if commit.Rev != rev.String() {
···
409
408
commit, err := atrepo.LoadCARCommit(ctx, bytes.NewReader([]byte(msg.Blocks)))
410
409
if err != nil {
411
410
commitVerifyErrors.WithLabelValues(hostname, "car").Inc()
412
-
if !val.Sync11ErrorsAreWarnings || commit == nil {
413
-
return nil, err
414
-
} else {
411
+
if val.Sync11ErrorsAreWarnings {
415
412
logger.Warn("invalid car", "err", err)
416
413
}
414
+
return nil, fmt.Errorf("invalid car, %w", err)
417
415
}
418
416
419
417
if commit.Rev != rev.String() {