feat: support staking btc by bnb chain

.github/workflows/codeql.yml

@@ -26,7 +26,7 @@ jobs:
         uses: actions/checkout@v3
       - uses: actions/setup-go@v3
         with:
-          go-version: "1.20"
+          go-version: "1.21"
       # Initializes the CodeQL tools for scanning.
       - name: Initialize CodeQL
         uses: github/codeql-action/init@v2

.github/workflows/golangci_lint.yml

@@ -15,7 +15,7 @@ jobs:
       - uses: actions/checkout@v4
       - uses: actions/setup-go@v4
         with:
-          go-version: "1.20"
+          go-version: "1.21"
           check-latest: true
       - uses: technote-space/[email protected]
         id: git_diff

.github/workflows/release_binary.yml

@@ -21,7 +21,7 @@ jobs:
       - name: Set up Go
         uses: actions/setup-go@v4
         with:
-          go-version: '1.20'
+          go-version: '1.21'
           check-latest: true
 
       - name: release dry run

.github/workflows/test.yml

@@ -20,7 +20,7 @@ jobs:
     steps:
       - uses: actions/setup-go@v4
         with:
-          go-version: '1.20'
+          go-version: '1.21'
           check-latest: true
       - uses: actions/checkout@v4
       - uses: technote-space/[email protected]

go.mod

@@ -1,6 +1,6 @@
 module github.com/Lorenzo-Protocol/lorenzo
 
