feat(pipelineFunctions): Added the sync options

sid88in · Jul 8, 2022 · a2bb44a · a2bb44a
1 parent 7d5c65d
commit a2bb44a
Show file tree

Hide file tree

Showing 2 changed files with 81 additions and 0 deletions.
diff --git a/index.test.js b/index.test.js
@@ -1619,6 +1619,68 @@ describe('SyncConfig', () => {
     expect(result).toMatchSnapshot();
   });
 
+  test('Pipeline Resolver Function uses default', () => {
+    const apiConfig = {
+      ...config,
+      functionConfigurationsLocation: 'mapping-templates',
+      functionConfigurations: [
+        {
+          dataSource: 'ds',
+          name: 'pipeline',
+          request: 'request.vtl',
+          response: 'response.vtl',
+          sync: true,
+        },
+      ],
+    };
+
+    const apiResources = plugin.getFunctionConfigurationResources(apiConfig);
+    expect(
+      apiResources.GraphQlFunctionConfigurationpipeline.Properties,
+    ).toHaveProperty('SyncConfig');
+    expect(
+      apiResources.GraphQlFunctionConfigurationpipeline.Properties.SyncConfig,
+    ).toEqual({
+      ConflictDetection: 'VERSION',
+    });
+  });
+
+  test('Pipeline Resolver Function uses advanced config', () => {
+    const apiConfig = {
+      ...config,
+      functionConfigurationsLocation: 'mapping-templates',
+      functionConfigurations: [
+        {
+          dataSource: 'ds',
+          name: 'pipeline',
+          request: 'request.vtl',
+          response: 'response.vtl',
+          sync: {
+            conflictDetection: 'VERSION',
+            conflictHandler: 'LAMBDA',
+            functionName: 'syncLambda',
+          },
+        },
+      ],
+    };
+
+    const apiResources = plugin.getFunctionConfigurationResources(apiConfig);
+    expect(
+      apiResources.GraphQlFunctionConfigurationpipeline.Properties,
+    ).toHaveProperty('SyncConfig');
+    expect(
+      apiResources.GraphQlFunctionConfigurationpipeline.Properties.SyncConfig,
+    ).toEqual({
+      ConflictDetection: 'VERSION',
+      ConflictHandler: 'LAMBDA',
+      LambdaConflictHandlerConfig: {
+        LambdaConflictHandlerArn: {
+          'Fn::GetAtt': ['SyncLambdaLambdaFunction', 'Arn'],
+        },
+      },
+    });
+  });
+
   test('Uses lambda config', () => {
     Object.assign(config, {
       mappingTemplates: [

diff --git a/src/index.js b/src/index.js
@@ -1240,6 +1240,25 @@ class ServerlessAppsyncPlugin {
         FunctionVersion: '2018-05-29',
       };
 
+      if (tpl.sync === true) {
+        // Use defaults
+        Properties.SyncConfig = {
+          ConflictDetection: 'VERSION',
+        };
+      } else if (typeof tpl.sync === 'object') {
+        Properties.SyncConfig = {
+          ConflictDetection: tpl.sync.conflictDetection,
+          ConflictHandler: tpl.sync.conflictHandler,
+          ...(tpl.sync.conflictHandler === 'LAMBDA'
+            ? {
+                LambdaConflictHandlerConfig: {
+                  LambdaConflictHandlerArn: this.getLambdaArn(tpl.sync),
+                },
+              }
+            : {}),
+        };
+      }
+
       if (tpl.maxBatchSize) {
         Properties.MaxBatchSize = tpl.maxBatchSize;
       }