PandaX/iothub/server/emqxserver/const.go

package emqxserver

import (
	"pandax/pkg/rule_engine/message"
	"strings"
)

const (
	// Topic 上行
	RowTopic        = `v1/devices/me/row`
	TelemetryTopic  = `v1/devices/me/telemetry`
	AttributesTopic = `v1/devices/me/attributes`

	//网关子设备
	AttributesGatewayTopic = "v1/gateway/attributes"
	TelemetryGatewayTopic  = "v1/gateway/telemetry"
	ConnectGatewayTopic    = "v1/gateway/connect"

	RpcReq = `v1/devices/me/rpc/(.*?)/(.*?)$`

	EventReq = `v1/devices/event/(.*?)$`
)

var IotHubTopic = NewIotHubTopic()

type TopicMeg map[string]string

// 消息的来源类型
func NewIotHubTopic() TopicMeg {
	return map[string]string{
		AttributesTopic:        message.AttributesMes,
		RowTopic:               message.RowMes,
		TelemetryTopic:         message.TelemetryMes,
		AttributesGatewayTopic: message.GATEWAY,
		TelemetryGatewayTopic:  message.GATEWAY,
		ConnectGatewayTopic:    message.GATEWAY,
	}
}

func (iht TopicMeg) GetMessageType(topic string) string {
    //删除topic的前后空格
	topic = strings.TrimSpace(topic)
	if meg, ok := iht[topic]; ok {
		return meg
	}
	if strings.Contains(topic, "v1/devices/me/rpc/request") || strings.Contains(topic, "v1/devices/me/rpc/response") {
		return message.RpcRequestFromDevice
	}
	if strings.Contains(topic, "v1/devices/event") {
		return message.UpEventMes
	}
	return ""
}