Update examples to include blocks streaming

Author: aleksej-paschenko

examples/sse/go.mod

@@ -1,8 +1,8 @@
 module github.com/tonkeeper/tonapi-go/examples/sse
 
-go 1.20
+go 1.21.3
 
-require github.com/tonkeeper/tonapi-go v0.0.2
+require github.com/tonkeeper/tonapi-go v0.0.3
 
 require (
 	github.com/dlclark/regexp2 v1.10.0 // indirect

examples/sse/go.sum

@@ -51,9 +51,8 @@ github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
-github.com/tonkeeper/tonapi-go v0.0.1 h1:miD7wFpocflt0seNhJ4kKhiXsWkozwotO2gJGlib4C0=
-github.com/tonkeeper/tonapi-go v0.0.1/go.mod h1:2n+LizNjCQbCZhvVSooKGnzxAgdIrgePsh6Kgea0NPY=
-github.com/tonkeeper/tonapi-go v0.0.2/go.mod h1:2n+LizNjCQbCZhvVSooKGnzxAgdIrgePsh6Kgea0NPY=
+github.com/tonkeeper/tonapi-go v0.0.3 h1:T0C40m4OnGJmR17ijRBFDBqlJm3IktjP3JOi8VRXZWk=
+github.com/tonkeeper/tonapi-go v0.0.3/go.mod h1:2n+LizNjCQbCZhvVSooKGnzxAgdIrgePsh6Kgea0NPY=
 github.com/tonkeeper/tongo v1.4.1 h1:QMIya/ongFuOyHgVOFmHF+Cu4nt23KumPRLApmp90zE=
 github.com/tonkeeper/tongo v1.4.1/go.mod h1:LdOBjpUz6vLp1EdX3E0XLNks9YI5XMSqaQahfOMrBEY=
 go.opentelemetry.io/otel v1.19.0 h1:MuS/TNf4/j4IXsZuJegVzI1cwut7Qc00344rgH7p8bs=

examples/sse/main.go

@@ -8,6 +8,10 @@ import (
 	"github.com/tonkeeper/tonapi-go"
 )
 
+func intPointer(x int) *int {
+	return &x
+}
+
 func subscribeToMempool(token string) {
 	streamingAPI := tonapi.NewStreamingAPI(tonapi.WithStreamingToken(token))
 	for {
@@ -57,6 +61,19 @@ func subscribeToTraces(token string) {
 	}
 }
 
+func subscribeToBlocks(token string) {
+	streamingAPI := tonapi.NewStreamingAPI(tonapi.WithStreamingToken(token))
+	for {
+		err := streamingAPI.SubscribeToBlocks(context.Background(), intPointer(-1),
+			func(data tonapi.BlockEventData) {
+				fmt.Printf("New block: (%v,%v,%v)\n", data.Workchain, data.Shard, data.Seqno)
+			})
+		if err != nil {
+			fmt.Printf("block error: %v, reconnecting...\n", err)
+		}
+	}
+}
+
 func main() {
 	// When working with tonapi.io, you should consider getting an API key at https://tonconsole.com/
 	// because tonapi.io has per-ip limits for sse and websocket connections.
@@ -72,5 +89,6 @@ func main() {
 	go subscribeToTraces(token)
 	go subscribeToMempool(token)
 	go subscribeToTransactions(token)
+	go subscribeToBlocks(token)
 	select {}
 }

examples/websocket/go.mod

@@ -1,8 +1,8 @@
 module github.com/tonkeeper/tonapi-go/examples/websocket
 
-go 1.20
+go 1.21.3
 
-require github.com/tonkeeper/tonapi-go v0.0.2
+require github.com/tonkeeper/tonapi-go v0.0.3
 
 require (
 	github.com/dlclark/regexp2 v1.10.0 // indirect

examples/websocket/go.sum

@@ -51,9 +51,8 @@ github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
 github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
-github.com/tonkeeper/tonapi-go v0.0.1 h1:miD7wFpocflt0seNhJ4kKhiXsWkozwotO2gJGlib4C0=
-github.com/tonkeeper/tonapi-go v0.0.1/go.mod h1:2n+LizNjCQbCZhvVSooKGnzxAgdIrgePsh6Kgea0NPY=
-github.com/tonkeeper/tonapi-go v0.0.2/go.mod h1:2n+LizNjCQbCZhvVSooKGnzxAgdIrgePsh6Kgea0NPY=
+github.com/tonkeeper/tonapi-go v0.0.3 h1:T0C40m4OnGJmR17ijRBFDBqlJm3IktjP3JOi8VRXZWk=
+github.com/tonkeeper/tonapi-go v0.0.3/go.mod h1:2n+LizNjCQbCZhvVSooKGnzxAgdIrgePsh6Kgea0NPY=
 github.com/tonkeeper/tongo v1.4.1 h1:QMIya/ongFuOyHgVOFmHF+Cu4nt23KumPRLApmp90zE=
 github.com/tonkeeper/tongo v1.4.1/go.mod h1:LdOBjpUz6vLp1EdX3E0XLNks9YI5XMSqaQahfOMrBEY=
 go.opentelemetry.io/otel v1.19.0 h1:MuS/TNf4/j4IXsZuJegVzI1cwut7Qc00344rgH7p8bs=

examples/websocket/main.go

@@ -29,8 +29,11 @@ func main() {
 		ws.SetTraceHandler(func(data tonapi.TraceEventData) {
 			fmt.Printf("New trace with hash: %v\n", data.Hash)
 		})
+		ws.SetBlockHandler(func(data tonapi.BlockEventData) {
+			fmt.Printf("New block: (%v,%v,%v)\n", data.Workchain, data.Shard, data.Seqno)
+		})
 
-		if err := ws.SubscribeToMempool(accounts); err != nil {
+		if err := ws.SubscribeToMempool(nil); err != nil {
 			return err
 		}
 		if err := ws.SubscribeToTransactions(accounts, nil); err != nil {
@@ -39,6 +42,10 @@ func main() {
 		if err := ws.SubscribeToTraces(accounts); err != nil {
 			return err
 		}
+		masterchain := -1
+		if err := ws.SubscribeToBlocks(&masterchain); err != nil {
+			return err
+		}
 		// It is possible to run a loop updating subscription on the go:
 		//
 		// subscribeCh := make(chan []string) // channel to send accounts to subscribe.