Merge pull request #1 from Switcheo/feat/oracle-reactor

Feat/oracle reactor
Switcheo · Jun 11, 2024 · 9387a39 · 9387a39
2 parents e10b1f0 + d947aab
commit 9387a39
Show file tree

Hide file tree

Showing 46 changed files with 5,159 additions and 472 deletions.
diff --git a/Makefile b/Makefile
@@ -15,6 +15,8 @@ GOOS ?= linux
 GOARCH ?= amd64
 GOARM ?=
 
+DOCKER := $(shell which docker)
+
 ifeq (linux/arm,$(findstring linux/arm,$(TARGETPLATFORM)))
 	GOOS=linux
 	GOARCH=arm

diff --git a/abci/client/grpc_client.go b/abci/client/grpc_client.go
@@ -245,3 +245,15 @@ func (cli *grpcClient) VerifyVoteExtension(ctx context.Context, req *types.Reque
 func (cli *grpcClient) FinalizeBlock(ctx context.Context, req *types.RequestFinalizeBlock) (*types.ResponseFinalizeBlock, error) {
 	return cli.client.FinalizeBlock(ctx, types.ToRequestFinalizeBlock(req).GetFinalizeBlock(), grpc.WaitForReady(true))
 }
+
+func (cli *grpcClient) CreateOracleResultTx(ctx context.Context, req *types.RequestCreateOracleResultTx) (*types.ResponseCreateOracleResultTx, error) {
+	return cli.client.CreateOracleResultTx(ctx, types.ToRequestCreateOracleResultTx(req).GetCreateOracleResultTx(), grpc.WaitForReady(true))
+}
+
+func (cli *grpcClient) FetchOracleVotes(ctx context.Context, req *types.RequestFetchOracleVotes) (*types.ResponseFetchOracleVotes, error) {
+	return cli.client.FetchOracleVotes(ctx, types.ToRequestFetchOracleVotes(req).GetFetchOracleVotes(), grpc.WaitForReady(true))
+}
+
+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))
+}
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
@@ -412,6 +412,39 @@ func (cli *socketClient) FinalizeBlock(ctx context.Context, req *types.RequestFi
 	return reqRes.Response.GetFinalizeBlock(), cli.Error()
 }
 
+func (cli *socketClient) CreateOracleResultTx(ctx context.Context, req *types.RequestCreateOracleResultTx) (*types.ResponseCreateOracleResultTx, error) {
+	reqRes, err := cli.queueRequest(ctx, types.ToRequestCreateOracleResultTx(req))
+	if err != nil {
+		return nil, err
+	}
+	if err := cli.Flush(ctx); err != nil {
+		return nil, err
+	}
+	return reqRes.Response.GetCreateOracleResultTx(), cli.Error()
+}
+
+func (cli *socketClient) FetchOracleVotes(ctx context.Context, req *types.RequestFetchOracleVotes) (*types.ResponseFetchOracleVotes, error) {
+	reqRes, err := cli.queueRequest(ctx, types.ToRequestFetchOracleVotes(req))
+	if err != nil {
+		return nil, err
+	}
+	if err := cli.Flush(ctx); err != nil {
+		return nil, err
+	}
+	return reqRes.Response.GetFetchOracleVotes(), cli.Error()
+}
+
+func (cli *socketClient) ValidateOracleVotes(ctx context.Context, req *types.RequestValidateOracleVotes) (*types.ResponseValidateOracleVotes, error) {
+	reqRes, err := cli.queueRequest(ctx, types.ToRequestValidateOracleVotes(req))
+	if err != nil {
+		return nil, err
+	}
+	if err := cli.Flush(ctx); err != nil {
+		return nil, err
+	}
+	return reqRes.Response.GetValidateOracleVotes(), cli.Error()
+}
+
 func (cli *socketClient) queueRequest(ctx context.Context, req *types.Request) (*ReqRes, error) {
 	reqres := NewReqRes(req)
 
@@ -493,6 +526,12 @@ func resMatchesReq(req *types.Request, res *types.Response) (ok bool) {
 		_, ok = res.Value.(*types.Response_ProcessProposal)
 	case *types.Request_FinalizeBlock:
 		_, ok = res.Value.(*types.Response_FinalizeBlock)
+	case *types.Request_CreateOracleResultTx:
+		_, ok = res.Value.(*types.Response_CreateOracleResultTx)
+	case *types.Request_ValidateOracleVotes:
+		_, ok = res.Value.(*types.Response_ValidateOracleVotes)
+	case *types.Request_FetchOracleVotes:
+		_, ok = res.Value.(*types.Response_FetchOracleVotes)
 	}
 	return ok
 }