-go 1.20
+go 1.21
 
 require (
 	cosmossdk.io/errors v1.0.1
@@ -40,6 +40,7 @@ require (
 	github.com/pkg/errors v0.9.1
 	github.com/spf13/pflag v1.0.5
 	github.com/stretchr/testify v1.9.0
+	golang.org/x/crypto v0.21.0
 	golang.org/x/exp v0.0.0-20230905200255-921286631fa9
 )
 
@@ -208,7 +209,6 @@ require (
 	go.opentelemetry.io/otel/trace v1.21.0 // indirect
 	go.uber.org/atomic v1.10.0 // indirect
 	go.uber.org/multierr v1.9.0 // indirect
-	golang.org/x/crypto v0.21.0 // indirect
 	golang.org/x/net v0.23.0 // indirect
 	golang.org/x/oauth2 v0.16.0 // indirect
 	golang.org/x/sync v0.6.0 // indirect

proto/lorenzo/bnblightclient/v1/client.proto

@@ -0,0 +1,21 @@
+syntax = "proto3";
+package lorenzo.bnblightclient.v1;
+
+import "gogoproto/gogo.proto";
+
+option go_package = "github.com/Lorenzo-Protocol/lorenzo/x/bnblightclient/types";
+
+message Header {
+  option (gogoproto.goproto_getters) = false;
+
+  // header defines the bnb header bytes
+  bytes raw_header = 1;
+  // parent_hash defines the previous bnb header hash
+  bytes parent_hash = 2;
+  // hash defines the bnb header hash
+  bytes hash = 3;
+  // number defines the block number
+  uint64 number = 4;
+  // receipt_root defines the receipts merkle root hash
+  bytes receipt_root = 5;
+}

proto/lorenzo/bnblightclient/v1/genesis.proto

@@ -0,0 +1,23 @@
+syntax = "proto3";
+package lorenzo.bnblightclient.v1;
+
+import "lorenzo/bnblightclient/v1/client.proto";
+import "lorenzo/bnblightclient/v1/params.proto";
+
+option go_package = "github.com/Lorenzo-Protocol/lorenzo/x/bnblightclient/types";
+
+// GenesisState defines the bnb light client state
+message GenesisState {
+    // params defines the bnb light client parameters
+    lorenzo.bnblightclient.v1.Params params = 1;
+    // headers defines the bnb light client headers
+    repeated lorenzo.bnblightclient.v1.Header headers = 2;
+    // records defines the bnb light client event records
+    repeated EventRecord records = 3;
+}
+
+message EventRecord {
+  uint64 block_number = 1;
+  bytes contract = 2;
+  uint64 index = 3;
+}

proto/lorenzo/bnblightclient/v1/params.proto

@@ -0,0 +1,23 @@
+syntax = "proto3";
+package lorenzo.bnblightclient.v1;
+
+import "gogoproto/gogo.proto";
+
+option go_package = "github.com/Lorenzo-Protocol/lorenzo/x/bnblightclient/types";
+
+// Params defines the parameters for the module.
+message Params {
+  option (gogoproto.equal) = true;
+
+  // the stake plan hub contract address
+  string stake_plan_hub_address = 1;
+  // event_index defines index of generated the event in the contract
+  repeated string event_indices = 2;
+  // event_name defines the event name
+  string event_name = 3;
+  // the maximum number of bnb block headers to retain
+  uint64 retained_blocks = 4;
+  // list of people who can upload bnb block header information
+  repeated string allow_list = 5;
+
+}

proto/lorenzo/bnblightclient/v1/query.proto

@@ -0,0 +1,74 @@
+syntax = "proto3";
+package lorenzo.bnblightclient.v1;
+
+import "gogoproto/gogo.proto";
+import "google/api/annotations.proto";
+import "lorenzo/bnblightclient/v1/client.proto";
+import "lorenzo/bnblightclient/v1/params.proto";
+
+option go_package = "github.com/Lorenzo-Protocol/lorenzo/x/bnblightclient/types";
+
+// Query defines the gRPC querier service.
+service Query {
+  // Params queries the parameters of the module.
+  rpc Params(QueryParamsRequest) returns (QueryParamsResponse) {
+    option (google.api.http).get = "/lorenzo/bnblightclient/v1/params";
+  }
+
+  // Header returns the header in bnb chain by number
+  rpc Header(QueryHeaderRequest) returns (QueryHeaderResponse) {
+    option (google.api.http).get = "/lorenzo/bnblightclient/v1/header/{number}";
+  }
+
+  // HeaderByHash returns the header in bnb chain by hash
+  rpc HeaderByHash(QueryHeaderByHashRequest)
+      returns (QueryHeaderByHashResponse) {
+    option (google.api.http).get = "/lorenzo/bnblightclient/v1/header/{hash}/hash";
+  }
+
+  // LatestedHeader returns the latested header in bnb chain
+  rpc LatestedHeader(QueryLatestedHeaderRequest)
+      returns (QueryLatestedHeaderResponse) {
+    option (google.api.http).get = "/lorenzo/bnblightclient/v1/latested_header";
+  }
+}
+
+// QueryParamsRequest is the request type for the Query/Params RPC method.
+message QueryParamsRequest {}
+
+// QueryParamsResponse is the response type for the Query/Params RPC method.
+message QueryParamsResponse {
+  // params holds all the parameters of this module.
+  lorenzo.bnblightclient.v1.Params params = 1 [ (gogoproto.nullable) = false ];
+}
+
+// QueryHeaderRequest is the request type for the Query/Header RPC method.
+message QueryHeaderRequest { uint64 number = 1; }
+
+// QueryParamsResponse is the response type for the Query/Header RPC method.
+message QueryHeaderResponse {
+  // params holds all the parameters of this module.
+  lorenzo.bnblightclient.v1.Header header = 1 [ (gogoproto.nullable) = true ];
+}
+
+// QueryHeaderByHashRequest is the request type for the Query/HeaderByHash RPC
+// method.
+message QueryHeaderByHashRequest { bytes hash = 1; }
+
+// QueryHeaderByHashResponse is the response type for the Query/HeaderByHash RPC
+// method.
+message QueryHeaderByHashResponse {
+  // params holds all the parameters of this module.
+  lorenzo.bnblightclient.v1.Header header = 1 [ (gogoproto.nullable) = true ];
+}
+
+// QueryLatestedHeaderRequest is the request type for the Query/LatestedHeader
+// RPC method.
+message QueryLatestedHeaderRequest {}
+
+// QueryLatestedHeaderResponse is the response type for the Query/LatestedHeader
+// RPC method.
+message QueryLatestedHeaderResponse {
+  // header holds the bnb light client header.
+  lorenzo.bnblightclient.v1.Header header = 1 [ (gogoproto.nullable) = false ];
+}

proto/lorenzo/bnblightclient/v1/tx.proto

@@ -0,0 +1,65 @@
+syntax = "proto3";
+package lorenzo.bnblightclient.v1;
+
+import "gogoproto/gogo.proto";
+import "cosmos_proto/cosmos.proto";
+import "cosmos/msg/v1/msg.proto";
+import "lorenzo/bnblightclient/v1/client.proto";
+import "lorenzo/bnblightclient/v1/params.proto";
+
+option go_package = "github.com/Lorenzo-Protocol/lorenzo/x/bnblightclient/types";
+
+// Msg defines the Msg service.
+service Msg {
+  option (cosmos.msg.v1.service) = true;
+
+  // UploadHeaders adds a batch of headers to the bnb light client chain
+  rpc UploadHeaders(MsgUploadHeaders) returns (MsgUploadHeadersResponse) {};
+
+  // UpdateParams defines a method for updating bnb light client module
+  // parameters.
+  rpc UpdateParams(MsgUpdateParams) returns (MsgUpdateParamsResponse);
+
+  // UpdateHeader defines a method for updating bnb light client header.
+  rpc UpdateHeader(MsgUpdateHeader) returns (MsgUpdateHeaderResponse);
+}
+
+// MsgUploadHeaders defines the message for multiple incoming header bytes
+message MsgUploadHeaders {
+  option (cosmos.msg.v1.signer) = "signer";
+
+  repeated lorenzo.bnblightclient.v1.Header headers = 1;
+  string signer = 2 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+}
+// MsgUploadHeadersResponse defines the response for the UploadHeaders transaction
+message MsgUploadHeadersResponse {}
+
+// MsgUpdateHeader defines the message for updating bnb light client header.
+message MsgUpdateHeader {
+  option (cosmos.msg.v1.signer) = "signer";
+
+  lorenzo.bnblightclient.v1.Header header = 1;
+  string signer = 2 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+}
+// MsgUpdateHeaderResponse defines the response for the UpdateHeader
+// transaction
+message MsgUpdateHeaderResponse {}
+
+// MsgUpdateParams defines a message for updating fee module parameters.
+message MsgUpdateParams {
+  option (cosmos.msg.v1.signer) = "authority";
+
+  // authority is the address of the governance account.
+  // just FYI: cosmos.AddressString marks that this field should use type alias
+  // for AddressString instead of string, but the functionality is not yet
+  // implemented in cosmos-proto
+  string authority = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // params defines the bnb light client parameters.
+  //
+  // NOTE: All parameters must be supplied.
+  lorenzo.bnblightclient.v1.Params params = 2 [ (gogoproto.nullable) = false ];
+}
+
+// MsgUpdateParamsResponse is the response to the MsgUpdateParams message.
+message MsgUpdateParamsResponse {}

proto/lorenzo/btcstaking/v1/tx.proto

@@ -15,6 +15,9 @@ service Msg {
 
   rpc CreateBTCStaking(MsgCreateBTCStaking) returns (MsgCreateBTCStakingResponse);
 
+  rpc CreateBTCStakingFromBNB(MsgCreateBTCStakingFromBNB)
+      returns (MsgCreateBTCStakingFromBNBResponse);
+
   rpc Burn(MsgBurnRequest) returns (MsgBurnResponse);
 
   rpc AddReceiver(MsgAddReceiver) returns (MsgAddReceiverResponse);
@@ -58,6 +61,16 @@ message MsgCreateBTCStaking {
 
 message MsgCreateBTCStakingResponse {}
 
+message MsgCreateBTCStakingFromBNB {
+  option (cosmos.msg.v1.signer) = "signer";
+
+  string signer = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+  bytes  receipt = 2;
+  bytes  proof = 3;
+}
+
+message MsgCreateBTCStakingFromBNBResponse {}
+
 message MsgBurnRequest {
   option (cosmos.msg.v1.signer) = "signer";
   string signer = 1;

x/bnblightclient/keeper/grpc_query.go

@@ -0,0 +1,56 @@
+package keeper
+
+import (
+	"context"
+
+	errorsmod "cosmossdk.io/errors"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+
+	"github.com/Lorenzo-Protocol/lorenzo/x/bnblightclient/types"
+)
+
+var _ types.QueryServer = Querier{}
+
+// Querier defines a wrapper around the x/bnblightclient keeper providing gRPC method
+type Querier struct {
+	k Keeper
+}
+
+// Header implements types.QueryServer.
+func (q Querier) Header(goCtx context.Context, req *types.QueryHeaderRequest) (*types.QueryHeaderResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	header, found := q.k.GetHeader(ctx, req.Number)
+	if !found {
+		return nil, errorsmod.Wrapf(types.ErrHeaderNotFound, "header %d not found", req.Number)
+	}
+	return &types.QueryHeaderResponse{Header: header}, nil
+}
+
+// HeaderByHash implements types.QueryServer.
+func (q Querier) HeaderByHash(goCtx context.Context, req *types.QueryHeaderByHashRequest) (*types.QueryHeaderByHashResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	header, found := q.k.GetHeaderByHash(ctx, req.Hash)
+	if !found {
+		return nil, errorsmod.Wrapf(types.ErrHeaderNotFound, "header %x not found", req.Hash)
+	}
+	return &types.QueryHeaderByHashResponse{Header: header}, nil
+}
+
+// LatestedHeader implements types.QueryServer.
+func (q Querier) LatestedHeader(goCtx context.Context, req *types.QueryLatestedHeaderRequest) (*types.QueryLatestedHeaderResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+	header, found := q.k.GetLatestedHeader(ctx)
+	if !found {
+		return nil, errorsmod.Wrap(types.ErrHeaderNotFound, "latested header not found")
+	}
+	return &types.QueryLatestedHeaderResponse{Header: *header}, nil
+}
+
+// Params implements types.QueryServer.
+func (q Querier) Params(goCtx context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+	params := q.k.GetParams(ctx)
+	return &types.QueryParamsResponse{Params: params}, nil
+}