require "aws-sdk" class S3Helper def initialize(s3_bucket, tombstone_prefix=nil) raise Discourse::InvalidParameters.new("s3_bucket") if s3_bucket.blank? @s3_bucket = s3_bucket @tombstone_prefix = tombstone_prefix check_missing_site_settings end def upload(file, path, options={}) obj = s3_bucket.object(path) obj.upload_file(file, options) end def remove(s3_filename, tombstone_filename=false) bucket = s3_bucket # copy the file in tombstone if tombstone_filename && @tombstone_prefix.present? bucket .object(File.join(@tombstone_prefix, tombstone_filename)) .copy_from(copy_source: File.join(@s3_bucket, s3_filename)) end # delete the file bucket.object(s3_filename).delete rescue Aws::S3::Errors::NoSuchKey end def update_tombstone_lifecycle(grace_period) return if @tombstone_prefix.blank? # cf. http://docs.aws.amazon.com/AmazonS3/latest/dev/object-lifecycle-mgmt.html s3_resource.client.put_bucket_lifecycle({ bucket: @s3_bucket, lifecycle_configuration: { rules: [ { id: "purge-tombstone", status: "Enabled", expiration: { days: grace_period }, prefix: @tombstone_prefix } ] } }) end private def s3_resource opts = { region: SiteSetting.s3_region } unless SiteSetting.s3_use_iam_profile opts[:access_key_id] = SiteSetting.s3_access_key_id opts[:secret_access_key] = SiteSetting.s3_secret_access_key end Aws::S3::Resource.new(opts) end def s3_bucket bucket = s3_resource.bucket(@s3_bucket) bucket.create unless bucket.exists? bucket end def check_missing_site_settings unless SiteSetting.s3_use_iam_profile raise Discourse::SiteSettingMissing.new("s3_access_key_id") if SiteSetting.s3_access_key_id.blank? raise Discourse::SiteSettingMissing.new("s3_secret_access_key") if SiteSetting.s3_secret_access_key.blank? end end end