mock v0

common/model/Chain.go

@@ -0,0 +1 @@
+package model

common/model/api_request.go

@@ -0,0 +1,11 @@
+package model
+
+type TryPayUserOpRequest struct {
+	ForceStrategyId        string            `json:"strategy_id"`
+	ForceNetWork           string            `json:"force_network"`
+	ForceTokens            string            `json:"force_tokens"`
+	ForceEntryPointAddress string            `json:"force_entry_point_address"`
+	UserOperation          UserOperationItem `json:"user_operation"`
+	Apikey                 string            `json:"apikey"`
+	Extra                  interface{}       `json:"extra"`
+}

common/model/api_response.go

@@ -0,0 +1,18 @@
+package model
+
+type TryPayUserOpResponse struct {
+	StrategyId         string             `json:"strategy_id"`
+	EntryPointAddress  string             `json:"entry_point_address"`
+	PayMasterAddress   string             `json:"pay_master_address"`
+	PayMasterSignature string             `json:"pay_master_signature"`
+	PayReceipt         interface{}        `json:"pay_receipt"`
+	GasInfo            ComputeGasResponse `json:"gaf_info"`
+}
+
+type ComputeGasResponse struct {
+	StrategyId string
+	tokenCost  string
+	network    string
+	token      string
+	UsdCost    string
+}

rpc_server/models/client_credential.go → common/model/client_credential.go

