refactor: add signature to dispersePaidBlob API request

Layr-Labs · Oct 22, 2024 · bdcea7f · bdcea7f
1 parent 660efdd
commit bdcea7f
Show file tree

Hide file tree

Showing 7 changed files with 300 additions and 518 deletions.
diff --git a/api/clients/disperser_client.go b/api/clients/disperser_client.go
@@ -42,7 +42,6 @@ type DisperserClient interface {
 	DisperseBlob(ctx context.Context, data []byte, customQuorums []uint8) (*disperser.BlobStatus, []byte, error)
 	DisperseBlobAuthenticated(ctx context.Context, data []byte, customQuorums []uint8) (*disperser.BlobStatus, []byte, error)
 	DispersePaidBlob(ctx context.Context, data []byte, customQuorums []uint8) (*disperser.BlobStatus, []byte, error)
-	DispersePaidBlobAuthenticated(ctx context.Context, data []byte, customQuorums []uint8) (*disperser.BlobStatus, []byte, error)
 	GetBlobStatus(ctx context.Context, key []byte) (*disperser_rpc.BlobStatusReply, error)
 	RetrieveBlob(ctx context.Context, batchHeaderHash []byte, blobIndex uint32) ([]byte, error)
 }
@@ -223,11 +222,6 @@ func (c *disperserClient) DisperseBlobAuthenticated(ctx context.Context, data []
 	return blobStatus, disperseReply.DisperseReply.GetRequestId(), nil
 }
 
-// TODO: implemented in subsequent PR
-func (c *disperserClient) DispersePaidBlobAuthenticated(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) {
-	return nil, nil, api.NewGRPCError(codes.Unimplemented, "not implemented")
-}
-
 func (c *disperserClient) GetBlobStatus(ctx context.Context, requestID []byte) (*disperser_rpc.BlobStatusReply, error) {
 	addr := fmt.Sprintf("%v:%v", c.config.Hostname, c.config.Port)
 	dialOptions := c.getDialOptions()

diff --git a/api/clients/mock/disperser_client.go b/api/clients/mock/disperser_client.go
@@ -81,12 +81,6 @@ func (c *MockDisperserClient) DisperseBlob(ctx context.Context, data []byte, quo
 	return status, key, err
 }
 
-// TODO: implement in the subsequent PR
-func (c *MockDisperserClient) DispersePaidBlobAuthenticated(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) {
-	return nil, nil, nil
-
-}
-
 // TODO: implement in the subsequent PR
 func (c *MockDisperserClient) DispersePaidBlob(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) {
 	return nil, nil, nil