<?php

namespace App\Docker;

use Exception;
use Illuminate\Support\Facades\Log;
use Psr\Http\Message\ResponseInterface;
use React\Http\Browser;
use React\Socket\FixedUriConnector;
use React\Socket\UnixConnector;
use function React\Async\await;


class Container 
{
    protected $id;
    protected $connector;
    protected $browser;

    public function __construct($id) 
    {
        $this->id = $id;
        $connection = Docker::connect();
        $this->connector = $connection->connector;
        $this->browser = $connection->browser;
    }

    public function getId() { return $this->id; }

    public function start() 
    {
        try {
            $response = await($this->browser->post(Docker::endpoint("/containers/" . $this->id . "/start"), [
                "Content-Type" => "text/plain" 
            ]));
            return json_decode($response->getBody());
        } catch (Exception $e) {
            throw $e;
        }
    }

    public function restart() 
    {
        try {
            $response = await($this->browser->post(
                Docker::endpoint("/containers/" . $this->id . "/restart"), 
                [ "Content-Type" => "text/plain" ]
            ));
            return json_decode($response->getBody());
        } catch (Exception $e) {
            throw $e;
        }
    }

    public function stop() 
    {
        try {
            $response = await($this->browser->post(
                Docker::endpoint("/containers/" . $this->id . "/stop"), 
                [ "Content-Type" => "text/plain" ]
            ));
            return json_decode($response->getBody());
        } catch (Exception $e) {
            throw $e;
        }
    }

    public function kill() 
    {
        try {
            $response = await($this->browser->post(
                Docker::endpoint("/containers/" . $this->id . "/kill"), 
                [ "Content-Type" => "text/plain" ]
            ));
            return json_decode($response->getBody());
        } catch (Exception $e) {
            throw $e;
        }
    }

    public function inspect($size = false)
    {
        try {
            $response = await($this->browser->get(
                Docker::endpoint("/containers/" . $this->id . "/json?size=" . $size), 
                [ "Content-Type" => "text/plain" ]
            ));
            return json_decode($response->getBody());
        } catch (Exception $e) {
            throw $e;
        }
    }

    public function logs($args = [])
    {
        try {
            $response = await($this->browser->requestStreaming("GET",
                Docker::endpoint("/containers/" . $this->id . "/logs?stdout=true?stderr=true"), 
                [ "Content-Type" => "text/plain" ]
            ));
            return $response->getBody();
        } catch (Exception $e) {
            throw $e;
        }
    }

    public function exec($command)
    {
        try {
            $response = await($this->browser->post(
                Docker::endpoint("/containers/" . $this->id . "/exec"), 
                [ "Content-Type" => "application/json" ],
                json_encode([
                    'AttachStdout' => true,
                    'AttachStderr' => true,
                    'Cmd' => $command
                ])
            ));
            return new Exec(json_decode($response->getBody())->Id);
        } catch (Exception $e) {
            throw $e;
        }
    }

    public static function create($name, $config)
    {
        try {
            $connection = Docker::connect();
            $response = await($connection->browser->post(Docker::endpoint('/containers/create?name='. $name), 
                [ "Content-Type" => "application/json" ], 
                json_encode($config, JSON_UNESCAPED_SLASHES)
            ));
            $data = json_decode($response->getBody());
            $container = new Container($data->Id);
            return $container;
        } catch (Exception $e) {
            throw $e;
        }
    }
}