lib/ej/commands.rb in ej-0.0.5 vs lib/ej/commands.rb in ej-0.0.6

- old
+ new

@@ -6,18 +6,14 @@ require 'ej/core' require 'active_support/core_ext/array' require 'active_support/core_ext/string' require 'logger' -USER_SETTING_FILE = "#{ENV['HOME']}/.ejrc" -CURRENT_SETTING_FILE = ".ejrc" - module Ej class Commands < Thor class_option :index, aliases: '-i', type: :string, default: '_all', desc: 'index' class_option :host, aliases: '-h', type: :string, default: 'localhost', desc: 'host' - class_option :profile, aliases: '-p', type: :string, default: 'default', desc: 'profile by .ejrc' class_option :debug, aliases: '-d', type: :string, default: false, desc: 'debug mode' map '-s' => :search map '-f' => :facet map '-c' => :count map '-I' => :bulk @@ -32,22 +28,10 @@ super(args, options, config) @global_options = config[:shell].base.options @core = Ej::Core.new(@global_options['host'], @global_options['index'], @global_options['debug']) end - desc 'init', 'init' - def init - setting_file_path = "#{ENV['HOME']}/.ejrc" - default = {} - default['default'] = {} - default['default']['host'] = ask("What is default host?", default: 'localhost') - default['default']['port'] = ask("What is default port?", default: 9200) - default['default']['index'] = ask("What is default index?", default: '_all') - File.write(setting_file_path, default.to_yaml) - say("save setting file #{setting_file_path}", :green) - end - desc '-s [lucene query]', 'search' option :type, type: :string, aliases: '-t', default: nil, desc: 'type' option :size, type: :numeric, aliases: '-n', default: 10, desc: 'size' option :from, type: :numeric, aliases: '--from', default: 0, desc: 'from' option :source_only, type: :boolean, aliases: '--so', default: true, desc: 'from' @@ -119,31 +103,31 @@ desc '-a', 'list aliases' def aliases puts_json(@core.aliases) end - desc 'state', 'health' + desc 'state', 'state' def state puts_json(@core.state) end - desc 'indices', 'indices' + desc 'indices', 'show indices summary' def indices puts_json(@core.indices) end - desc 'stats', 'count' + desc 'stats', 'index stats' def stats puts_json(@core.stats) end - desc 'mapping', 'count' + desc 'mapping', 'show mapping' def mapping puts_json(@core.mapping) end - desc 'not_analyzed', 'not_analyzed' + desc 'not_analyzed', 'not analyzed' def not_analyzed json = File.read(File.expand_path('../../../template/not_analyze_template.json', __FILE__)) hash = Yajl::Parser.parse(json) puts_json(@core.put_template('ej_init', hash)) end @@ -155,57 +139,58 @@ def put_routing body = { options['type'] => {"_routing"=>{"required"=>true, "path"=>options['path']}}} puts_json(@core.put_mapping(options['index'], options['type'], body)) end - desc 'put_template', 'put_template' + desc 'put_template', 'put template' def put_template(name) hash = Yajl::Parser.parse(STDIN.read) puts_json(@core.put_template(name, hash)) end - desc 'create_aliases', 'create_aliases' - option :alias, type: :string, aliases: '-a', default: nil, required: true, desc: 'type' - option :indices, type: :array, aliases: '-x', default: nil, required: true, desc: 'type' + desc 'create_aliases', 'create aliases' + option :alias, type: :string, aliases: '-a', default: nil, required: true, desc: 'alias name' + option :indices, type: :array, aliases: '-x', default: nil, required: true, desc: 'index array' def create_aliases @core.create_aliases(options['alias'], options['indices']) end desc 'recovery', 'recovery' def recovery @core.recovery end - desc 'delete', 'delete index' - option :index, aliases: '-i', type: :string, default: nil, required: true, desc: 'profile by .database.yml' + desc 'delete', 'delete' + option :index, aliases: '-i', type: :string, default: nil, required: true, desc: 'index' + option :type, type: :string, aliases: '-t', default: nil, desc: 'type' option :query, type: :string, aliases: '-q', default: nil, desc: 'query' def delete - @core.delete(options['index'], options['query']) + @core.delete(options['index'], options['type'], options['query']) end desc 'delete_template --name [name]', 'delete_template' option :name, type: :string, default: nil, required: true, desc: 'template name' def delete_template @core.delete_template(options['name']) end - desc 'template', 'get template' + desc 'template', 'show template' def template puts_json(@core.template) end - desc 'settings', 'get template' + desc 'settings', 'show template' def settings puts_json(@core.settings) end - desc 'warmer', 'get warmer' + desc 'warmer', 'warmer' def warmer puts_json(@core.warmer) end - desc 'refresh', 'get refresh' + desc 'refresh', 'refresh' def refresh puts_json(@core.refresh) end desc '--j2h', 'json to hash' @@ -217,17 +202,7 @@ def puts_json(object) puts Yajl::Encoder.encode(object) end - def setting - if File.exist?(CURRENT_SETTING_FILE) - return YAML.load_file(CURRENT_SETTING_FILE) - end - - if File.exist?(USER_SETTING_FILE) - return YAML.load_file(USER_SETTING_FILE) - end - return { host: 'localhost', index: '_all', port: 9200 } - end end end