🍲dfcv🏰dd⋉(● ∸ ●)⋊@% PNG %k25u25%fgd5n! PNG %k25u25%fgd5n!PK bX]O,* * $ psysh/src/ExecutionLoop/Listener.phpnu [ 0) {
// This is the main thread. We'll just wait for a while.
// We won't be needing this one.
\fclose($up);
// Wait for a return value from the loop process.
$read = [$down];
$write = null;
$except = null;
do {
$n = @\stream_select($read, $write, $except, null);
if ($n === 0) {
throw new \RuntimeException('Process timed out waiting for execution loop');
}
if ($n === false) {
$err = \error_get_last();
if (!isset($err['message']) || \stripos($err['message'], 'interrupted system call') === false) {
$msg = $err['message'] ?
\sprintf('Error waiting for execution loop: %s', $err['message']) :
'Error waiting for execution loop';
throw new \RuntimeException($msg);
}
}
} while ($n < 1);
$content = \stream_get_contents($down);
\fclose($down);
if ($content) {
$shell->setScopeVariables(@\unserialize($content));
}
throw new BreakException('Exiting main thread');
}
// This is the child process. It's going to do all the work.
if (!@\cli_set_process_title('psysh (loop)')) {
// Fall back to `setproctitle` if that wasn't succesful.
if (\function_exists('setproctitle')) {
@\setproctitle('psysh (loop)');
}
}
// We won't be needing this one.
\fclose($down);
// Save this; we'll need to close it in `afterRun`
$this->up = $up;
}
/**
* Create a savegame at the start of each loop iteration.
*
* @param Shell $shell
*/
public function beforeLoop(Shell $shell)
{
$this->createSavegame();
}
/**
* Clean up old savegames at the end of each loop iteration.
*
* @param Shell $shell
*/
public function afterLoop(Shell $shell)
{
// if there's an old savegame hanging around, let's kill it.
if (isset($this->savegame)) {
\posix_kill($this->savegame, \SIGKILL);
\pcntl_signal_dispatch();
}
}
/**
* After the REPL session ends, send the scope variables back up to the main
* thread (if this is a child thread).
*
* @param Shell $shell
*/
public function afterRun(Shell $shell)
{
// We're a child thread. Send the scope variables back up to the main thread.
if (isset($this->up)) {
\fwrite($this->up, $this->serializeReturn($shell->getScopeVariables(false)));
\fclose($this->up);
\posix_kill(\posix_getpid(), \SIGKILL);
}
}
/**
* Create a savegame fork.
*
* The savegame contains the current execution state, and can be resumed in
* the event that the worker dies unexpectedly (for example, by encountering
* a PHP fatal error).
*/
private function createSavegame()
{
// the current process will become the savegame
$this->savegame = \posix_getpid();
$pid = \pcntl_fork();
if ($pid < 0) {
throw new \RuntimeException('Unable to create savegame fork');
} elseif ($pid > 0) {
// we're the savegame now... let's wait and see what happens
\pcntl_waitpid($pid, $status);
// worker exited cleanly, let's bail
if (!\pcntl_wexitstatus($status)) {
\posix_kill(\posix_getpid(), \SIGKILL);
}
// worker didn't exit cleanly, we'll need to have another go
$this->createSavegame();
}
}
/**
* Serialize all serializable return values.
*
* A naïve serialization will run into issues if there is a Closure or
* SimpleXMLElement (among other things) in scope when exiting the execution
* loop. We'll just ignore these unserializable classes, and serialize what
* we can.
*
* @param array $return
*/
private function serializeReturn(array $return): string
{
$serializable = [];
foreach ($return as $key => $value) {
// No need to return magic variables
if (Context::isSpecialVariableName($key)) {
continue;
}
// Resources and Closures don't error, but they don't serialize well either.
if (\is_resource($value) || $value instanceof \Closure) {
continue;
}
if (\version_compare(\PHP_VERSION, '8.1', '>=') && $value instanceof \UnitEnum) {
// Enums defined in the REPL session can't be unserialized.
$ref = new \ReflectionObject($value);
if (\strpos($ref->getFileName(), ": eval()'d code") !== false) {
continue;
}
}
try {
@\serialize($value);
$serializable[$key] = $value;
} catch (\Throwable $e) {
// we'll just ignore this one...
}
}
return @\serialize($serializable);
}
}
PK bX] 0 0 * psysh/src/ExecutionLoop/RunkitReloader.phpnu [ parser = (new ParserFactory())->createParser();
}
/**
* Reload code on input.
*
* @param Shell $shell
* @param string $input
*/
public function onInput(Shell $shell, string $input)
{
$this->reload($shell);
}
/**
* Look through included files and update anything with a new timestamp.
*
* @param Shell $shell
*/
private function reload(Shell $shell)
{
\clearstatcache();
$modified = [];
foreach (\get_included_files() as $file) {
$timestamp = \filemtime($file);
if (!isset($this->timestamps[$file])) {
$this->timestamps[$file] = $timestamp;
continue;
}
if ($this->timestamps[$file] === $timestamp) {
continue;
}
if (!$this->lintFile($file)) {
$msg = \sprintf('Modified file "%s" could not be reloaded', $file);
$shell->writeException(new ParseErrorException($msg));
continue;
}
$modified[] = $file;
$this->timestamps[$file] = $timestamp;
}
// switch (count($modified)) {
// case 0:
// return;
// case 1:
// printf("Reloading modified file: \"%s\"\n", str_replace(getcwd(), '.', $file));
// break;
// default:
// printf("Reloading %d modified files\n", count($modified));
// break;
// }
foreach ($modified as $file) {
$flags = (
RUNKIT_IMPORT_FUNCTIONS |
RUNKIT_IMPORT_CLASSES |
RUNKIT_IMPORT_CLASS_METHODS |
RUNKIT_IMPORT_CLASS_CONSTS |
RUNKIT_IMPORT_CLASS_PROPS |
RUNKIT_IMPORT_OVERRIDE
);
// these two const cannot be used with RUNKIT_IMPORT_OVERRIDE in runkit7
if (\extension_loaded('runkit7')) {
$flags &= ~RUNKIT_IMPORT_CLASS_PROPS & ~RUNKIT_IMPORT_CLASS_STATIC_PROPS;
runkit7_import($file, $flags);
} else {
runkit_import($file, $flags);
}
}
}
/**
* Should this file be re-imported?
*
* Use PHP-Parser to ensure that the file is valid PHP.
*
* @param string $file
*/
private function lintFile(string $file): bool
{
// first try to parse it
try {
$this->parser->parse(\file_get_contents($file));
} catch (\Throwable $e) {
return false;
}
return true;
}
}
PK bX]a'5 5 6 psysh/src/VersionUpdater/Downloader/CurlDownloader.phpnu [ tempDir = $tempDir;
}
/** {@inheritDoc} */
public function download(string $url): bool
{
$tempDir = $this->tempDir ?: \sys_get_temp_dir();
$this->outputFile = \tempnam($tempDir, 'psysh-archive-');
$targetName = $this->outputFile.'.tar.gz';
if (!\rename($this->outputFile, $targetName)) {
return false;
}
$this->outputFile = $targetName;
$outputHandle = \fopen($this->outputFile, 'w');
if (!$outputHandle) {
return false;
}
$curl = \curl_init();
\curl_setopt_array($curl, [
\CURLOPT_FAILONERROR => true,
\CURLOPT_HEADER => 0,
\CURLOPT_FOLLOWLOCATION => true,
\CURLOPT_TIMEOUT => 10,
\CURLOPT_FILE => $outputHandle,
\CURLOPT_HTTPHEADER => [
'User-Agent' => 'PsySH/'.Shell::VERSION,
],
]);
\curl_setopt($curl, \CURLOPT_URL, $url);
$result = \curl_exec($curl);
$error = \curl_error($curl);
\curl_close($curl);
\fclose($outputHandle);
if (!$result) {
throw new ErrorException('cURL Error: '.$error);
}
return (bool) $result;
}
/** {@inheritDoc} */
public function getFilename(): string
{
return $this->outputFile;
}
/** {@inheritDoc} */
public function cleanup()
{
if (\file_exists($this->outputFile)) {
\unlink($this->outputFile);
}
}
}
PK bX]e / psysh/src/VersionUpdater/Downloader/Factory.phpnu [ tempDir = $tempDir;
}
/** {@inheritDoc} */
public function download(string $url): bool
{
$tempDir = $this->tempDir ?: \sys_get_temp_dir();
$this->outputFile = \tempnam($tempDir, 'psysh-archive-');
$targetName = $this->outputFile.'.tar.gz';
if (!\rename($this->outputFile, $targetName)) {
return false;
}
$this->outputFile = $targetName;
return (bool) \file_put_contents($this->outputFile, \file_get_contents($url));
}
/** {@inheritDoc} */
public function getFilename(): string
{
return $this->outputFile;
}
/** {@inheritDoc} */
public function cleanup()
{
if (\file_exists($this->outputFile)) {
\unlink($this->outputFile);
}
}
}
PK bX]
$ psysh/src/VersionUpdater/Checker.phpnu [ checker = $checker;
$this->installer = $installer;
}
/**
* Allow the downloader to be injected for testing.
*
* @param Downloader $downloader
*
* @return void
*/
public function setDownloader(Downloader $downloader)
{
$this->downloader = $downloader;
}
/**
* Get the currently set Downloader or create one based on the capabilities of the php environment.
*
* @throws ErrorException if a downloader cannot be created for the php environment
*/
private function getDownloader(): Downloader
{
if (!isset($this->downloader)) {
return Downloader\Factory::getDownloader();
}
return $this->downloader;
}
/**
* Build the download URL for the latest release.
*
* The file name used in the URL will include the flavour postfix extracted from the current version
* if it's present
*
* @param string $latestVersion
*/
private function getAssetUrl(string $latestVersion): string
{
$versionPostfix = '';
if (\strpos(Shell::VERSION, '+')) {
$versionPostfix = '-'.\substr(Shell::VERSION, \strpos(Shell::VERSION, '+') + 1);
}
$downloadFilename = \sprintf('psysh-%s%s.tar.gz', $latestVersion, $versionPostfix);
// check if latest release data contains an asset matching the filename?
return \sprintf('%s/%s/%s', self::URL_PREFIX, $latestVersion, $downloadFilename);
}
/**
* Execute the self-update process.
*
* @param InputInterface $input
* @param OutputInterface $output
*
* @throws ErrorException if the current version is not restored when installation fails
*/
public function run(InputInterface $input, OutputInterface $output): int
{
$currentVersion = Shell::VERSION;
// already have the latest version?
if ($this->checker->isLatest()) {
// current version is latest version...
$output->writeln('Current version is up-to-date.');
return self::SUCCESS;
}
// can overwrite current version?
if (!$this->installer->isInstallLocationWritable()) {
$output->writeln('Installed version is not writable.');
return self::FAILURE;
}
// can download to, and create a backup in the temp directory?
if (!$this->installer->isTempDirectoryWritable()) {
$output->writeln('Temporary directory is not writable.');
return self::FAILURE;
}
$latestVersion = $this->checker->getLatest();
$downloadUrl = $this->getAssetUrl($latestVersion);
$output->write("Downloading PsySH $latestVersion ...");
try {
$downloader = $this->getDownloader();
$downloader->setTempDir($this->installer->getTempDirectory());
$downloaded = $downloader->download($downloadUrl);
} catch (ErrorException $e) {
$output->write(' Failed.');
$output->writeln(\sprintf('%s', $e->getMessage()));
return self::FAILURE;
}
if (!$downloaded) {
$output->writeln('Download failed.');
$downloader->cleanup();
return self::FAILURE;
} else {
$output->write(' OK'.\PHP_EOL);
}
$downloadedFile = $downloader->getFilename();
if (!$this->installer->isValidSource($downloadedFile)) {
$downloader->cleanup();
$output->writeln('Downloaded file is not a valid archive.');
return self::FAILURE;
}
// create backup as bin.old-version in the temporary directory
$backupCreated = $this->installer->createBackup($currentVersion);
if (!$backupCreated) {
$downloader->cleanup();
$output->writeln('Failed to create a backup of the current version.');
return self::FAILURE;
} elseif ($input->getOption('verbose')) {
$backupFilename = $this->installer->getBackupFilename($currentVersion);
$output->writeln('Created backup of current version: '.$backupFilename);
}
if (!$this->installer->install($downloadedFile)) {
$this->installer->restoreFromBackup($currentVersion);
$downloader->cleanup();
$output->writeln("Failed to install new PsySH version $latestVersion.");
return self::FAILURE;
}
// Remove the downloaded archive file from the temporary directory
$downloader->cleanup();
$output->writeln("Updated PsySH from $currentVersion to $latestVersion");
return self::SUCCESS;
}
}
PK bX]8r# # &