Function waitForTxInclusion

plugin/go/tutorial/rpc_test.go:272–307

waitForTxInclusion waits for a transaction to be included in a block

(rpcURL, senderAddr, txHash string, timeout time.Duration)

// waitForTxInclusion waits for a transaction to be included in a block
func waitForTxInclusion(rpcURL, senderAddr, txHash string, timeout time.Duration) (bool, error) {
	deadline := time.Now().Add(timeout)

	for time.Now().Before(deadline) {
		// Query transactions by sender
		reqJSON := fmt.Sprintf(`{"address":"%s","perPage":20}`, senderAddr)
		respBody, err := postRawJSON(rpcURL+"/v1/query/txs-by-sender", reqJSON)
		if err != nil {
			time.Sleep(1 * time.Second)
			continue
		}

		var result struct {
			Results []struct {
				TxHash string `json:"txHash"`
				Height uint64 `json:"height"`
			} `json:"results"`
			TotalCount int `json:"totalCount"`
		}
		if err := json.Unmarshal(respBody, &result); err != nil {
			time.Sleep(1 * time.Second)
			continue
		}

		// Check if our transaction is in the results
		for _, tx := range result.Results {
			if tx.TxHash == txHash {
				return true, nil
			}
		}

		time.Sleep(1 * time.Second)
	}

	return false, fmt.Errorf("transaction %s not included within timeout", txHash)
}

// checkTxNotFailed verifies that a transaction is not in the failed transactions list
func checkTxNotFailed(rpcURL, senderAddr string) (int, error) {