# Copyright (C) 2012-2016 Zammad Foundation, http://zammad-foundation.org/ class Store::Provider::File # write file to fs def self.add(data, sha) # install file location = get_location(sha) permission = '600' if !File.exist?(location) Rails.logger.debug "storge write '#{location}' (#{permission})" file = File.new(location, 'wb') file.write(data) file.close end File.chmod(permission.to_i(8), location) # check sha local_sha = Digest::SHA256.hexdigest(get(sha)) if sha != local_sha raise "ERROR: Corrupt file in fs #{location}, sha should be #{sha} but is #{local_sha}" end true end # read file from fs def self.get(sha) location = get_location(sha) Rails.logger.debug "read from fs #{location}" if !File.exist?(location) raise "ERROR: No such file #{location}" end data = File.open(location, 'rb') content = data.read # check sha local_sha = Digest::SHA256.hexdigest(content) if local_sha != sha raise "ERROR: Corrupt file in fs #{location}, sha should be #{sha} but is #{local_sha}" end content end # unlink file from fs def self.delete(sha) location = get_location(sha) if File.exist?(location) Rails.logger.info "storge remove '#{location}'" File.delete(location) end # check if dir need to be removed base = "#{Rails.root}/storage/fs" locations = location.split('/') (0..locations.count).reverse_each { |count| local_location = locations[0, count].join('/') break if local_location =~ %r{storage/fs/{0,4}$} break if !Dir["#{local_location}/*"].empty? FileUtils.rmdir(local_location) } end # generate file location def self.get_location(sha) # generate directory base = "#{Rails.root}/storage/fs/" parts = [] length1 = 4 length2 = 5 length3 = 7 last_position = 0 (0..1).each { |_count| end_position = last_position + length1 parts.push sha[last_position, length1] last_position = end_position } (0..1).each { |_count| end_position = last_position + length2 parts.push sha[last_position, length2] last_position = end_position } (0..1).each { |_count| end_position = last_position + length3 parts.push sha[last_position, length3] last_position = end_position } path = parts[ 0..6 ].join('/') + '/' file = sha[last_position, sha.length] location = "#{base}/#{path}" # create directory if not exists if !File.exist?(location) FileUtils.mkdir_p(location) end full_path = location += file full_path.gsub('//', '/') end end