如何获取交易的结果和状态
How to get the result and the status of a transaction
我正在尝试使用以太坊区块链和 Solidity 合约。
我目前正在部署合约并对其执行一些操作,但我想知道如何获得特定交易的一些 'feedback/callback/returns'。
有没有办法将事务的状态设置为 0(错误)并仍然获取事件,例如?
if (id.length <= 0) {
emit Result("KO", "1");
revert();
}
这将不起作用(无事件),因为我还原了所有内容,但状态将设置为 0
if (id.length <= 0) {
emit Result("KO", "1");
return;
}
我会收到一些事件,但状态会保持为 1
if (id.length <= 0) {
revert("KO_1");
}
状态将为0,但我不会有任何事件
这是我执行操作的代码:
func testFunction(id []byte) {
//...
//...
tx, err := instance.Action(opt, id)
if (errors.HasError(err)) {
return
}
callbackValue := subscribeToContract(tx.Hash().Hex())
logs.Pretty(tx, callbackValue)
//...
//...
}
func subscribeToContract(hashToRead string) myStruct {
query := ethereum.FilterQuery{
Addresses: []common.Address{address},
}
soc := make(chan types.Log)
sub, err := WssClient.SubscribeFilterLogs(context.Background(), query, soc)
if err != nil {
logs.Error(err)
}
for {
select {
case err := <-sub.Err():
logs.Info(`SOMETHING ERROR`)
logs.Error(err)
case vLog := <-soc:
logs.Info(`SOMETHING`)
contractAbi, _ := abi.JSON(strings.NewReader(string(SignABI)))
event := myStruct{}
contractAbi.Unpack(&event, "Result", vLog.Data)
logs.Info(`New Event from [` + vLog.TxHash.Hex() + `] : ` + event.Message)
}
}
}
如果id.length > 0
,一切都很好。
但是如果 id.length <= 0
,我没有来自 subscribeToContract
函数的回调。
有没有办法直接得到结果状态,或者应该循环 tx, err := client.TransactionReceipt(context.Background(), txHash)
直到我得到一个状态?
我没有找到任何方法来订阅交易的特定状态更改,但有一个解决方法:
go-ethereum
包提供了 2 个函数 SubscribeFilterLogs
和 SubscribeNewHead
。我们可以使用第一个获取日志(如果相关),第二个获取块信息:
SubscribeNewHead subscribes to notifications about the current
blockchain head on the given channel.
一个交易可以被验证或者rejected/reverted当一个区块被开采时,所以我们可以使用这个'trick'
func checkTransactionReceipt(_txHash string) int {
client, _ := getClient("https://ropsten.infura.io/v3/XXXXXX")
txHash := common.HexToHash(_txHash)
tx, err := client.TransactionReceipt(context.Background(), txHash)
if (Error.HasError(err)) {
return (-1)
}
return (int(tx.Status))
}
func WaitForBlockCompletation(data EthData, hashToRead string) int {
soc := make(chan *types.Header)
sub, err := data.WssClient.SubscribeNewHead(context.Background(), soc)
if (err != nil) {
return -1
}
for {
select {
case err := <-sub.Err():
_ = err
return -1
case header := <-soc:
logs.Info(header.TxHash.Hex())
transactionStatus := checkTransactionReceipt(hashToRead)
if (transactionStatus == 0) {
//FAILURE
sub.Unsubscribe()
return 0
} else if (transactionStatus == 1) {
//SUCCESS
sub.Unsubscribe()
return 1
}
}
}
}
基本上我们在等待区块被挖掘,然后我们检查TransactionReceipt
,如果交易还没有validated/rejected,它会失败并出现错误(not found
)。然后,如果交易是,我们可以取消订阅,return交易状态(0失败,1成功)。
不确定这是否是最差、最好、唯一的方法,但它确实有效!欢迎改进此解决方案!
我正在尝试使用以太坊区块链和 Solidity 合约。 我目前正在部署合约并对其执行一些操作,但我想知道如何获得特定交易的一些 'feedback/callback/returns'。
有没有办法将事务的状态设置为 0(错误)并仍然获取事件,例如?
if (id.length <= 0) {
emit Result("KO", "1");
revert();
}
这将不起作用(无事件),因为我还原了所有内容,但状态将设置为 0
if (id.length <= 0) {
emit Result("KO", "1");
return;
}
我会收到一些事件,但状态会保持为 1
if (id.length <= 0) {
revert("KO_1");
}
状态将为0,但我不会有任何事件
这是我执行操作的代码:
func testFunction(id []byte) {
//...
//...
tx, err := instance.Action(opt, id)
if (errors.HasError(err)) {
return
}
callbackValue := subscribeToContract(tx.Hash().Hex())
logs.Pretty(tx, callbackValue)
//...
//...
}
func subscribeToContract(hashToRead string) myStruct {
query := ethereum.FilterQuery{
Addresses: []common.Address{address},
}
soc := make(chan types.Log)
sub, err := WssClient.SubscribeFilterLogs(context.Background(), query, soc)
if err != nil {
logs.Error(err)
}
for {
select {
case err := <-sub.Err():
logs.Info(`SOMETHING ERROR`)
logs.Error(err)
case vLog := <-soc:
logs.Info(`SOMETHING`)
contractAbi, _ := abi.JSON(strings.NewReader(string(SignABI)))
event := myStruct{}
contractAbi.Unpack(&event, "Result", vLog.Data)
logs.Info(`New Event from [` + vLog.TxHash.Hex() + `] : ` + event.Message)
}
}
}
如果id.length > 0
,一切都很好。
但是如果 id.length <= 0
,我没有来自 subscribeToContract
函数的回调。
有没有办法直接得到结果状态,或者应该循环 tx, err := client.TransactionReceipt(context.Background(), txHash)
直到我得到一个状态?
我没有找到任何方法来订阅交易的特定状态更改,但有一个解决方法:
go-ethereum
包提供了 2 个函数 SubscribeFilterLogs
和 SubscribeNewHead
。我们可以使用第一个获取日志(如果相关),第二个获取块信息:
SubscribeNewHead subscribes to notifications about the current blockchain head on the given channel.
一个交易可以被验证或者rejected/reverted当一个区块被开采时,所以我们可以使用这个'trick'
func checkTransactionReceipt(_txHash string) int {
client, _ := getClient("https://ropsten.infura.io/v3/XXXXXX")
txHash := common.HexToHash(_txHash)
tx, err := client.TransactionReceipt(context.Background(), txHash)
if (Error.HasError(err)) {
return (-1)
}
return (int(tx.Status))
}
func WaitForBlockCompletation(data EthData, hashToRead string) int {
soc := make(chan *types.Header)
sub, err := data.WssClient.SubscribeNewHead(context.Background(), soc)
if (err != nil) {
return -1
}
for {
select {
case err := <-sub.Err():
_ = err
return -1
case header := <-soc:
logs.Info(header.TxHash.Hex())
transactionStatus := checkTransactionReceipt(hashToRead)
if (transactionStatus == 0) {
//FAILURE
sub.Unsubscribe()
return 0
} else if (transactionStatus == 1) {
//SUCCESS
sub.Unsubscribe()
return 1
}
}
}
}
基本上我们在等待区块被挖掘,然后我们检查TransactionReceipt
,如果交易还没有validated/rejected,它会失败并出现错误(not found
)。然后,如果交易是,我们可以取消订阅,return交易状态(0失败,1成功)。
不确定这是否是最差、最好、唯一的方法,但它确实有效!欢迎改进此解决方案!