Class: RemoteFiles::Configuration

Inherits:
Object
  • Object
show all
Defined in:
lib/remote_files/configuration.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, config = {}) ⇒ Configuration

Returns a new instance of Configuration.



7
8
9
10
11
12
 
# File 'lib/remote_files/configuration.rb', line 7

def initialize(name, config = {})
  @name       = name
  @stores     = []
  @stores_map = {}
  from_hash(config)
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



5
6
7
 
# File 'lib/remote_files/configuration.rb', line 5

def name
  @name
end

Instance Method Details

#add_store(store_identifier, options = {}, &block) ⇒ Object 



55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/remote_files/configuration.rb', line 55

def add_store(store_identifier, options = {}, &block)
  store = (options[:class] || FogStore).new(store_identifier)
  block.call(store) if block_given?

  if options[:primary]
    @stores.unshift(store)
  else
    @stores << store
  end

  @stores_map[store_identifier] = store
end

#clear ⇒ Object 



22
23
24
25
 
# File 'lib/remote_files/configuration.rb', line 22

def clear
  @stores.clear
  @stores_map.clear
end

#configured? ⇒ Boolean

Returns:

  • (Boolean) 


68
69
70
 
# File 'lib/remote_files/configuration.rb', line 68

def configured?
  !@stores.empty?
end

#delete!(file) ⇒ Object 



114
115
116
 
# File 'lib/remote_files/configuration.rb', line 114

def delete!(file)
  RemoteFiles.delete_file(file)
end

#delete_now!(file) ⇒ Object 



118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
 
# File 'lib/remote_files/configuration.rb', line 118

def delete_now!(file)
  exceptions = []
  file.stored_in.each do |store_identifier|
    store = lookup_store(store_identifier)
    begin
      store.delete!(file.identifier)
    rescue NotFoundError => e
      exceptions << e
    end
  end

  if exceptions.size == file.stored_in.size # they all failed
    raise exceptions.first
  end

  true
end

#file_from_url(url, options = {}) ⇒ Object 



143
144
145
146
147
148
149
150
 
# File 'lib/remote_files/configuration.rb', line 143

def file_from_url(url, options = {})
  stores.each do |store|
    file = store.file_from_url(url, options.merge(:configuration => name))
    return file if file
  end

  nil
end

#from_hash(hash) ⇒ Object 



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
 
# File 'lib/remote_files/configuration.rb', line 27

def from_hash(hash)
  hash.each do |store_identifier, config|
    #symbolize_keys!
    cfg = {}
    config.each { |name, value| cfg[name.to_sym] = config[name] }
    config = cfg

    #camelize
    type = config[:type].gsub(/\/(.?)/) { "::#{$1.upcase}" }.gsub(/(?:^|_)(.)/) { $1.upcase } + 'Store'

    klass = RemoteFiles.const_get(type) rescue nil
    unless klass
      require "remote_files/#{config[:type]}_store"
      klass = RemoteFiles.const_get(type)
    end

    config.delete(:type)

    add_store(store_identifier.to_sym, :class => klass, :primary => !!config.delete(:primary)) do |store|
      config.each do |name, value|
        store[name] = value
      end
    end
  end

  self
end

#logger ⇒ Object 



18
19
20
 
# File 'lib/remote_files/configuration.rb', line 18

def logger
  @logger ||= RemoteFiles.logger
end

#logger=(logger) ⇒ Object 



14
15
16
 
# File 'lib/remote_files/configuration.rb', line 14

def logger=(logger)
  @logger = logger
end

#lookup_store(store_identifier) ⇒ Object 



77
78
79
 
# File 'lib/remote_files/configuration.rb', line 77

def lookup_store(store_identifier)
  @stores_map[store_identifier.to_sym]
end

#primary_store ⇒ Object 



81
82
83
 
# File 'lib/remote_files/configuration.rb', line 81

def primary_store
  stores.first
end

#store!(file) ⇒ Object 



106
107
108
109
110
111
112
 
# File 'lib/remote_files/configuration.rb', line 106

def store!(file)
  store_once!(file) unless file.stored?

  RemoteFiles.synchronize_stores(file) unless file.stored_everywhere?

  true
end

#store_once!(file) ⇒ Object 



85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
 
# File 'lib/remote_files/configuration.rb', line 85

def store_once!(file)
  return file.stored_in.first if file.stored?

  exception = nil

  stores.each do |store|
    begin
      stored = store.store!(file)
      file.stored_in << store.identifier
      break
    rescue ::RemoteFiles::Error => e
      file.logger.info(e) if file.logger
      exception = e
    end
  end

  raise exception unless file.stored?

  file.stored_in.first
end

#stores ⇒ Object 



72
73
74
75
 
# File 'lib/remote_files/configuration.rb', line 72

def stores
  raise "You need to configure add stores to the #{name} RemoteFiles configuration" unless configured?
  @stores
end

#synchronize!(file) ⇒ Object 



136
137
138
139
140
141
 
# File 'lib/remote_files/configuration.rb', line 136

def synchronize!(file)
  file.missing_stores.each do |store|
    store.store!(file)
    file.stored_in << store.identifier
  end
end