forked from OffchainLabs/arbitrum-classic
-
Notifications
You must be signed in to change notification settings - Fork 0
/
announcerListener.go
116 lines (98 loc) · 3.85 KB
/
announcerListener.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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
/*
* Copyright 2020, Offchain Labs, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package chainlistener
import (
"context"
"github.com/offchainlabs/arbitrum/packages/arb-validator/nodegraph"
"github.com/offchainlabs/arbitrum/packages/arb-validator/structures"
"log"
"github.com/offchainlabs/arbitrum/packages/arb-validator-core/arbbridge"
"github.com/offchainlabs/arbitrum/packages/arb-validator-core/valprotocol"
)
type AnnouncerListener struct {
Prefix string
}
func (al *AnnouncerListener) AddedToChain(context.Context, []*structures.Node) {
log.Println("AddedToChain")
}
func (al *AnnouncerListener) RestartingFromLatestValid(context.Context, *structures.Node) {
log.Println("RestartingFromLatestValid")
}
func (al *AnnouncerListener) StakeCreated(ctx context.Context, ng *nodegraph.StakedNodeGraph, ev arbbridge.StakeCreatedEvent) {
log.Printf("%v Staker %v created at %v\n", al.Prefix, ev.Staker, ev.NodeHash)
}
func (al *AnnouncerListener) StakeRemoved(ctx context.Context, ev arbbridge.StakeRefundedEvent) {
log.Printf("%v Staker %v removed\n", al.Prefix, ev.Staker)
}
func (al *AnnouncerListener) StakeMoved(ctx context.Context, ng *nodegraph.StakedNodeGraph, ev arbbridge.StakeMovedEvent) {
log.Printf("%v Staker %v moved to location: %v\n", al.Prefix, ev.Staker, ev.Location)
}
func (al *AnnouncerListener) StartedChallenge(
context.Context,
*structures.MessageStack,
*nodegraph.Challenge) {
log.Println(al.Prefix, "StartedChallenge")
}
func (al *AnnouncerListener) ResumedChallenge(
context.Context,
*structures.MessageStack,
*nodegraph.Challenge) {
log.Println(al.Prefix, "ResumedChallenge")
}
func (al *AnnouncerListener) CompletedChallenge(
ctx context.Context,
ng *nodegraph.StakedNodeGraph,
event arbbridge.ChallengeCompletedEvent,
) {
log.Println(al.Prefix, "CompletedChallenge")
}
func (al *AnnouncerListener) SawAssertion(ctx context.Context, ev arbbridge.AssertedEvent) {
log.Println(al.Prefix, "SawAssertion on leaf", ev.PrevLeafHash)
log.Println(al.Prefix, "Params:", ev.AssertionParams)
}
func (al *AnnouncerListener) ConfirmedNode(ctx context.Context, ev arbbridge.ConfirmedEvent) {
log.Println(al.Prefix, "ConfirmedNode", ev.NodeHash)
}
func (al *AnnouncerListener) PrunedLeaf(ctx context.Context, ev arbbridge.PrunedEvent) {
log.Println(al.Prefix, "PrunedLeaf", ev.Leaf)
}
func (al *AnnouncerListener) MessageDelivered(_ context.Context, ev arbbridge.MessageDeliveredEvent) {
//log.Println(al.Prefix, "MessageDelivered", ev.Message)
}
func (al *AnnouncerListener) AssertionPrepared(
context.Context,
valprotocol.ChainParams,
*nodegraph.StakedNodeGraph,
*structures.Node,
*PreparedAssertion,
) {
log.Println(al.Prefix, "AssertionPrepared")
}
func (al *AnnouncerListener) ConfirmableNodes(context.Context, *valprotocol.ConfirmOpportunity) {
log.Println(al.Prefix, "ConfirmableNodes")
}
func (al *AnnouncerListener) PrunableLeafs(context.Context, []valprotocol.PruneParams) {
log.Println(al.Prefix, "PrunableLeafs")
}
func (al *AnnouncerListener) MootableStakes(context.Context, []nodegraph.RecoverStakeMootedParams) {
log.Println(al.Prefix, "MootableStakes")
}
func (al *AnnouncerListener) OldStakes(context.Context, []nodegraph.RecoverStakeOldParams) {
log.Println(al.Prefix, "OldStakes")
}
func (al *AnnouncerListener) AdvancedKnownNode(context.Context, *nodegraph.StakedNodeGraph, *structures.Node) {
log.Println(al.Prefix, "AdvancedKnownNode")
}