lijian il y a 4 ans
Parent
commit
3b7e9b60be
2 fichiers modifiés avec 7 ajouts et 4 suppressions
  1. 2 1
      pkg/models/rule.go
  2. 5 3
      pkg/ruleEngine/nodes/rest_api_request_node.go

+ 2 - 1
pkg/models/rule.go

@@ -1,5 +1,6 @@
 package models
 
+
 import (
 	"github.com/jinzhu/gorm"
 )
@@ -21,4 +22,4 @@ type Rule struct {
 	Action string `sql:"type:varchar(200);not null;"`
 	// if trigger once
 	Once bool `sql:"default(false)"`
-}
+}

+ 5 - 3
pkg/ruleEngine/nodes/rest_api_request_node.go

@@ -86,9 +86,11 @@ func (r *RestApiRequestNode) OnMessage(ctx ruleEngine.Context, message *protocol
 			ctx.TellError(next, err)
 			return
 		}
-		if res.Response().StatusCode == http.StatusOK {
-			msg := r.processResponse(ctx, message, res)
-			ctx.TellSuccess(msg)
+		if res != nil && res.Response() != nil {
+			if res.Response().StatusCode == http.StatusOK {
+				msg := r.processResponse(ctx, message, res)
+				ctx.TellSuccess(msg)
+			}
 		}
 	})
 }