mirror of
https://github.com/discourse/discourse.git
synced 2024-11-23 22:26:26 +08:00
70bb2aa426
This refactors handling of s3 so it can be specified via GlobalSetting This means that in a multisite environment you can configure s3 uploads without actual sites knowing credentials in s3 It is a critical setting for situations where assets are mirrored to s3.
90 lines
2.3 KiB
Ruby
90 lines
2.3 KiB
Ruby
class Backup
|
|
include ActiveModel::SerializerSupport
|
|
|
|
attr_reader :filename
|
|
attr_accessor :size, :path, :link
|
|
|
|
def initialize(filename)
|
|
@filename = filename
|
|
end
|
|
|
|
def self.all
|
|
Dir.glob(File.join(Backup.base_directory, "*.{gz,tgz}"))
|
|
.sort_by { |file| File.mtime(file) }
|
|
.reverse
|
|
.map { |backup| Backup.create_from_filename(File.basename(backup)) }
|
|
end
|
|
|
|
def self.[](filename)
|
|
path = File.join(Backup.base_directory, filename)
|
|
if File.exists?(path)
|
|
Backup.create_from_filename(filename)
|
|
else
|
|
nil
|
|
end
|
|
end
|
|
|
|
def remove
|
|
File.delete(@path) if File.exists?(path)
|
|
after_remove_hook
|
|
end
|
|
|
|
def after_create_hook
|
|
upload_to_s3 if SiteSetting.enable_s3_backups?
|
|
DiscourseEvent.trigger(:backup_created)
|
|
end
|
|
|
|
def after_remove_hook
|
|
remove_from_s3 if SiteSetting.enable_s3_backups? && !SiteSetting.s3_disable_cleanup?
|
|
end
|
|
|
|
def s3_bucket
|
|
return @s3_bucket if @s3_bucket
|
|
raise Discourse::SiteSettingMissing.new("s3_backup_bucket") if SiteSetting.s3_backup_bucket.blank?
|
|
@s3_bucket = SiteSetting.s3_backup_bucket.downcase
|
|
end
|
|
|
|
def s3
|
|
require "s3_helper" unless defined? S3Helper
|
|
@s3_helper ||= S3Helper.new(s3_bucket, '', S3Helper.s3_options(SiteSetting))
|
|
end
|
|
|
|
def upload_to_s3
|
|
return unless s3
|
|
File.open(@path) do |file|
|
|
s3.upload(file, @filename)
|
|
end
|
|
end
|
|
|
|
def remove_from_s3
|
|
return unless s3
|
|
s3.remove(@filename)
|
|
end
|
|
|
|
def self.base_directory
|
|
base_directory = File.join(Rails.root, "public", "backups", RailsMultisite::ConnectionManagement.current_db)
|
|
FileUtils.mkdir_p(base_directory) unless Dir.exists?(base_directory)
|
|
base_directory
|
|
end
|
|
|
|
def self.chunk_path(identifier, filename, chunk_number)
|
|
File.join(Backup.base_directory, "tmp", identifier, "#{filename}.part#{chunk_number}")
|
|
end
|
|
|
|
def self.create_from_filename(filename)
|
|
Backup.new(filename).tap do |b|
|
|
b.path = File.join(Backup.base_directory, b.filename)
|
|
b.link = UrlHelper.schemaless "#{Discourse.base_url}/admin/backups/#{b.filename}"
|
|
b.size = File.size(b.path)
|
|
end
|
|
end
|
|
|
|
def self.remove_old
|
|
return if Rails.env.development?
|
|
all_backups = Backup.all
|
|
return if all_backups.size <= SiteSetting.maximum_backups
|
|
all_backups[SiteSetting.maximum_backups..-1].each(&:remove)
|
|
end
|
|
|
|
end
|