MigratedLanguageFileSyncLockTestCase.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
use ILIAS\Language\ComponentTranslation\CustomizingLanguageFileDirectory;
use ILIAS\Language\ComponentTranslation\LanguageFileDirectory;
use ILIAS\Language\ComponentTranslation\LanguageFileDirectoryManager;
use PHPUnit\Framework\TestCase;
 
abstract class MigratedLanguageFileSyncLockTestCase extends TestCase
{
    use RestoresProcessState;
 
    protected const string MODULE = 'stest';
 
    protected string $client_data_dir;
 
    protected LanguageFileDirectory $directory;
 
    protected LanguageFileDirectoryManager $manager;
 
    protected function setUp(): void
    {
        // never the build of the installation, see MigratedPoFixture::resetRuntime()
        MigratedPoFixture::resetRuntime();
        parent::setUp();
 
        if (!defined('ILIAS_ABSOLUTE_PATH')) {
            define('ILIAS_ABSOLUTE_PATH', realpath(__DIR__ . '/../../../../../'));
        }
 
        $this->client_data_dir = sys_get_temp_dir() . '/ilias_mlfs_lock_test_' . bin2hex(random_bytes(4));
        mkdir($this->client_data_dir, 0775, true);
        $this->directory = MigratedPoFixture::directory(self::MODULE, 'x/');
        $this->manager = new LanguageFileDirectoryManager(new CustomizingLanguageFileDirectory(), $this->directory);
    }
 
    protected function tearDown(): void
    {
        MigratedPoFixture::removeDirectory($this->client_data_dir);
 
        parent::tearDown();
    }
 
    protected function lockFile(): string
    {
        return MigratedPoFixture::overlayLock(MigratedPoFixture::overlayBase($this->client_data_dir, $this->directory, 'de'));
    }
 
    protected function seedLockDirectory(): void
    {
        mkdir(dirname($this->lockFile()), 0775, true);
    }
 
    protected function runPhpWithTimeout(string $code, float $timeout_seconds): array
    {
        $started = ChildPhp::open(['-r', $code]);
        if ($started === null) {
            $this->fail('Could not start the child PHP process.');
        }
        [$process, $pipes] = $started;
        stream_set_blocking($pipes[1], false);
        stream_set_blocking($pipes[2], false);
 
        $deadline = microtime(true) + $timeout_seconds;
        $output = '';
        do {
            $output .= (string) stream_get_contents($pipes[1]);
            $output .= (string) stream_get_contents($pipes[2]);
            $status = proc_get_status($process);
            if (!$status['running']) {
                fclose($pipes[1]);
                fclose($pipes[2]);
                proc_close($process);
 
                return ['finished' => true, 'exit_code' => $status['exitcode'], 'output' => $output];
            }
            usleep(20_000);
        } while (microtime(true) < $deadline);
 
        proc_terminate($process, 9);
        usleep(100_000);
        $output .= (string) stream_get_contents($pipes[1]);
        $output .= (string) stream_get_contents($pipes[2]);
        fclose($pipes[1]);
        fclose($pipes[2]);
        proc_close($process);
 
        return ['finished' => false, 'exit_code' => null, 'output' => $output];
    }
}