Skip to content

Commit

Permalink
refactor: rename api DispersePaidBlob
Browse files Browse the repository at this point in the history
  • Loading branch information
hopeyen committed Oct 11, 2024
1 parent 6210183 commit 6972c65
Show file tree
Hide file tree
Showing 6 changed files with 48 additions and 48 deletions.
4 changes: 2 additions & 2 deletions api/clients/disperser_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ 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)
GetBlobStatus(ctx context.Context, key []byte) (*disperser_rpc.BlobStatusReply, error)
PaidDisperseBlob(ctx context.Context, data []byte, customQuorums []uint8) (*disperser.BlobStatus, []byte, error)
DispersePaidBlob(ctx context.Context, data []byte, customQuorums []uint8) (*disperser.BlobStatus, []byte, error)
RetrieveBlob(ctx context.Context, batchHeaderHash []byte, blobIndex uint32) ([]byte, error)
}

Expand Down Expand Up @@ -107,7 +107,7 @@ func (c *disperserClient) DisperseBlob(ctx context.Context, data []byte, quorums
return blobStatus, reply.GetRequestId(), nil
}

func (c *disperserClient) PaidDisperseBlob(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) {
func (c *disperserClient) DispersePaidBlob(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) {
return nil, nil, nil
}

Expand Down
2 changes: 1 addition & 1 deletion api/clients/mock/disperser_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ func (c *MockDisperserClient) DisperseBlob(ctx context.Context, data []byte, quo
return status, key, err
}

func (c *MockDisperserClient) PaidDisperseBlob(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) {
func (c *MockDisperserClient) DispersePaidBlob(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) {
return nil, nil, nil
}

Expand Down
54 changes: 27 additions & 27 deletions api/grpc/disperser/disperser.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

28 changes: 14 additions & 14 deletions api/grpc/disperser/disperser_grpc.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions api/proto/disperser/disperser.proto
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ service Disperser {
// This executes the dispersal async, i.e. it returns once the request
// is accepted. The client could use GetBlobStatus() API to poll the the
// processing status of the blob.
rpc PaidDisperseBlob(PaidDisperseBlobRequest) returns (DisperseBlobReply) {}
rpc DispersePaidBlob(DispersePaidBlobRequest) returns (DisperseBlobReply) {}


// DisperseBlobAuthenticated is similar to DisperseBlob, except that it requires the
Expand Down Expand Up @@ -48,7 +48,7 @@ message AuthenticatedRequest {
oneof payload {
DisperseBlobRequest disperse_request = 1;
AuthenticationData authentication_data = 2;
PaidDisperseBlobRequest paid_disperse_request = 3;
DispersePaidBlobRequest paid_disperse_request = 3;
}
}

Expand Down Expand Up @@ -96,7 +96,7 @@ message DisperseBlobRequest {
string account_id = 3;
}

message PaidDisperseBlobRequest {
message DispersePaidBlobRequest {
// The data to be dispersed.
// The size of data must be <= 2MiB. Every 32 bytes of data chunk is interpreted as an integer in big endian format
// where the lower address has more significant bits. The integer must stay in the valid range to be interpreted
Expand Down
2 changes: 1 addition & 1 deletion tools/traffic/workers/mock_disperser.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ func (m *MockDisperserClient) DisperseBlobAuthenticated(
return args.Get(0).(*disperser.BlobStatus), args.Get(1).([]byte), args.Error(2)
}

func (m *MockDisperserClient) PaidDisperseBlob(
func (m *MockDisperserClient) DispersePaidBlob(
ctx context.Context,
data []byte,
customQuorums []uint8) (*disperser.BlobStatus, []byte, error) {
Expand Down

0 comments on commit 6972c65

Please sign in to comment.