Class: AliyunOpenSearch::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/aliyun_open_search/base.rb

Direct Known Subclasses

Search, Syncs

Class Attribute Summary collapse

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initializeBase



12
13
14
15
16
17
18
19
20
21
# File 'lib/aliyun_open_search/base.rb', line 12

def initialize
  @basic_params = {
    "Version" => "v2",
    "AccessKeyId" => ENV.fetch("ACCESS_KEY_ID"),
    "SignatureMethod" => "HMAC-SHA1",
    "Timestamp" => Time.now.utc.iso8601,
    "SignatureVersion" => "1.0",
    "SignatureNonce" => signature_nonce
  }
end

Class Attribute Details

.request_methodObject

Returns the value of attribute request_method.



9
10
11
# File 'lib/aliyun_open_search/base.rb', line 9

def request_method
  @request_method
end

Instance Attribute Details

#base_urlObject (readonly)

Returns the value of attribute base_url.



6
7
8
# File 'lib/aliyun_open_search/base.rb', line 6

def base_url
  @base_url
end

#basic_paramsObject (readonly)

Returns the value of attribute basic_params.



6
7
8
# File 'lib/aliyun_open_search/base.rb', line 6

def basic_params
  @basic_params
end

Class Method Details

.signature(params) ⇒ Object



38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
# File 'lib/aliyun_open_search/base.rb', line 38

def self.signature(params)
  params =  params.sort_by { |k, _v| k.to_s }
            .map do |arr|
    str = if arr[1].is_a?(String) || arr[1].is_a?(Fixnum)
            arr[1].to_s
          else
            arr[1].to_json
          end

    "#{arr[0]}=#{Base.escape(str)}"
  end.join("&")

  Base64.encode64(
    OpenSSL::HMAC.digest(
      OpenSSL::Digest.new("sha1"),
      "#{ENV["ACCESS_KEY_SECRET"]}&",
      request_method + "&" + CGI.escape("/") + "&" + Base.escape(params)
    )
  ).strip
end

Instance Method Details

#uri(special_base_url = nil, params) ⇒ Object



23
24
25
26
27
28
29
30
31
32
# File 'lib/aliyun_open_search/base.rb', line 23

def uri(special_base_url = nil, params)
  encoded_params = params.inject([]) do |arr, (k, v)|
    arr << "#{k}=#{Base.escape(v)}"
  end.join("&")

  url = (special_base_url || base_url) + "?" + encoded_params
  Rails.logger.info url if defined?(Rails)

  URI(url)
end