fix: downgrade logging if attestation does not exist yet (#1847)

downgrade logging if attestation does not exist yet

Author: ian-shim

disperser/apiserver/get_blob_status_v2.go

@@ -12,6 +12,7 @@ import (
 	corev2 "github.com/Layr-Labs/eigenda/core/v2"
 	dispcommon "github.com/Layr-Labs/eigenda/disperser/common"
 	dispv2 "github.com/Layr-Labs/eigenda/disperser/common/v2"
+	blobstore "github.com/Layr-Labs/eigenda/disperser/common/v2/blobstore"
 )
 
 func (s *DispersalServerV2) GetBlobStatus(ctx context.Context, req *pb.BlobStatusRequest) (*pb.BlobStatusReply, error) {
@@ -80,6 +81,11 @@ func (s *DispersalServerV2) GetBlobStatus(ctx context.Context, req *pb.BlobStatu
 		}
 		batchHeader, attestation, err := s.blobMetadataStore.GetSignedBatch(ctx, batchHeaderHash)
 		if err != nil {
+			if errors.Is(err, blobstore.ErrAttestationNotFound) {
+				// attestation may not exist yet if the blob has not been processed by the dispatcher
+				s.logger.Info("attestation not found for signed batch", "err", err, "blobKey", blobKey.Hex())
+				continue
+			}
 			s.logger.Error("failed to get signed batch", "err", err, "blobKey", blobKey.Hex())
 			continue
 		}

disperser/common/v2/blobstore/dynamo_metadata_store.go

@@ -1392,7 +1392,7 @@ func (s *BlobMetadataStore) GetSignedBatch(ctx context.Context, batchHeaderHash
 	}
 
 	if attestation == nil {
-		return nil, nil, fmt.Errorf("%w: attestation not found for hash %x", ErrMetadataNotFound, batchHeaderHash)
+		return nil, nil, fmt.Errorf("%w: attestation not found for hash %x", ErrAttestationNotFound, batchHeaderHash)
 	}
 
 	return header, attestation, nil

disperser/common/v2/blobstore/errors.go

@@ -7,4 +7,5 @@ var (
 	ErrMetadataNotFound       = errors.New("metadata not found")
 	ErrAlreadyExists          = errors.New("record already exists")
 	ErrInvalidStateTransition = errors.New("invalid state transition")
+	ErrAttestationNotFound    = errors.New("attestation not found")
 )