Go言語によるコントラクトコードのイベント監視方法

Question

前提・実現したいこと

下記書籍に沿って、スマートコントラクトを実装したDAppsの開発演習をしています。
「試して学ぶ　スマートコントラクト開発(マイナビ出版)」

実際にropstenネットワークにコントラクトコードをデプロイし、トランザクションの発行まで確認したのですが、イベントの発火が行われません。イベントが発火するとブラウザ常に新しいトークルームが生成されるというものになっています。

発生している問題・エラーメッセージ

トランザクションとイベントの監視を、Go言語によって行なっています。
エラーメッセージは出ていないのですが、Go言語の無限ループがされていないように見えます。
ソースコードとログを下記に記載いたします。

もしくはtopics["RoomCreated"]が入ってきていないのではないかと思っています。
何かご意見ありましたら参考にさせていただきたく投稿いたしました

solidityによるコントラクトコードです。

contract RoomFactory is Destructible, Pausable {

    event RoomCreated(
        address indexed _creator,
        address _room,
        uint256 _depositedValue
    );

    function createRoom() external payable whenNotPaused {
        address newRoom = (new Room).value(msg.value)(msg.sender);
        emit RoomCreated(msg.sender, newRoom, msg.value);
    }
}

Go言語によるイベント監視コードです。

想定では、for文直下のlog.Println("イベント検知中")により、ログに「イベント監視中」が無限に出続けるのではないかと考えています。

func main() {

	log.Println("Starting Event Server!!")
	db := connectDB()
	defer db.Close()

	// ③Ethereumネットワークに参加中のノードに接続
	client, err := ethclient.Dial(os.Getenv("GETH_URL"))
	// client, err := ethclient.Dial("ws://127.0.0.1:8545")
	if err != nil {
		log.Fatalf("err: %v\n", err)
	}

	// ④Solidityで定義したイベントをハッシュ化する
	topics := map[string]common.Hash{
		"RoomCreated": crypto.Keccak256Hash([]byte("RoomCreated(address,address,uint256)")),
	}
	log.Println("solidityで定義したイベントをハッシュ化する", topics)

	// ⑤どのコントラクトのどのTopicを対象にイベントを検知処理するか設定
	query := ethereum.FilterQuery{
		Addresses: []common.Address{common.HexToAddress(os.Getenv("ROOM_FACTORY_ADDRESS"))},
		Topics: [][]common.Hash{{
			topics["RoomCreated"],
		}},
	}
	log.Println("どのコントラクトのどのTopicを対象にイベントを検知処理するか設定：", query)

	// ⑥client.SubscribeFilterLogsでコントラクトとの接続を開始
	event := make(chan types.Log)
	sub, err := client.SubscribeFilterLogs(context.Background(), query, event)
	if err != nil {
		log.Fatal(err)
	}
	log.Println("コントラクトとの接続：", event, sub, err)

	roomFactoryAbi, err := abi.JSON(strings.NewReader(string(bindings.RoomFactoryABI)))
	if err != nil {
		log.Fatal(err)
	}
	log.Println("roomFactoryAbiをオブジェクト化:", roomFactoryAbi, err)

	// ⑦イベント検知のための無限ループ

	for {

		log.Println("イベント検知中")

		// ⑧select文を使ってチャネルの監視を行い、コントラクトとの接続が切断された場合はエラーメッセージを返す
		select {

		case err := <-sub.Err():
			log.Println("イベントエラー")
			log.Println(err)
			close(event)

		case vLog := <-event:
			log.Println("Topicsのエラー")
			if len(vLog.Topics) == 0 {
				log.Println("Topicsが存在しません")
			}

			// ⑩イベントを検知した場合はeventチャンネルを通じてイベントデータを返す。
			log.Println("イベント検知準備")

			switch vLog.Topics[0] {
			case topics["RoomCreated"]:
				var roomCreatedEvent RoomCreatedEvent
				log.Println("イベントを検知")
				if err := roomFactoryAbi.Unpack(&roomCreatedEvent, "RoomCreated", vLog.Data); err != nil {
					log.Printf("Failed unpack: %v\n", err)
					continue
				}

				// データベースに新しいデータを登録する処理
				room := Room{
					Address:      roomCreatedEvent.Room.Hex(),                         // デプロイされた新しいルームのコントラクトアドレス
					CreateTxHash: vLog.TxHash.Hex(),                                   // Transaction Hash
					OwnerAddress: common.BytesToAddress(vLog.Topics[1].Bytes()).Hex(), // デプロイしたユーザーのアドレス
					WeiBalance:   roomCreatedEvent.DepositedValue.Uint64(),            // デプロイ時に指定したDeposit額
					EventCode:    getEventCode(4),                                     // イベントコード
					OwnerID:      1,                                                   // ダミー
				}

				if err := db.Create(&room).Error; err != nil {
					log.Printf("Failed create room: %v\n", err)
				}

				break
			}
		}
	}
}

