sphereio/sphere-product-type-json-generator

_ = require 'underscore'
path = require 'path'
Promise = require 'bluebird'
ProductTypeImport = require 'sphere-product-type-import'
{ExtendedLogger, ProjectCredentialsConfig} = require 'sphere-node-utils'
package_json = require '../package.json'

class ProductTypeImporter

  ###
  Prepare for importing, initialize used modules
  ###
  init: (argv) ->
    logPath = path.join(argv.logDir || '.', package_json.name + ".log")
    @logOptions =
      name: "#{package_json.name}-#{package_json.version}"
      silent: !! argv.logSilent
      streams: [
        { level: 'error', stream: process.stderr }
        { level: argv.logLevel || 'info', path: logPath }
      ]

    @logger = new ExtendedLogger
      additionalFields:
        'project_key': argv.projectKey
      logConfig: @logOptions
    if argv.logSilent
      @logger.bunyanLogger.trace = -> # noop
      @logger.bunyanLogger.debug = -> # noop

    @_ensureCredentials argv
    .then (credentials) =>
      @sphereImporter = new ProductTypeImport.default(@logger, credentials)
      Promise.resolve @

  ###
  Create sphere credentials config from command line arguments
  ###
  _ensureCredentials: (argv) ->
    credentialsPromise = null

    if argv.accessToken
      credentialsPromise = Promise.resolve
        config:
          project_key: argv.projectKey
        access_token: argv.accessToken
    else
      credentialsPromise = ProjectCredentialsConfig.create()
      .then (credentials) ->
        config = credentials.enrichCredentials
          project_key: argv.projectKey

        if(argv.clientId)
          config.client_id = argv.clientId

        if(argv.clientSecret)
          config.client_secret = argv.clientSecret
        config: config

    credentialsPromise.then (credentials) ->
      options = _.extend credentials,
        timeout: argv.timeout
        user_agent: "#{package_json.name} - #{package_json.version}"

      options.host = argv.sphereHost if argv.sphereHost
      options.protocol = argv.sphereProtocol if argv.sphereProtocol
      if argv.sphereAuthHost
        options.oauth_host = argv.sphereAuthHost
        options.rejectUnauthorized = false
      options.oauth_protocol = argv.sphereAuthProtocol if argv.sphereAuthProtocol
      sphereClientConfig: options

  ###
  Import product types using sphere product import tool
  ###
  import: (data) ->
    console.log "Importing product types to sphere"
    Promise.map data.productTypes, (productType) =>
      console.log "Importing product type with name:", productType.name
      @sphereImporter.importProductType productType
      .then (res) ->
        console.log "Imported product type", res.name
        Promise.resolve res
      .catch (e) ->
        console.error "Oops, something went wrong when importing product type #{productType.name} to sphere"
        Promise.reject e
    , concurrency: 5
module.exports = ProductTypeImporter