gem 'aliyun_open_search'

# or

gem 'aliyun_open_search', github: "LcpMarvel/aliyun_open_search"

ACCESS_KEY_ID: "your access_key_id"
ACCESS_KEY_SECRET: "your access_key_secret"

OPEN_SEARCH_HOST: "http://opensearch-cn-hangzhou.aliyuncs.com"

# app_name 是阿里云 应用名称
# params 的内容按照阿里云文档中的约定组织
require "aliyun_open_search"

params =  {
            action: :push,
            table_name: :cars,
            items: [
              {
                "cmd": "update",
                "timestamp": 1_420_070_400_010,
                "fields": {
                  "id": "121139313135",
                  "styl_name": "aodi",
                  "acquirer_id": "1"
                }
              },
              {
                "cmd": "update",
                "timestamp": 1_420_070_400_020,
                "fields": {
                  "id": "1211391233136",
                  "styl_name": "baoma",
                  "acquirer_id": "1"
                }
              },
              {
                "cmd": "delete",
                "fields": {
                  "id": "3"
                }
              }
            ]
          }

response = AliyunOpenSearch::Syncs.new(app_name).execute(params)
response_body = JSON.load(response.body)

require "aliyun_open_search"

# index_names 是阿里云 应用名称, 可以多个
# params 的内容按照阿里云文档中的约定组织

params =  {
            query: "config=start:0,hit:10,format=fulljson&&query=default:'的'&&filter=create_timestamp>1423000000&&sort=+type;-RANK&fetch_fields=id;title;body;url;type;create_timestamp",
            first_formula_name: "first_bbs",
            formula: "second_bbs",
            summary: "summary_snipped:1,summary_field:title,summary_element:high,summary_len:32,summary_ellipsis:...;summary_snipped:2,summary_field:body,summary_element:high,summary_len:60,summary_ellipsis:..."
          }
# 更多例子

# 1. 
# params = {
#   query: [
#     [
#       "query=default:'#{value}'",
#       "cars_company_id:'#{value}'",
#       "cars_shop_id:'#{value}'",
#       "default:'#{value}'",
#       "configuration:'#{value}'",
#       "user_info:'#{value}'",
#       "authority_roles:'#{value}'",
#     ].join(" OR "),
# 
#     "config=start:#{page},hit:#{params[:per_page]}"
#   ],
#   fetch_fields: :id
# }

# 2. 
# start = per_page * (current_page - 1)
# query = [
#   "default:'#{@value}'",
#   "configuration:'#{@value}'",
#   "user_info:'#{@value}'",
#   "authority_roles:'#{@value}'"
# ].join(" OR ")

# query = "query=(" + query + ") AND cars_company_id:'#{@company_id}'"

# params = {
#   query: [
#     query,
#     "config=start:#{start},hit:#{@per_page}"
#   ],
#   fetch_fields: :id
# }

AliyunOpenSearch::Search.new("test", "test2", "test3").execute(params)

  
  AliyunOpenSearch.request_method = "POST" # 默认是 GET, 大写

  # custom_params 的内容按照阿里云文档中的约定组织
  custom_params = {
    "action" => "push",
    "table_name" => "cars",
    "items" => [
      {
        "cmd": "update",
        "timestamp": 1_420_070_400_010,
        "fields": {
          "id": "121139313135",
          "styl_name": "aodi",
          "acquirer_id": "1"
        }
      }
    ].to_json
  }

  AliyunOpenSearch::Base.signature(
    AliyunOpenSearch::Base.basic_params.merge!(custom_params)
  )

require "aliyun_open_search"

scan_service = AliyunOpenSearch::Scan.new("test")
scan_service = AliyunOpenSearch::Scan.new(["test", "test2"])

# AliyunOpenSearch::Scan.new(
#   ["test", "test2"], 

# 配置: 
#   query: "query=default:'abc'", # 默认所有
#   hit: "400", # 默认500, 范围 0~500
#   scroll: "1w", 
#   # 用来表示scroll请求的有效期，默认时间单位为ms, 也可以用1m表示1min
#   # 支持的时间单位包括：w=Week, d=Day, h=Hour, m=minute, s=second
#   format: "xml" # 默认 JSON
# )

scan_service.execute # 获取第一页
scan_service.result # 获取结果

# 下一页
scan_service.execute # 获取第二页
scan_service.result # 获取结果

require "aliyun_open_search"

# index_names 是阿里云应用名称，只能一个
# params 的内容按照阿里云文档中的约定组织

params =  {
            query: "test",
            suggest_name: "test_suggest",
            hit: 10
          }

AliyunOpenSearch::Suggest.new("test_suggest").execute(params)

# RSpec

# spec_helper.rb
config.before(:each) do
  @aliyun_open_search_syncs = allow_any_instance_of(AliyunOpenSearch::Syncs)
                              .to receive(:execute).and_return(true)
end

# 需要真正发出请求的时候
allow_any_instance_of(AliyunOpenSearch::Syncs).to receive(:execute).and_call_original