Skip to content

Commit 9766c82

Browse files
committed
feat: support chainsync transaction and rollback in notify output
Signed-off-by: Chris Gianelloni <[email protected]>
1 parent b14c47d commit 9766c82

File tree

1 file changed

+39
-0
lines changed

1 file changed

+39
-0
lines changed

output/notify/notify.go

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,45 @@ func (n *NotifyOutput) Start() error {
6767
if err != nil {
6868
panic(err)
6969
}
70+
case "chainsync.rollback":
71+
payload := evt.Payload
72+
if payload == nil {
73+
panic(fmt.Errorf("ERROR: %v", payload))
74+
}
75+
76+
re := payload.(chainsync.RollbackEvent)
77+
err := beeep.Notify(
78+
"Snek",
79+
fmt.Sprintf("Rollback!\nSlotNumber: %d\nBlockHash: %s",
80+
re.SlotNumber,
81+
re.BlockHash,
82+
),
83+
"assets/snek-icon.png",
84+
)
85+
if err != nil {
86+
panic(err)
87+
}
88+
case "chainsync.transaction":
89+
payload := evt.Payload
90+
if payload == nil {
91+
panic(fmt.Errorf("ERROR: %v", payload))
92+
}
93+
94+
te := payload.(chainsync.TransactionEvent)
95+
err := beeep.Notify(
96+
"Snek",
97+
fmt.Sprintf("New Transaction!\nBlockNumber: %d, SlotNumber: %d\nInputs: %d, Outputs: %d\nHash: %s",
98+
te.BlockNumber,
99+
te.SlotNumber,
100+
len(te.Inputs),
101+
len(te.Outputs),
102+
te.TransactionHash,
103+
),
104+
"assets/snek-icon.png",
105+
)
106+
if err != nil {
107+
panic(err)
108+
}
70109
default:
71110
err := beeep.Notify(
72111
"Snek",

0 commit comments

Comments
 (0)