/*******************************************************************************
 * Copyright (c) 2014-2015 IBM Corp.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *    Allan Stockdill-Mander - initial API and implementation
 *******************************************************************************/

package main

import (
	"fmt"
	"git.eclipse.org/gitroot/paho.incubator/smidge.git/client"
	"git.eclipse.org/gitroot/paho.incubator/smidge.git/packets"
	"log"
	"os"
	"time"
)

func main() {
	smidge.DEBUG = log.New(os.Stdout, "", 0)
	c, err := smidge.NewClient("udp://127.0.0.1:1884", "gotestclient")
	if err != nil {
		panic(err)
	}
	c.SetWill("testwill", 1, true, []byte("Will test"))
	ct := c.Connect()
	ct.Wait()
	fmt.Println(ct.ReturnCode)
	rt := c.Register("gotest")
	rt.WaitTimeout(10 * time.Second)
	fmt.Println(rt.TopicName, rt.TopicId, rt.ReturnCode)
	st := c.Subscribe("gotest", 0, func(c *smidge.SNClient, m *packets.PublishMessage) {
		fmt.Println(string(m.Data))
	})
	st.WaitTimeout(10 * time.Second)
	fmt.Println(st.TopicName, st.Qos, st.TopicId, st.ReturnCode)
	pt := c.Publish("gotest", 1, false, []byte("Hello smidge"))
	pt.WaitTimeout(10 * time.Second)
	fmt.Println(pt.TopicId, pt.ReturnCode)
	time.Sleep(3 * time.Second)
}