refactor: add signature to DispersePaidBlob, rm DispersePaidBlobAuthe…

…nticated
Layr-Labs · Oct 24, 2024 · 9ed0ed8 · 9ed0ed8
1 parent 40dedb4
commit 9ed0ed8
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 5 deletions.
diff --git 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
diff --git 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
@@ -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