Skip to content
This repository has been archived by the owner on Jan 25, 2021. It is now read-only.

Commit

Permalink
Merge pull request #49 from O3Labs/oep4transfer
Browse files Browse the repository at this point in the history
oep4 transfer
  • Loading branch information
apisit committed Jul 22, 2019
2 parents 0b137e4 + fcaaf34 commit d6b6938
Show file tree
Hide file tree
Showing 11 changed files with 234 additions and 39 deletions.
6 changes: 3 additions & 3 deletions neoutils/multisig.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,9 +23,9 @@ var _ MultiSigInterface = (*MultiSig)(nil)
func (m *MultiSig) CreateMultiSigRedeemScript() ([]byte, error) {

numberOfPublicKeys := len(m.PublicKeys)
if numberOfPublicKeys <= 1 {
return nil, fmt.Errorf("Number of required Signature must be more than one")
}
// if numberOfPublicKeys <= 1 {
// return nil, fmt.Errorf("Number of required Signature must be more than one")
// }
if m.NumberOfRequiredSignatures > numberOfPublicKeys {
return nil, fmt.Errorf("Number of required Signature is more than public keys provided.")
}
Expand Down
11 changes: 5 additions & 6 deletions neoutils/multisig_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,13 +11,12 @@ import (

func TestGenerateMultiSigAddress(t *testing.T) {
// 1/2
pb1 := "024e543aee592c4dd2361f8e02b4275e18eb665bcfb1c4b6c09bc6aed125b2f13c"
pb2 := "030adab68b3eeb02734f65b8ced64f023e70c15bcdfae94c3e74b9d647ddf9c976"
pb1 := "020ef8767aeb514780a8fb0a21f2568c521eb1e633a161dcdc39e78745762cb843"
// pb2 := "030adab68b3eeb02734f65b8ced64f023e70c15bcdfae94c3e74b9d647ddf9c976"
require := 1
pubKeys := [][]byte{}

pubKeys = append(pubKeys, neoutils.HexTobytes(pb1))
pubKeys = append(pubKeys, neoutils.HexTobytes(pb2))

multisign := neoutils.MultiSig{
NumberOfRequiredSignatures: require,
Expand All @@ -31,9 +30,9 @@ func TestGenerateMultiSigAddress(t *testing.T) {

multisigAddress := neoutils.VMCodeToNEOAddress(vmCode)
log.Printf("multi sig address %v", multisigAddress)
if multisigAddress != "AKo8k27H5nCG8MwSirmnraH6uUG6fQQVC2" {
t.Fail()
}
// if multisigAddress != "AKo8k27H5nCG8MwSirmnraH6uUG6fQQVC2" {
// t.Fail()
// }
}

func TestSortPublicKeys(t *testing.T) {
Expand Down
68 changes: 48 additions & 20 deletions neoutils/native_asset_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ import (
"testing"

"github.com/o3labs/neo-utils/neoutils"
"github.com/o3labs/neo-utils/neoutils/neorpc"
"github.com/o3labs/neo-utils/neoutils/o3"
"github.com/o3labs/neo-utils/neoutils/smartcontract"
)
Expand Down Expand Up @@ -108,24 +109,25 @@ func TestSendingGAS(t *testing.T) {
log.Printf("%v\n%x", txid, rawtx)
}

func TestSendingNEO(t *testing.T) {
//TEST WIF on privatenet
wif := ""
privateNetwallet, err := neoutils.GenerateFromWIF(wif)
func TestSendingNativeAsset(t *testing.T) {

key := ""
passphrase := ""
privateNetwallet, err := neoutils.NEP2DecryptToWallet(key, passphrase)
if err != nil {
log.Printf("%v", err)
t.Fail()
}

unspent, err := utxoFromO3Platform("private", privateNetwallet.Address)
unspent, err := utxoFromO3Platform("test", privateNetwallet.Address)
if err != nil {
log.Printf("error %v", err)
t.Fail()
return
}
asset := smartcontract.GAS
amount := float64(1000)
toAddress := "Adm9ER3UwdJfimFtFhHq1L5MQ5gxLLTUes"
amount := float64(10)
toAddress := privateNetwallet.Address
to := smartcontract.ParseNEOAddress(toAddress)
// remark := "O3TX"
attributes := map[smartcontract.TransactionAttribute][]byte{}
Expand All @@ -139,21 +141,48 @@ func TestSendingNEO(t *testing.T) {
t.Fail()
return
}
log.Printf("%v\n%x", txid, rawtx)
log.Printf("%v\n%x %v", txid, rawtx, len(rawtx))
}

func TestSendingGASFromMultiSig(t *testing.T) {
fromAddress := "AFrFrNjKKLc6vEztHeDhNmqpdHuciKzBqt" //this is multi signature adddress 3/2
unspent, err := utxoFromO3Platform("test", fromAddress)
if err != nil {
log.Printf("error %v", err)
t.Fail()
return
func TestSendingNEOFromMultiSig(t *testing.T) {
fromAddress := "AXeKhuHRUXMJFAXLwyHxvyCNQb8X7mtnQU" //this is multi signature adddress 3/2
neoclient := neorpc.NewClient("http://localhost:30333")
unspentResponse := neoclient.GetUnspents(fromAddress)

unspent := smartcontract.Unspent{
Assets: map[smartcontract.NativeAsset]*smartcontract.Balance{},
}

gasBalance := smartcontract.Balance{
Amount: float64(0),
UTXOs: []smartcontract.UTXO{},
}

neoBalance := smartcontract.Balance{
Amount: float64(10000000),
UTXOs: []smartcontract.UTXO{},
}

for _, v := range unspentResponse.Result.Balance {
for _, unspent := range v.Unspent {

utxo := smartcontract.UTXO{
TXID: fmt.Sprintf("0x%v", unspent.Txid),
Index: unspent.N,
Value: float64(unspent.Value),
}
log.Printf("asset %+v", utxo)
neoBalance.UTXOs = append(neoBalance.UTXOs, utxo)

}
}
unspent.Assets[smartcontract.GAS] = &gasBalance
unspent.Assets[smartcontract.NEO] = &neoBalance

asset := smartcontract.NEO
amount := float64(1)
amount := float64(100 * 1000000)

toAddress := "ANovQs3YXipL4HxRmj4D62YLCLEGsK7iDG"
toAddress := "AVFobKv2y7i66gbGPAGDT67zv1RMQQj9GB"
to := smartcontract.ParseNEOAddress(toAddress)

attributes := map[smartcontract.TransactionAttribute][]byte{}
Expand All @@ -162,15 +191,14 @@ func TestSendingGASFromMultiSig(t *testing.T) {
nativeAsset := neoutils.UseNativeAsset(fee)
rawtx, txid, err := nativeAsset.GenerateRawTx(fromAddress, asset, amount, to, unspent, attributes)
if err != nil {
log.Printf("error sending natie %v", err)
log.Printf("error sending native %v", err)
t.Fail()
return
}
log.Printf("txid %v\n", txid)
log.Printf("raw %x\n", rawtx)

wallet1, _ := neoutils.GenerateFromWIF("")
// wallet2, _ := neoutils.GenerateFromWIF("")

wallets := []*neoutils.Wallet{wallet1}

Expand Down Expand Up @@ -205,7 +233,7 @@ func TestSendingGASFromMultiSig(t *testing.T) {
endPayload = append(endPayload, rawtx...)
endPayload = append(endPayload, verificationScripts...)

redeemScript := "5121030adab68b3eeb02734f65b8ced64f023e70c15bcdfae94c3e74b9d647ddf9c97621024e543aee592c4dd2361f8e02b4275e18eb665bcfb1c4b6c09bc6aed125b2f13c52ae"
redeemScript := "5121020ef8767aeb514780a8fb0a21f2568c521eb1e633a161dcdc39e78745762cb84351ae"
b := neoutils.HexTobytes(redeemScript)
length := len(b)
log.Printf("%x%x%v", endPayload, length, redeemScript)
Expand Down
20 changes: 20 additions & 0 deletions neoutils/neorpc/getunspents.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
package neorpc

type GetUnspentsResponse struct {
Jsonrpc string `json:"jsonrpc"`
ID int `json:"id"`
Result struct {
Balance []struct {
Unspent []struct {
Txid string `json:"txid"`
N int `json:"n"`
Value int `json:"value"`
} `json:"unspent"`
AssetHash string `json:"asset_hash"`
Asset string `json:"asset"`
AssetSymbol string `json:"asset_symbol"`
Amount int `json:"amount"`
} `json:"balance"`
Address string `json:"address"`
} `json:"result"`
}
11 changes: 11 additions & 0 deletions neoutils/neorpc/rpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ type NEORPCInterface interface {
GetAccountState(address string) GetAccountStateResponse
InvokeScript(scriptInHex string) InvokeScriptResponse
GetTokenBalance(tokenHash string, adddress string) TokenBalanceResponse
GetUnspents(adddress string) GetUnspentsResponse
}

type NEORPCClient struct {
Expand Down Expand Up @@ -175,3 +176,13 @@ func (n *NEORPCClient) InvokeScript(scriptInHex string) InvokeScriptResponse {
}
return response
}

func (n *NEORPCClient) GetUnspents(adddress string) GetUnspentsResponse {
response := GetUnspentsResponse{}
params := []interface{}{adddress}
err := n.makeRequest("getunspents", params, &response)
if err != nil {
return response
}
return response
}
2 changes: 1 addition & 1 deletion neoutils/nep5.go
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ func (n *NEP5) TransferNEP5RawTransaction(wallet Wallet, toAddress smartcontract

func (n *NEP5) MintTokensRawTransaction(wallet Wallet, assetToSend smartcontract.NativeAsset, amount float64, unspent smartcontract.Unspent, remark string) ([]byte, string, error) {

needVerification := false
needVerification := true
operation := "mintTokens"
args := []interface{}{}
attributes := map[smartcontract.TransactionAttribute][]byte{}
Expand Down
8 changes: 4 additions & 4 deletions neoutils/nep5_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import (
)

func TestMintTokens(t *testing.T) {
scripthash := ""
scripthash := "06360b85b04bded387aa633bcc4bdda4354b5493"
fee := smartcontract.NetworkFeeAmount(0)
nep5 := neoutils.UseNEP5WithNetworkFee(scripthash, fee)

Expand All @@ -25,12 +25,12 @@ func TestMintTokens(t *testing.T) {
t.Fail()
return
}
unspent := smartcontract.Unspent{}
unspent, _ := utxo("test", "AeNkbJdiMx49kBStQdDih7BzfDwyTNVRfb")

remark := "APISIT FROM O3 IS HERE."

asset := smartcontract.NEO
amount := float64(10)
asset := smartcontract.GAS
amount := float64(1)

tx, txID, err := nep5.MintTokensRawTransaction(*privateNetwallet, asset, amount, unspent, remark)
if err != nil {
Expand Down
35 changes: 33 additions & 2 deletions neoutils/ont.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,10 @@
package neoutils

import (
"encoding/json"
"fmt"
"log"
"math"

"github.com/o3labs/ont-mobile/ontmobile"
)
Expand Down Expand Up @@ -36,7 +38,7 @@ func ClaimONG(endpoint string, gasPrice int, gasLimit int, wif string) (string,
}

func BuildOntologyInvocationTransaction(contract string, method string, args string, gasPrice int, gasLimit int, wif string) (string, error) {
raw, err := ontmobile.BuildInvocationTransaction(contract, method, args, uint(gasPrice), uint(gasLimit), wif)
raw, err := ontmobile.BuildInvocationTransaction(contract, method, args, uint(gasPrice), uint(gasLimit), wif, "")
if err != nil {
return "", err
}
Expand All @@ -46,7 +48,36 @@ func BuildOntologyInvocationTransaction(contract string, method string, args str

// OntologyInvoke : Invoke a neovm contract in Ontology
func OntologyInvoke(endpoint string, contract string, method string, args string, gasPrice int, gasLimit int, wif string) (string, error) {
raw, err := ontmobile.BuildInvocationTransaction(contract, method, args, uint(gasPrice), uint(gasLimit), wif)
raw, err := ontmobile.BuildInvocationTransaction(contract, method, args, uint(gasPrice), uint(gasLimit), wif, "")
if err != nil {
return "", err
}

txid, err := ontmobile.SendRawTransaction(endpoint, raw)
if err != nil {
return "", err
}

return txid, nil
}

func OEP4Transfer(endpoint string, contract string, fromAddress string, toAddress string, amount float64, tokenDecimals int, gasPrice int, gasLimit int, wif string) (string, error) {

transferringAmount := uint(ontmobile.RoundFixed(float64(amount), tokenDecimals) * float64(math.Pow10(tokenDecimals)))
payer := fromAddress
fromAddressParam := ontmobile.ParameterJSONForm{T: "Address", V: fromAddress}

toAddressParam := ontmobile.ParameterJSONForm{T: "Address", V: toAddress}
amountParam := ontmobile.ParameterJSONForm{T: "Integer", V: transferringAmount}

jsonData := &ontmobile.ParameterJSONArrayForm{A: []ontmobile.ParameterJSONForm{fromAddressParam,
toAddressParam,
amountParam}}

argData, _ := json.Marshal(jsonData)
argString := string(argData)

raw, err := ontmobile.BuildInvocationTransaction(contract, "transfer", argString, uint(gasPrice), uint(gasLimit), wif, payer)
if err != nil {
return "", err
}
Expand Down
36 changes: 36 additions & 0 deletions neoutils/ont_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -118,3 +118,39 @@ func TestOntologyInvoke(t *testing.T) {
log.Printf("tx id = %s", txid)
}
}

func TestOEP4Transfer(t *testing.T) {
wif := ""
if wif == "" {
log.Printf("No wif")
return
}
account, _ := neoutils.GenerateFromWIF(wif)
address := account.Address

gasPrice := int(500)
gasLimit := int(20000)

endpoint := "http://polaris2.ont.io:20336"
oep4Contract := "35666bb22c59d20925d7c761a4d1088be52f000d" //testnet
fromAddress := address
toAddress := "AMgVktoAhY8wX8byyNjUX3Jhiq94T7hSak"
amount := float64(1000)
decimals := 8

txid, err := neoutils.OEP4Transfer(endpoint,
oep4Contract,
fromAddress,
toAddress,
amount,
decimals,
gasPrice,
gasLimit,
wif)
if err != nil {
log.Printf("Error creating invocation transaction: %s", err)
t.Fail()
} else {
log.Printf("tx id = %s", txid)
}
}
Loading

0 comments on commit d6b6938

Please sign in to comment.