fix: unit test for StartingPositionTimestamp

serverless · Oct 27, 2022 · cebb796 · cebb796
1 parent 7e829f7
commit cebb796
Showing 1 changed file with 25 additions and 25 deletions.
diff --git a/test/unit/lib/plugins/aws/package/compile/events/kafka.test.js b/test/unit/lib/plugins/aws/package/compile/events/kafka.test.js
@@ -536,7 +536,7 @@ describe('test/unit/lib/plugins/aws/package/compile/events/kafka.test.js', () =>
     describe('startingPositionTimestamp', () => {
       it('should fail to compile EventSourceMapping resource properties for startingPosition AT_TIMESTAMP with no startingPositionTimestamp', async () => {
         await expect(
-          await runServerless({
+          runServerless({
             fixture: 'function',
             configExt: {
               functions: {
@@ -561,35 +561,35 @@ describe('test/unit/lib/plugins/aws/package/compile/events/kafka.test.js', () =>
           code: 'FUNCTION_KAFKA_STARTING_POSITION_TIMESTAMP_INVALID',
         });
       });
-    });
 
-    it('should correctly compile EventSourceMapping resource properties for startingPosition', async () => {
-      const { awsNaming, cfTemplate } = await runServerless({
-        fixture: 'function',
-        configExt: {
-          functions: {
-            basic: {
-              role: { 'Fn::ImportValue': 'MyImportedRole' },
-              events: [
-                {
-                  kafka: {
-                    topic,
-                    bootstrapServers: ['abc.xyz:9092'],
-                    accessConfigurations: { saslScram256Auth: saslScram256AuthArn },
-                    startingPosition: 'AT_TIMESTAMP',
-                    startingPositionTimestamp: 123,
+      it('should correctly compile EventSourceMapping resource properties for startingPosition', async () => {
+        const { awsNaming, cfTemplate } = await runServerless({
+          fixture: 'function',
+          configExt: {
+            functions: {
+              basic: {
+                role: { 'Fn::ImportValue': 'MyImportedRole' },
+                events: [
+                  {
+                    kafka: {
+                      topic,
+                      bootstrapServers: ['abc.xyz:9092'],
+                      accessConfigurations: { saslScram256Auth: saslScram256AuthArn },
+                      startingPosition: 'AT_TIMESTAMP',
+                      startingPositionTimestamp: 123,
+                    },
                   },
-                },
-              ],
+                ],
+              },
             },
           },
-        },
-        command: 'package',
-      });
+          command: 'package',
+        });
 
-      const eventSourceMappingResource =
-        cfTemplate.Resources[awsNaming.getKafkaEventLogicalId('basic', 'TestingTopic')];
-      expect(eventSourceMappingResource.Properties.StartingPositionTimestamp).to.deep.equal(123);
+        const eventSourceMappingResource =
+          cfTemplate.Resources[awsNaming.getKafkaEventLogicalId('basic', 'TestingTopic')];
+        expect(eventSourceMappingResource.Properties.StartingPositionTimestamp).to.deep.equal(123);
+      });
     });
 
     it('should not add dependsOn for imported role', async () => {