transform

type ExprAssignNode struct {
	// Config 节点配置
	Config ExprAssignNodeConfiguration
	// contains filtered or unexported fields
}

type ExprAssignNodeConfiguration struct {
	// ExprScript JavaScript脚本，用于确定消息路由路径
	// 函数参数：msg, metadata, msgType, dataType
	// 必须返回字符串数组，表示路由关系类型
	//
	// 内置变量：
	//   - $ctx: 上下文对象，提供缓存操作
	//   - global: 全局配置属性
	//   - vars: 规则链变量
	//   - UDF函数: 用户自定义函数
	//
	// 示例: "return ['route1', 'route2'];"
	Script string `json:"script"`
}

type ExprFilterNode struct {
	// Config 表达式过滤器配置
	// Config holds the expression filter configuration
	Config ExprFilterNodeConfiguration
	// contains filtered or unexported fields
}

type ExprFilterNodeConfiguration struct {
	// Expr 用于过滤评估的表达式，必须返回布尔值
	// Expr contains the expression to evaluate for filtering.
	// The expression has access to the following variables:
	//   - id: Message ID (string)
	//   - ts: Message timestamp (int64)
	//   - data: Original message data (string)
	//   - msg: Parsed message body (object for JSON, string otherwise)
	//   - metadata: Message metadata (object with key-value pairs)
	//   - type: Message type (string)
	//   - dataType: Message data type (string)
	//
	// The expression must evaluate to a boolean value:
	//   - true: Message passes the filter (routed to "True" relation)
	//   - false: Message fails the filter (routed to "False" relation)
	//
	// Example expressions:
	// 表达式示例：
	//   - "msg.temperature > 50"
	//   - "metadata.deviceType == 'sensor' && msg.value > 100"
	//   - "type == 'TELEMETRY' && data contains 'alarm'"
	//   - "ts > 1640995200 && msg.status == 'active'"
	Script string `json:"script"`
}

type ExprSwitchNode struct {
	// Config 开关节点配置
	// Config holds the switch node configuration
	Config ExprSwitchNodeConfiguration
	// contains filtered or unexported fields
}

type ExprSwitchNodeConfiguration struct {
	// JsScript JavaScript脚本，用于确定消息路由路径
	// 函数参数：msg, metadata, msgType, dataType
	// 必须返回字符串数组，表示路由关系类型
	//
	// 内置变量：
	//   - $ctx: 上下文对象，提供缓存操作
	//   - global: 全局配置属性
	//   - vars: 规则链变量
	//   - UDF函数: 用户自定义函数
	//
	// 示例: "return ['route1', 'route2'];"
	// student=="3" ? "A" : ((score > 75 && level == "B")|| student == "C") ? "B" : (score > 60) ? "C" : "Default"
	Script string `json:"script"`

	Cases []types.Case `json:"cases"`
}

type JsFilterNode struct {
	// Config 节点配置
	Config JsFilterNodeConfiguration
	// contains filtered or unexported fields
}

type JsFilterNodeConfiguration struct {
	// JsScript JavaScript脚本，用于评估过滤条件
	// 函数参数：msg, metadata, msgType, dataType
	// 必须返回布尔值：true通过过滤，false不通过
	//
	// 内置变量：
	//   - $ctx: 上下文对象，提供缓存操作
	//   - global: 全局配置属性
	//   - vars: 规则链变量
	//   - UDF函数: 用户自定义函数
	//
	// 示例: "return msg.temperature > 25.0;"
	Script string `json:"script"`
}

type JsSwitchNode struct {
	// Config 节点配置
	Config JsSwitchNodeConfiguration
	// contains filtered or unexported fields
}

type JsSwitchNodeConfiguration struct {
	// JsScript JavaScript脚本，用于确定消息路由路径
	// 函数参数：msg, metadata, msgType, dataType
	// 必须返回字符串数组，表示路由关系类型
	//
	// 内置变量：
	//   - $ctx: 上下文对象，提供缓存操作
	//   - global: 全局配置属性
	//   - vars: 规则链变量
	//   - UDF函数: 用户自定义函数
	//
	// 示例: "return ['route1', 'route2'];"
	Script string `json:"script"`
}