# SolrCloud Layout

    module.exports = headler: 'SolrCloud Atlas Layout', handler: (options) ->
      atlas =  @contexts('@rybajs/metal/atlas')[0].config.ryba.atlas
      @file.download
        source: "#{__dirname}/resources/solr/lang/stopwords_en.txt"
        target: "#{options.atlas_collection_dir}/lang/stopwords_en.txt"
      @file.download
        source: "#{__dirname}/resources/solr/currency.xml"
        target: "#{options.atlas_collection_dir}/currency.xml"
      @file.download
        source: "#{__dirname}/resources/solr/protwords.txt"
        target: "#{options.atlas_collection_dir}/protwords.txt"
      @file.download
        source: "#{__dirname}/resources/solr/schema.xml"
        target: "#{options.atlas_collection_dir}/schema.xml"
      @file.download
        source: "#{__dirname}/resources/solr/solrconfig.xml"
        target: "#{options.atlas_collection_dir}/solrconfig.xml"
      @file.download
        source: "#{__dirname}/resources/solr/stopwords.txt"
        target: "#{options.atlas_collection_dir}/stopwords.txt"
      @file.download
        source: "#{__dirname}/resources/solr/synonyms.txt"
        target: "#{options.atlas_collection_dir}/synonyms.txt"

## Create Atlas Collection in Solr

      @call
        if: [
          @config.host is options.master
          atlas.solr_type is 'cloud_docker'
        ]
        header:'Atlas Collection (cloud_docker)'
      , (options) ->
          container = null
          @wait.execute
            if: @contexts('@rybajs/metal/swarm/manager').length isnt 0
            cmd: docker.wrap options, "ps | grep #{atlas.solr_cluster_name.split('_').join('')} | grep #{options['master']} | awk '{print $1}'"
          @system.execute
            if: @contexts('@rybajs/metal/swarm/manager').length isnt 0
            cmd: docker.wrap options, "ps | grep #{atlas.solr_cluster_name.split('_').join('')} | grep #{options['master']} | awk '{print $1}'"
          , (err, status, stdout) ->
            throw err if err
            container = stdout?.trim()
          @call ->
            @docker.exec
              container: "#{container or options.master_container_runtime_name}"
              cmd: "/usr/solr-cloud/current/bin/solr healthcheck -c vertex_index"
              code_skipped: [1,126]
            @docker.exec
              unless: -> @status -1
              header: 'Create vertex_index collection'
              container: "#{container or options.master_container_runtime_name}"
              cmd: """
              /usr/solr-cloud/current/bin/solr create_collection -c vertex_index \
              -shards #{options.hosts.length}  \
              -replicationFactor #{options.hosts.length-1} \
              -d /atlas_solr
              """
            @docker.exec
              container: "#{container or options.master_container_runtime_name}"
              cmd: "/usr/solr-cloud/current/bin/solr healthcheck -c edge_index"
              code_skipped: [1,126]
            @docker.exec
              unless: -> @status -1
              header: 'Create edge_index collection'
              container: "#{container or options.master_container_runtime_name}"
              cmd: """
              /usr/solr-cloud/current/bin/solr create_collection -c edge_index \
              -shards #{options.hosts.length}  \
              -replicationFactor #{options.hosts.length-1} \
              -d /atlas_solr
              """
            @docker.exec
              container: "#{container or options.master_container_runtime_name}"
              cmd: "/usr/solr-cloud/current/bin/solr healthcheck -c fulltext_index"
              code_skipped: [1,126]
            @docker.exec
              unless: -> @status -1
              header: 'Create fulltext_index collection'
              container: "#{container or options.master_container_runtime_name}"
              cmd: """
              /usr/solr-cloud/current/bin/solr create_collection -c fulltext_index \
              -shards #{options.hosts.length}  \
              -replicationFactor #{options.hosts.length-1} \
              -d /atlas_solr
              """
      @call
        if: [
          @config.host is options.master
          atlas.solr_type is 'cloud' and options.hosts[0] is @config.host
        ]
        header:'Atlas Collection (cloud)'
      , ->
        @connection.wait
          servers: for host in options.hosts
            host: host
            port: @contexts('@rybajs/metal/solr/cloud')[0].config.ryba.solr.cloud.port
        @system.execute
          unless_exec: "/usr/solr-cloud/current/bin/solr healthcheck -c vertex_index"
          cmd: """
          /usr/solr-cloud/current/bin/solr create_collection -c vertex_index \
          -shards #{options.hosts.length}  \
          -replicationFactor #{options.hosts.length} \
          -d #{options.atlas_collection_dir}
          """
        @system.execute
          unless_exec: "/usr/solr-cloud/current/bin/solr healthcheck -c edge_index"
          cmd: """
          /usr/solr-cloud/current/bin/solr create_collection -c edge_index \
          -shards #{options.hosts.length}  \
          -replicationFactor #{options.hosts.length} \
          -d #{options.atlas_collection_dir}
          """
        @system.execute
          unless_exec: "/usr/solr-cloud/current/bin/solr healthcheck -c fulltext_index"
          cmd: """
          /usr/solr-cloud/current/bin/solr create_collection -c fulltext_index \
          -shards #{options.hosts.length}  \
          -replicationFactor #{options.hosts.length} \
          -d #{options.atlas_collection_dir}
          """

## Dependecies

    docker = require '@nikitajs/core/lib/misc/docker'