fix(tests): Fix cleaning project before tests

commercetools · May 31, 2017 · 3c903f6 · 3c903f6
1 parent f6f8382
commit 3c903f6
Show file tree

Hide file tree

Showing 2 changed files with 38 additions and 8 deletions.
diff --git a/src/spec/helper/helper.coffee b/src/spec/helper/helper.coffee
@@ -41,3 +41,30 @@ exports.createReader = (fileType, delimiter = ',', encoding = 'utf-8' ) ->
     csvDelimiter: delimiter,
     encoding: encoding,
     importFormat: fileType,
+
+exports.unpublishAllProducts = (client) ->
+  client.productProjections
+  .where 'published=true'
+  .perPage 200
+  .process (res) ->
+    Promise.map res.body.results, (item) ->
+      client.products
+        .byId item.id
+        .update
+          version: item.version
+          actions: [{
+            action: 'unpublish'
+          }]
+    , { concurrency: 10 }
+
+exports.deleteAllProducts = (client) ->
+  exports.unpublishAllProducts client
+  .then ->
+    client.products
+    .perPage 200
+    .process (res) ->
+      Promise.map res.body.results, (item) ->
+        client.products
+          .byId item.id
+          .delete item.version
+      , { concurrency: 10 }
diff --git a/src/spec/integration/product-type-importer.spec.coffee b/src/spec/integration/product-type-importer.spec.coffee
@@ -4,6 +4,7 @@ Promise = require 'bluebird'
 ProductTypeImporter = require '../../lib/product-type-import'
 {SphereClient} = require 'sphere-node-sdk'
 {ProjectCredentialsConfig} = require 'sphere-node-utils'
+Helper = require '../helper/helper'
 
 errMissingCredentials = 'Missing configuration in env variable named SPHERE_PROJECT_KEY'
 
@@ -75,14 +76,16 @@ describe 'ProductTypeImporter', ->
     # increase timeout so we will have time to delete all previous product types
     this.timeout 60000
 
-    sphereClient.productTypes
-    .perPage(50)
-    .process (res) ->
-      console.log "Deleting old product types", res.body.results.length
-      Promise.map res.body.results, (productType) ->
-        sphereClient.productTypes.byId(productType.id)
-        .delete(productType.version)
-      , concurrency: 10
+    Helper.deleteAllProducts sphereClient
+    .then ->
+      sphereClient.productTypes
+      .perPage(50)
+      .process (res) ->
+        console.log "Deleting old product types", res.body.results.length
+        Promise.map res.body.results, (productType) ->
+          sphereClient.productTypes.byId(productType.id)
+          .delete(productType.version)
+        , concurrency: 10
     .then ->
       console.log "Product types were deleted"
     .catch (err) ->