fix(portable plugin): support portable plugin load and run when ekuiper set up

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

internal/plugin/native/manager.go

@@ -841,6 +841,7 @@ func (rr *Manager) pluginInstallWhenReboot() {
 		}
 		err = rr.Register(plgType, sd)
 		if err != nil {
+			conf.Log.Errorf(`install native plugin %s error: %v`, k, err)
 			_ = rr.plgStatusDb.Set(k, err.Error())
 			continue
 		}

internal/plugin/portable/manager.go

@@ -438,6 +438,7 @@ func (m *Manager) PluginImport(plugins map[string]string) {
 		}
 		err = m.Register(sd)
 		if err != nil {
+			conf.Log.Errorf(`install portable plugin %s error: %v`, k, err)
 			_ = m.plgStatusDb.Set(k, err.Error())
 			continue
 		}

internal/server/rest.go

@@ -17,6 +17,7 @@ package server
 import (
 	"bytes"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"github.com/lf-edge/ekuiper/internal/conf"
 	"github.com/lf-edge/ekuiper/internal/meta"
@@ -579,17 +580,17 @@ func importHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 	if rsi.Content != "" && rsi.FilePath != "" {
-		handleError(w, nil, "Invalid body: Cannot specify both content and file", logger)
+		handleError(w, errors.New("bad request"), "Invalid body: Cannot specify both content and file", logger)
 		return
 	} else if rsi.Content == "" && rsi.FilePath == "" {
-		handleError(w, nil, "Invalid body: must specify content or file", logger)
+		handleError(w, errors.New("bad request"), "Invalid body: must specify content or file", logger)
 		return
 	}
 	content := []byte(rsi.Content)
 	if rsi.FilePath != "" {
 		reader, err := httpx.ReadFile(rsi.FilePath)
 		if err != nil {
-			handleError(w, nil, "Fail to read file", logger)
+			handleError(w, err, "Fail to read file", logger)
 			return
 		}
 		defer reader.Close()
@@ -783,17 +784,17 @@ func configurationImportHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 	if rsi.Content != "" && rsi.FilePath != "" {
-		handleError(w, nil, "Invalid body: Cannot specify both content and file", logger)
+		handleError(w, errors.New("bad request"), "Invalid body: Cannot specify both content and file", logger)
 		return
 	} else if rsi.Content == "" && rsi.FilePath == "" {
-		handleError(w, nil, "Invalid body: must specify content or file", logger)
+		handleError(w, errors.New("bad request"), "Invalid body: must specify content or file", logger)
 		return
 	}
 	content := []byte(rsi.Content)
 	if rsi.FilePath != "" {
 		reader, err := httpx.ReadFile(rsi.FilePath)
 		if err != nil {
-			handleError(w, nil, "Fail to read file", logger)
+			handleError(w, err, "Fail to read file", logger)
 			return
 		}
 		defer reader.Close()

internal/server/server.go

@@ -94,7 +94,6 @@ func StartUp(Version, LoadFileType string) {
 	ruleProcessor = processor.NewRuleProcessor()
 	streamProcessor = processor.NewStreamProcessor()
 	rulesetProcessor = processor.NewRulesetProcessor(ruleProcessor, streamProcessor)
-	initRuleset()
 
 	// register all extensions
 	for k, v := range components {
@@ -113,6 +112,7 @@ func StartUp(Version, LoadFileType string) {
 		panic(err)
 	}
 	meta.Bind()
+	initRuleset()
 
 	registry = &RuleRegistry{internal: make(map[string]*rule.RuleState)}
 	//Start lookup tables