Class: Kiba::Extend::Registry::FileRegistry

Inherits:
Object
  • Object
show all
Includes:
Dry::Container::Mixin
Defined in:
lib/kiba/extend/registry/file_registry.rb

Overview

Transforms a file_registry hash into an object that can return source, lookup, or destination config for that file, for passing to jobs

Since:

  • 2.2.0

Defined Under Namespace

Classes: KeyNotRegisteredError

Instance Method Summary collapse

Instance Method Details

#as_destination(filekey, for_job) ⇒ Kiba::Extend::Registry::RegisteredDestination

Parameters:

  • filekey (String, Symbol) —

    file registry key for file to be used as destination

Returns:

Since:

  • 2.2.0



36
37
38
39
40
41
42
43
44
45
46
47
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 36

def as_destination(filekey, for_job)
  if Kiba::Extend.job_verbosity == :debug
    puts "Registering #{filekey} as destination for #{for_job}"
  end
  RegisteredDestination.new(
    key: filekey,
    data: lookup(filekey),
    for_job: for_job
  )
rescue KeyNotRegisteredError => err
  raise KeyNotRegisteredError.new(err.key, :destination)
end

#as_lookup(filekey, for_job) ⇒ Kiba::Extend::Registry::RegisteredLookup

Parameters:

Returns:

Since:

  • 2.2.0



54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 54

def as_lookup(filekey, for_job)
  jobkey = filekey.is_a?(Hash) ? filekey[:jobkey] : filekey
  if Kiba::Extend.job_verbosity == :debug
    puts "Registering #{jobkey} as lookup for #{for_job}"
  end
  RegisteredLookup.new(
    key: filekey,
    data: lookup(jobkey),
    for_job: for_job
  )
rescue KeyNotRegisteredError => err
  raise KeyNotRegisteredError.new(err.key, :lookup)
end

#as_source(filekey, for_job) ⇒ Kiba::Extend::Registry::RegisteredSource

Parameters:

  • filekey (String, Symbol) —

    file registry key for file to be used as a source

Returns:

Since:

  • 2.2.0



71
72
73
74
75
76
77
78
79
80
81
82
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 71

def as_source(filekey, for_job)
  if Kiba::Extend.job_verbosity == :debug
    puts "Registering #{filekey} as source for #{for_job}"
  end
  RegisteredSource.new(
    key: filekey,
    data: lookup(filekey),
    for_job: for_job
  )
rescue KeyNotRegisteredError => err
  raise KeyNotRegisteredError.new(err.key, :source)
end

#entries ⇒ Array<Hash,FileRegistryEntry>

TODO:

Refactor this away, if possible

Note:

In general, avoid this. Prior to registry finalization, it will return Hashes. After, it will return FileRegistryEntry objects. This makes the results unpredicatable to work with.

Returns:

Since:

  • 2.2.0



89
90
91
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 89

def entries
  @entries ||= populate_entries
end

#entry_objs ⇒ Array<FileRegistryEntry>

Returns:

Since:

  • 2.2.0



94
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 94

def entry_objs = _container.values.map(&:item)

#finalize ⇒ Object

Convenience method combining the steps of transforming initial registry entry hashes into FileRegistryEntry objects, and then making the registry immutable for the rest of the application’s run. :freeze is from dry-container.

Since:

  • 2.2.0



125
126
127
128
129
130
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 125

def finalize
  transform
  @frozen = true
  puts "Registry is frozen!" if Kiba::Extend.job_verbosity == :debug
  freeze
end

#replace_entries(arr) ⇒ Object

Parameters:

  • arr (Array<Hash>)

Since:

  • 2.2.0



97
98
99
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 97

def replace_entries(arr)
  @entries = arr
end

#replace_entry_x_with_entry_y(x:, y:) ⇒ Object

Note:

This method only works before #freeze or #finalize are called on the FileRegistry.

Parameters:

  • x (String) —

    job_key to replace; this job_key will be retained, but its entry is deleted and replaced by the entry for job_key y

  • y (String) —

    job_key whose entry is assigned to job_key x; this job_key is removed

Since:

  • 2.2.0



107
108
109
110
111
112
113
114
115
116
117
118
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 107

def replace_entry_x_with_entry_y(x:, y:)
  if @frozen
    return self && warn("#{Kiba::Extend.warning_label}: Cannot modify "\
                        "frozen registry (replace #{x} with #{y})")
  end

  _container.delete(x.to_s)
  entry = _container[y.to_s]
  _container.delete(y.to_s)
  _container[x.to_s] = entry
  self
end

#transform ⇒ Object

Transforms registered file hashes into Kiba::Extend::Registry::FileRegistryEntry objects

Since:

  • 2.2.0



134
135
136
137
138
139
140
141
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 134

def transform
  if Kiba::Extend.job_verbosity == :debug
    puts "Transforming registered jobs into FileRegistryEntries"
  end

  each { |key, val| decorate(key) { FileRegistryEntry.new(key, val) } }
  verify_paths
end

#valid? ⇒ Boolean

Returns:

  • (Boolean)

Since:

  • 2.2.0



143
144
145
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 143

def valid?
  validator.valid?
end

#warnings? ⇒ Boolean

Returns:

  • (Boolean)

Since:

  • 2.2.0



147
148
149
 
# File 'lib/kiba/extend/registry/file_registry.rb', line 147

def warnings?
  validator.warnings?
end