fix(plugin): fix sink image plugin config error

Signed-off-by: Jianxiang Ran <rxan_embedded@163.com>

extensions/sinks/image/image.go

@@ -37,7 +37,7 @@ type imageSink struct {
 }
 
 func (m *imageSink) Configure(props map[string]interface{}) error {
-	if i, ok := props["format"]; ok {
+	if i, ok := props["imageFormat"]; ok {
 		if i, ok := i.(string); ok {
 			if "png" != i && "jpeg" != i {
 				return fmt.Errorf("%s image type is not currently supported", i)

extensions/sinks/image/image.json

@@ -0,0 +1,82 @@
+{
+	"about": {
+		"trial": true,
+		"author": {
+			"name": "EMQ",
+			"email": "contact@emqx.io",
+			"company": "EMQ Technologies Co., Ltd",
+			"website": "https://www.emqx.io"
+		},
+		"helpUrl": {
+			"en_US": "https://github.com/lf-edge/ekuiper/blob/master/docs/en_US/rules/sinks/plugin/file.md",
+			"zh_CN": "https://github.com/lf-edge/ekuiper/blob/master/docs/zh_CN/rules/sinks/plugin/file.md"
+		},
+		"description": {
+			"en_US": "This a sink plugin for file, it can be used for saving the analysis data into file system.",
+			"zh_CN": "本插件为文件持久化插件，可以用于将分析数据存入指定的文件中。"
+		}
+	},
+	"libs": [
+	],
+	"properties": [{
+		"name": "path",
+		"default": "",
+		"optional": false,
+		"control": "text",
+		"type": "string",
+		"hint": {
+			"en_US": "The name of the folder where the pictures are saved, such as ./tmp. Note: For multiple rules, their paths cannot be repeated, otherwise they will be deleted from each other.",
+			"zh_CN": "保存图片的文件夹名，例如 ./tmp。注意：多条 rule 路径不能重复，否则会出现彼此删除的现象。"
+		},
+		"label": {
+			"en_US": "Path of file",
+			"zh_CN": "文件路径"
+		}
+	}, {
+		"name": "imageFormat",
+		"default": "jpeg",
+		"optional": true,
+		"control": "select",
+		"values": [
+			"jpeg",
+			"png"
+		],
+		"type": "list_string",
+		"hint": {
+			"en_US": "File format, support jpeg and png.",
+			"zh_CN": "文件格式，支持 jpeg 和 png。"
+		},
+		"label": {
+			"en_US": "The format of image",
+			"zh_CN": "图片格式"
+		}
+	},{
+		"name": "maxAge",
+		"default": 1000,
+		"optional": true,
+		"control": "text",
+		"type": "int",
+		"hint": {
+			"en_US": "Maximum file storage time (hours). The default value is 72, which means that the picture can be stored for up to 3 days.",
+			"zh_CN": "最长文件存储时间(小时)。默认值为72，这表示图片最多保存3天。"
+		},
+		"label": {
+			"en_US": "maxAge",
+			"zh_CN": "最长保留时间"
+		}
+	},{
+		"name": "maxCount",
+		"default": 1000,
+		"optional": true,
+		"control": "text",
+		"type": "int",
+		"hint": {
+			"en_US": "The maximum number of stored pictures. The default value is 1000. The earlier pictures will be deleted. The relationship with maxAge is OR.",
+			"zh_CN": "存储图片的最大数量，默认值是1000，删除时间较早的图片，与maxAge是或的关系。"
+		},
+		"label": {
+			"en_US": "maxCount",
+			"zh_CN": "最大写入数量"
+		}
+	}]
+}

internal/topo/node/sink_node.go

@@ -280,8 +280,8 @@ func (m *SinkNode) parseConf(logger api.Logger) (*SinkConf, error) {
 	m.concurrency = sconf.Concurrency
 	if sconf.Format == "" {
 		sconf.Format = "json"
-	} else if sconf.Format != message.FormatJson && sconf.Format != message.FormatProtobuf {
-		logger.Warnf("invalid type for format property, should be json or protobuf but found %s", sconf.Format)
+	} else if sconf.Format != message.FormatJson && sconf.Format != message.FormatProtobuf && sconf.Format != message.FormatBinary {
+		logger.Warnf("invalid type for format property, should be json protobuf or binary but found %s", sconf.Format)
 		sconf.Format = "json"
 	}
 	err = cast.MapToStruct(m.options, &sconf.SinkConf)