composer require pipeopshq/rexec

<?php

require 'vendor/autoload.php';

use Rexec\RexecClient;

// Create client
$client = new RexecClient('https://your-instance.com', 'your-api-token');

// Create a container
$container = $client->containers()->create('ubuntu:24.04');
echo "Created: {$container->id}\n";

// Start it
$client->containers()->start($container->id);

// Execute a command
$result = $client->containers()->exec($container->id, "echo 'Hello from PHP!'");
echo $result->stdout;

// Clean up
$client->containers()->delete($container->id);

use Rexec\RexecClient;

$client = new RexecClient(
    'https://your-instance.com',
    'your-api-token'
);

$client = new RexecClient(
    'https://your-instance.com',
    'your-api-token',
    [
        'timeout' => 60,
        'verify' => true,
    ]
);

$containers = $client->containers()->list();

foreach ($containers as $c) {
    echo "{$c->name}: {$c->status}\n";
}

// Simple creation
$container = $client->containers()->create('ubuntu:24.04');

// With options
$container = $client->containers()->create('python:3.12', [
    'name' => 'my-python-sandbox',
    'environment' => ['PYTHONPATH' => '/app'],
    'labels' => ['project' => 'demo'],
]);

echo "Created: {$container->id}\n";

$container = $client->containers()->get($containerId);
echo "Container {$container->name} is {$container->status}\n";

$client->containers()->start($containerId);

$client->containers()->stop($containerId);

$client->containers()->delete($containerId);

// Execute a simple command
$result = $client->containers()->exec($containerId, 'python --version');

if ($result->isSuccess()) {
    echo "Output: {$result->stdout}\n";
} else {
    echo "Error: {$result->stderr}\n";
}

// Execute with array command
$result = $client->containers()->exec(
    $containerId,
    ['python', '-c', 'print("Hello")']
);

$files = $client->files()->list($containerId, '/app');

foreach ($files as $file) {
    $type = $file->isDir ? 'DIR' : "{$file->size} bytes";
    echo "{$file->name} - {$type}\n";
}

$content = $client->files()->read($containerId, '/etc/hostname');
echo "Hostname: {$content}\n";

$client->files()->write(
    $containerId,
    '/app/script.py',
    "print('Hello!')"
);

$client->files()->delete($containerId, '/tmp/scratch.txt');

use React\EventLoop\Loop;

$terminal = $client->terminal()->connect($containerId);

// Set up handlers
$terminal->onData(function ($data) {
    echo $data;
});

$terminal->onClose(function () {
    echo "Disconnected\n";
});

$terminal->onError(function ($e) {
    echo "Error: {$e->getMessage()}\n";
});

// Open connection
$terminal->open();

// Send commands
$terminal->write("ls -la\n");
$terminal->write("cd /app && python main.py\n");

// Resize terminal
$terminal->resize(120, 40);

// Run the event loop
Loop::run();

// Clean up
$terminal->close();

$terminal = $client->terminal()->connect($containerId, [
    'cols' => 120,
    'rows' => 40,
]);

function runScript(
    RexecClient $client,
    string $containerId,
    string $script
): string {
    $output = '';
    $terminal = $client->terminal()->connect($containerId);
    
    $terminal->onData(function ($data) use (&$output) {
        $output .= $data;
    });
    
    $terminal->open();
    $terminal->write("{$script}\nexit\n");
    
    Loop::run();
    
    return $output;
}

// Usage
$result = runScript(
    $client,
    $container->id,
    'apt update && apt install -y curl'
);
echo $result;

use React\Promise\all;

function createBatch(
    RexecClient $client,
    int $count
): array {
    $promises = [];
    
    for ($i = 0; $i < $count; $i++) {
        $promises[] = $client->containers()->createAsync('ubuntu:24.04', [
            'name' => "worker-{$i}",
        ]);
    }
    
    return all($promises)->wait();
}

// Create 5 containers
$containers = createBatch($client, 5);
echo "Created " . count($containers) . " containers\n";

function uploadFile(
    RexecClient $client,
    string $containerId,
    string $localPath,
    string $remotePath
): void {
    $content = file_get_contents($localPath);
    $client->files()->write($containerId, $remotePath, $content);
}

// Usage
uploadFile(
    $client,
    $container->id,
    './local-script.sh',
    '/home/script.sh'
);

function syncDirectory(
    RexecClient $client,
    string $containerId,
    string $localDir,
    string $remoteDir
): void {
    $client->files()->mkdir($containerId, $remoteDir);
    
    $iterator = new RecursiveIteratorIterator(
        new RecursiveDirectoryIterator($localDir)
    );
    
    foreach ($iterator as $file) {
        if ($file->isFile()) {
            $relativePath = substr($file->getPathname(), strlen($localDir));
            $remotePath = $remoteDir . $relativePath;
            
            $content = file_get_contents($file->getPathname());
            $client->files()->write($containerId, $remotePath, $content);
            
            echo "Uploaded: {$remotePath}\n";
        }
    }
}

use Rexec\RexecException;

try {
    $container = $client->containers()->get('invalid-id');
} catch (RexecException $e) {
    if ($e->isApiError()) {
        echo "API error {$e->getStatusCode()}: {$e->getMessage()}\n";
    } else {
        echo "Network error: {$e->getMessage()}\n";
    }
}

// All methods have full type hints
public function create(
    string $image,
    array $options = []
): Container;

// Return types are declared
public function list(): array;

// Nullable types where appropriate
public function get(string $id): ?Container;

composer require react/event-loop
composer require ratchet/pawl

cd sdk/php
composer install
composer test