feat(iotevents): allow setting description, evaluation method and key of DetectorModel

packages/@aws-cdk/aws-iotevents/README.md

@@ -51,7 +51,7 @@ import * as iotevents from '@aws-cdk/aws-iotevents';
 
 const input = new iotevents.Input(this, 'MyInput', {
   inputName: 'my_input', // optional
-  attributeJsonPaths: ['payload.temperature'],
+  attributeJsonPaths: ['payload.deviceId', 'payload.temperature'],
 });
 
 const onlineState = new iotevents.State({
@@ -64,6 +64,9 @@ const onlineState = new iotevents.State({
 
 new iotevents.DetectorModel(this, 'MyDetectorModel', {
   detectorModelName: 'test-detector-model', // optional
+  detectorModelDescription: 'test-detector-model-description', // optional property, default is none
+  evaluationMethod: iotevents.EvaluationMethod.SERIAL, // optional property, default is iotevents.EvaluationMethod.BATCH
+  key: 'payload.deviceId', // optional property, default is none and single detector instance will be created and all inputs will be routed to it
   initialState: onlineState,
 });
 ```

packages/@aws-cdk/aws-iotevents/lib/detector-model.ts

@@ -16,6 +16,22 @@ export interface IDetectorModel extends IResource {
   readonly detectorModelName: string;
 }
 
+/**
+ * Information about the order in which events are evaluated and how actions are executed.
+ */
+export enum EvaluationMethod {
+  /**
+   * When setting to SERIAL, variables are updated and event conditions are evaluated in the order
+   * that the events are defined.
+   */
+  BATCH = 'BATCH',
+  /**
+   * When setting to BATCH, variables within a state are updated and events within a state are
+   * performed only after all event conditions are evaluated.
+   */
+  SERIAL = 'SERIAL',
+}
+
 /**
  * Properties for defining an AWS IoT Events detector model
  */
@@ -27,6 +43,38 @@ export interface DetectorModelProps {
    */
   readonly detectorModelName?: string;
 
+  /**
+   * A brief description of the detector model.
+   *
+   * @default none
+   */
+  readonly detectorModelDescription?: string;
+
+  /**
+   * Information about the order in which events are evaluated and how actions are executed.
+   *
+   * When setting to SERIAL, variables are updated and event conditions are evaluated in the order
+   * that the events are defined.
+   * When setting to BATCH, variables within a state are updated and events within a state are
+   * performed only after all event conditions are evaluated.
+   *
+   * @default EvaluationMethod.BATCH
+   */
+  readonly evaluationMethod?: EvaluationMethod;
+
+  /**
+   * The value used to identify a detector instance. When a device or system sends input, a new
+   * detector instance with a unique key value is created. AWS IoT Events can continue to route
+   * input to its corresponding detector instance based on this identifying information.
+   *
+   * This parameter uses a JSON-path expression to select the attribute-value pair in the message
+   * payload that is used for identification. To route the message to the correct detector instance,
+   * the device must send a message payload that contains the same attribute-value.
+   *
+   * @default - none (single detector instance will be created and all inputs will be routed to it)
+   */
+  readonly key?: string;
+
   /**
    * The state that is entered at the creation of each detector.
    */
@@ -70,6 +118,9 @@ export class DetectorModel extends Resource implements IDetectorModel {
 
     const resource = new CfnDetectorModel(this, 'Resource', {
       detectorModelName: this.physicalName,
+      detectorModelDescription: props.detectorModelDescription,
+      evaluationMethod: props.evaluationMethod,
+      key: props.key,
       detectorModelDefinition: {
         initialStateName: props.initialState.stateName,
         states: [props.initialState._toStateJson()],

packages/@aws-cdk/aws-iotevents/test/detector-model.test.ts

@@ -95,6 +95,65 @@ test('can set physical name', () => {
   });
 });
 
+test('can set description', () => {
+  // WHEN
+  new iotevents.DetectorModel(stack, 'MyDetectorModel', {
+    detectorModelDescription: 'test-detector-model-description',
+    initialState: new iotevents.State({
+      stateName: 'test-state',
+      onEnter: [{
+        eventName: 'test-eventName',
+        condition: iotevents.Expression.fromString('test-eventCondition'),
+      }],
+    }),
+  });
+
+  // THEN
+  Template.fromStack(stack).hasResourceProperties('AWS::IoTEvents::DetectorModel', {
+    DetectorModelDescription: 'test-detector-model-description',
+  });
+});
+
+test('can set evaluationMethod', () => {
+  // WHEN
+  new iotevents.DetectorModel(stack, 'MyDetectorModel', {
+    detectorModelDescription: 'test-detector-model-description',
+    evaluationMethod: iotevents.EvaluationMethod.SERIAL,
+    initialState: new iotevents.State({
+      stateName: 'test-state',
+      onEnter: [{
+        eventName: 'test-eventName',
+        condition: iotevents.Expression.fromString('test-eventCondition'),
+      }],
+    }),
+  });
+
+  // THEN
+  Template.fromStack(stack).hasResourceProperties('AWS::IoTEvents::DetectorModel', {
+    EvaluationMethod: 'SERIAL',
+  });
+});
+
+test('can set key', () => {
+  // WHEN
+  new iotevents.DetectorModel(stack, 'MyDetectorModel', {
+    detectorModelDescription: 'test-detector-model-description',
+    key: 'payload.deviceId',
+    initialState: new iotevents.State({
+      stateName: 'test-state',
+      onEnter: [{
+        eventName: 'test-eventName',
+        condition: iotevents.Expression.fromString('test-eventCondition'),
+      }],
+    }),
+  });
+
+  // THEN
+  Template.fromStack(stack).hasResourceProperties('AWS::IoTEvents::DetectorModel', {
+    Key: 'payload.deviceId',
+  });
+});
+
 test('can set multiple events to State', () => {
   // WHEN
   new iotevents.DetectorModel(stack, 'MyDetectorModel', {

packages/@aws-cdk/aws-iotevents/test/integ.detector-model.expected.json

@@ -5,6 +5,9 @@
       "Properties": {
         "InputDefinition": {
           "Attributes": [
+            {
+              "JsonPath": "payload.deviceId"
+            },
             {
               "JsonPath": "payload.temperature"
             }
@@ -70,7 +73,10 @@
             "Arn"
           ]
         },
-        "DetectorModelName": "test-detector-model"
+        "DetectorModelDescription": "test-detector-model-description",
+        "DetectorModelName": "test-detector-model",
+        "EvaluationMethod": "SERIAL",
+        "Key": "payload.deviceId"
       }
     }
   }

packages/@aws-cdk/aws-iotevents/test/integ.detector-model.ts

@@ -7,7 +7,7 @@ class TestStack extends cdk.Stack {
 
     const input = new iotevents.Input(this, 'MyInput', {
       inputName: 'test_input',
-      attributeJsonPaths: ['payload.temperature'],
+      attributeJsonPaths: ['payload.deviceId', 'payload.temperature'],
     });
 
     const onlineState = new iotevents.State({
@@ -27,6 +27,9 @@ class TestStack extends cdk.Stack {
 
     new iotevents.DetectorModel(this, 'MyDetectorModel', {
       detectorModelName: 'test-detector-model',
+      detectorModelDescription: 'test-detector-model-description',
+      evaluationMethod: iotevents.EvaluationMethod.SERIAL,
+      key: 'payload.deviceId',
       initialState: onlineState,
     });
   }