mqtt

var DefaultPublishHandler MQTT.MessageHandler = func(c MQTT.Client, msg MQTT.Message) {
	topic := msg.Topic()
	device := config.GetConfig().Device
	topic = strings.Replace(topic, device.ProductKey+"/"+device.DeviceName, "{pk}/{dn}", 1)
	log.Debug("topic = ", topic)
	log.Debug("payload = ", string(msg.Payload()))

	if strings.Contains(topic, "/sys/{pk}/{dn}/rrpc/request/") {
		RRpcHandle(c, topic, string(msg.Payload()))
		return
	}

	switch topic {
	case "/sys/{pk}/{dn}/thing/config/push":
		config.SaveParamsYaml(msg.Payload())
	default:
		log.Warn("miss topic = ", topic)
	}
}