package kiosk

import (
	"fmt"
	"os"

	MQTT "github.com/eclipse/paho.mqtt.golang"
)

func brokerConsume() {
	opts := MQTT.NewClientOptions()
	opts.AddBroker(config.broker)
	hostname, err := os.Hostname()
	if err != nil {
		panic(err)
	}
	opts.SetClientID(fmt.Sprintf("hasskiosk-%s-%d", hostname, os.Getpid()))
	opts.SetUsername(config.username)
	opts.SetPassword(config.password)
	opts.SetDefaultPublishHandler(func(client MQTT.Client, msg MQTT.Message) {

	})
}

func defaultMQTTHandler(client MQTT.Client, msg MQTT.Message) {

}