Feat/optimise oracle (#6)

* add chainID to signing of oracle votes * update gossip interval to 250ms * add lifecycle hook for checking if oracle result exist * add pruning oracle vote logic for already committed results * add sig prefix for oracle votes signing * add signType to sigPrefix * add configs and init for oracle subaccount signing * update oracle votes signing and verification flow with new sig prefixes wip * add hook to check if subaccount belongs to val * update oracle votes signing and verification flow with new sig prefixes done * update subAccount and pubKey fields with proper camel casing * abstract out getter and creation of sig prefix * fix lint on signer test * remove naming of updateMtx field to improve code readability * add helper func to get signature without prefix, and handle signature index errors --------- Co-authored-by: yan-soon <[email protected]>
Switcheo · Jul 23, 2024 · 532def2 · 532def2
1 parent 388af56
commit 532def2
Show file tree

Hide file tree

Showing 29 changed files with 2,297 additions and 681 deletions.
diff --git a/abci/client/grpc_client.go b/abci/client/grpc_client.go
@@ -257,3 +257,11 @@ func (cli *grpcClient) FetchOracleVotes(ctx context.Context, req *types.RequestF
 func (cli *grpcClient) ValidateOracleVotes(ctx context.Context, req *types.RequestValidateOracleVotes) (*types.ResponseValidateOracleVotes, error) {
 	return cli.client.ValidateOracleVotes(ctx, types.ToRequestValidateOracleVotes(req).GetValidateOracleVotes(), grpc.WaitForReady(true))
 }
+
+func (cli *grpcClient) DoesOracleResultExist(ctx context.Context, req *types.RequestDoesOracleResultExist) (*types.ResponseDoesOracleResultExist, error) {
+	return cli.client.DoesOracleResultExist(ctx, types.ToRequestDoesOracleResultExist(req).GetDoesOracleResultExist(), grpc.WaitForReady(true))
+}
+
+func (cli *grpcClient) DoesSubAccountBelongToVal(ctx context.Context, req *types.RequestDoesSubAccountBelongToVal) (*types.ResponseDoesSubAccountBelongToVal, error) {
+	return cli.client.DoesSubAccountBelongToVal(ctx, types.ToRequestDoesSubAccountBelongToVal(req).GetDoesSubAccountBelongToVal(), grpc.WaitForReady(true))
+}
diff --git a/abci/client/mocks/client.go b/abci/client/mocks/client.go
diff --git a/abci/client/socket_client.go b/abci/client/socket_client.go
@@ -445,6 +445,28 @@ func (cli *socketClient) ValidateOracleVotes(ctx context.Context, req *types.Req
 	return reqRes.Response.GetValidateOracleVotes(), cli.Error()
 }
 
+func (cli *socketClient) DoesOracleResultExist(ctx context.Context, req *types.RequestDoesOracleResultExist) (*types.ResponseDoesOracleResultExist, error) {
+	reqRes, err := cli.queueRequest(ctx, types.ToRequestDoesOracleResultExist(req))
+	if err != nil {
+		return nil, err
+	}
+	if err := cli.Flush(ctx); err != nil {
+		return nil, err
+	}
+	return reqRes.Response.GetDoesOracleResultExist(), cli.Error()
+}
+
+func (cli *socketClient) DoesSubAccountBelongToVal(ctx context.Context, req *types.RequestDoesSubAccountBelongToVal) (*types.ResponseDoesSubAccountBelongToVal, error) {
+	reqRes, err := cli.queueRequest(ctx, types.ToRequestDoesSubAccountBelongToVal(req))
+	if err != nil {
+		return nil, err
+	}
+	if err := cli.Flush(ctx); err != nil {
+		return nil, err
+	}
+	return reqRes.Response.GetDoesSubAccountBelongToVal(), cli.Error()
+}
+
 func (cli *socketClient) queueRequest(ctx context.Context, req *types.Request) (*ReqRes, error) {
 	reqres := NewReqRes(req)
 

diff --git a/abci/types/application.go b/abci/types/application.go
@@ -39,6 +39,8 @@ type Application interface {
 	CreateOracleResultTx(context.Context, *RequestCreateOracleResultTx) (*ResponseCreateOracleResultTx, error)
 	FetchOracleVotes(context.Context, *RequestFetchOracleVotes) (*ResponseFetchOracleVotes, error)
 	ValidateOracleVotes(context.Context, *RequestValidateOracleVotes) (*ResponseValidateOracleVotes, error)
+	DoesOracleResultExist(context.Context, *RequestDoesOracleResultExist) (*ResponseDoesOracleResultExist, error)
+	DoesSubAccountBelongToVal(context.Context, *RequestDoesSubAccountBelongToVal) (*ResponseDoesSubAccountBelongToVal, error)
 }
 
 //-------------------------------------------------------
@@ -136,3 +138,11 @@ func (BaseApplication) FetchOracleVotes(_ context.Context, req *RequestFetchOrac
 func (BaseApplication) ValidateOracleVotes(_ context.Context, req *RequestValidateOracleVotes) (*ResponseValidateOracleVotes, error) {
 	return &ResponseValidateOracleVotes{}, nil
 }
+
+func (BaseApplication) DoesOracleResultExist(_ context.Context, req *RequestDoesOracleResultExist) (*ResponseDoesOracleResultExist, error) {
+	return &ResponseDoesOracleResultExist{}, nil
+}
+
+func (BaseApplication) DoesSubAccountBelongToVal(_ context.Context, req *RequestDoesSubAccountBelongToVal) (*ResponseDoesSubAccountBelongToVal, error) {
+	return &ResponseDoesSubAccountBelongToVal{}, nil
+}
diff --git a/abci/types/messages.go b/abci/types/messages.go
@@ -142,6 +142,18 @@ func ToRequestValidateOracleVotes(req *RequestValidateOracleVotes) *Request {
 	}
 }
 
+func ToRequestDoesOracleResultExist(req *RequestDoesOracleResultExist) *Request {
+	return &Request{
+		Value: &Request_DoesOracleResultExist{req},
+	}
+}
+
+func ToRequestDoesSubAccountBelongToVal(req *RequestDoesSubAccountBelongToVal) *Request {
+	return &Request{
+		Value: &Request_DoesSubAccountBelongToVal{req},
+	}
+}
+
 //----------------------------------------
 
 func ToResponseException(errStr string) *Response {