<?php

declare(strict_types=1);

namespace Docker\Tests\Resource;

use Docker\API\Client;

use Docker\API\Model\AuthConfig;

use Docker\Context\ContextBuilder;

use Docker\Tests\TestCase;

class ImageResourceTest extends TestCase

{

/**

* Return a container manager.

*/

private function getManager()

{

return self::getDocker();

}

public function testBuild(): void

{

$contextBuilder = new ContextBuilder();

$contextBuilder->from('ubuntu:precise');

$contextBuilder->add('/test', 'test file content');

$context = $contextBuilder->getContext();

$buildStream = $this->getManager()->imageBuild($context->read(), ['t' => 'test-image']);

$this->assertInstanceOf('Docker\Stream\BuildStream', $buildStream);

$lastMessage = '';

$buildStream->onFrame(function ($frame) use (&$lastMessage): void {

$lastMessage = $frame->getStream();

});

$buildStream->wait();

$this->assertContains('Successfully', $lastMessage);

}

public function testCreate(): void

{

$createImageStream = $this->getManager()->imageCreate('', [

'fromImage' => 'registry:latest',

]);

$this->assertInstanceOf('Docker\Stream\CreateImageStream', $createImageStream);

$firstMessage = null;

$createImageStream->onFrame(function ($createImageInfo) use (&$firstMessage): void {

if (null === $firstMessage) {

$firstMessage = $createImageInfo->getStatus();

}

});

$createImageStream->wait();

$this->assertContains('Pulling from library/registry', $firstMessage);

}

public function testPushStream(): void

{

$contextBuilder = new ContextBuilder();

$contextBuilder->from('ubuntu:precise');

$contextBuilder->add('/test', 'test file content');

$context = $contextBuilder->getContext();

$this->getManager()->imageBuild($context->read(), ['t' => 'localhost:5000/test-image'], [], Client::FETCH_OBJECT);

$registryConfig = new AuthConfig();

$registryConfig->setServeraddress('localhost:5000');

$pushImageStream = $this->getManager()->imagePush('localhost:5000/test-image', [], [

'X-Registry-Auth' => $registryConfig,

]);

$this->assertInstanceOf('Docker\Stream\PushStream', $pushImageStream);

$firstMessage = null;

$pushImageStream->onFrame(function ($pushImageInfo) use (&$firstMessage): void {

if (null === $firstMessage) {

$firstMessage = $pushImageInfo->getStatus();

}

});

$pushImageStream->wait();

$this->assertContains('repository [localhost:5000/test-image]', $firstMessage);

}

}