diff --git a/abci/types/application.go b/abci/types/application.go
@@ -1,6 +1,8 @@
 package types
 
-import "context"
+import (
+	"context"
+)
 
 //go:generate ../../scripts/mockery_generate.sh Application
 
@@ -32,6 +34,11 @@ type Application interface {
 	OfferSnapshot(context.Context, *RequestOfferSnapshot) (*ResponseOfferSnapshot, error)                // Offer a snapshot to the application
 	LoadSnapshotChunk(context.Context, *RequestLoadSnapshotChunk) (*ResponseLoadSnapshotChunk, error)    // Load a snapshot chunk
 	ApplySnapshotChunk(context.Context, *RequestApplySnapshotChunk) (*ResponseApplySnapshotChunk, error) // Apply a shapshot chunk
+
+	// Hooks
+	CreateOracleResultTx(context.Context, *RequestCreateOracleResultTx) (*ResponseCreateOracleResultTx, error)
+	FetchOracleVotes(context.Context, *RequestFetchOracleVotes) (*ResponseFetchOracleVotes, error)
+	ValidateOracleVotes(context.Context, *RequestValidateOracleVotes) (*ResponseValidateOracleVotes, error)
 }
 
 //-------------------------------------------------------
@@ -117,3 +124,15 @@ func (BaseApplication) FinalizeBlock(_ context.Context, req *RequestFinalizeBloc
 		TxResults: txs,
 	}, nil
 }
+
+func (BaseApplication) CreateOracleResultTx(_ context.Context, req *RequestCreateOracleResultTx) (*ResponseCreateOracleResultTx, error) {
+	return &ResponseCreateOracleResultTx{}, nil
+}
+
+func (BaseApplication) FetchOracleVotes(_ context.Context, req *RequestFetchOracleVotes) (*ResponseFetchOracleVotes, error) {
+	return &ResponseFetchOracleVotes{}, nil
+}
+
+func (BaseApplication) ValidateOracleVotes(_ context.Context, req *RequestValidateOracleVotes) (*ResponseValidateOracleVotes, error) {
+	return &ResponseValidateOracleVotes{}, nil
+}
diff --git a/abci/types/messages.go b/abci/types/messages.go
@@ -124,6 +124,24 @@ func ToRequestFinalizeBlock(req *RequestFinalizeBlock) *Request {
 	}
 }
 
+func ToRequestCreateOracleResultTx(req *RequestCreateOracleResultTx) *Request {
+	return &Request{
+		Value: &Request_CreateOracleResultTx{req},
+	}
+}
+
+func ToRequestFetchOracleVotes(req *RequestFetchOracleVotes) *Request {
+	return &Request{
+		Value: &Request_FetchOracleVotes{req},
+	}
+}
+
+func ToRequestValidateOracleVotes(req *RequestValidateOracleVotes) *Request {
+	return &Request{
+		Value: &Request_ValidateOracleVotes{req},
+	}
+}
+
 //----------------------------------------
 
 func ToResponseException(errStr string) *Response {
@@ -227,3 +245,9 @@ func ToResponseFinalizeBlock(res *ResponseFinalizeBlock) *Response {
 		Value: &Response_FinalizeBlock{res},
 	}
 }
+
+func ToResponseCreateOracleResultTx(res *ResponseCreateOracleResultTx) *Response {
+	return &Response{
+		Value: &Response_CreateOracleResultTx{res},
+	}
+}
diff --git a/abci/types/mocks/application.go b/abci/types/mocks/application.go