package main

import (
    "fmt"
    "os"
    "os/signal"

    "github.com/yosssi/gmq/mqtt"
    "github.com/yosssi/gmq/mqtt/client"
)

func main() {

    sigc := make(chan os.Signal, 1)
    signal.Notify(sigc, os.Interrupt, os.Kill)

    cli := client.New(&client.Options{
        // Define the processing of the error handler.
        ErrorHandler: func(err error) {
            fmt.Println(err)
        },
    })
    err := cli.Connect(&client.ConnectOptions{
        Network:  "tcp",
        Address:  "io.adafruit.com:1883",
        UserName:        []byte("imperator666"),
        Password:        []byte("320063c3dabf40f49b68dc602e0b1bd8"),
        CleanSession: true,
    })
    if err != nil {
        panic(err)
    }
    fmt.Println("connected")
    defer cli.Terminate()

    err = cli.Publish(&client.PublishOptions{
        QoS:       mqtt.QoS0,
        TopicName: []byte("imperator666/feeds/chatcount"),
        Retain:    true,
        Message:   []byte("NUMBER"),

    })

    if err != nil {
        panic(err)
    }

    <- sigc

    if err := cli.Disconnect(); err != nil {
        panic(err)
    }
}