chainrpc: update proto to expose GetBlockHeader

This commit is contained in:
Jonathan Harvey-Buschel
2023-10-26 11:09:12 -04:00
parent 7d2e0ae3e4
commit 7a8803e3cf
7 changed files with 404 additions and 58 deletions

View File

@@ -21,6 +21,9 @@ type ChainKitClient interface {
// lncli: `chain getblock`
// GetBlock returns a block given the corresponding block hash.
GetBlock(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (*GetBlockResponse, error)
// lncli: `chain getblockheader`
// GetBlockHeader returns a block header with a particular block hash.
GetBlockHeader(ctx context.Context, in *GetBlockHeaderRequest, opts ...grpc.CallOption) (*GetBlockHeaderResponse, error)
// lncli: `chain getbestblock`
// GetBestBlock returns the block hash and current height from the valid
// most-work chain.
@@ -48,6 +51,15 @@ func (c *chainKitClient) GetBlock(ctx context.Context, in *GetBlockRequest, opts
return out, nil
}
func (c *chainKitClient) GetBlockHeader(ctx context.Context, in *GetBlockHeaderRequest, opts ...grpc.CallOption) (*GetBlockHeaderResponse, error) {
out := new(GetBlockHeaderResponse)
err := c.cc.Invoke(ctx, "/chainrpc.ChainKit/GetBlockHeader", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *chainKitClient) GetBestBlock(ctx context.Context, in *GetBestBlockRequest, opts ...grpc.CallOption) (*GetBestBlockResponse, error) {
out := new(GetBestBlockResponse)
err := c.cc.Invoke(ctx, "/chainrpc.ChainKit/GetBestBlock", in, out, opts...)
@@ -73,6 +85,9 @@ type ChainKitServer interface {
// lncli: `chain getblock`
// GetBlock returns a block given the corresponding block hash.
GetBlock(context.Context, *GetBlockRequest) (*GetBlockResponse, error)
// lncli: `chain getblockheader`
// GetBlockHeader returns a block header with a particular block hash.
GetBlockHeader(context.Context, *GetBlockHeaderRequest) (*GetBlockHeaderResponse, error)
// lncli: `chain getbestblock`
// GetBestBlock returns the block hash and current height from the valid
// most-work chain.
@@ -91,6 +106,9 @@ type UnimplementedChainKitServer struct {
func (UnimplementedChainKitServer) GetBlock(context.Context, *GetBlockRequest) (*GetBlockResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetBlock not implemented")
}
func (UnimplementedChainKitServer) GetBlockHeader(context.Context, *GetBlockHeaderRequest) (*GetBlockHeaderResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetBlockHeader not implemented")
}
func (UnimplementedChainKitServer) GetBestBlock(context.Context, *GetBestBlockRequest) (*GetBestBlockResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetBestBlock not implemented")
}
@@ -128,6 +146,24 @@ func _ChainKit_GetBlock_Handler(srv interface{}, ctx context.Context, dec func(i
return interceptor(ctx, in, info, handler)
}
func _ChainKit_GetBlockHeader_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetBlockHeaderRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(ChainKitServer).GetBlockHeader(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/chainrpc.ChainKit/GetBlockHeader",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(ChainKitServer).GetBlockHeader(ctx, req.(*GetBlockHeaderRequest))
}
return interceptor(ctx, in, info, handler)
}
func _ChainKit_GetBestBlock_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetBestBlockRequest)
if err := dec(in); err != nil {
@@ -175,6 +211,10 @@ var ChainKit_ServiceDesc = grpc.ServiceDesc{
MethodName: "GetBlock",
Handler: _ChainKit_GetBlock_Handler,
},
{
MethodName: "GetBlockHeader",
Handler: _ChainKit_GetBlockHeader_Handler,
},
{
MethodName: "GetBestBlock",
Handler: _ChainKit_GetBestBlock_Handler,