ManageIQ/amazon_ssa_support

require_relative 'ssa_common'

module AmazonSsaSupport
  module SsaBucket
    include Logging

    def self.get(arg_hash)
      raise ArgumentError, "Bucket and region must be specified." unless arg_hash[:ssa_bucket] && arg_hash[:region]

      ssa_bucket_name = arg_hash[:ssa_bucket]
      s3              = arg_hash[:s3] || Aws::S3::Resource.new(region: arg_hash[:region])

      if (ssa_bucket = s3.bucket(ssa_bucket_name)).exists?
        _log.debug("Found reply bucket #{ssa_bucket_name}")
      else
        _log.debug("Reply bucket #{ssa_bucket_name} does not exist, creating...")
        ssa_bucket.create
        _log.debug("Created reply bucket #{ssa_bucket_name}")
      end

      ssa_bucket
    end
  end
end