104 lines
3.6 KiB
PHP
104 lines
3.6 KiB
PHP
<?php
|
|
|
|
use LanguageServer\{LanguageServer, ProtocolStreamReader, ProtocolStreamWriter};
|
|
use Sabre\Event\Loop;
|
|
use Composer\{Factory, XdebugHandler};
|
|
|
|
$options = getopt('', ['tcp::', 'tcp-server::', 'memory-limit::']);
|
|
|
|
ini_set('memory_limit', $options['memory-limit'] ?? '4G');
|
|
|
|
foreach ([__DIR__ . '/../../../autoload.php', __DIR__ . '/../autoload.php', __DIR__ . '/../vendor/autoload.php'] as $file) {
|
|
if (file_exists($file)) {
|
|
require $file;
|
|
break;
|
|
}
|
|
}
|
|
|
|
// Convert all errors to ErrorExceptions
|
|
set_error_handler(function (int $severity, string $message, string $file, int $line) {
|
|
if (!(error_reporting() & $severity)) {
|
|
// This error code is not included in error_reporting (can also be caused by the @ operator)
|
|
return;
|
|
}
|
|
throw new \ErrorException($message, 0, $severity, $file, $line);
|
|
});
|
|
|
|
// Only write uncaught exceptions to STDERR, not STDOUT
|
|
set_exception_handler(function (\Throwable $e) {
|
|
fwrite(STDERR, (string)$e);
|
|
});
|
|
|
|
@cli_set_process_title('PHP Language Server');
|
|
|
|
// If XDebug is enabled, restart without it
|
|
(new XdebugHandler(Factory::createOutput()))->check();
|
|
|
|
if (!empty($options['tcp'])) {
|
|
// Connect to a TCP server
|
|
$address = $options['tcp'];
|
|
$socket = stream_socket_client('tcp://' . $address, $errno, $errstr);
|
|
if ($socket === false) {
|
|
fwrite(STDERR, "Could not connect to language client. Error $errno\n$errstr");
|
|
exit(1);
|
|
}
|
|
stream_set_blocking($socket, false);
|
|
$ls = new LanguageServer(
|
|
new ProtocolStreamReader($socket),
|
|
new ProtocolStreamWriter($socket)
|
|
);
|
|
Loop\run();
|
|
} else if (!empty($options['tcp-server'])) {
|
|
// Run a TCP Server
|
|
$address = $options['tcp-server'];
|
|
$tcpServer = stream_socket_server('tcp://' . $address, $errno, $errstr);
|
|
if ($tcpServer === false) {
|
|
fwrite(STDERR, "Could not listen on $address. Error $errno\n$errstr");
|
|
exit(1);
|
|
}
|
|
fwrite(STDOUT, "Server listening on $address\n");
|
|
if (!extension_loaded('pcntl')) {
|
|
fwrite(STDERR, "PCNTL is not available. Only a single connection will be accepted\n");
|
|
}
|
|
while ($socket = stream_socket_accept($tcpServer, -1)) {
|
|
fwrite(STDOUT, "Connection accepted\n");
|
|
stream_set_blocking($socket, false);
|
|
if (extension_loaded('pcntl')) {
|
|
// If PCNTL is available, fork a child process for the connection
|
|
// An exit notification will only terminate the child process
|
|
$pid = pcntl_fork();
|
|
if ($pid === -1) {
|
|
fwrite(STDERR, "Could not fork\n");
|
|
exit(1);
|
|
} else if ($pid === 0) {
|
|
// Child process
|
|
$reader = new ProtocolStreamReader($socket);
|
|
$writer = new ProtocolStreamWriter($socket);
|
|
$reader->on('close', function () {
|
|
fwrite(STDOUT, "Connection closed\n");
|
|
});
|
|
$ls = new LanguageServer($reader, $writer);
|
|
Loop\run();
|
|
// Just for safety
|
|
exit(0);
|
|
}
|
|
} else {
|
|
// If PCNTL is not available, we only accept one connection.
|
|
// An exit notification will terminate the server
|
|
$ls = new LanguageServer(
|
|
new ProtocolStreamReader($socket),
|
|
new ProtocolStreamWriter($socket)
|
|
);
|
|
Loop\run();
|
|
}
|
|
}
|
|
} else {
|
|
// Use STDIO
|
|
stream_set_blocking(STDIN, false);
|
|
$ls = new LanguageServer(
|
|
new ProtocolStreamReader(STDIN),
|
|
new ProtocolStreamWriter(STDOUT)
|
|
);
|
|
Loop\run();
|
|
}
|