# frozen_string_literal: true

require 'openssl'
require 'csv'

Before('@s3', '@client') do
  @client = Aws::S3::Client.new
  @created_buckets = []
end

After('@s3', '@client') do
  @created_buckets.each do |bucket|
    loop do
      object_versions = @client.list_object_versions(bucket: bucket)
      objects = object_versions.data.versions.map do |v|
        { key: v.key, version_id: v.version_id }
      end
      break if objects.empty?

      @client.delete_objects(bucket: bucket, delete: { objects: objects })
    end
    @client.delete_bucket(bucket: bucket)
  end
end

def create_bucket(options = {})
  unless options[:bucket]
    @bucket_name = "aws-sdk-test-#{Time.now.to_i}-#{rand(1000)}"
    options[:bucket] = @bucket_name
  end
  if @client.config.region != 'us-east-1' &&
     !options[:create_bucket_configuration]
    options[:create_bucket_configuration] = {
      location_constraint: @client.config.region
    }
  end

  options[:object_ownership] ||= 'ObjectWriter'

  @client.create_bucket(options)
  @client.wait_until(:bucket_exists, bucket: @bucket_name)
  @client.delete_public_access_block(bucket: @bucket_name)
  @created_buckets << @bucket_name
end

When(/^I force path style requests$/) do
  @client = Aws::S3::Client.new(force_path_style: true)
end

Given(/^I am using the S3 "(.*?)" region$/) do |region|
  @client = Aws::S3::Client.new(region: region)
end

When(/^I create a bucket$/) do
  create_bucket
end

Given(/^I create a DNS compatible bucket$/) do
  create_bucket
end

When(/^I create a bucket with the location constraint "(.*?)"$/) do |loc|
  create_bucket(create_bucket_configuration: { location_constraint: loc })
end

Then(/^the bucket should have a location constraint of "(.*?)"$/) do |loc|
  resp = @client.get_bucket_location(bucket: @bucket_name)
  expect(resp.data.location_constraint).to eq(loc)
end

Then(/^the bucket should exist$/) do
  expect do
    @client.get_bucket_location(bucket: @bucket_name)
  end.not_to raise_error
end

Then(/^I should be able to HEAD the bucket$/) do
  expect { @client.head_bucket(bucket: @bucket_name) }.not_to raise_error
end

When(/^I delete the bucket$/) do
  @client.delete_bucket(bucket: @bucket_name)
  @created_buckets.delete(@bucket_name)
end

Then(/^the bucket should not exist$/) do
  eventually(upto: 60) do
    begin
      @client.get_bucket_location(bucket: @bucket_name)
    rescue StandardError => e
      @error = e
    end
    expect(@error).to be_kind_of(Aws::S3::Errors::NoSuchBucket)
  end
end

When(/^I put nothing to the key "(.*?)"$/) do |key|
  @client.put_object(bucket: @bucket_name, key: key)
end

When(/^I put "(.*?)" to the key "(.*?)"$/) do |data, key|
  @response = @client.put_object(bucket: @bucket_name, key: key, body: data)
end

When(/^I put the test png to the key "(.*?)"$/) do |key|
  file = File.open(File.join(File.dirname(__FILE__), 'test.png'), 'rb')
  @client.put_object(bucket: @bucket_name, key: key, body: file)
  file.close
end

Then(/^the object with the key "(.*?)" should have a content length of (\d+)$/) do |key, size|
  resp = @client.head_object(bucket: @bucket_name, key: key)
  expect(resp.data.content_length).to eq(size.to_i)
end

When(/^I page s3 objects prefixed "(.*?)" delimited "(.*?)" limit (\d+)$/) do |prefix, delimiter, max_keys|
  @responses = []
  @client.list_objects(
    bucket: @bucket_name,
    prefix: prefix,
    delimiter: delimiter,
    max_keys: max_keys
  ).each do |resp|
    @responses << resp
  end
end

Then(/^I should have received (\d+) responses$/) do |count|
  expect(@responses.size).to eq(count.to_i)
end

Given(/^I am using the S3 "(.*?)" endpoint$/) do |endpoint|
  @client = Aws::S3::Client.new(endpoint: endpoint)
end

When(/^I create a bucket with a DNS compatible name that contains a dot$/) do
  @bucket_name = "aws.#{Time.now.to_i}.sdk"
  create_bucket(bucket: @bucket_name)
end

Then(/^I should be able to delete the bucket$/) do
  @client.delete_bucket(bucket: @bucket_name)
  @created_buckets.delete(@bucket_name)
end

Then(/^the bucket name should be in the request path$/) do
  endpoint = @response.context.http_request.endpoint
  expect(endpoint.path).to include(@bucket_name)
end

Then(/^the bucket name should not be in the request host$/) do
  endpoint = @response.context.http_request.endpoint
  expect(endpoint.host).not_to include(@bucket_name)
end

Then(/^the bucket name should be in the request host$/) do
  endpoint = @response.context.http_request.endpoint
  expect(endpoint.host).to include(@bucket_name)
