Class: Usps::Imis::Query

Inherits:
Object
  • Object
show all
Includes:
Enumerable, Requests
Defined in:
lib/usps/imis/query.rb

Overview

API wrapper for IQA and Business Object Queries

Constant Summary collapse

IQA_PATH =

Endpoint for IQA query requests

'api/Query'

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(api, query_name, page_size: 100, offset: nil, **query_params) ⇒ Query

A new instance of Query

Parameters:

  • api (Api) —

    Parent to use for making requests

  • query_name (String) —

    Full path of the query in IQA, e.g. $/_ABC/Fiander/iMIS_ID

  • page_size (Integer) (defaults to: 100) —

    Number of records to return on each request page

  • offset (Integer) (defaults to: nil) —

    Offset index of records to return on next request page

  • query_params (Hash) —

    Conforms to pattern { param_name => param_value }



51
52
53
54
55
56
57
58
59
60
 
# File 'lib/usps/imis/query.rb', line 51

def initialize(api, query_name, page_size: 100, offset: nil, **query_params)
  @api = api
  @query_name = query_name
  @query_params = query_params
  @page_size = page_size
  @offset = offset
  @count = 0

  logger.debug "URI: #{uri}"
end

Instance Attribute Details

#api ⇒ Object (readonly)

The parent Api object



17
18
19
 
# File 'lib/usps/imis/query.rb', line 17

def api
  @api
end

#count ⇒ Object (readonly)

Count of records processed



37
38
39
 
# File 'lib/usps/imis/query.rb', line 37

def count
  @count
end

#next_page ⇒ Object (readonly)

Whether the current query has a next page



41
42
43
 
# File 'lib/usps/imis/query.rb', line 41

def next_page
  @next_page
end

#offset ⇒ Object

Current offset for paging through the Query



33
34
35
 
# File 'lib/usps/imis/query.rb', line 33

def offset
  @offset
end

#page_size ⇒ Object

Current page size for paging through the Query



29
30
31
 
# File 'lib/usps/imis/query.rb', line 29

def page_size
  @page_size
end

#query_name ⇒ Object (readonly)

Name of the Query to run



21
22
23
 
# File 'lib/usps/imis/query.rb', line 21

def query_name
  @query_name
end

#query_params ⇒ Object (readonly)

Parameters for the Query



25
26
27
 
# File 'lib/usps/imis/query.rb', line 25

def query_params
  @query_params
end

Instance Method Details

#each ⇒ Object

Iterate through all results from the query



64
65
66
67
68
69
70
 
# File 'lib/usps/imis/query.rb', line 64

def each(&)
  logger.info 'Running'

  items = []
  find_each { items << it }
  items.each(&)
end

#fetch ⇒ Object

Fetch a raw query page



113
 
# File 'lib/usps/imis/query.rb', line 113

def fetch = JSON.parse(submit(uri, authorize(http_get)).body)

#fetch_next ⇒ Object

Fetch the next raw query page, and update the current offset



92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
 
# File 'lib/usps/imis/query.rb', line 92

def fetch_next
  return unless page?

  logger.info "Fetching #{query_type} Query page"

  result = fetch

  @count += result['Count'] || 0
  total = result['TotalCount']
  logger.info "  -> #{@count} / #{total} #{'item'.pluralize(total)}"
  logger.debug '  -> Query page data:'
  JSON.pretty_generate(result).split("\n").each { logger.debug "    -> #{it}" }

  @offset = result['NextOffset']
  @next_page = result['HasNext']

  result
end

#find_each ⇒ Object

Iterate through all results from the query, fetching one page at a time



74
75
76
77
78
79
80
81
82
83
84
 
# File 'lib/usps/imis/query.rb', line 74

def find_each(&)
  reset!

  while page?
    fetch_next.tap do |result_page|
      result_page['Items']['$values'].map { it.except('$type') }.each(&)
    end
  end

  nil
end

#instance_variables_to_inspect ⇒ Object

Ruby 3.5 instance variable filter



129
 
# File 'lib/usps/imis/query.rb', line 129

def instance_variables_to_inspect = instance_variables - %i[@api]

#page ⇒ Object

Fetch a filtered query page, and update the current offset



88
 
# File 'lib/usps/imis/query.rb', line 88

def page = fetch_next['Items']['$values'].map { iqa? ? it.except('$type') : Imis::Data[it] }

#reset! ⇒ Object

Reset query paging progress



117
118
119
120
121
122
123
124
125
 
# File 'lib/usps/imis/query.rb', line 117

def reset!
  return if next_page.nil?

  logger.debug 'Resetting progress'

  @count = 0
  @offset = 0
  @next_page = nil
end