試したこと

イベント監視コードのログです

ログに「イベント検知中」が一回しか出ていません。
なので、イベント監視のコードが常時監視していないのではないかと思っています。

test_event  | 2019/09/05 02:56:37 Starting Event Server!!
test_event  | 2019/09/05 02:56:37 データベースに接続
test_event  | 2019/09/05 02:56:38 solidityで定義したイベントをハッシュ化する map[RoomCreated:[104 73 247 164 9 173 151 211 156 95 250 7 75 247 101 51 11 241 165 116 218 153 212 196 131 17 150 236 215 126 168 218]]
test_event  | 2019/09/05 02:56:38 どのコントラクトのどのTopicを対象にイベントを検知処理するか設定： {<nil> <nil> <nil> [[125 137 92 95 62 226 4 96 16 225 156 245 254 164 133 206 67 15 12 205]] [[[104 73 247 164 9 173 151 211 156 95 250 7 75 247 101 51 11 241 165 116 218 153 212 196 131 17 150 236 215 126 168 218]]]}
test_event  | 2019/09/05 02:56:39 コントラクトとの接続： 0xc000075680 &{0xc000414680 0xb37700 {0xa5d340 0xc000075680 18} eth 0x1feed340575875d6fe33bb68948a66c4 0xc0000757a0 {{0 0} 0} 0xc000075740 {{0 0} 0} 0xc0004476e0} <nil>
test_event  | 2019/09/05 02:56:39 roomFactoryAbiをオブジェクト化: {function () returns() map[createRoom:function createRoom() returns() destroy:function destroy() returns() destroyAndSend:function destroyAndSend(address _recipient) returns() owner:function owner() constant returns(address) pause:function pause() returns() paused:function paused() constant returns(bool) renounceOwnership:function renounceOwnership() returns() transferOwnership:function transferOwnership(address _newOwner) returns() unpause:function unpause() returns()] map[OwnershipRenounced:event OwnershipRenounced(address indexed previousOwner) OwnershipTransferred:event OwnershipTransferred(address indexed previousOwner, address indexed newOwner) Pause:event Pause() RoomCreated:event RoomCreated(address indexed _creator, address _room, uint256 _depositedValue) Unpause:event Unpause()]} <nil>
test_event  | 2019/09/05 02:56:39 イベント検知中

なにかヒントになることがありましたらご教示頂けますと助かります。

Answer 1

イベントが届けば

• イベントを検知
• イベント検知中

というように表示されるのではないでしょうか。
「イベントが届いてない、エラーも発生していない」から一度表示してイベントの受信待ちになっていると思います。

Comments

[AK4747471]

確かに先日、何かの原因でWebSocket通信が切れた時に「イベント検知中」のログが表示されたのを確認してます。(他の仕込んであるログ表示もされました)
イベント情報が渡されていない可能性で少し深掘りしてみます。

ご意見出していただきありがとうございます！

[AK4747471]

event := make(chan types.Log)
でチャネルを作成しているのはわかったのですが、チャネルにデータを渡す記述がないため、イベントの発火が検知できていないということでしょうか？

[AK4747471]

張り付いた結果、なんとかイベント検知できるようになりました！
```
[]common.Address{common.HexToAddress(os.Getenv("ROOM_FACTORY_ADDRESS"))}

この文を変更　↓

[]common.Address{common.HexToAddress("コントラクトアドレス")}
```
としたら検知しました！
docker-compose.ymlで環境変数を設定していたのですが、それがよくなかったのかもしれません。