From e655eb280cf5c3239830ae7dd9df4298ac7cd0f4 Mon Sep 17 00:00:00 2001 From: Siddharth More Date: Sun, 5 May 2024 15:26:15 -0700 Subject: [PATCH] fix test --- .../blobstore/blob_metadata_store_test.go | 35 ------------------- disperser/common/blobstore/blobstore_test.go | 3 -- 2 files changed, 38 deletions(-) diff --git a/disperser/common/blobstore/blob_metadata_store_test.go b/disperser/common/blobstore/blob_metadata_store_test.go index 90f3dae69d..23ac3ad591 100644 --- a/disperser/common/blobstore/blob_metadata_store_test.go +++ b/disperser/common/blobstore/blob_metadata_store_test.go @@ -297,13 +297,6 @@ func TestBlobMetadataStoreWithAccountId(t *testing.T) { err = blobMetadataStore.QueueNewBlobMetadata(ctx, metadata2) assert.NoError(t, err) - fetchedMetadata, err := blobMetadataStore.GetBlobMetadata(ctx, blobKey1) - assert.NoError(t, err) - assert.Equal(t, metadata1, fetchedMetadata) - fetchedMetadata, err = blobMetadataStore.GetBlobMetadata(ctx, blobKey2) - assert.NoError(t, err) - assert.Equal(t, metadata2, fetchedMetadata) - processing, err := blobMetadataStore.GetBlobMetadataByStatus(ctx, disperser.Processing) assert.NoError(t, err) assert.Len(t, processing, 1) @@ -317,34 +310,6 @@ func TestBlobMetadataStoreWithAccountId(t *testing.T) { assert.NoError(t, err) assert.Equal(t, int32(2), blobCountByAccountId) - err = blobMetadataStore.IncrementNumRetries(ctx, metadata1) - assert.NoError(t, err) - fetchedMetadata, err = blobMetadataStore.GetBlobMetadata(ctx, blobKey1) - assert.NoError(t, err) - metadata1.NumRetries = 1 - assert.Equal(t, metadata1, fetchedMetadata) - - finalized, err := blobMetadataStore.GetBlobMetadataByStatus(ctx, disperser.Finalized) - assert.NoError(t, err) - assert.Len(t, finalized, 1) - assert.Equal(t, metadata2, finalized[0]) - - finalizedCount, err := blobMetadataStore.GetBlobMetadataByStatusCount(ctx, disperser.Finalized) - assert.NoError(t, err) - assert.Equal(t, int32(1), finalizedCount) - - confirmedMetadata := getConfirmedMetadata(t, blobKey1) - err = blobMetadataStore.UpdateBlobMetadata(ctx, blobKey1, confirmedMetadata) - assert.NoError(t, err) - - metadata, err := blobMetadataStore.GetBlobMetadataInBatch(ctx, confirmedMetadata.ConfirmationInfo.BatchHeaderHash, confirmedMetadata.ConfirmationInfo.BlobIndex) - assert.NoError(t, err) - assert.Equal(t, metadata, confirmedMetadata) - - confirmedCount, err := blobMetadataStore.GetBlobMetadataByStatusCount(ctx, disperser.Confirmed) - assert.NoError(t, err) - assert.Equal(t, int32(1), confirmedCount) - deleteItems(t, []commondynamodb.Key{ { "MetadataHash": &types.AttributeValueMemberS{Value: blobKey1.MetadataHash}, diff --git a/disperser/common/blobstore/blobstore_test.go b/disperser/common/blobstore/blobstore_test.go index 71c5f66af4..22e527b04e 100644 --- a/disperser/common/blobstore/blobstore_test.go +++ b/disperser/common/blobstore/blobstore_test.go @@ -31,9 +31,6 @@ var ( blob = &core.Blob{ RequestHeader: core.BlobRequestHeader{ SecurityParams: securityParams, - BlobAuthHeader: core.BlobAuthHeader{ - AccountID: "test", - }, }, Data: []byte("test"),