LBRYCommunity/lbcd
1
0
Fork 0
Code Issues 17 Pull requests 4 Projects Releases 28 Packages Wiki Activity

Update ws example to use new filtered blocks ntfns.

Browse source 
The old notifications are now deprecated, so the examples shouldn't use
them.
This commit is contained in:
Dave Collins 2017-01-25 23:48:44 -06:00
parent abcdfb702a
commit eef39394b7
No known key found for this signature in database
GPG key ID: B8904D9D9C93D1F2
1 changed files with 8 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
examples/btcdwebsockets/main.go
View file

@ -1,4 +1,4 @@
// Copyright (c) 2014-2015 The btcsuite developers // Copyright (c) 2014-2017 The btcsuite developers
// Use of this source code is governed by an ISC // Use of this source code is governed by an ISC
// license that can be found in the LICENSE file. // license that can be found in the LICENSE file.
@ -10,7 +10,7 @@ import (
"path/filepath" "path/filepath"
"time" "time"
"github.com/btcsuite/btcd/chaincfg/chainhash" "github.com/btcsuite/btcd/wire"
"github.com/btcsuite/btcrpcclient" "github.com/btcsuite/btcrpcclient"
"github.com/btcsuite/btcutil" "github.com/btcsuite/btcutil"
) )
@ -21,11 +21,13 @@ func main() {
// for notifications. See the documentation of the btcrpcclient // for notifications. See the documentation of the btcrpcclient
// NotificationHandlers type for more details about each handler. // NotificationHandlers type for more details about each handler.
ntfnHandlers := btcrpcclient.NotificationHandlers{ ntfnHandlers := btcrpcclient.NotificationHandlers{
OnBlockConnected: func(hash *chainhash.Hash, height int32, time time.Time) { OnFilteredBlockConnected: func(height int32, header *wire.BlockHeader, txns []*btcutil.Tx) {
log.Printf("Block connected: %v (%d) %v", hash, height, time) log.Printf("Block connected: %v (%d) %v",
header.BlockHash(), height, header.Timestamp)
}, },
OnBlockDisconnected: func(hash *chainhash.Hash, height int32, time time.Time) { OnFilteredBlockDisconnected: func(height int32, header *wire.BlockHeader) {
log.Printf("Block disconnected: %v (%d) %v", hash, height, time) log.Printf("Block disconnected: %v (%d) %v",
header.BlockHash(), height, header.Timestamp)
}, },
} }