package main

import (
	"encoding/json"
	"gitee.com/aywc_1/aywc_judge/src/mqtt2/lib"
	"gitee.com/aywc_1/aywc_judge/src/mqtt2/service"
	"gitee.com/aywc_1/aywc_judge/src/utils"
	"github.com/astaxie/beego/logs"
)

func main() {

	const (
		clientId = "pub-001"
		// topic规则：设备编号/接口名
		topicName      = "device001/user"
		actionNameUser = "user/detail"
	)

	client := lib.NewClient(clientId)
	err := client.Connect()
	if err != nil {
		logs.Error(err.Error())
	}

	// 发布一个 user 消息
	body := service.User{1, "小宝", 2}

	msg := &lib.Message{
		ClientID: clientId,
		Action:   actionNameUser,
		Type:     "json",
		Time:     utils.GetNowTime().Unix(),
		Body:     body,
	}
	data, _ := json.Marshal(msg)
	err = client.Publish(topicName, 0, false, data)
	if err != nil {
		panic(err)
	}
}