end

Then(/^the bucket name should not be in the request path$/) do
  endpoint = @response.context.http_request.endpoint
  expect(endpoint.path).not_to include(@bucket_name)
end

When(/^I put "(.*?)" to the key "(.*?)" with an aes key$/) do |body, key|
  @aes_key = OpenSSL::Cipher.new('aes-256-cbc').random_key
  @client.put_object(
    bucket: @bucket_name,
    key: key,
    body: body,
    sse_customer_algorithm: 'AES256',
    sse_customer_key: @aes_key
  )
end

Then(/^I can download the key "(.*?)" with the aes key$/) do |key|
  @client.get_object(
    bucket: @bucket_name,
    key: key,
    sse_customer_algorithm: 'AES256',
    sse_customer_key: @aes_key
  )
end

When(/^I get the object with the key "(.*?)"$/) do |key|
  @response = @client.get_object(bucket: @bucket_name, key: key)
end

Then(/^the body should be an IO object$/) do
  expect(@response.body).to be_kind_of(StringIO)
end

Then(/^the body #read method should return "(.*?)"$/) do |str|
  expect(@response.body.read).to eq(str)
end

When(/^I put a large object with a broken content-md5$/) do
  begin
    @client.put_object(
      bucket: @bucket_name,
      key: 'key',
      body: '.' * 1024 * 1024,
      content_md5: 'abc'
    )
  rescue StandardError => e
    @error = e
  end
end

Then(/^I should receive an invalid digest error$/) do
  expect(@error).to be_kind_of(Aws::S3::Errors::InvalidDigest)
end

When(/^I put a large object$/) do
  @key = 'large-object'
  @client.put_object(bucket: @bucket_name, key: @key, body: '.' * 1024 * 1024)
end

Then(/^the object should exist$/) do
  @client.head_object(bucket: @bucket_name, key: @key)
end

When(/^I create a (non-secure )?presigned url for "(.*?)" with:$/) do |non_secure, method, params|
  presigner = Aws::S3::Presigner.new(client: @client)
  params = symbolized_params(params)
  params[:bucket] = @bucket_name
  params[:secure] = false if non_secure
  @url = presigner.presigned_url(method.to_sym, params)
end

When(/^I send an HTTP get request for the presigned url$/) do
  uri = URI(@url)
  @resp = Net::HTTP.get_response(uri.host, uri.request_uri)
end

Then(/^the response should be "(.*?)"$/) do |expected|
  expect(@resp.body).to eq(expected)
end

When(/^I send an HTTP put request for the presigned url with body "(.*?)"$/) do |body|
  uri = URI(@url)
  http = Net::HTTP.new(uri.host)
  req = Net::HTTP::Put.new(
    uri.request_uri, 'content-length' => body.bytesize.to_s
  )
  req.body = body
  @resp = http.request(req)
  expect(@resp.code).to eq('200')
end

Then(/^I make an unauthenticated HTTPS GET request for key "(.*?)"$/) do |key|
  uri = URI.parse("https://#{@bucket_name}.s3.amazonaws.com/#{key}")
  http = Net::HTTP.new(uri.host, 443)
  http.use_ssl = true
  req = Net::HTTP::Get.new(uri.request_uri)
  @resp = http.request(req)
end

Then(/^I make an unauthenticated HTTP GET request for key "(.*?)"$/) do |key|
  uri = URI.parse("http://#{@bucket_name}.s3.amazonaws.com/#{key}")
  @resp = Net::HTTP.get_response(uri)
end

When(/^I get an object that doesn't exist with a read block$/) do
  @yielded = []
  begin
    @client.get_object(bucket: @bucket_name, key: 'bad-key') do |chunk|
      @yielded << chunk
    end
  rescue StandardError => e
    @error = e
  end
end

Then(/^an error should be raise and the block should not yield$/) do
  expect(@error).to be_kind_of(Aws::S3::Errors::NoSuchKey)
  expect(@yielded).to eq([])
end

Then(/^the response content\-type should be "(.*?)"$/) do |_arg1|
  expect(@resp.to_hash['content-type']).to eq(['text/plain'])
end

When(/^I send an HTTP put request with the content type as "(.*?)"$/) do |content_type|
  uri = URI(@url)
  http = Net::HTTP.new(uri.host)
  req = Net::HTTP::Put.new(uri.request_uri, 'content-type' => content_type)
  req.body = 'data'
  @resp = http.request(req)
end

When(/^the response should have a (\d+) status code$/) do |code|
  expect(@resp.code.to_i).to eq(code)
end

Then(/^the object "([^"]*)" should have a "([^"]*)" storage class$/) do |key, sc|
  resp = @client.list_objects(bucket: @bucket_name, prefix: key, max_keys: 1)
  expect(resp.contents.first.storage_class).to eq(sc)
end

Then(/^the keys in my bucket should be$/) do |table|
  keys = @client.list_objects(bucket: @bucket_name).contents.map(&:key)
  expect(keys.sort).to eq(table.rows.map(&:first).sort)
end

Given(/^I have a bucket configured with a virtual hosted CNAME$/) do
  @bucket_name = cfg_value('s3', 'virtual_hosted_bucket')
end

When(/^I get the bucket location$/) do
  @response = @client.get_bucket_location(bucket: @bucket_name)
end

Then(/^the location constraint should be "([^"]*)"$/) do |lc|
  expect(@response.location_constraint).to eq(lc)
end

Then(/^I can streaming download key "([^"]*)"$/) do |key|
  resp = @client.get_object(bucket: @bucket_name, key: key) do |chunk|
    expect(chunk).to eq('hello world')
  end
  expect(resp.body).to be_a(Aws::S3::Plugins::RetryableBlockIO)
  expect(resp.context[:response_target]).to be_a(Proc)
