Skip to content

Commit

Permalink
feat: support chainsync transaction and rollback in notify output
Browse files Browse the repository at this point in the history
Signed-off-by: Chris Gianelloni <wolf31o2@blinklabs.io>
  • Loading branch information
wolf31o2 committed Aug 2, 2023
1 parent b14c47d commit 9766c82
Showing 1 changed file with 39 additions and 0 deletions.
39 changes: 39 additions & 0 deletions output/notify/notify.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,6 +67,45 @@ func (n *NotifyOutput) Start() error {
if err != nil {
panic(err)
}
case "chainsync.rollback":
payload := evt.Payload
if payload == nil {
panic(fmt.Errorf("ERROR: %v", payload))
}

re := payload.(chainsync.RollbackEvent)
err := beeep.Notify(
"Snek",
fmt.Sprintf("Rollback!\nSlotNumber: %d\nBlockHash: %s",
re.SlotNumber,
re.BlockHash,
),
"assets/snek-icon.png",
)
if err != nil {
panic(err)
}
case "chainsync.transaction":
payload := evt.Payload
if payload == nil {
panic(fmt.Errorf("ERROR: %v", payload))
}

te := payload.(chainsync.TransactionEvent)
err := beeep.Notify(
"Snek",
fmt.Sprintf("New Transaction!\nBlockNumber: %d, SlotNumber: %d\nInputs: %d, Outputs: %d\nHash: %s",
te.BlockNumber,
te.SlotNumber,
len(te.Inputs),
len(te.Outputs),
te.TransactionHash,
),
"assets/snek-icon.png",
)
if err != nil {
panic(err)
}
default:
err := beeep.Notify(
"Snek",
Expand Down

0 comments on commit 9766c82

Please sign in to comment.