Repeated parameters

docs/guide/service/emit-an-event.md

@@ -29,6 +29,7 @@ To create an event, the first step is to update the Service's [`mesg.yml`](servi
 | **description** | `""` | `String` | Description of the data |
 | **type** | `String` | [`Type`](emit-an-event.md#type-of-your-data) | Type of data |
 | **optional** | `false` | `boolean` | Mark the data as optional |
+| **repeated** | `false` | `boolean` | Define this data as an array of the type selected |
 
 ### Data's type
 
@@ -52,14 +53,15 @@ events:
         data:
             foo:
                 name: "Foo"
-                description: "Foo is the first data"
+                description: "Foo is a string"
                 type: String
                 optional: false
             bar:
                 name: "Bar"
-                description: "Bar is the second data"
+                description: "Bar is an optional array of boolean"
                 type: Boolean
                 optional: true
+                repeated: true
 ...
 ```
 

docs/guide/service/listen-for-tasks.md

@@ -39,6 +39,7 @@ The first step is to declare the tasks that the service will be able to execute
 | **description** | `""` | `String` | Description of the parameter. |
 | **type** | `String` | [`Type`](listen-for-tasks.md#type-of-your-data) | Type of the parameter. |
 | **optional** | `false` | `Boolean` | If true, this parameter is considered as optional and might remain empty. |
+| **repeated** | `false` | `Boolean` | Define this parameter as an array of the type selected |
 
 ### Type of parameter
 
@@ -62,14 +63,15 @@ tasks:
         inputs:
             inputX:
                 name: "Input x"
-                description: "Foo is the first data"
+                description: "Foo is a string"
                 type: String
                 optional: false
             inputY:
                 name: "Input y"
-                description: "Bar is the second data"
+                description: "Bar is an optional array of boolean"
                 type: Boolean
                 optional: true
+                repeated: true
         outputs:
             outputX:
                 name: "OutputX"

interface/grpc/core/core.go

@@ -87,6 +87,7 @@ func toProtoParameters(params []*service.Parameter) []*coreapi.Parameter {
 			Name:        param.Name,
 			Description: param.Description,
 			Type:        param.Type,
+			Repeated:    param.Repeated,
 			Optional:    param.Optional,
 		}
 	}

protobuf/coreapi/api.proto

@@ -528,6 +528,7 @@ message Parameter {
   string description = 2; // Parameter's description.
   string type = 3;        // Parameter's type: `String`, `Number`, `Boolean` or `Object`.
   bool optional = 4;      // Set the parameter as optional.
+  bool repeated = 9;      // Mark a parameter as an array of the defined type
 }
 
 // A dependency is a configuration of an other Docker container that runs separately from the service.

service/importer/assets/schema.json

@@ -89,6 +89,9 @@
                 "optional": {
                   "type": "boolean"
                 },
+                "repeated": {
+                  "type": "boolean"
+                },
                 "type": {
                   "type": "string",
                   "enum": [

service/importer/definition.go

@@ -106,4 +106,7 @@ type Parameter struct {
 
 	// Optional indicates if parameter is optional.
 	Optional bool `yaml:"optional"`
+
+	// Repeated is to have an array of this parameter
+	Repeated bool `yaml:"repeated"`
 }

service/inject_definition.go

@@ -144,6 +144,7 @@ func (s *Service) defParametersToService(params map[string]*importer.Parameter)
 			Description: param.Description,
 			Type:        param.Type,
 			Optional:    param.Optional,
+			Repeated:    param.Repeated,
 		}
 	}
 	return ps

service/parameter.go

@@ -17,4 +17,7 @@ type Parameter struct {
 
 	// Optional indicates if parameter is optional.
 	Optional bool `hash:"name:5"`
+
+	// Repeated is to have an array of this parameter
+	Repeated bool `hash:"name:6"`
 }

service/validation.go

@@ -2,6 +2,7 @@ package service
 
 import (
 	"fmt"
+	"reflect"
 )
 
 // ParameterWarning contains a specific warning related to a parameter.
@@ -48,7 +49,20 @@ func (v *parameterValidator) Validate(value interface{}) *ParameterWarning {
 		}
 		return v.newParameterWarning("required")
 	}
-
+	if v.parameter.Repeated {
+		// Check if the value is a slice
+		if reflect.TypeOf(value).Kind() != reflect.Slice {
+			return v.newParameterWarning("not an array")
+		}
+		array := reflect.ValueOf(value)
+		for i := 0; i < array.Len(); i++ {
+			x := array.Index(i).Interface() // Get the value as an interface{}
+			if warning := v.validateType(x); warning != nil {
+				return warning
+			}
+		}
+		return nil
+	}
 	return v.validateType(value)
 }
 

service/validation_test.go

@@ -28,6 +28,11 @@ var eventDataSchema = []*Parameter{
 		Key:  "object",
 		Type: "Object",
 	},
+	{
+		Key:      "array",
+		Type:     "String",
+		Repeated: true,
+	},
 }
 
 func validateParameterData(paramKey string, data interface{}) bool {
@@ -74,6 +79,13 @@ func TestObject(t *testing.T) {
 	require.False(t, validateParameterData("object", 42))
 }
 
+func TestArray(t *testing.T) {
+	require.True(t, validateParameterData("array", []string{"foo", "bar"}))
+	require.True(t, validateParameterData("array", []string{}))
+	require.False(t, validateParameterData("array", []uint{10}))
+	require.False(t, validateParameterData("array", 42))
+}
+
 func TestValidateParameters(t *testing.T) {
 	require.Len(t, validateParametersSchema(eventDataSchema, map[string]interface{}{
 		"string":  "hello",
@@ -82,6 +94,7 @@ func TestValidateParameters(t *testing.T) {
 		"object": map[string]interface{}{
 			"foo": "bar",
 		},
+		"array": []string{"foo", "bar"},
 	}), 0)
 	require.Len(t, validateParametersSchema(eventDataSchema, map[string]interface{}{
 		"optional": "yeah",
@@ -91,15 +104,18 @@ func TestValidateParameters(t *testing.T) {
 		"object": map[string]interface{}{
 			"foo": "bar",
 		},
+		"array": []string{"foo", "bar"},
 	}), 0)
-	// 4 errors
+	// 5 errors
 	//  - not required string
 	//  - invalid number
 	//  - invalid boolean
 	//  - invalid object
+	//  - invalid array
 	require.Len(t, validateParametersSchema(eventDataSchema, map[string]interface{}{
 		"number":  "string",
 		"boolean": 42,
 		"object":  false,
-	}), 4)
+		"array":   42,
+	}), 5)
 }