Support trigger content type (#26)

Author: bivas

engine/actions/trigger/rule.go

@@ -5,10 +5,11 @@ var (
 )
 
 type rule struct {
-	Endpoint string            `mapstructure:"endpoint"`
-	Method   string            `mapstructure:"method"`
-	Headers  map[string]string `mapstructure:"headers"`
-	Body     string            `mapstructure:"body"`
+	Endpoint    string            `mapstructure:"endpoint"`
+	Method      string            `mapstructure:"method"`
+	Headers     map[string]string `mapstructure:"headers"`
+	Body        string            `mapstructure:"body"`
+	ContentType string            `mapstructure:"content-type"`
 }
 
 func (r *rule) Defaults() {
@@ -22,4 +23,7 @@ func (r *rule) Defaults() {
 	if !allowedMethod {
 		r.Method = "POST"
 	}
+	if r.ContentType == "" {
+		r.ContentType = "application/json"
+	}
 }

engine/actions/trigger/trigger.go

@@ -68,7 +68,7 @@ func (a *action) prepareRequest(meta types.Data) *http.Request {
 func (a *action) setRequestHeaders(request *http.Request) {
 	request.Header.Set("User-Agent", "Rivi-Agent/1.0")
 	request.Header.Set("X-Rivi-Event", "trigger")
-	request.Header.Set("Content-Type", "application/json")
+	request.Header.Set("Content-Type", a.rule.ContentType)
 	for name, value := range a.rule.Headers {
 		lowerName := strings.ToLower(name)
 		if !strings.HasPrefix(lowerName, "x-") || strings.HasPrefix(lowerName, "x-rivi") {

engine/actions/trigger/trigger.md

@@ -32,6 +32,8 @@ None
 - `endpoint` (required) - the target endpoint
 - `method` (optional) - HTTP method (`GET` or `POST`) (default: **POST**)
 - `headers` (optional) - key-values to add to request. Must start with `X-` otherwise will not be included
+- `body` (optional) - Template for posted data
+- `content-type` (optional) - Set `Content-Type` header (default: **`application/json`**)
 
 ## Example
 ```yaml