# frozen_string_literal: true

require_relative './spec_helper'

module Aws
  module RDS
    describe Client do
      let(:client) do
        Client.new(
          region: 'us-west-2',
          credentials: Credentials.new('akid', 'secret'),
          stub_responses: true
        )
      end

      let(:kms_key_id) { '238f8ec9-420a-0690-8ec9-009f34fc3ef5' }
      let(:source_region) { 'us-east-1' }

      before { allow(Time).to receive(:now).and_return(Time.utc(2020, 8, 27)) }

      context '#copy_db_snapshot' do
        let(:copy_db_snapshot_params) do
          {
            kms_key_id: kms_key_id,
            source_db_snapshot_identifier: "arn:aws:rds:#{source_region}:123456789012:snapshot:source-db-snapshot",
            target_db_snapshot_identifier: 'target-db-snapshot'
          }
        end

        context 'no source_region and no pre_signed_url' do
          it 'does not generate pre_signed_url' do
            resp = client.copy_db_snapshot(
              copy_db_snapshot_params
            )
            expect(resp.context.params[:pre_signed_url]).to eq nil
          end
        end

        context 'source_region and pre_signed_url' do
          it 'uses provided pre_signed_url' do
            resp = client.copy_db_snapshot(
              copy_db_snapshot_params.merge(
                pre_signed_url: 'https://aws.com'
              )
            )
            expect(resp.context.params[:pre_signed_url]).to eq 'https://aws.com'
          end
        end

        context 'source_region and no pre_signed_url' do
          it 'generates pre_signed_url' do
            resp = client.copy_db_snapshot(
              copy_db_snapshot_params.merge(
                source_region: source_region
              )
            )

            expect(resp.context.params[:pre_signed_url]).to match(
              /afee7e7f55fcbce926a89482f01acb51e9dc1df0adb09ee172622a079b47ea71/
            )
          end
        end
      end

      context 'create_db_instance_read_replica' do
        let(:create_db_instance_read_replica_params) do
          {
            kms_key_id: kms_key_id,
            source_db_instance_identifier: "arn:aws:rds:#{source_region}:123456789012:db:source-db-instance",
            db_instance_identifier: 'target-db-instance'
          }
        end

        context 'no source_region and no pre_signed_url' do
          it 'does not generate pre_signed_url' do
            resp = client.create_db_instance_read_replica(
              create_db_instance_read_replica_params
            )
            expect(resp.context.params[:pre_signed_url]).to eq nil
          end
        end

        context 'source_region and pre_signed_url' do
          it 'uses provided pre_signed_url' do
            resp = client.create_db_instance_read_replica(
              create_db_instance_read_replica_params.merge(
                pre_signed_url: 'https://aws.com'
              )
            )
            expect(resp.context.params[:pre_signed_url]).to eq 'https://aws.com'
          end
        end

        context 'source_region and no pre_signed_url' do
          it 'generates pre_signed_url' do
            resp = client.create_db_instance_read_replica(
              create_db_instance_read_replica_params.merge(
                source_region: source_region
              )
            )

            expect(resp.context.params[:pre_signed_url]).to match(
              /ddab9b46aa026dd36339e3f80c16c361f0e9e4f86368ee7e391dcdd45cb385e6/
            )
          end
        end
      end

      context 'copy_db_cluster_snapshot' do
        let(:copy_db_cluster_snapshot_params) do
          {
            kms_key_id: kms_key_id,
            source_db_cluster_snapshot_identifier: "arn:aws:rds:#{source_region}:123456789012:cluster-snapshot:source-db-cluster-snapshot",
            target_db_cluster_snapshot_identifier: 'target-db-cluster-snapshot'
          }
        end

        context 'no source_region and no pre_signed_url' do
          it 'does not generate pre_signed_url' do
            resp = client.copy_db_cluster_snapshot(
              copy_db_cluster_snapshot_params
            )
            expect(resp.context.params[:pre_signed_url]).to eq nil
          end
        end

        context 'source_region and pre_signed_url' do
          it 'uses provided pre_signed_url' do
            resp = client.copy_db_cluster_snapshot(
              copy_db_cluster_snapshot_params.merge(
                pre_signed_url: 'https://aws.com'
              )
            )
            expect(resp.context.params[:pre_signed_url]).to eq 'https://aws.com'
          end
        end

        context 'source_region and no pre_signed_url' do
          it 'generates pre_signed_url' do
            resp = client.copy_db_cluster_snapshot(
              copy_db_cluster_snapshot_params.merge(
                source_region: source_region
              )
            )

            expect(resp.context.params[:pre_signed_url]).to match(
              /01eda84cb84ff1558373f4759aaf76aa4b7be8664241a58f6906ae842a0a9d74/
            )
          end
        end
      end

      context 'create_db_cluster' do
        let(:create_db_cluster_params) do
          {
            kms_key_id: kms_key_id,
            storage_encrypted: true,
            replication_source_identifier: "arn:aws:rds:#{source_region}:123456789012:cluster:source-db-cluster",
            db_cluster_identifier: 'db-cluster',
            engine: 'aurora'
          }
        end

        context 'no source_region and no pre_signed_url' do
          it 'does not generate pre_signed_url' do
            resp = client.create_db_cluster(
              create_db_cluster_params
            )
            expect(resp.context.params[:pre_signed_url]).to eq nil
          end
        end

        context 'source_region and pre_signed_url' do
          it 'uses provided pre_signed_url' do
            resp = client.create_db_cluster(
              create_db_cluster_params.merge(
                pre_signed_url: 'https://aws.com'
              )
            )
            expect(resp.context.params[:pre_signed_url]).to eq 'https://aws.com'
          end
        end

        context 'source_region and no pre_signed_url' do
          it 'generates pre_signed_url' do
            resp = client.create_db_cluster(
              create_db_cluster_params.merge(
                source_region: source_region
              )
            )

            expect(resp.context.params[:pre_signed_url]).to match(
              /1f654a3049149ef925f2ad58d4fd71fdf94791eb65848f866a6f451f9be655f7/
            )
          end
        end
      end

      context 'start_db_instance_automated_backups_replication' do
        let(:start_db_instance_automated_backups_replication_params) do
          {
            kms_key_id: kms_key_id,
            source_db_instance_arn: "arn:aws:rds:#{source_region}:123456789012:db:source-db-instance"
          }
        end

        context 'no source_region and no pre_signed_url' do
          it 'does not generate pre_signed_url' do
            resp = client.start_db_instance_automated_backups_replication(
              start_db_instance_automated_backups_replication_params
            )
            expect(resp.context.params[:pre_signed_url]).to eq nil
          end
        end

        context 'source_region and pre_signed_url' do
          it 'uses provided pre_signed_url' do
            resp = client.start_db_instance_automated_backups_replication(
              start_db_instance_automated_backups_replication_params.merge(
                pre_signed_url: 'https://aws.com'
              )
            )
            expect(resp.context.params[:pre_signed_url]).to eq 'https://aws.com'
          end
        end

        context 'source_region and no pre_signed_url' do
          it 'generates pre_signed_url' do
            resp = client.start_db_instance_automated_backups_replication(
              start_db_instance_automated_backups_replication_params.merge(
                source_region: source_region
              )
            )

            expect(resp.context.params[:pre_signed_url]).to match(
              /6beef10ce9ebd1602ed908c7d7121ebfff57f41343ac338a9163a759e66e619c/
            )
          end
        end
      end
    end
  end
end