Merge pull request #146 from Cyclonecode/feature/mage2vs-delta-indexer

Add delta indexer

Author: pkarw

README.md

@@ -131,6 +131,14 @@ You can run the following command to execute the full import:
 ``bash
  yarn mage2vs import --store-code=de
  ```
+ 
+## Executing delta indexer
+
+You can use the following command to run a delta indexer for a specific storeview:
+
+```
+yarn mage2vs productsdelta --store-code=de
+```
 
 License
 -------

scripts/mage2vs.js

@@ -36,12 +36,69 @@ function exec(cmd, args, opts) {
     }); 
 
     child.on('error', (error) => {
-      console.error(errror)
+      console.error(error)
       reject(error)
     });     
   })
 }
 
+program
+  .command('productsdelta')
+  .option('--store-code <storeCode>', 'storeCode in multistore setup', null)
+  .option('--adapter <adapter>', 'name of the adapter', 'magento')
+  .option('--partitions <partitions>', 'number of partitions', 1)
+  .option('--partitionSize <partitionSize>', 'size of the partitions', 200)
+  .option('--initQueue <initQueue>', 'use the queue', true)
+  .option('--skus <skus>', 'comma delimited list of SKUs to fetch fresh informations from', '')
+  .option('--removeNonExistent <removeNonExistent>', 'remove non existent products', false)
+  .action((cmd) => {
+    const apiConfig = multiStoreConfig(config.magento2.api, cmd.storeCode)
+    let magentoConfig = {
+      TIME_TO_EXIT: 2000,
+      PRODUCTS_SPECIAL_PRICES: true,
+      MAGENTO_CONSUMER_KEY: apiConfig.consumerKey,
+      MAGENTO_CONSUMER_SECRET: apiConfig.consumerSecret,
+      MAGENTO_ACCESS_TOKEN: apiConfig.accessToken,
+      MAGENTO_ACCESS_TOKEN_SECRET: apiConfig.accessTokenSecret,
+      MAGENTO_STORE_ID: 1,
+      INDEX_META_PATH: '.lastIndex.json',
+      MAGENTO_URL: apiConfig.url,
+      REDIS_HOST: config.redis.host,
+      REDIS_PORT: config.redis.port,
+      INDEX_NAME: config.elasticsearch.indices[0]
+
+    }
+    if (cmd.storeCode) {
+      const storeView = config.storeViews[cmd.storeCode]
+      if (!storeView) {
+        console.error('Wrong storeCode provided - no such store in the config.storeViews[storeCode]', cmd.storeCode)
+        process.exit(-1)
+      } else {
+        magentoConfig.INDEX_NAME = storeView.elasticsearch.index
+        magentoConfig.INDEX_META_PATH = '.lastIndex-' + cmd.storeCode + '.json'
+        magentoConfig.MAGENTO_STORE_ID = storeView.storeId
+      }
+    }
+
+    const env = Object.assign({}, magentoConfig, process.env)  // use process env as well
+    console.log('=== Delta indexer is about to start ===')
+
+    exec('node', [
+      '--harmony',
+      'node_modules/mage2vuestorefront/src/cli.js',
+      'productsdelta',
+      '--adapter=' + cmd.adapter,
+      '--partitions=' + cmd.partitions,
+      '--partitionSize=' + cmd.partitionSize,
+      '--initQueue=' + cmd.initQueue,
+      '--skus=' + cmd.skus,
+      '--removeNonExistent=' + cmd.removeNonExistent
+    ], { env: env, shell: true }).then((res) => {
+
+    })
+
+  })
+
 program
   .command('import')
   .option('--store-code <storeCode>', 'storeCode in multistore setup', null)