Commit 080e43fa authored by mdj33's avatar mdj33 Committed by vipwzw

add relay rpc test

parent 2c9b73ba
...@@ -57,7 +57,7 @@ if [ -n "${DAPP}" ]; then ...@@ -57,7 +57,7 @@ if [ -n "${DAPP}" ]; then
fi fi
if [ -z "$DAPP" ]; then if [ -z "$DAPP" ] || [ "$DAPP" == "paracross" ]; then
# shellcheck source=/dev/null # shellcheck source=/dev/null
source system-test-rpc.sh source system-test-rpc.sh
# shellcheck source=/dev/null # shellcheck source=/dev/null
...@@ -328,16 +328,20 @@ function transfer() { ...@@ -328,16 +328,20 @@ function transfer() {
} }
function base_config() { function base_config() {
sync # sync
transfer "${CLI}" transfer "${CLI}"
# transfer "${CLI4}" # transfer "${CLI4}"
} }
function base_test() { function base_test() {
if [ "$DAPP" == "" ]; then if [ "$DAPP" == "" ]; then
system_test_rpc "${1}" system_test_rpc "http://${1}:8801"
dapp_test_rpc "${1}" dapp_test_rpc "http://${1}:8801"
fi fi
# if [ "$DAPP" == "paracross" ]; then
# system_test_rpc "http://${1}:8901"
# dapp_test_rpc "http://${1}:8901"
# fi
} }
function dapp_run() { function dapp_run() {
......
...@@ -30,8 +30,7 @@ chain33_unlock() { ...@@ -30,8 +30,7 @@ chain33_unlock() {
} }
function system_test_rpc() { function system_test_rpc() {
local ip=$1 MAIN_HTTP="$1"
MAIN_HTTP="http://$ip:8801"
echo "=========== # system rpc test =============" echo "=========== # system rpc test ============="
echo "ip=$MAIN_HTTP" echo "ip=$MAIN_HTTP"
...@@ -44,4 +43,4 @@ function system_test_rpc() { ...@@ -44,4 +43,4 @@ function system_test_rpc() {
fi fi
} }
#system_rpc_test #system_test_rpc $1
This diff is collapsed.
...@@ -36,7 +36,6 @@ func RelayCmd() *cobra.Command { ...@@ -36,7 +36,6 @@ func RelayCmd() *cobra.Command {
CreateRawRelayAcceptTxCmd(), CreateRawRelayAcceptTxCmd(),
CreateRawRevokeTxCmd(), CreateRawRevokeTxCmd(),
CreateRawRelayConfirmTxCmd(), CreateRawRelayConfirmTxCmd(),
CreateRawRelayVerifyBTCTxCmd(),
CreateRawRelayBtcHeaderCmd(), CreateRawRelayBtcHeaderCmd(),
) )
...@@ -566,52 +565,3 @@ func relaySaveBtcHead(cmd *cobra.Command, args []string) { ...@@ -566,52 +565,3 @@ func relaySaveBtcHead(cmd *cobra.Command, args []string) {
ctx.RunWithoutMarshal() ctx.RunWithoutMarshal()
} }
// CreateRawRelayVerifyBTCTxCmd verify btc tx from cli
func CreateRawRelayVerifyBTCTxCmd() *cobra.Command {
cmd := &cobra.Command{
Use: "verify",
Short: "Create a verify coin transaction",
Run: relayVerifyBTC,
}
addVerifyBTCFlags(cmd)
return cmd
}
func addVerifyBTCFlags(cmd *cobra.Command) {
cmd.Flags().StringP("order_id", "o", "", "order id")
cmd.MarkFlagRequired("order_id")
cmd.Flags().StringP("raw_tx", "t", "", "coin raw tx")
cmd.MarkFlagRequired("raw_tx")
cmd.Flags().Uint32P("tx_index", "i", 0, "raw tx index")
cmd.MarkFlagRequired("tx_index")
cmd.Flags().StringP("merk_branch", "m", "", "tx merkle branch")
cmd.MarkFlagRequired("merk_branch")
cmd.Flags().StringP("block_hash", "b", "", "block hash of tx ")
cmd.MarkFlagRequired("block_hash")
}
func relayVerifyBTC(cmd *cobra.Command, args []string) {
rpcLaddr, _ := cmd.Flags().GetString("rpc_laddr")
orderid, _ := cmd.Flags().GetString("order_id")
rawtx, _ := cmd.Flags().GetString("raw_tx")
txindex, _ := cmd.Flags().GetUint32("tx_index")
merkbranch, _ := cmd.Flags().GetString("merk_branch")
blockhash, _ := cmd.Flags().GetString("block_hash")
params := &ty.RelayVerifyCli{
OrderId: orderid,
RawTx: rawtx,
TxIndex: txindex,
MerkBranch: merkbranch,
BlockHash: blockhash,
}
var res string
ctx := jsonclient.NewRPCCtx(rpcLaddr, "relay.CreateRawRelayVerifyBTCTx", params, &res)
ctx.RunWithoutMarshal()
}
...@@ -34,10 +34,6 @@ func (r *relay) Exec_Verify(payload *rty.RelayVerify, tx *types.Transaction, ind ...@@ -34,10 +34,6 @@ func (r *relay) Exec_Verify(payload *rty.RelayVerify, tx *types.Transaction, ind
return action.verifyTx(payload) return action.verifyTx(payload)
} }
func (r *relay) Exec_VerifyCli(payload *rty.RelayVerifyCli, tx *types.Transaction, index int) (*types.Receipt, error) {
action := newRelayDB(r, tx)
return action.verifyCmdTx(payload)
}
func (r *relay) Exec_BtcHeaders(payload *rty.BtcHeaders, tx *types.Transaction, index int) (*types.Receipt, error) { func (r *relay) Exec_BtcHeaders(payload *rty.BtcHeaders, tx *types.Transaction, index int) (*types.Receipt, error) {
action := newRelayDB(r, tx) action := newRelayDB(r, tx)
......
...@@ -566,6 +566,7 @@ func (action *relayDB) verifyTx(verify *ty.RelayVerify) (*types.Receipt, error) ...@@ -566,6 +566,7 @@ func (action *relayDB) verifyTx(verify *ty.RelayVerify) (*types.Receipt, error)
} }
//之前用作cli verify, 检查不严格,现在弃用
func (action *relayDB) verifyCmdTx(verify *ty.RelayVerifyCli) (*types.Receipt, error) { func (action *relayDB) verifyCmdTx(verify *ty.RelayVerifyCli) (*types.Receipt, error) {
orderID := []byte(verify.OrderId) orderID := []byte(verify.OrderId)
order, err := action.getOrderByID(orderID) order, err := action.getOrderByID(orderID)
......
...@@ -41,13 +41,7 @@ func createRawRelayConfirmTx(parm *ty.RelayConfirmTx) ([]byte, error) { ...@@ -41,13 +41,7 @@ func createRawRelayConfirmTx(parm *ty.RelayConfirmTx) ([]byte, error) {
return types.CallCreateTx(types.ExecName(ty.RelayX), "ConfirmTx", parm) return types.CallCreateTx(types.ExecName(ty.RelayX), "ConfirmTx", parm)
} }
func createRawRelayVerifyBTCTx(parm *ty.RelayVerifyCli) ([]byte, error) {
if parm == nil {
return nil, types.ErrInvalidParam
}
v := *parm
return types.CallCreateTx(types.ExecName(ty.RelayX), "VerifyCli", &v)
}
func createRawRelaySaveBTCHeadTx(parm *ty.BtcHeader) ([]byte, error) { func createRawRelaySaveBTCHeadTx(parm *ty.BtcHeader) ([]byte, error) {
if parm == nil { if parm == nil {
...@@ -58,6 +52,10 @@ func createRawRelaySaveBTCHeadTx(parm *ty.BtcHeader) ([]byte, error) { ...@@ -58,6 +52,10 @@ func createRawRelaySaveBTCHeadTx(parm *ty.BtcHeader) ([]byte, error) {
PreviousHash: parm.PreviousHash, PreviousHash: parm.PreviousHash,
MerkleRoot: parm.MerkleRoot, MerkleRoot: parm.MerkleRoot,
Height: parm.Height, Height: parm.Height,
Version: parm.Version,
Time: parm.Time,
Nonce: parm.Nonce,
Bits: parm.Bits,
IsReset: parm.IsReset, IsReset: parm.IsReset,
} }
...@@ -109,16 +107,6 @@ func (c *Jrpc) CreateRawRelayConfirmTx(in *ty.RelayConfirmTx, result *interface{ ...@@ -109,16 +107,6 @@ func (c *Jrpc) CreateRawRelayConfirmTx(in *ty.RelayConfirmTx, result *interface{
return nil return nil
} }
//CreateRawRelayVerifyBTCTx jrpc create veirfy btc tx
func (c *Jrpc) CreateRawRelayVerifyBTCTx(in *ty.RelayVerifyCli, result *interface{}) error {
reply, err := createRawRelayVerifyBTCTx(in)
if err != nil {
return err
}
*result = hex.EncodeToString(reply)
return nil
}
//CreateRawRelaySaveBTCHeadTx jrpc save btc header //CreateRawRelaySaveBTCHeadTx jrpc save btc header
func (c *Jrpc) CreateRawRelaySaveBTCHeadTx(in *ty.BtcHeader, result *interface{}) error { func (c *Jrpc) CreateRawRelaySaveBTCHeadTx(in *ty.BtcHeader, result *interface{}) error {
reply, err := createRawRelaySaveBTCHeadTx(in) reply, err := createRawRelaySaveBTCHeadTx(in)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment