require 'spec_helper'

SingleCov.covered! uncovered: 39

describe Docker::Container do
  describe '#to_s' do
    subject {
      described_class.send(:new, Docker.connection, 'id' => rand(10000).to_s)
    }

    let(:id) { 'bf119e2' }
    let(:connection) { Docker.connection }
    let(:expected_string) {
      "Docker::Container { :id => #{id}, :connection => #{connection} }"
    }
    before do
      {
        :@id => id,
        :@connection => connection
      }.each { |k, v| subject.instance_variable_set(k, v) }
    end

    its(:to_s) { should == expected_string }
  end

  describe '#json' do
    subject {
      described_class.create('Cmd' => %w[true], 'Image' => 'debian:stable')
    }
    let(:description) { subject.json }
    after(:each) { subject.remove }

    it 'returns the description as a Hash' do
      expect(description).to be_a Hash
      expect(description['Id']).to start_with(subject.id)
    end
  end

  describe '#streaming_logs' do
    let(:options) { {} }
    subject do
      described_class.create(
        {'Cmd' => ['/bin/bash', '-lc', 'echo hello'], 'Image' => 'debian:stable'}.merge(options)
      )
    end

    before(:each) { subject.tap(&:start).wait }
    after(:each) { subject.remove }

    context 'when not selecting any stream' do
      let(:non_destination) { subject.streaming_logs }
      it 'raises a client error' do
        expect { non_destination }.to raise_error(Docker::Error::ClientError)
      end
    end

    context 'when selecting stdout' do
      let(:stdout) { subject.streaming_logs(stdout: 1) }
      it 'returns blank logs' do
        expect(stdout).to be_a String
        expect(stdout).to match("hello")
      end
    end

    context 'when using a tty' do
      let(:options) { { 'Tty' => true } }

      let(:output) { subject.streaming_logs(stdout: 1, tty: 1) }
      it 'returns `hello`' do
        expect(output).to be_a(String)
        expect(output).to match("hello")
      end
    end

    context 'when passing a block' do
      let(:lines) { [] }
      let(:output) { subject.streaming_logs(stdout: 1, follow: 1) { |s,c| lines << c } }
      it 'returns `hello`' do
        expect(output).to be_a(String)
        expect(output).to match("hello")
        expect(lines.join).to match("hello")
      end
    end
  end

  describe '#stats', :docker_1_9 do
    after(:each) do
      subject.wait
      subject.remove
    end

    context "when requesting container stats" do
      subject {
        described_class.create('Cmd' => ['echo', 'hello'], 'Image' => 'debian:stable')
      }

      let(:output) { subject.stats }
      it "returns a Hash" do
        skip('Not supported on podman') if ::Docker.podman?
        expect(output).to be_a Hash
      end
    end

    context "when streaming container stats" do
      subject {
        described_class.create(
          'Cmd' => ['sleep', '3'],
          'Image' => 'debian:stable'
        )
      }

      it "yields a Hash" do
        skip('Not supported on podman') if ::Docker.podman?
        subject.start! # If the container isn't started, no stats will be streamed
        called_count = 0
        subject.stats do |output|
          expect(output).to be_a Hash
          called_count += 1
          break if called_count == 2
        end
        expect(called_count).to eq 2
      end
    end
  end

  describe '#logs' do
    subject {
      described_class.create('Cmd' => ['echo',  'hello'], 'Image' => 'debian:stable')
    }
    after(:each) { subject.remove }

    context "when not selecting any stream" do
      let(:non_destination) { subject.logs }
      it 'raises a client error' do
        expect { non_destination }.to raise_error(Docker::Error::ClientError)
      end
    end

    context "when selecting stdout" do
      let(:stdout) { subject.logs(stdout: 1) }
      it 'returns blank logs' do
        expect(stdout).to be_a String
        expect(stdout).to eq ""
      end
    end
  end

  describe '#create' do
    subject {
      described_class.create({
        'Cmd' => %w[true],
        'Image' => 'debian:stable'
      }.merge(opts))
    }

    context 'when creating a container named bob' do
      let(:opts) { {"name" => "bob"} }
      after(:each) { subject.remove }

      it 'should have name set to bob' do
        expect(subject.json["Name"]).to eq("/bob")
      end
    end
  end

  describe '#rename' do
    subject {
      described_class.create({
        'name' => 'foo',
        'Cmd' => %w[true],
        'Image' => 'debian:stable'
      })
    }

    before { subject.start }
    after(:each) { subject.tap(&:wait).remove }

    it 'renames the container' do
      skip('Not supported on podman') if ::Docker.podman?
      subject.rename('bar')
      expect(subject.json["Name"]).to match(%r{bar})
    end
  end

  describe "#update", :docker_1_10 do
    subject {
      described_class.create({
        "name" => "foo",
        'Cmd' => %w[true],
        "Image" => "debian:stable",
        "HostConfig" => {
          "CpuShares" => 60000
        }
      })
    }

    before { subject.tap(&:start).tap(&:wait) }
    after(:each) { subject.tap(&:wait).remove }

    it "updates the container" do
      skip('Podman containers are immutable once created') if ::Docker.podman?
      subject.refresh!
      expect(subject.info.fetch("HostConfig").fetch("CpuShares")).to eq 60000
      subject.update("CpuShares" => 50000)
      subject.refresh!
      expect(subject.info.fetch("HostConfig").fetch("CpuShares")).to eq 50000
    end
  end

  describe '#changes' do
    subject {
      described_class.create(
        'Cmd' => %w[rm -rf /root],
        'Image' => 'debian:stable'
      )
    }
    let(:changes) { subject.changes }

    before { subject.tap(&:start).tap(&:wait) }
    after(:each) { subject.tap(&:wait).remove }

    it 'returns the changes as an array' do
      expect(changes).to be_a(Array)
      expect(changes).to include(
        {
          "Path" => "/root",
          "Kind" => 2
        },
      )
    end
  end

  describe '#top' do
    let(:dir) {
      File.join(File.dirname(__FILE__), '..', 'fixtures', 'top')
    }
    let(:image) { Docker::Image.build_from_dir(dir) }
    let(:top_empty) { sleep 1; container.top }
    let(:top_ary) { sleep 1; container.top }
    let(:top_hash) { sleep 1; container.top(format: :hash) }
    let!(:container) { image.run('/while') }
    after do
      container.kill!.remove
      image.remove
    end

    it 'returns the top commands as an Array' do
      expect(top_ary).to be_a Array
      expect(top_ary).to_not be_empty
      expect(top_ary.first.keys).to include(/PID/)
    end

    it 'returns the top commands as an Hash' do
      expect(top_hash).to be_a Hash
      expect(top_hash).to_not be_empty
      expect(top_hash.keys).to eq ['Processes', 'Titles']
    end

    it 'returns nothing when Processes were not returned due to an error' do
      expect(Docker::Util).to receive(:parse_json).and_return({}).at_least(:once)
      expect(top_empty).to eq []
    end
  end

  describe '#archive_in', :docker_1_8 do
    let(:license_path) { File.absolute_path(File.join(__FILE__, '..', '..', '..', 'LICENSE')) }
    subject { Docker::Container.create('Image' => 'debian:stable', 'Cmd' => ['/bin/sh']) }
    let(:committed_image) { subject.commit }
    let(:ls_container) { committed_image.run('ls /').tap(&:wait) }
    let(:output) { ls_container.streaming_logs(stdout: true, stderr: true) }

    after do
      subject.remove
    end

    context 'when the input is a tar' do
      after do
        ls_container.remove
        committed_image.remove
      end

      it 'file exists in the container' do
        skip('Not supported on podman') if ::Docker.podman?
        subject.archive_in(license_path, '/', overwrite: false)
        expect(output).to include('LICENSE')
      end
    end
  end

  describe '#archive_in_stream', :docker_1_8 do
    let(:tar) { StringIO.new(Docker::Util.create_tar('/lol' => 'TEST')) }
    subject { Docker::Container.create('Image' => 'debian:stable', 'Cmd' => ['/bin/sh']) }
    let(:committed_image) { subject.commit }
    let(:ls_container) { committed_image.run('ls /').tap(&:wait) }
    let(:output) { ls_container.streaming_logs(stdout: true, stderr: true) }

    after do
      subject.remove
    end

    context 'when the input is a tar' do
      after do
        ls_container.remove
        committed_image.remove
      end

      it 'file exists in the container' do
        skip('Not supported on podman') if ::Docker.podman?
        subject.archive_in_stream('/', overwrite: false) { tar.read }
        expect(output).to include('lol')
      end
    end

    context 'when the input would overwrite a directory with a file' do
      let(:tar) { StringIO.new(Docker::Util.create_tar('/etc' => 'TEST')) }

      it 'raises an error' do
        skip('Not supported on podman') if ::Docker.podman?
        # Docs say this should return a client error: clearly wrong
        # https://docs.docker.com/engine/reference/api/docker_remote_api_v1.21/
        # #extract-an-archive-of-files-or-folders-to-a-directory-in-a-container
        expect {
          subject.archive_in_stream('/', overwrite: false) { tar.read }
        }.to raise_error(Docker::Error::ServerError)
      end
    end
  end

  describe '#archive_out', :docker_1_8 do
    subject { Docker::Container.create('Image' => 'debian:stable', 'Cmd' => ['touch','/test']) }

    after { subject.remove }

    context 'when the file does not exist' do
      it 'raises an error' do
        skip('Not supported on podman') if ::Docker.podman?
        subject.start
        subject.wait

        expect { subject.archive_out('/lol') { |chunk| puts chunk } }
          .to raise_error(Docker::Error::NotFoundError)
      end
    end

    context 'when the input is a file' do
      it 'yields each chunk of the tarred file' do
        skip('Not supported on podman') if ::Docker.podman?
        subject.start; subject.wait

        chunks = []
        subject.archive_out('/test') { |chunk| chunks << chunk }
        chunks = chunks.join("\n")
        expect(chunks).to be_include('test')
      end
    end

    context 'when the input is a directory' do
      it 'yields each chunk of the tarred directory' do
        skip('Not supported on podman') if ::Docker.podman?
        subject.start; subject.wait

        chunks = []
        subject.archive_out('/etc/logrotate.d') { |chunk| chunks << chunk }
        chunks = chunks.join("\n")
        expect(%w[apt dpkg]).to be_all { |file| chunks.include?(file) }
      end
    end
  end

  describe "#read_file", :docker_1_8 do
    subject {
      Docker::Container.create(
        "Image" => "debian:stable",
        "Cmd" => ["/bin/bash", "-c", "echo \"Hello world\" > /test"]
      )
    }

    after { subject.remove }

    before do
      subject.start
      subject.wait
    end

    it "reads contents from files" do
      skip('Not supported on podman') if ::Docker.podman?
      expect(subject.read_file("/test")).to eq "Hello world\n"
    end
  end

  describe "#store_file", :docker_1_8 do
    subject { Docker::Container.create('Image' => 'debian:stable', 'Cmd' => ["ls"]) }

    after { subject.remove }

    it "stores content in files" do
      skip('Not supported on podman') if ::Docker.podman?
      subject.store_file("/test", "Hello\nWorld")
      expect(subject.read_file("/test")).to eq "Hello\nWorld"
    end
  end

  describe '#export' do
    subject { described_class.create('Cmd' => %w[/true],
                                     'Image' => 'tianon/true') }
    before { subject.start }
    after { subject.tap(&:wait).remove }

    it 'yields each chunk' do
      first = nil
      subject.export do |chunk|
        first ||= chunk
      end
      expect(first[257..261]).to eq "ustar" # Make sure the export is a tar.
    end
  end

  describe '#attach' do
    subject {
      described_class.create(
        'Cmd' => ['bash','-c','sleep 2; echo hello'],
        'Image' => 'debian:stable'
      )
    }

    before { subject.start }
    after(:each) { subject.stop.remove }

    context 'with normal sized chunks' do
      it 'yields each chunk' do
        chunk = nil
        subject.attach do |stream, c|
          chunk ||= c
        end
        expect(chunk).to eq("hello\n")
      end
    end

    context 'with very small chunks' do
      before do
        Docker.options = { :chunk_size => 1 }
      end

      after do
        Docker.options = {}
      end

      it 'yields each chunk' do
        chunk = nil
        subject.attach do |stream, c|
          chunk ||= c
        end
        expect(chunk).to eq("hello\n")
      end
    end
  end

  describe '#attach with stdin' do
    it 'yields the output' do
      skip('Currently broken in podman') if ::Docker.podman?
      container = described_class.create(
        'Cmd'       => %w[cat],
        'Image'     => 'debian:stable',
        'OpenStdin' => true,
        'StdinOnce' => true
      )
      chunk = nil
      container
        .tap(&:start)
        .attach(stdin: StringIO.new("foo\nbar\n")) do |stream, c|
          chunk ||= c
        end
      container.tap(&:wait).remove

      expect(chunk).to eq("foo\nbar\n")
    end
  end

  describe '#start' do
    subject {
      described_class.create(
        'Cmd' => %w[test -d /foo],
        'Image' => 'debian:stable',
        'Volumes' => {'/foo' => {}},
        'HostConfig' => { 'Binds' => ["/tmp:/foo"] }
      )
    }
    let(:all) { Docker::Container.all(all: true) }

    before { subject.start }
    after(:each) { subject.remove }

    it 'starts the container' do
      expect(all.map(&:id)).to be_any { |id| id.start_with?(subject.id) }
      expect(subject.wait(10)['StatusCode']).to be_zero
    end
  end

  describe '#stop' do
    subject {
      described_class.create('Cmd' => %w[true], 'Image' => 'debian:stable')
    }

    before { subject.tap(&:start).stop('timeout' => '10') }
    after { subject.remove }

    it 'stops the container' do
      expect(described_class.all(:all => true).map(&:id)).to be_any { |id|
        id.start_with?(subject.id)
      }
      expect(described_class.all.map(&:id)).to be_none { |id|
        id.start_with?(subject.id)
      }
    end

    context 'with a timeout' do
      let(:custom_timeout) { 60 }

      before do
        subject.tap(&:start)
      end

      it 'extends the Excon timeout ensuring the request does not timeout before Docker' do
        expect(subject.connection).to receive(:request).with(
          :post,
          anything,
          anything,
          hash_including(read_timeout: custom_timeout + 5, write_timeout: custom_timeout + 5)
        ).once
        allow(subject.connection).to receive(:request).with(:delete, anything, anything)
        subject.stop('timeout' => custom_timeout)
      end
    end

    context 'without a timeout' do
      before do
        subject.tap(&:start)
      end

      it 'does not adjust the default Excon HTTP timeout' do
        expect(subject.connection).to receive(:request).with(
          :post,
          anything,
          anything,
          hash_including(body: '{}')
        ).once
        allow(subject.connection).to receive(:request).with(:delete, anything, anything)
        subject.stop
      end
    end
  end

  describe '#exec' do
    subject {
      described_class.create(
        'Cmd' => %w[sleep 20],
        'Image' => 'debian:stable'
      ).start
    }
    after { subject.kill!.remove }

    context 'when passed only a command' do
      let(:output) { subject.exec(['bash','-c','sleep 2; echo hello']) }

      it 'returns the stdout/stderr messages and exit code' do
        expect(output).to eq([["hello\n"], [], 0])
      end
    end

    context 'when detach is true' do
      let(:output) { subject.exec(['date'], detach: true) }

      it 'returns the Docker::Exec object' do
        expect(output).to be_a Docker::Exec
        expect(output.id).to_not be_nil
      end
    end

    context 'when passed a block' do
      it 'streams the stdout/stderr messages' do
        chunk = nil
        subject.exec(['bash','-c','sleep 2; echo hello']) do |stream, c|
          chunk ||= c
        end
        expect(chunk).to eq("hello\n")
      end
    end

    context 'when stdin object is passed' do
      let(:output) { subject.exec(['cat'], stdin: StringIO.new("hello")) }

      it 'returns the stdout/stderr messages' do
        skip('Not supported on podman') if ::Docker.podman?
        expect(output).to eq([["hello"],[],0])
      end
    end

    context 'when tty is true' do
      let(:command) { [
        "bash", "-c",
        "if [ -t 1 ]; then echo -n \"I'm a TTY!\"; fi"
      ] }
      let(:output) { subject.exec(command, tty: true) }

      it 'returns the raw stdout/stderr output' do
        expect(output).to eq([["I'm a TTY!"], [], 0])
      end
    end
  end

  describe '#kill' do
    let(:command) { ['/bin/bash', '-c', 'while [ 1 ]; do echo hello; done'] }
    subject {
      described_class.create('Cmd' => command, 'Image' => 'debian:stable')
    }

    before { subject.start }
    after(:each) {subject.remove }

    it 'kills the container' do
      subject.kill
      expect(described_class.all.map(&:id)).to be_none { |id|
        id.start_with?(subject.id)
      }
      expect(described_class.all(:all => true).map(&:id)).to be_any { |id|
        id.start_with?(subject.id)
      }
    end

    context 'with a kill signal' do
      let(:command) {
        [
          '/bin/bash',
          '-c',
          'trap echo SIGTERM; while [ 1 ]; do echo hello; done'
        ]
      }
      it 'kills the container' do
        subject.kill(:signal => "SIGTERM")
        expect(described_class.all.map(&:id)).to be_any { |id|
          id.start_with?(subject.id)
        }
        expect(described_class.all(:all => true).map(&:id)).to be_any { |id|
          id.start_with?(subject.id)
        }

        subject.kill(:signal => "SIGKILL")
        expect(described_class.all.map(&:id)).to be_none { |id|
          id.start_with?(subject.id)
        }
        expect(described_class.all(:all => true).map(&:id)).to be_any { |id|
          id.start_with?(subject.id)
        }
      end
    end
  end

  describe '#delete' do
    subject {
      described_class.create('Cmd' => ['ls'], 'Image' => 'debian:stable')
    }

    it 'deletes the container' do
      subject.delete(:force => true)
      expect(described_class.all.map(&:id)).to be_none { |id|
        id.start_with?(subject.id)
      }
    end
  end

  describe '#restart' do
    subject {
      described_class.create('Cmd' => %w[sleep 10], 'Image' => 'debian:stable')
    }

    before { subject.start }
    after { subject.kill!.remove }

    it 'restarts the container' do
      expect(described_class.all.map(&:id)).to be_any { |id|
        id.start_with?(subject.id)
      }
      subject.stop
      expect(described_class.all.map(&:id)).to be_none { |id|
        id.start_with?(subject.id)
      }
      subject.restart('timeout' => '10')
      expect(described_class.all.map(&:id)).to be_any { |id|
        id.start_with?(subject.id)
      }
    end
  end

  describe '#pause' do
    subject {
      described_class.create(
        'Cmd' => %w[sleep 50],
        'Image' => 'debian:stable'
      ).start
    }
    after { subject.unpause.kill!.remove }

    it 'pauses the container' do
      skip('Not supported on rootless podman') if (::Docker.podman? && ::Docker.rootless?)
      subject.pause
      expect(described_class.get(subject.id).info['State']['Paused']).to be true
    end
  end

  describe '#unpause' do
    subject {
      described_class.create(
        'Cmd' => %w[sleep 50],
        'Image' => 'debian:stable'
      ).start
    }
    before { subject.pause }
    after { subject.kill!.remove }

    it 'unpauses the container' do
      subject.unpause
      expect(
        described_class.get(subject.id).info['State']['Paused']
      ).to be false
    end
  end

  describe '#wait' do
    subject {
      described_class.create(
        'Cmd' => %w[tar nonsense],
        'Image' => 'debian:stable'
      )
    }

    before { subject.start }
    after(:each) { subject.remove }

    it 'waits for the command to finish' do
      expect(subject.wait['StatusCode']).to_not be_zero
    end

    context 'when an argument is given' do
      subject { described_class.create('Cmd' => %w[sleep 5],
                                       'Image' => 'debian:stable') }

      it 'sets the :read_timeout to that amount of time' do
        expect(subject.wait(6)['StatusCode']).to be_zero
      end

      context 'and a command runs for too long' do
        it 'raises a ServerError' do
          expect{subject.wait(4)}.to raise_error(Docker::Error::TimeoutError)
          subject.tap(&:wait)
        end
      end
    end
  end

  describe '#run' do
    let(:run_command) { subject.run('ls') }

    context 'when the Container\'s command does not return status code of 0' do
      subject { described_class.create('Cmd' => %w[false],
                                       'Image' => 'debian:stable') }

      after do
        subject.remove
      end

      it 'raises an error' do
        expect { run_command }
            .to raise_error(Docker::Error::UnexpectedResponseError)
      end
    end

    context 'when the Container\'s command returns a status code of 0' do
      subject { described_class.create('Cmd' => %w[pwd],
                                       'Image' => 'debian:stable') }
      after do
        subject.remove
        image = run_command.json['Image']
        run_command.remove
        Docker::Image.get(image).history.each do |layer|
          next unless layer['CreatedBy'] == 'pwd'
          Docker::Image.get(layer['Id']).remove(:noprune => true)
        end
      end

      it 'creates a new container to run the specified command' do
        expect(run_command.wait['StatusCode']).to be_zero
      end
    end
  end

  describe '#commit' do
    subject {
      described_class.create('Cmd' => %w[true], 'Image' => 'debian:stable')
    }
    let(:image) { subject.commit }

    after(:each) do
      subject.remove
      image.remove
    end

    it 'creates a new Image from the  Container\'s changes' do
      subject.tap(&:start).wait

      expect(image).to be_a Docker::Image
      expect(image.id).to_not be_nil
    end

    context 'if run is passed, it saves the command in the image' do
      let(:image) { subject.commit }
      let(:container) { image.run('pwd') }

      it 'saves the command' do
        skip('Not supported on podman') if ::Docker.podman?
        container.wait
        expect(container.attach(logs: true, stream: false)).to eql [["/\n"],[]]
        container.remove
      end
    end
  end

  describe '.create' do
    subject { described_class }

    context 'when the Container does not yet exist' do
      context 'when the HTTP request does not return a 200' do
        before do
          Docker.options = { :mock => true }
          Excon.stub({ :method => :post }, { :status => 400 })
        end
        after do
          Excon.stubs.shift
          Docker.options = {}
        end

        it 'raises an error' do
          expect { subject.create }.to raise_error(Docker::Error::ClientError)
        end
      end

      context 'when the HTTP request returns a 200' do
        let(:options) do
          {
            "Cmd"          => ["date"],
            "Image"        => "debian:stable",
          }
        end
        let(:container) { subject.create(options) }
        after { container.remove }

        it 'sets the id' do
          expect(container).to be_a Docker::Container
          expect(container.id).to_not be_nil
          expect(container.connection).to_not be_nil
        end
      end
    end
  end

  describe '.get' do
    subject { described_class }

    context 'when the HTTP response is not a 200' do
      before do
        Docker.options = { :mock => true }
        Excon.stub({ :method => :get }, { :status => 500 })
      end
      after do
        Excon.stubs.shift
        Docker.options = {}
      end

      it 'raises an error' do
        expect { subject.get('randomID') }
            .to raise_error(Docker::Error::ServerError)
      end
    end

    context 'when the HTTP response is a 200' do
      let(:container) {
        subject.create('Cmd' => ['ls'], 'Image' => 'debian:stable')
      }
      after { container.remove }

      it 'materializes the Container into a Docker::Container' do
        expect(subject.get(container.id)).to be_a Docker::Container
      end
    end

  end

  describe '.all' do
    subject { described_class }

    context 'when the HTTP response is not a 200' do
      before do
        Docker.options = { :mock => true }
        Excon.stub({ :method => :get }, { :status => 500 })
      end
      after do
        Excon.stubs.shift
        Docker.options = {}
      end

      it 'raises an error' do
        expect { subject.all }
            .to raise_error(Docker::Error::ServerError)
      end
    end

    context 'when the HTTP response is a 200' do
      let(:container) {
        subject.create('Cmd' => ['ls'], 'Image' => 'debian:stable')
      }
      before { container }
      after { container.remove }

      it 'materializes each Container into a Docker::Container' do
        expect(subject.all(:all => true)).to be_all { |container|
          container.is_a?(Docker::Container)
        }
        expect(subject.all(:all => true).length).to_not be_zero
      end
    end
  end

  describe '.prune', :docker_17_03 => true do
    it 'prune containers' do
      expect { Docker::Container.prune }.not_to raise_error
    end
  end
end