Class: Dina::SearchConnection

Inherits:
Object
  • Object
show all
Defined in:
lib/dina/search/search_connection.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) {|_self| ... } ⇒ SearchConnection

Returns a new instance of SearchConnection.

Yields:

  • (_self)

Yield Parameters:



8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/dina/search/search_connection.rb', line 8

def initialize(options = {})
  site = options.fetch(:site)
  connection_options = options.slice(:proxy, :ssl, :request, :headers, :params)
  adapter_options = Array(options.fetch(:adapter, Faraday.default_adapter))

  @faraday = Faraday.new(site, connection_options) do |builder|
    builder.request :json
    builder.response :json
    builder.adapter(*adapter_options)
  end
  yield(self) if block_given?
end

Instance Attribute Details

#faraday ⇒ Object (readonly)

Returns the value of attribute faraday.



6
7
8
 
# File 'lib/dina/search/search_connection.rb', line 6

def faraday
  @faraday
end

Instance Method Details

#custom_headers ⇒ Object 



31
32
33
 
# File 'lib/dina/search/search_connection.rb', line 31

def custom_headers
  { content_type: "application/json", authorization: Dina.header }
end

#index_name(index:) ⇒ String

Sets the search index name

Parameters:

  • index (String) —

    the search index; options are “agent”, “material_sample”, “object_store”

Returns:

  • (String) —

    the internally-recognized search index name



26
27
28
29
 
# File 'lib/dina/search/search_connection.rb', line 26

def index_name(index:)
  return nil if !index
  "dina_#{index}_index"
end

#run(request_method, path, params: nil, headers: {}, body: nil) ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
# File 'lib/dina/search/search_connection.rb', line 35

def run(request_method, path, params: nil, headers: {}, body: nil)
  path.slice!("/execute")
  if params && params.has_key?(:index)
    params.merge!(indexName: index_name(index: params[:index]))
  elsif body && body.has_key?(:index)
    params = { indexName: index_name(index: body[:index]) }
  end
  payload = JSON.generate(body[:payload]) rescue ""

  response = faraday.run_request(request_method, path, body, headers) do |request|
    request.params.update(params) if params
    request.headers = custom_headers
    request.body = payload
  end

  attributes = response.body.dup
  meta = {}
  if attributes.has_key?("hits")
    #TODO: does not work with SearchAutoComplete because response is different from Search
    meta["count"] = attributes["hits"]["total"]["value"] rescue 0
  elsif attributes.has_key?("count")
    meta["count"] = attributes["count"]
  elsif attributes.has_key?("attributes")
    meta = attributes
  end
  response.body["meta"] = meta
  response.body["errors"] = []
  response.body["data"] = attributes["hits"]["hits"].map{|d| d["_source"]["data"]} rescue []
  response
end

#use(middleware, *args, &block) ⇒ Object 



66
67
68
 
# File 'lib/dina/search/search_connection.rb', line 66

def use(middleware, *args, &block)
  return if faraday.builder.locked?
end