end

Given(/^I put a file with content:$/) do |table|
  @select_file_name = 'test.csv'
  csv = Tempfile.new('file.csv')
  CSV.open(csv.path, 'wb') do |f|
    table.raw.each { |row| f << row }
  end
  @client.put_object(
    bucket: @bucket_name,
    key: @select_file_name,
    body: File.read(csv.path)
  )
  csv.unlink
end

When(/^I select it with query "([^"]*)"$/) do |query|
  @select_resp = @client.select_object_content(
    bucket: @bucket_name,
    key: @select_file_name,
    expression_type: 'SQL',
    expression: query,
    input_serialization: {
      csv: {
        file_header_info: 'USE'
      }
    },
    output_serialization: { csv: {} }
  )
  @tracker = Hash.new([])
end

Then(/^response should contain "([^"]*)" event$/) do |type|
  @select_resp.payload.each do |event|
    next unless event.event_type == type.to_sym

    @tracker[type.to_sym] << event
  end
  expect(@tracker[:records]).not_to be_nil
end

Then(/^the event should have payload member with content "([^"]*)"$/) do |payload|
  @tracker[:records].each do |e|
    # same event process twice, same string IO
    e.payload.rewind
    expect(e.payload.read.strip).to eq(payload)
  end
end

When(/^I select it with query "([^"]*)" with block$/) do |query|
  @tracker = Hash.new([])
  @select_resp = @client.select_object_content(
    bucket: @bucket_name,
    key: @select_file_name,
    expression_type: 'SQL',
    expression: query,
    input_serialization: {
      csv: {
        file_header_info: 'USE'
      }
    },
    output_serialization: { csv: {} }
  ) do |stream|
    stream.on_records_event do |e|
      @tracker[e.event_type] << e
    end
  end
end

Then(/^"([^"]*)" event should be processed "(\d+)" times when it arrives$/) do |type, times|
  expect(@tracker[type.to_sym].size).to eq(times.to_i)
end

When(/^I select it with query "([^"]*)" with event stream handler$/) do |string|
  @tracker = Hash.new([])
  handler = Aws::S3::EventStreams::SelectObjectContentEventStream.new
  handler.on_records_event do |e|
    @tracker[:records] << e
  end
  @select_resp = @client.select_object_content(
    bucket: @bucket_name,
    key: @select_file_name,
    expression_type: 'SQL',
    expression: string,
    input_serialization: {
      csv: {
        file_header_info: 'USE'
      }
    },
    output_serialization: { csv: {} },
    event_stream_handler: handler
  )
end

When(/^I select it with query "([^"]*)" with Proc Object$/) do |query|
  @tracker = Hash.new([])
  handler = Proc.new do |stream|
    stream.on_records_event do |e|
      @tracker[:records] << e
    end
  end
  @select_resp = @client.select_object_content(
    bucket: @bucket_name,
    key: @select_file_name,
    expression_type: 'SQL',
    expression: query,
    input_serialization: {
      csv: {
        file_header_info: 'USE'
      }
    },
    output_serialization: { csv: {} },
    event_stream_handler: handler
  )
end

When(/^I select it with query "([^"]*)" with handler and block$/) do |query|
  @tracker = Hash.new([])
  handler = Aws::S3::EventStreams::SelectObjectContentEventStream.new
  handler.on_records_event do |e|
    @tracker[:records] << e
  end
  @select_resp = @client.select_object_content(
    bucket: @bucket_name,
    key: @select_file_name,
    expression_type: 'SQL',
    expression: query,
    input_serialization: {
      csv: {
        file_header_info: 'USE'
      }
    },
    output_serialization: { csv: {} },
    event_stream_handler: handler
  ) do |stream|
    stream.on_records_event do |e|
      @tracker[:records] << e
    end
  end
end

When(/I have access to an MRAP bucket and CRT/) do
  unless Aws::Sigv4::Signer.use_crt?
    pending("CRT is not available")
  end

  begin
    @client.head_bucket(bucket: 'ruby-sdk-integtest-mrap-bucket')
  rescue
    pending("Account does not have access to the MRAP test bucket: ruby-sdk-integtest-mrap-bucket")
  end
  @bucket_name = "arn:aws:s3::469596866844:accesspoint/mpatcdsojq97c.mrap"
end