Class: InventoryRefresh::InventoryCollection::DataStorage

Inherits:
Object
  • Object
show all
Defined in:
lib/inventory_refresh/inventory_collection/data_storage.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(inventory_collection, secondary_refs) ⇒ DataStorage

Returns a new instance of DataStorage.

Parameters:

  • inventory_collection (InventoryRefresh::InventoryCollection) —

    InventoryCollection object we want the storage for

  • secondary_refs (Hash) —

    Secondary_refs in format => [:attribute1, :attribute2]


31
32
33
34
35
36
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 31

def initialize(inventory_collection, secondary_refs)
  @inventory_collection = inventory_collection
  @data                 = []

  @index_proxy = InventoryRefresh::InventoryCollection::Index::Proxy.new(inventory_collection, secondary_refs)
end

Instance Attribute Details

#data ⇒ Array<InventoryObject>

Returns objects of the InventoryCollection in an Array.

Returns:

  • (Array<InventoryObject>) —

    objects of the InventoryCollection in an Array


7
8
9
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 7

def data
  @data
end

#index_proxy ⇒ Object (readonly)

Returns the value of attribute index_proxy.


9
10
11
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 9

def index_proxy
  @index_proxy
end

#inventory_collection ⇒ Object (readonly)

Returns the value of attribute inventory_collection.


9
10
11
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 9

def inventory_collection
  @inventory_collection
end

Instance Method Details

#<<(inventory_object) ⇒ InventoryRefresh::InventoryCollection Also known as: push

Adds passed InventoryObject into the InventoryCollection’s storage

Parameters:

Returns:


42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 42

def <<(inventory_object)
  if inventory_object.manager_uuid.present? && !primary_index.find(inventory_object.manager_uuid)
    data << inventory_object

    # TODO(lsmola) Maybe we do not need the secondary indexes here?
    # Maybe we should index it like LocalDb indexes, on demand, and storing what was
    # indexed? Maybe we should allow only lazy access and no direct find from a parser. Since for streaming
    # refresh, things won't be parsed together and no full state will be taken.
    build_primary_index_for(inventory_object)
    build_secondary_indexes_for(inventory_object)
  end
  inventory_collection
end

#build(hash) ⇒ InventoryRefresh::InventoryObject

Finds of builds a new InventoryObject. By building it, we also put in into the InventoryCollection’s storage.

Parameters:

  • hash (Hash) —

    Hash that needs to contain attributes defined in :manager_ref of the InventoryCollection

Returns:


87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 87

def build(hash)
  hash, uuid, inventory_object = primary_index_scan(hash)

  # Return InventoryObject if found in primary index
  return inventory_object unless inventory_object.nil?

  # We will take existing skeletal record, so we don't duplicate references for saving. We can have duplicated
  # reference from local_db index, (if we are using .find in parser, that causes N+1 db queries), but that is ok,
  # since that one is not being saved.
  inventory_object = skeletal_primary_index.delete(uuid)

  # We want to update the skeletal record with actual data
  inventory_object&.assign_attributes(hash)

  # Build the InventoryObject
  inventory_object ||= new_inventory_object(enrich_data(hash))

  # Store new InventoryObject and return it
  push(inventory_object)
  inventory_object
end

#build_partial(hash) ⇒ InventoryRefresh::InventoryObject

Finds of builds a new InventoryObject with incomplete data.

Parameters:

  • hash (Hash) —

    Hash that needs to contain attributes defined in :manager_ref of the InventoryCollection

Returns:


114
115
116
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 114

def build_partial(hash)
  skeletal_primary_index.build(hash)
end

#find_in_data(hash) ⇒ InventoryRefresh::InventoryObject

Finds InventoryObject.

Parameters:

  • hash (Hash) —

    Hash that needs to contain attributes defined in :manager_ref of the InventoryCollection

Returns:


77
78
79
80
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 77

def find_in_data(hash)
  _hash, _uuid, inventory_object = primary_index_scan(hash)
  inventory_object
end

#find_or_build(manager_uuid) ⇒ InventoryRefresh::InventoryObject

Finds of builds a new InventoryObject. By building it, we also put in into the InventoryCollection’s storage.

Parameters:

  • manager_uuid (String) —

    manager_uuid of the InventoryObject

Returns:


62
63
64
65
66
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 62

def find_or_build(manager_uuid)
  raise "The uuid consists of #{manager_ref.size} attributes, please find_or_build_by method" if manager_ref.size > 1

  find_or_build_by(manager_ref.first => manager_uuid)
end

#find_or_build_by(hash) ⇒ InventoryRefresh::InventoryObject

Finds of builds a new InventoryObject. By building it, we also put in into the InventoryCollection’s storage.

Parameters:

  • hash (Hash) —

    Hash that needs to contain attributes defined in :manager_ref of the InventoryCollection

Returns:


69
70
71
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 69

def find_or_build_by(hash)
  build(hash)
end

#from_hash(inventory_objects_data, available_inventory_collections) ⇒ Object 


129
130
131
132
133
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 129

def from_hash(inventory_objects_data, available_inventory_collections)
  InventoryRefresh::InventoryCollection::Serialization
    .new(inventory_collection)
    .from_hash(inventory_objects_data, available_inventory_collections)
end

#to_a ⇒ Array<InventoryRefresh::InventoryObject>

Returns array of built InventoryObject objects

Returns:


121
122
123
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 121

def to_a
  data
end

#to_hash ⇒ Object 


125
126
127
 
# File 'lib/inventory_refresh/inventory_collection/data_storage.rb', line 125

def to_hash
  InventoryRefresh::InventoryCollection::Serialization.new(inventory_collection).to_hash
end