start.php

<?php
/**
 * This file is part of workerman.
*
* Licensed under The MIT License
* For full copyright and license information, please see the MIT-LICENSE.txt
* Redistributions of files must retain the above copyright notice.
*
* @author walkor<walkor@workerman.net>
* @copyright walkor<walkor@workerman.net>
* @link http://www.workerman.net/
* @license http://www.opensource.org/licenses/mit-license.php MIT License
*/

use \Workerman\Worker;
use Workerman\Protocols\Http\Request;
use Workerman\Protocols\Http\Response;
use Workerman\Connection\TcpConnection;

// Command. For example 'tail -f /var/log/nginx/access.log'.
define('CMD', 'htop');

// Whether to allow client input.
define('ALLOW_CLIENT_INPUT', true);

// Uinix user for command. Recommend nobody www etc. 
define('USER', 'www-data');

require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker("Websocket://0.0.0.0:7778");
$worker->name = 'phptty';
$worker->user = USER;

$worker->onConnect = function($connection)
{
    //To do this, PHP_CAN_DO_PTS must be enabled. See ext/standard/proc_open.c in PHP directory.
    /*$descriptorspec = array(
        0 => array('pty'),
        1 => array('pty'),
        2 => array('pty')
    );*/
    
    //Pipe can not do PTY. Thus, many features of PTY can not be used.
    //e.g. sudo, w3m, luit, all C programs using termios.h, etc.
    $descriptorspec = array(
        0=>array("pipe", "r"),
        1=>array("pipe", "w"),
        2=>array("pipe", "w")
    );
    
    unset($_SERVER['argv']);
    $env = array_merge(
        array('COLUMNS'=>130, 'LINES'=> 50), $_SERVER
    );
    $connection->process = proc_open(CMD, $descriptorspec, $pipes, null, $env);
    $connection->pipes = $pipes;
    stream_set_blocking($pipes[0], 0);
    $connection->process_stdout = new TcpConnection($pipes[1]);
    $connection->process_stdout->onMessage = function($process_connection, $data)use($connection)
    {
        $connection->send($data);
    };
    $connection->process_stdout->onClose = function($process_connection)use($connection)
    {
        $connection->close();   //Close WebSocket connection on process exit.
    };
    $connection->process_stdin = new TcpConnection($pipes[2]);
    $connection->process_stdin->onMessage = function($process_connection, $data)use($connection)
    {
        $connection->send($data);
    };
};

$worker->onMessage = function($connection, $data)
{
    if(ALLOW_CLIENT_INPUT)
    {
        fwrite($connection->pipes[0], $data);
    }
};

$worker->onClose = function($connection)
{
    $connection->process_stdin->close();
    $connection->process_stdout->close();
    fclose($connection->pipes[0]);
    $connection->pipes = null;
    proc_terminate($connection->process);
    proc_close($connection->process);
    $connection->process = null;
};

$worker->onWorkerStop = function($worker)
{
    foreach($worker->connections as $connection)
    {
        $connection->close();
    }
};

$web = new Worker('http://0.0.0.0:7779');
$web->name = 'web';

define('WEBROOT', __DIR__ . '/Web');

$web->onMessage = function (TcpConnection $connection, Request $request) {
    $path = $request->path();
    if ($path === '/') {
        $connection->send(exec_php_file(WEBROOT.'/index.html'));
        return;
    }
    $file = realpath(WEBROOT. $path);
    if (false === $file) {
        $connection->send(new Response(404, array(), '<h3>404 Not Found</h3>'));
        return;
    }
    // Security check! Very important!!!
    if (strpos($file, WEBROOT) !== 0) {
        $connection->send(new Response(400));
        return;
    }
    if (\pathinfo($file, PATHINFO_EXTENSION) === 'php') {
        $connection->send(exec_php_file($file));
        return;
    }

    $if_modified_since = $request->header('if-modified-since');
    if (!empty($if_modified_since)) {
        // Check 304.
        $info = \stat($file);
        $modified_time = $info ? \date('D, d M Y H:i:s', $info['mtime']) . ' ' . \date_default_timezone_get() : '';
        if ($modified_time === $if_modified_since) {
            $connection->send(new Response(304));
            return;
        }
    }
    $connection->send((new Response())->withFile($file));
};

function exec_php_file($file) {
    \ob_start();
    // Try to include php file.
    try {
        include $file;
    } catch (\Exception $e) {
        echo $e;
    }
    return \ob_get_clean();
}

if(!defined('GLOBAL_START'))
{
    Worker::runAll();
}