aboutsummaryrefslogtreecommitdiff
path: root/examples/example_longpolling.go
diff options
context:
space:
mode:
Diffstat (limited to 'examples/example_longpolling.go')
-rw-r--r--examples/example_longpolling.go62
1 files changed, 62 insertions, 0 deletions
diff --git a/examples/example_longpolling.go b/examples/example_longpolling.go
new file mode 100644
index 0000000..67a0d7c
--- /dev/null
+++ b/examples/example_longpolling.go
@@ -0,0 +1,62 @@
+// +build ignore
+
+/**
+ * Updates loop example
+ */
+package main
+
+import (
+ "context"
+ "fmt"
+ "log"
+ "os"
+ "os/signal"
+
+ "github.com/neonxp/tamtam"
+)
+
+func main() {
+ // Initialisation
+ api := tamtam.New(os.Getenv("TOKEN"))
+
+ // Some methods demo:
+ info, err := api.Bots.GetBot()
+ log.Printf("Get me: %#v %#v", info, err)
+
+ ctx, cancel := context.WithCancel(context.Background())
+ go func() {
+ for {
+ select {
+ case upd := <-api.GetUpdates():
+ log.Printf("Received: %#v", upd)
+ switch upd := upd.(type) {
+ case *tamtam.MessageCreatedUpdate:
+ res, err := api.Messages.SendMessage(0, upd.Message.Sender.UserId, &tamtam.NewMessageBody{
+ Text: fmt.Sprintf("Hello, %s! Your message: %s", upd.Message.Sender.Name, upd.Message.Body.Text),
+ })
+ log.Printf("Answer: %#v %#v", res, err)
+ default:
+ log.Printf("Unknown type: %#v", upd)
+ }
+ case <-ctx.Done():
+ return
+ }
+
+ }
+ }()
+ go func() {
+ exit := make(chan os.Signal)
+ signal.Notify(exit, os.Kill, os.Interrupt)
+ select {
+ case <-exit:
+ cancel()
+ case <-ctx.Done():
+ return
+ }
+ }()
+
+ if err := api.UpdatesLoop(ctx); err != nil {
+ log.Fatalln(err)
+ }
+
+}