agent

type Action struct {
	Topic   string
	Payload string
	QoS     byte
	Retain  bool
}

type Agent interface {
	Connect() bool
	Subscribe() bool
	Listen()
	Disconnect()

	HandleMessage(topic string, payload []byte)

	SetParameterFromString(name string, value string)
	SetParameter(name string, param Parameter)
	GetParameterValue(parameter string) interface{}
	TriggerParameterUpdate(parameter string, value string)
	EvalExpressionsInString(in string, functions map[string]govaluate.ExpressionFunction) string

	AddParameterSubscription(topic string, parameter string)
	RemoveParameterSubscription(topic string, parameter string)

	AddRuleFromString(ruleset string, rule string, value string)
	AddRule(ruleset string, rule string, r Rule)
	GetRule(ruleset string, rule string) *Rule
	AddRuleSubscription(topic string, ruleset string, rule string)
	RemoveRuleSubscription(topic string, ruleset string, rule string)

	ExecuteRule(ruleset string, rule string, triggerPayload string)
	Publish(topic string, qos byte, retained bool, payload string)
	IsSubscribed(topic string) bool
	InjectConfigFile(c ConfigFile)
}

type Config struct {
	Broker             string
	ClientID           string
	Username           string
	Password           string
	Prefix             string
	DisableRulesUpdate bool
	Loglevel           string
}

type ConfigFile struct {
	Config     Config
	Parameters map[string]Parameter
	Rules      map[string]map[string]Rule
}

type MessageHandler func(topic string, payload string)

type MqttClient interface {
	IsConnected() bool
	Connect() bool
	Disconnect()
	SetSubscriptionCallback(callback func(string, string))
	Publish(topic string, qos byte, retained bool, payload interface{}) bool
	Subscribe(topic string, qos byte) bool
	Unsubscribe(topics ...string) bool
}

type PahoClient interface {
	IsConnected() bool
	Connect() bool
	Disconnect()
	SetSubscriptionCallback(callback func(string, string))
	Publish(topic string, qos byte, retained bool, payload interface{}) bool
	Subscribe(topic string, qos byte) bool
	Unsubscribe(topics ...string) bool
}

type Parameter struct {
	Value      interface{}
	Topic      string
	Expression string
}

type Rule struct {
	Trigger   string
	Schedule  string
	Condition string
	Actions   []Action
	// contains filtered or unexported fields
}