Abstract Class luya\testsuite\cases\ServerTestCase

                public function afterSetup()
{
    $this->_pid = $this->bootstrapServer($this->host, $this->port, $this->documentRoot);
}

            

                public function assertUrlGetResponseContains($url, $contains, array $params = [])
{
    $curl = $this->createGetCurl($url, $params);
    $this->assertContains($this->buildPartialJson($contains, true), $curl->response);
}

            

                public function assertUrlGetResponseSame($url, $same, array $params = [])
{
    $curl = $this->createGetCurl($url, $params);
    $this->assertSame($this->buildPartialJson($same), $curl->response);
}

            

                public function assertUrlHomepageIsOk()
{
    $this->assertUrlIsOk(null);
}

            

                public function assertUrlIsError($url, array $params = [])
{
    $curl = $this->createGetCurl($url, $params);
    $printUrl = $this->buildCallUrl($url, $params);
    $this->assertTrue($curl->isError(), "GET URL '{$printUrl}' return {$curl->http_status_code} instead of 400 (Error).");
}

            

                public function assertUrlIsOk($url, array $params = [])
{
    $curl = $this->createGetCurl($url, $params);
    $printUrl = $this->buildCallUrl($url, $params);
    $this->assertTrue($curl->isSuccess(), "GET URL '{$printUrl}' return {$curl->http_status_code} instead of 200 (OK).");
}

            

                public function assertUrlIsRedirect($url, array $params = [])
{
    $curl = $this->createGetCurl($url, $params);
    $printUrl = $this->buildCallUrl($url, $params);
    $this->assertTrue($curl->isRedirect(), "GET URL '{$printUrl}' return {$curl->http_status_code} instead of 300 (Error).");
}

            

                public function assertUrlPostResponseContains($url, $contains, array $data = [], array $params = [])
{
    $curl = $this->createPostCurl($url, $data, $params);
    $this->assertContains($this->buildPartialJson($contains, true), $curl->response);
}

            

                public function assertUrlPostResponseSame($url, $same, array $data = [], array $params = [])
{
    $curl = $this->createPostCurl($url, $data, $params);
    $this->assertSame($this->buildPartialJson($same), $curl->response);
}

            

                public function beforeTearDown()
{
    $this->killServer($this->_pid);
    $this->waitForServerShutdown($this->host, $this->port);
}

            

                public function bootApplication(Boot $boot)
{
    $boot->applicationConsole();
}

            

                protected function bootstrapServer($host, $port, $documentRoot)
{
    $documentRoot = Yii::getAlias($documentRoot);
    if ($this->connectToServer($host, $port)) {
        throw new Exception("The $host:$port is already taken, choose another host and/or port.");
    }
    
    $pid = $this->createServer($host, $port, $documentRoot);
    
    $this->waitForServer($host, $port);
    
    return $pid;
}

            

                protected function buildCallUrl($url, array $params = [])
{
    if (is_array($url)) {
        $path = $url[0];
        unset($url[0]);
        $params = array_merge($url, $params);
    } else {
        $path = $url;
    }
    
    $url = "{$this->host}:{$this->port}/" . ltrim($path, '/');
    
    if (!empty($params)) {
        $url .= '?' . http_build_query($params);
    }
    
    return $url;
}

            

                protected function buildPartialJson($contains, $removeBrackets = false)
{
    if (is_array($contains)) {
        $contains = Json::encode($contains);
        if ($removeBrackets) {
            $contains = substr(substr($contains, 1), 0, -1);
        }
    }
    
    return $contains;
}

            

                protected function connectToServer($host, $port)
{
    $fp = @fsockopen($host, $port, $errno, $errstr, 3);
    if ($fp === false) {
        return false;
    }
    fclose($fp);
    return true;
}

            

                public function createGetCurl($url, array $params = [])
{
    $callUrl = $this->buildCallUrl($url, $params);
    $curl = (new Curl())->get($callUrl);
    
    if ($this->debug) {
        $this->debugMessage($callUrl, $curl);
    }
    
    return $curl;
}

            

                public function createPostCurl($url, array $data = [], array $params = [])
{
    $callUrl = $this->buildCallUrl($url, $params);
    $curl = (new Curl())->post($callUrl, $data);
    
    if ($this->debug) {
        $this->debugMessage($callUrl, $curl);
    }
    
    return $curl;
}

            

                protected function createServer($host, $port, $documentRoot)
{
    $command = sprintf(PHP_BINARY . ' -S %s:%d -t %s >/dev/null 2>&1 & echo $!', $host, $port, $documentRoot);
    
    // Execute the command and store the process ID
    $output = [];
    exec($command, $output);
    
    return (int) $output[0];
}

            

                protected function debugMessage($url, Curl $curl)
{
    echo PHP_EOL;
    echo "======================================================" . PHP_EOL;
    echo "REQUEST URL: " . $url . PHP_EOL;
    echo "------------------------------------------------------" . PHP_EOL;
    echo "REQUEST HEADERS:" . PHP_EOL;
    print_r($curl->request_headers) . PHP_EOL;
    echo "------------------------------------------------------" . PHP_EOL;
    echo "RESPONSE:" . PHP_EOL;
    echo $curl->response;
    echo "------------------------------------------------------" . PHP_EOL;
    echo "RESPONSE HEADERS:" . PHP_EOL;
    print_r($curl->response_headers) . PHP_EOL;
    echo "======================================================" . PHP_EOL;
    echo PHP_EOL;
}

            

                protected function killServer($pid)
{
    exec('kill -9 ' . (int) $pid);
}

            

                protected function waitForServer($host, $port)
{
    $start = microtime(true);
    while (microtime(true) - $start <= (int) 200) {
        if ($this->connectToServer($host, $port)) {
            break;
        }
    }
    
    return true;
}

            

                protected function waitForServerShutdown($host, $port)
{
    $start = microtime(true);
    while (microtime(true) - $start <= (int) 200) {
        if (!$this->connectToServer($host, $port)) {
            break;
        }
    }
    
    return true;
}