<?php
use Utopia\Proxy\Resolver;
use Utopia\Proxy\Resolver\Result;
use Utopia\Proxy\Resolver\Exception;

class MyResolver implements Resolver
{
    public function resolve(string $resourceId): Result
    {
        $backends = [
            'api.example.com' => 'localhost:3000',
            'app.example.com' => 'localhost:3001',
        ];

        if (!isset($backends[$resourceId])) {
            throw new Exception(
                "No backend for: {$resourceId}",
                Exception::NOT_FOUND
            );
        }

        return new Result(endpoint: $backends[$resourceId]);
    }

    public function track(string $resourceId, array $metadata = []): void {}
    public function purge(string $resourceId): void {}
    public function getStats(): array { return []; }
    public function onConnect(string $resourceId, array $metadata = []): void {}
    public function onDisconnect(string $resourceId, array $metadata = []): void {}
}

<?php
require 'vendor/autoload.php';

use Utopia\Proxy\Server\HTTP\Config;
use Utopia\Proxy\Server\HTTP\Swoole as HTTPServer;

$resolver = new MyResolver();

$config = new Config(
    host: '0.0.0.0',
    port: 80,
    workers: swoole_cpu_num() * 2,
);

$server = new HTTPServer($resolver, $config);
$server->start();

<?php
require 'vendor/autoload.php';

use Utopia\Proxy\Server\TCP\Config;
use Utopia\Proxy\Server\TCP\Swoole as TCPServer;

$resolver = new MyResolver();

$config = new Config(
    host: '0.0.0.0',
    ports: [5432, 3306, 27017],
    workers: swoole_cpu_num() * 2,
);

$server = new TCPServer($resolver, $config);
$server->start();

<?php
require 'vendor/autoload.php';

use Utopia\Proxy\Server\SMTP\Config;
use Utopia\Proxy\Server\SMTP\Swoole as SMTPServer;

$resolver = new MyResolver();

$config = new Config(
    host: '0.0.0.0',
    port: 25,
    workers: swoole_cpu_num() * 2,
);

$server = new SMTPServer($resolver, $config);
$server->start();

<?php
use Utopia\Proxy\Server\TCP\Config;
use Utopia\Proxy\Server\TCP\TLS;
use Utopia\Proxy\Server\TCP\Swoole as TCPServer;

$tls = new TLS(
    certificate: '/certs/server.crt',
    key: '/certs/server.key',
    ca: '/certs/ca.crt',           // Optional: for mTLS
    requireClientCert: true,            // Optional: require client certs
);

$config = new Config(
    ports: [5432, 3306],
    tls: $tls,
);

$server = new TCPServer($resolver, $config);
$server->start();

<?php
use Utopia\Proxy\Server\HTTP\Config;
use Utopia\Proxy\Server\HTTP\Swoole as HTTPServer;

$config = new Config(
    host: '0.0.0.0',
    port: 80,
    workers: 16,

    // Performance
    maxConnections: 100_000,
    maxCoroutine: 100_000,
    socketBufferSize: 2 * 1024 * 1024,
    bufferOutputSize: 2 * 1024 * 1024,
    poolSize: 1024,
    timeout: 30.0,
    connectTimeout: 5.0,
    keepAlive: true,

    // Behavior
    fastPath: false,           // Minimal header processing
    fastPathAssumeOk: false,   // Skip status code forwarding
    fixedBackend: null,        // Route all requests to static endpoint
    directResponse: null,      // Return static response without forwarding
    rawBackend: false,         // Use raw TCP for GET/HEAD (benchmark only)
    telemetry: true,           // Add X-Proxy-* response headers
    skipValidation: false,     // Disable SSRF protection

    // Protocol
    http2Protocol: false,
    keepaliveTimeout: 60,
    cacheTTL: 60,
);

$server = new HTTPServer($resolver, $config);

<?php
use Utopia\Proxy\Server\TCP\Config;
use Utopia\Proxy\Server\TCP\Swoole as TCPServer;

$config = new Config(
    host: '0.0.0.0',
    ports: [5432, 3306, 27017],
    workers: 16,
    maxConnections: 200_000,
    maxCoroutine: 200_000,
    socketBufferSize: 16 * 1024 * 1024,
    bufferOutputSize: 16 * 1024 * 1024,
    receiveBufferSize: 131_072,
    timeout: 30.0,
    connectTimeout: 5.0,
    skipValidation: false,
    tls: null,

    // TCP keep-alive
    tcpKeepidle: 30,
    tcpKeepinterval: 10,
    tcpKeepcount: 3,
);

$server = new TCPServer($resolver, $config);

<?php
use Utopia\Proxy\Server\SMTP\Config;
use Utopia\Proxy\Server\SMTP\Swoole as SMTPServer;

$config = new Config(
    host: '0.0.0.0',
    port: 25,
    workers: 16,
    maxConnections: 50_000,
    maxCoroutine: 50_000,
    timeout: 30.0,
    connectTimeout: 5.0,
    skipValidation: false,
    cacheTTL: 60,
);

$server = new SMTPServer($resolver, $config);

enum Protocol: string
{
    case HTTP = 'http';
    case SMTP = 'smtp';
    case TCP = 'tcp';
    case PostgreSQL = 'postgresql';
    case MySQL = 'mysql';
    case MongoDB = 'mongodb';
    case Redis = 'redis';
    case Memcached = 'memcached';
    case Kafka = 'kafka';
    case AMQP = 'amqp';
    case ClickHouse = 'clickhouse';
    case Cassandra = 'cassandra';
    case NATS = 'nats';
    case MSSQL = 'mssql';
    case Oracle = 'oracle';
    case Elasticsearch = 'elasticsearch';
    case MQTT = 'mqtt';
    case GRPC = 'grpc';
    case ZooKeeper = 'zookeeper';
    case Etcd = 'etcd';
    case Neo4j = 'neo4j';
    case Couchbase = 'couchbase';
    case CockroachDB = 'cockroachdb';
    case TiDB = 'tidb';
    case Pulsar = 'pulsar';
    case FTP = 'ftp';
    case LDAP = 'ldap';
    case RethinkDB = 'rethinkdb';
}

interface Resolver
{
    public function resolve(string $resourceId): Result;
    public function track(string $resourceId, array $metadata = []): void;
    public function purge(string $resourceId): void;
    public function getStats(): array;
    public function onConnect(string $resourceId, array $metadata = []): void;
    public function onDisconnect(string $resourceId, array $metadata = []): void;
}

new Result(
    endpoint: 'host:port',      // Required: backend endpoint
    metadata: ['key' => 'val'], // Optional: additional data
    timeout: 30                 // Optional: connection timeout override
);

throw new Exception('Not found', Exception::NOT_FOUND);    // 404
throw new Exception('Unavailable', Exception::UNAVAILABLE); // 503
throw new Exception('Timeout', Exception::TIMEOUT);         // 504
throw new Exception('Forbidden', Exception::FORBIDDEN);     // 403
throw new Exception('Error', Exception::INTERNAL);          // 500