trabajo-afectivo/app/models/store/file.rb

128 lines
2.8 KiB
Ruby
Raw Normal View History

# Copyright (C) 2012-2014 Zammad Foundation, http://zammad-foundation.org/
2015-04-27 21:44:41 +00:00
class Store
class File < ApplicationModel
include ApplicationLib
after_destroy :destroy_provider
2015-07-26 21:35:56 +00:00
=begin
2015-07-26 21:21:51 +00:00
add new file to store
store_file_id = Store::File.add(binary_data)
=end
2015-04-27 21:44:41 +00:00
def self.add(data)
2016-02-02 12:50:49 +00:00
sha = Digest::SHA256.hexdigest(data)
2016-02-02 12:50:49 +00:00
file = Store::File.find_by(sha: sha)
if file.nil?
2015-04-27 21:44:41 +00:00
# load backend based on config
adapter_name = Setting.get('storage_provider') || 'DB'
if !adapter_name
fail 'Missing storage_provider setting option'
2015-04-27 21:44:41 +00:00
end
2016-02-02 12:50:49 +00:00
adapter = load_adapter("Store::Provider::#{adapter_name}")
adapter.add(data, sha)
2015-04-27 21:44:41 +00:00
file = Store::File.create(
provider: adapter_name,
sha: sha,
)
end
2015-04-27 21:44:41 +00:00
file
end
2015-07-26 21:21:51 +00:00
=begin
read content of a file
store = Store::File.find(123)
store.content # returns binary
=end
2015-04-27 21:44:41 +00:00
def content
adapter = self.class.load_adapter("Store::Provider::#{provider}")
adapter.get(sha)
2014-05-03 19:02:38 +00:00
end
2015-07-26 21:21:51 +00:00
=begin
file system check of store, check data and sha (in case fix it)
Store::File.verify
read each file which should be in backend and verify agsinst sha hash
in case of fixing sha hash use:
Store::File.verify(true)
=end
2015-04-27 21:44:41 +00:00
def self.verify(fix_it = nil)
success = true
Store::File.all.each {|item|
content = item.content
2016-02-02 12:50:49 +00:00
sha = Digest::SHA256.hexdigest(content)
logger.info "CHECK: Store::File.find(#{item.id})"
next if sha == item.sha
success = false
2016-02-02 12:50:49 +00:00
logger.error "DIFF: sha diff of Store::File.find(#{item.id}) current:#{sha}/db:#{item.sha}/provider:#{item.provider}"
store = Store.find_by(store_file_id: item.id)
2016-02-02 12:50:49 +00:00
logger.error "STORE: #{store.inspect}"
if fix_it
2016-02-02 12:50:49 +00:00
item.update_attribute(:sha, sha)
end
2015-04-27 21:44:41 +00:00
}
success
end
2015-07-26 21:21:51 +00:00
=begin
move file from one to other provider
move files from file backend to db
Store::File.move('File', 'DB')
move files from db backend to fs
Store::File.move('DB', 'File')
=end
2015-04-27 21:44:41 +00:00
def self.move(source, target)
adapter_source = load_adapter("Store::Provider::#{source}")
adapter_target = load_adapter("Store::Provider::#{target}")
2015-04-27 21:44:41 +00:00
Store::File.all.each {|item|
next if item.provider == target
content = item.content
2015-04-27 21:44:41 +00:00
# add to new provider
2016-02-02 12:50:49 +00:00
adapter_target.add(content, item.sha)
2015-04-27 21:44:41 +00:00
# update meta data
2016-02-02 12:50:49 +00:00
item.update_attribute(:provider, target)
2015-04-27 21:44:41 +00:00
# remove from old provider
2016-02-02 12:50:49 +00:00
adapter_source.delete(item.sha)
2015-05-05 08:11:31 +00:00
logger.info "Moved file #{item.sha} from #{source} to #{target}"
2015-04-27 21:44:41 +00:00
}
true
end
2015-04-27 21:44:41 +00:00
private
2015-04-27 21:44:41 +00:00
def destroy_provider
adapter = self.class.load_adapter("Store::Provider::#{provider}")
2016-02-02 12:50:49 +00:00
adapter.delete(sha)
2015-04-27 21:44:41 +00:00
end
end
end