Module: HttpStore::Helpers::Storable

Included in:
Client, Middleware::RequestLog
Defined in:
lib/http_store/helpers/storable.rb

Constant Summary collapse

STRING_LIMIT_SIZE = 
1000
TEXT_LIMIT_SIZE = 
10000

Instance Method Summary collapse

Instance Method Details

#gen_storable_meta ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/http_store/helpers/storable.rb', line 47

def gen_storable_meta
  @meta.slice(*HttpStore::STORE_KEYS).map do |k, v|
    storable_v = storable(v)

    begin
      storable_v = storable_v.to_json[0..TEXT_LIMIT_SIZE] if v.is_a?(Hash) || v.is_a?(Array)

      [k, storable_v]
    rescue JSON::GeneratorError
      [k, storable_v.to_s[0..TEXT_LIMIT_SIZE]]
    end
  end.to_h
end

#json_safe_parse(str) ⇒ Object 



87
88
89
 
# File 'lib/http_store/helpers/storable.rb', line 87

def json_safe_parse(str)
  JSON.parse(str) rescue str
end

#load_storeable_record ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/http_store/helpers/storable.rb', line 14

def load_storeable_record
  return if storeable_record.nil?

  attrs =
    storeable_record.attributes.slice(*HttpStore::ALL_KEYS).map do |k, v|
      [k, v.is_a?(String) ? json_safe_parse(v) : v]
    end.to_h

  @meta.reverse_merge! attrs
  @meta.parent_id = storeable_record.id
end

#storable(value) ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/http_store/helpers/storable.rb', line 61

def storable(value)
  case value
  when Hash
    value.map { |k, v| [k, storable(v)] }.to_h
  when Array
    value.map { |v| storable(v) }
  when String
    json = JSON.parse(value) rescue nil
    json ? storable(json) : storable_string(value)
  when TrueClass, FalseClass, NilClass, Numeric
    value
  else
    storable_string(value.to_s)
  end
end

#storable_string(str) ⇒ Object 



77
78
79
80
81
82
83
84
85
 
# File 'lib/http_store/helpers/storable.rb', line 77

def storable_string(str)
  str = str.dup.force_encoding("UTF-8")
  raise EncodingError unless str.encoding.name == 'UTF-8'
  raise EncodingError unless str.valid_encoding?

  str.length > STRING_LIMIT_SIZE ? { digest: Digest::SHA1.hexdigest(str), origin: str[0..STRING_LIMIT_SIZE] } : str
rescue EncodingError
  { digest: Digest::SHA1.hexdigest(str) }
end

#store_class ⇒ Object 



39
40
41
 
# File 'lib/http_store/helpers/storable.rb', line 39

def store_class
  @store_class ||= HttpStore.config.store_class.to_s.constantize
end

#store_request ⇒ Object

you can rewrite this callback, to store the request



27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/http_store/helpers/storable.rb', line 27

def store_request
  return unless HttpStore.config.store_enable

  if HttpStore.config.store_job_enable
    @meta.parent_id = storeable_record.id if use_cache?
    HttpStore::Job::HttpLogStoreJob.perform_later(gen_storable_meta)
  else
    @storeable_record = store_class.new(gen_storable_meta)
    @storeable_record.save!
  end
end

#storeable_record ⇒ Object 



7
8
9
10
11
12
 
# File 'lib/http_store/helpers/storable.rb', line 7

def storeable_record
  return unless HttpStore.config.store_enable

  expired_time      = Time.current - HttpStore.config.store_time
  @storeable_record ||= store_class.where('created_at > ?', expired_time).where(request_digest: @meta.request_digest, cache_response: true).order(id: :desc).first
end

#use_cache? ⇒ Boolean

Returns:

  • (Boolean) 


43
44
45
 
# File 'lib/http_store/helpers/storable.rb', line 43

def use_cache?
  @use_cache ||= !@meta.force && storeable_record.present?
end