diff --git a/api/clients/disperser_client.go b/api/clients/disperser_client.go index 2d3aebcd6..e677b9683 100644 --- a/api/clients/disperser_client.go +++ b/api/clients/disperser_client.go @@ -15,7 +15,6 @@ import ( "github.com/Layr-Labs/eigenda/encoding" "github.com/Layr-Labs/eigenda/encoding/rs" "google.golang.org/grpc" - "google.golang.org/grpc/codes" "google.golang.org/grpc/credentials" "google.golang.org/grpc/credentials/insecure" ) @@ -149,7 +148,7 @@ func (c *disperserClient) DisperseBlob(ctx context.Context, data []byte, quorums // TODO: implemented in subsequent PR func (c *disperserClient) DispersePaidBlob(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) { - return nil, nil, api.NewGRPCError(codes.Unimplemented, "not implemented") + return nil, nil, api.NewErrorInternal("not implemented") } func (c *disperserClient) DisperseBlobAuthenticated(ctx context.Context, data []byte, quorums []uint8) (*disperser.BlobStatus, []byte, error) { diff --git a/api/grpc/disperser/disperser.pb.go b/api/grpc/disperser/disperser.pb.go index 7f22c0b08..0f766c33d 100644 --- a/api/grpc/disperser/disperser.pb.go +++ b/api/grpc/disperser/disperser.pb.go @@ -539,7 +539,7 @@ type DisperseBlobReply struct { // The request ID generated by the disperser. // Once a request is accepted (although not processed), a unique request ID will be // generated. - // Three different DisperseBlobRequests (determined by the hash of the DisperseBlobRequest) + // Two different DisperseBlobRequests (determined by the hash of the DisperseBlobRequest) // will have different IDs, and the same DisperseBlobRequest sent repeatedly at different // times will also have different IDs. // The client should use this ID to query the processing status of the request (via diff --git a/api/proto/disperser/disperser.proto b/api/proto/disperser/disperser.proto index 36fbcc16d..7df6c5eab 100644 --- a/api/proto/disperser/disperser.proto +++ b/api/proto/disperser/disperser.proto @@ -130,7 +130,7 @@ message DisperseBlobReply { // The request ID generated by the disperser. // Once a request is accepted (although not processed), a unique request ID will be // generated. - // Three different DisperseBlobRequests (determined by the hash of the DisperseBlobRequest) + // Two different DisperseBlobRequests (determined by the hash of the DisperseBlobRequest) // will have different IDs, and the same DisperseBlobRequest sent repeatedly at different // times will also have different IDs. // The client should use this ID to query the processing status of the request (via diff --git a/disperser/apiserver/server.go b/disperser/apiserver/server.go index 5c192eb32..e99a9ef53 100644 --- a/disperser/apiserver/server.go +++ b/disperser/apiserver/server.go @@ -252,7 +252,7 @@ func (s *DispersalServer) DisperseBlob(ctx context.Context, req *pb.DisperseBlob } func (s *DispersalServer) DispersePaidBlob(ctx context.Context, req *pb.DispersePaidBlobRequest) (*pb.DisperseBlobReply, error) { - return &pb.DisperseBlobReply{}, api.NewGRPCError(codes.Unimplemented, "not implemented") + return nil, api.NewErrorInternal("not implemented") } // Note: disperseBlob will internally update metrics upon an error; the caller doesn't need