Skip to content

Commit

Permalink
Replace BroadcastTxSync with BroadcastTxCommit
Browse files Browse the repository at this point in the history
  • Loading branch information
mbver committed Nov 22, 2019
1 parent 7466298 commit 787db5c
Show file tree
Hide file tree
Showing 4 changed files with 23 additions and 24 deletions.
12 changes: 6 additions & 6 deletions client/apis.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,20 +16,20 @@ func LoadBalanceAPI(
toAddress string, // receiving address
amount string, // amount, decimal is possible
denom string, // SHR or SHRP
) (res Response, err error) {
) (err error) {

// convert string to sdk.AccAddress
addressBytes, err := hex.DecodeString(toAddress)
if err != nil {
return res, err
return err
}

addr := sdk.AccAddress(addressBytes)

dec, err := types.NewDecFromStr(amount)

if err != nil {
return res, err
return err
}

coin := types.NewCoinFromDec(denom, dec)
Expand All @@ -45,20 +45,20 @@ func SendCoinAPI(
toAddress string, // *address* of the receiver
amount string, // amount, decimal is possible Ex: 1.23
denom string,
) (res Response, err error) {
) (err error) {

// convert string to sdk.AccAddress
addressBytes, err := hex.DecodeString(toAddress)
if err != nil {
return res, err
return err
}

addr := sdk.AccAddress(addressBytes)

dec, err := types.NewDecFromStr(amount)

if err != nil {
return res, err
return err
}

coin := types.NewCoinFromDec(denom, dec)
Expand Down
27 changes: 15 additions & 12 deletions client/context.go
Original file line number Diff line number Diff line change
Expand Up @@ -116,6 +116,7 @@ func (c CoreContext) GetNonce() (int64, error) {
}
return nonce, nil
}

func (c CoreContext) RegisterValidator(
amount int64, // Amount of tokens to be staked
moniker string, // name
Expand Down Expand Up @@ -158,26 +159,27 @@ func (c CoreContext) RegisterValidator(
return err
}

func (c CoreContext) LoadBalance(to sdk.AccAddress, amount types.Coin) (res Response, err error) {
func (c CoreContext) LoadBalance(to sdk.AccAddress, amount types.Coin) (err error) {

msgLoad := bmsg.NewMsgLoad(to, amount)

authTx, err := c.ConstructTransaction(msgLoad)
if err != nil {
return res, err
return err
}

tdmTx, err := c.ConstructTendermintTransaction(authTx)
if err != nil {
return res, err
return err
}

tdmres, err := c.Client.BroadcastTxSync(tdmTx)
r, err := c.Client.BroadcastTxCommit(tdmTx)
if err != nil {
return res, err
return err
}
err, _ = processTDMResponse(r)

return convertBroadcastResult(tdmres), nil
return err

}

Expand Down Expand Up @@ -206,26 +208,27 @@ func (c CoreContext) CheckBalance() error {
return nil
}

func (c CoreContext) SendCoins(to sdk.AccAddress, amt types.Coin) (res Response, err error) {
func (c CoreContext) SendCoins(to sdk.AccAddress, amt types.Coin) (err error) {

msgSend := bmsg.NewMsgSend(to, amt)

authTx, err := c.ConstructTransaction(msgSend)
if err != nil {
return res, err
return err
}

tdmTx, err := c.ConstructTendermintTransaction(authTx)
if err != nil {
return res, err
return err
}

tdmres, err := c.Client.BroadcastTxSync(tdmTx)
r, err := c.Client.BroadcastTxCommit(tdmTx)
if err != nil {
return res, err
return err
}
err, _ = processTDMResponse(r)

return convertBroadcastResult(tdmres), nil
return err

}

Expand Down
4 changes: 1 addition & 3 deletions cmd/shareledger/subcommands/load_coins.go
Original file line number Diff line number Diff line change
Expand Up @@ -64,12 +64,10 @@ func loadCoin(cmd *cobra.Command, args []string) error {

fmt.Printf("Address=%X Amount=%s\n", addr, dec)

res, err := context.LoadBalance(addr, amount)
err = context.LoadBalance(addr, amount)
if err != nil {
return err
}

fmt.Printf("%v\n", res)

return nil
}
4 changes: 1 addition & 3 deletions cmd/shareledger/subcommands/send_coins.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,12 +68,10 @@ func sendCoin(cmd *cobra.Command, args []string) error {

fmt.Printf("Address=%X Amount=%s\n", addr, dec)

res, err := context.SendCoins(addr, amount)
err = context.SendCoins(addr, amount)
if err != nil {
return err
}

fmt.Printf("%v\n", res)

return nil
}

0 comments on commit 787db5c

Please sign in to comment.