Fix: Match wrapped errors (#315)

Layr-Labs · Mar 5, 2024 · e83598b · e83598b
1 parent bb53a12
commit e83598b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/validator.go b/core/validator.go
@@ -132,7 +132,7 @@ func (v *chunkValidator) ValidateBatch(blobs []*BlobMessage, operatorState *Oper
 		// for each quorum
 		for _, quorumHeader := range blob.BlobHeader.QuorumInfos {
 			chunks, assignment, params, err := v.validateBlobQuorum(quorumHeader, blob, operatorState)
-			if err == ErrBlobQuorumSkip {
+			if errors.Is(err, ErrBlobQuorumSkip) {
 				continue
 			} else if err != nil {
 				return err

diff --git a/node/node.go b/node/node.go
@@ -303,7 +303,7 @@ func (n *Node) ProcessBatch(ctx context.Context, header *core.BatchHeader, blobs
 		if err != nil {
 			// If batch already exists, we don't store it again, but we should not
 			// error out in such case.
-			if err == ErrBatchAlreadyExist {
+			if errors.Is(err, ErrBatchAlreadyExist) {
 				storeChan <- storeResult{err: nil, keys: nil, latency: 0}
 			} else {
 				storeChan <- storeResult{err: fmt.Errorf("failed to store batch: %w", err), keys: nil, latency: 0}