-
Notifications
You must be signed in to change notification settings - Fork 0
/
event_read.go
65 lines (53 loc) · 1.59 KB
/
event_read.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
package main
import (
"context"
"fmt"
"log"
"math/big"
"os"
"strings"
"github.com/ethereum/go-ethereum"
"github.com/ethereum/go-ethereum/accounts/abi"
"github.com/ethereum/go-ethereum/common"
"github.com/ethereum/go-ethereum/crypto"
"github.com/ethereum/go-ethereum/ethclient"
store "github.com/marioidival/geth-study/contracts"
)
func main() {
client, err := ethclient.Dial(os.Getenv("RINKEBY_INFURA_WS"))
if err != nil {
log.Fatalf("ethclient connection error: %s", err.Error())
}
contractAddress := common.HexToAddress("0x147B8eb97fD247D06C4006D269c90C1908Fb5D54")
query := ethereum.FilterQuery{
FromBlock: big.NewInt(2394201),
ToBlock: big.NewInt(2394201),
Addresses: []common.Address{contractAddress},
}
logs, err := client.FilterLogs(context.Background(), query)
if err != nil {
log.Fatalf("try get logs error: %s", err.Error())
}
contractAbi, err := abi.JSON(strings.NewReader(string(store.StoreABI)))
if err != nil {
log.Fatalf("try parse ABI interface error: %s", err.Error())
}
for _, vLog := range logs {
fmt.Println("Block hash: ", vLog.BlockHash.Hex())
fmt.Println("Block number: ", vLog.BlockNumber)
fmt.Println("Tx Hash: ", vLog.TxHash.Hex())
event, err := contractAbi.Unpack("ItemSet", vLog.Data)
if err != nil {
log.Fatalf("try unpack error: %s", err.Error())
}
fmt.Printf("Event: %q\n", event)
var topics [4]string
for i := range vLog.Topics {
topics[i] = vLog.Topics[i].Hex()
}
fmt.Println(topics[0])
}
eventSignature := []byte("ItemSet(bytes32,bytes32")
hash := crypto.Keccak256Hash(eventSignature)
fmt.Println(hash.Hex())
}