@@ -1,4 +1,4 @@
-package models
+package model
 
 type ClientCredential struct {
 	ApiKey string `json:"apiKey"`

rpc_server/models/response.go → common/model/response.go

@@ -1,4 +1,4 @@
-package models
+package model
 
 import (
 	"github.com/gin-gonic/gin"

common/model/strategy.go

@@ -0,0 +1,7 @@
+package model
+
+type Strategy struct {
+	Id                string
+	EntryPointAddress string
+	PayMasterAddress  string
+}

common/model/user_operation.go

@@ -0,0 +1,14 @@
+package model
+
+type UserOperationItem struct {
+	Sender               string `json:"sender"`
+	Nonce                string `json:"nonce"`
+	InitCode             string `json:"init_code"`
+	CallGasLimit         string `json:"call_gas_limit"`
+	VerificationGasList  string `json:"verification_gas_list"`
+	PerVerificationGas   string `json:"per_verification_gas"`
+	MaxFeePerGas         string `json:"max_fee_per_gas"`
+	MaxPriorityFeePerGas string `json:"max_priority_fee_per_gas"`
+	//paymasterAndData     string `json:"paymaster_and_data"`
+	Signature string `json:"signature"`
+}

conf/appsettings.yaml

@@ -1,4 +1,4 @@
 jwt:
-  security: hello-eth-paymaster
+  security: hello-ethereum-paymaster
   realm: aastar
   idkey: id

go.mod

@@ -49,6 +49,7 @@ require (
 	golang.org/x/sys v0.17.0 // indirect
 	golang.org/x/text v0.14.0 // indirect
 	golang.org/x/tools v0.18.0 // indirect
+	golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 // indirect
 	google.golang.org/protobuf v1.32.0 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect

go.sum

@@ -151,6 +151,8 @@ golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc
 golang.org/x/tools v0.18.0 h1:k8NLag8AGHnn+PHbl7g43CtqZAwG60vZkLqgyZgIHgQ=
 golang.org/x/tools v0.18.0/go.mod h1:GL7B4CwcLLeo59yx/9UWWuNOW1n3VZ4f5axWfML7Lcg=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 h1:+cNy6SZtPcJQH3LJVLOSmiC7MMxXNOb3PU/VUEz+EhU=
+golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028/go.mod h1:NDW/Ps6MPRej6fsCIbMTohpP40sJ/P/vI1MoTEGwX90=
 google.golang.org/protobuf v1.32.0 h1:pPC6BG5ex8PDFnkbrGU3EixyhKcQ2aDuBS36lqK/C7I=
 google.golang.org/protobuf v1.32.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

rpc_server/api/health.go

@@ -1,8 +1,8 @@
 package api
 
 import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
 	"AAStarCommunity/EthPaymaster_BackService/conf"
-	"AAStarCommunity/EthPaymaster_BackService/rpc_server/models"
 	"github.com/gin-gonic/gin"
 	"time"
 )
@@ -16,7 +16,7 @@ import (
 // @Router /api/health [post,get,put,delete]
 // @Success 200
 func Healthz(c *gin.Context) {
-	response := models.GetResponse()
+	response := model.GetResponse()
 	response.WithDataSuccess(c, gin.H{
 		"hello":       "Eth Paymaster",
 		"environment": conf.Environment.Name,

rpc_server/api/v1/get_support_entrypoint.go

@@ -1,9 +1,9 @@
 package v1
 
 import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
 	"AAStarCommunity/EthPaymaster_BackService/rpc_server/api/utils"
-	"AAStarCommunity/EthPaymaster_BackService/rpc_server/models"
-	"AAStarCommunity/EthPaymaster_BackService/service"
+	"AAStarCommunity/EthPaymaster_BackService/service/executor"
 	"fmt"
 	"github.com/gin-gonic/gin"
 	"net/http"
@@ -18,13 +18,13 @@ import (
 // @Success 200
 // @Security JWT
 func GetSupportEntrypoint(c *gin.Context) {
-	response := models.GetResponse()
+	response := model.GetResponse()
 	if ok, apiKey := utils.CurrentUser(c); ok {
 		_ = apiKey
 
 		//1.TODO API validate
 		//2. recall service
-		result, err := service.GetSupportEntrypointExecute()
+		result, err := executor.GetSupportEntrypointExecute()
 		if err != nil {
 			errStr := fmt.Sprintf("%v", err)
 			response.SetHttpCode(http.StatusInternalServerError).FailCode(c, http.StatusInternalServerError, errStr)

rpc_server/api/v1/get_support_strategy.go

@@ -1,8 +1,8 @@
 package v1
 
 import (
-	"AAStarCommunity/EthPaymaster_BackService/rpc_server/models"
-	"AAStarCommunity/EthPaymaster_BackService/service"
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
+	"AAStarCommunity/EthPaymaster_BackService/service/executor"
 	"fmt"
 	"github.com/gin-gonic/gin"
 	"net/http"
@@ -19,8 +19,8 @@ import (
 func GetSupportStrategy(c *gin.Context) {
 	//1.TODO API validate
 	//2. recall service
-	result, err := service.GetSupportStrategyExecute()
-	response := models.GetResponse()
+	result, err := executor.GetSupportStrategyExecute()
+	response := model.GetResponse()
 	if err != nil {
 		errStr := fmt.Sprintf("%v", err)
 		response.SetHttpCode(http.StatusInternalServerError).FailCode(c, http.StatusInternalServerError, errStr)

rpc_server/api/v1/try_pay_user_operation.go

@@ -1,8 +1,8 @@
 package v1
 
 import (
-	"AAStarCommunity/EthPaymaster_BackService/rpc_server/models"
-	"AAStarCommunity/EthPaymaster_BackService/service"
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
+	"AAStarCommunity/EthPaymaster_BackService/service/executor"
 	"fmt"
 	"github.com/gin-gonic/gin"
 	"net/http"
@@ -19,10 +19,17 @@ import (
 func TryPayUserOperation(c *gin.Context) {
 	//1.TODO API validate
 	//2. recall service
-	result, err := service.TryPayUserOpExecute()
-	response := models.GetResponse()
+	request := model.TryPayUserOpRequest{}
+	response := model.GetResponse()
+
+	if err := c.ShouldBindJSON(&request); err != nil {
+		errStr := fmt.Sprintf("Conver Request Error [%v]", err)
+		response.SetHttpCode(http.StatusBadRequest).FailCode(c, http.StatusBadRequest, errStr)
+	}
+
+	result, err := executor.TryPayUserOpExecute(request)
 	if err != nil {
-		errStr := fmt.Sprintf("%v", err)
+		errStr := fmt.Sprintf("TryPayUserOpExecute ERROR [%v]", err)
 		response.SetHttpCode(http.StatusInternalServerError).FailCode(c, http.StatusInternalServerError, errStr)
 	}
 	response.WithData(result).Success(c)

rpc_server/middlewares/recovery.go

@@ -1,8 +1,8 @@
 package middlewares
 
 import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
 	"AAStarCommunity/EthPaymaster_BackService/conf"
-	"AAStarCommunity/EthPaymaster_BackService/rpc_server/models"
 	"errors"
 	"fmt"
 	"github.com/gin-gonic/gin"
@@ -18,7 +18,7 @@ func GenericRecoveryHandler() gin.HandlerFunc {
 		if conf.Environment.Debugger {
 			errStr = fmt.Sprintf("%v", err)
 		}
-		models.GetResponse().SetHttpCode(http.StatusInternalServerError).FailCode(c, http.StatusInternalServerError, errStr)
+		model.GetResponse().SetHttpCode(http.StatusInternalServerError).FailCode(c, http.StatusInternalServerError, errStr)
 	})
 }
 

rpc_server/routers/boot.go

@@ -1,10 +1,10 @@
 package routers
 
 import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
 	"AAStarCommunity/EthPaymaster_BackService/conf"
 	"AAStarCommunity/EthPaymaster_BackService/docs"
 	"AAStarCommunity/EthPaymaster_BackService/rpc_server/middlewares"
-	"AAStarCommunity/EthPaymaster_BackService/rpc_server/models"
 	"github.com/gin-gonic/gin"
 	swaggerFiles "github.com/swaggo/files"
 	ginSwagger "github.com/swaggo/gin-swagger"
@@ -19,7 +19,7 @@ func SetRouters() (routers *gin.Engine) {
 	buildMod(routers)
 	buildRoute(routers)
 	routers.NoRoute(func(ctx *gin.Context) {
-		models.GetResponse().SetHttpCode(http.StatusNotFound).FailCode(ctx, http.StatusNotFound)
+		model.GetResponse().SetHttpCode(http.StatusNotFound).FailCode(ctx, http.StatusNotFound)
 	})
 
 	return

service/dashboard_service/dashboard_service.go

@@ -0,0 +1,7 @@
+package dashboard_service
+
+import "AAStarCommunity/EthPaymaster_BackService/common/model"
+
+func GetStrategyById(strategyId string) model.Strategy {
+	return model.Strategy{}
+}

service/dashboard_service/strategy_selector.go

@@ -0,0 +1,11 @@
+package dashboard_service
+
+import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
+)
+
+func GetSuitableStrategy(entrypoint string, network string, token string) (model.Strategy, error) {
+
+	return model.Strategy{}, nil
+
+}

service/executor/executor.go

@@ -0,0 +1,12 @@
+package executor
+
+import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
+)
+
+func GetSupportEntrypointExecute() (model.Result, error) {
+	return model.Result{}, nil
+}
+func GetSupportStrategyExecute() (model.Result, error) {
+	return model.Result{}, nil
+}

service/executor/try_pay_user_op_execute.go

@@ -0,0 +1,90 @@
+package executor
+
+import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
+	"AAStarCommunity/EthPaymaster_BackService/service/dashboard_service"
+	"AAStarCommunity/EthPaymaster_BackService/service/gas_service"
+	"AAStarCommunity/EthPaymaster_BackService/service/validator_service"
+	"golang.org/x/xerrors"
+)
+
+func TryPayUserOpExecute(request model.TryPayUserOpRequest) (model.Result, error) {
+	//validator
+	if err := paramValidate(request); err != nil {
+		return model.Result{}, err
+	}
+	userOp := request.UserOperation
+	//getStrategy
+	strategy, err := strategyGenerate(request)
+	if err != nil {
+		return model.Result{}, err
+	}
+	if err := validator_service.ValidateStrategy(strategy, userOp); err != nil {
+		return model.Result{}, err
+	}
+
+	//base Strategy and UserOp computeGas
+	gasResponse, gasComputeError := gas_service.ComputeGas(userOp, strategy)
+	if gasComputeError != nil {
+		return model.Result{}, gasComputeError
+	}
+
+	//validate gas
+	if err := gas_service.ValidateGas(userOp, gasResponse); err != nil {
+		return model.Result{}, err
+	}
+	//pay
+	payReceipt, payError := executePay(strategy, request.UserOperation, gasResponse)
+	if payError != nil {
+		return model.Result{}, payError
+	}
+	paymasterSignature := getPayMasterSignature(strategy, request.UserOperation)
+	var result = model.TryPayUserOpResponse{
+		StrategyId:         strategy.Id,
+		EntryPointAddress:  strategy.EntryPointAddress,
+		PayMasterAddress:   strategy.EntryPointAddress,
+		PayReceipt:         payReceipt,
+		PayMasterSignature: paymasterSignature,
+		GasInfo:            gasResponse,
+	}
+
+	return model.Result{
+		Code:    0,
+		Data:    result,
+		Message: "message",
+		Cost:    "cost",
+	}, nil
+}
+func paramValidate(request model.TryPayUserOpRequest) error {
+	return nil
+}
+
+func executePay(strategy model.Strategy, userOp model.UserOperationItem, gasResponse model.ComputeGasResponse) (interface{}, error) {
+	//1.Recharge
+	//2.record account
+	//3.return Receipt
+	return nil, nil
+}
+func getPayMasterSignature(strategy model.Strategy, userOp model.UserOperationItem) string {
+	return ""
+}
+
+func strategyGenerate(request model.TryPayUserOpRequest) (model.Strategy, error) {
+	if forceStrategyId := request.ForceStrategyId; forceStrategyId != "" {
+		//force strategy
+		strategy := dashboard_service.GetStrategyById(forceStrategyId)
+		if strategy == (model.Strategy{}) {
+			return model.Strategy{}, xerrors.Errorf("Not Support Strategy ID: [%w]", forceStrategyId)
+		}
+		return strategy, nil
+	}
+
+	suitableStrategy, err := dashboard_service.GetSuitableStrategy(request.ForceEntryPointAddress, request.ForceNetWork, request.ForceTokens) //TODO
+	if err != nil {
+		return model.Strategy{}, err
+	}
+	if suitableStrategy == (model.Strategy{}) {
+		return model.Strategy{}, xerrors.Errorf("Empty Strategies")
+	}
+	return suitableStrategy, nil
+}

service/executor/try_pay_user_op_test.go

@@ -0,0 +1,28 @@
+package executor
+
+import (
+	"AAStarCommunity/EthPaymaster_BackService/common/model"
+
+	"testing"
+)
+
+func TestTryPayUserOpExecute(t *testing.T) {
+	request := getMockTryPayUserOpRequest()
+	TryPayUserOpExecute(request)
+
+}
+
+func getMockTryPayUserOpRequest() model.TryPayUserOpRequest {
+	return model.TryPayUserOpRequest{
+		ForceStrategyId: "1",
+		UserOperation: model.UserOperationItem{
+			Sender:               "0x123",
+			Nonce:                "",
+			CallGasLimit:         "",
+			VerificationGasList:  "",
+			PerVerificationGas:   "",
+			MaxFeePerGas:         "",
+			MaxPriorityFeePerGas: "",
+		},
+	}
+}

service/gas_service/gasWeiGenerator.go

@@ -0,0 +1 @@
+package gas_service