Allow to expose ports

Author: AydinHassan

src/Exercise/Scenario/ExerciseScenario.php

@@ -9,6 +9,11 @@ abstract class ExerciseScenario
      */
     private array $files = [];
 
+    /**
+     * @var list<int>
+     */
+    private array $exposedPorts = [];
+
     public function withFile(string $relativeFileName, string $content): static
     {
         $this->files[$relativeFileName] = $content;
@@ -23,4 +28,19 @@ public function getFiles(): array
     {
         return $this->files;
     }
+
+    public function exposePort(int $port): static
+    {
+        $this->exposedPorts = [$port];
+
+        return $this;
+    }
+
+    /**
+     * @return list<int>
+     */
+    public function getExposedPorts(): array
+    {
+        return $this->exposedPorts;
+    }
 }

src/ExerciseRunner/CgiRunner.php

@@ -215,7 +215,7 @@ private function executePhpFile(
         RequestInterface $request,
         string $type,
     ): ResponseInterface {
-        $process = $this->getPhpProcess($workingDirectory, $fileName, $request);
+        $process = $this->getPhpProcess($workingDirectory, $fileName, $request, $scenario->getExposedPorts());
 
         $process->start();
         $this->eventDispatcher->dispatch(
@@ -238,11 +238,9 @@ private function executePhpFile(
     }
 
     /**
-     * @param string $fileName
-     * @param RequestInterface $request
-     * @return Process
+     * @param list<int> $exposedPorts
      */
-    private function getPhpProcess(string $workingDirectory, string $fileName, RequestInterface $request): Process
+    private function getPhpProcess(string $workingDirectory, string $fileName, RequestInterface $request, array $exposedPorts): Process
     {
         $env = [
             'REQUEST_METHOD'  => $request->getMethod(),
@@ -270,6 +268,7 @@ private function getPhpProcess(string $workingDirectory, string $fileName, Reque
             ],
             $workingDirectory,
             $env,
+            $exposedPorts,
             $content,
         );
 
@@ -311,6 +310,7 @@ public function run(ExecutionContext $context, OutputInterface $output): bool
                 $context->getStudentExecutionDirectory(),
                 $context->getEntryPoint(),
                 $event->getRequest(),
+                $scenario->getExposedPorts(),
             );
 
             $process->start();

src/ExerciseRunner/CliRunner.php

@@ -206,6 +206,8 @@ public function run(ExecutionContext $context, OutputInterface $output): bool
         $scenario = $this->exercise->defineTestScenario();
 
         $this->environmentManager->prepareStudent($context, $scenario);
+        $this->environmentManager->prepareReference($context, $scenario);
+
 
         $this->eventDispatcher->dispatch(new CliExerciseRunnerEvent('cli.run.start', $context, $scenario));
 
@@ -222,6 +224,7 @@ public function run(ExecutionContext $context, OutputInterface $output): bool
                 $context->getStudentExecutionDirectory(),
                 $context->getEntryPoint(),
                 $args,
+                $scenario->getExposedPorts(),
             );
 
             $process->start();
@@ -231,6 +234,7 @@ public function run(ExecutionContext $context, OutputInterface $output): bool
             $process->wait(function ($outputType, $outputBuffer) use ($output) {
                 $output->write($outputBuffer);
             });
+
             $output->emptyLine();
 
             if (!$process->isSuccessful()) {
@@ -254,7 +258,7 @@ public function run(ExecutionContext $context, OutputInterface $output): bool
      */
     private function executePhpFile(ExecutionContext $context, CliScenario $scenario, string $workingDirectory, string $fileName, Collection $args, string $type): string
     {
-        $process = $this->getPhpProcess($workingDirectory, $fileName, $args);
+        $process = $this->getPhpProcess($workingDirectory, $fileName, $args, $scenario->getExposedPorts());
 
         $process->start();
         $this->eventDispatcher->dispatch(
@@ -271,11 +275,12 @@ private function executePhpFile(ExecutionContext $context, CliScenario $scenario
 
     /**
      * @param Collection<int, string> $args
+     * @param list<int> $exposedPorts
      */
-    private function getPhpProcess(string $workingDirectory, string $fileName, Collection $args): Process
+    private function getPhpProcess(string $workingDirectory, string $fileName, Collection $args, array $exposedPorts): Process
     {
         return $this->processFactory->create(
-            new ProcessInput('php', [$fileName, ...$args->getArrayCopy()], $workingDirectory, []),
+            new ProcessInput('php', [$fileName, ...$args->getArrayCopy()], $workingDirectory, [], $exposedPorts),
         );
     }
 }

src/Listener/PrepareSolutionListener.php

@@ -41,7 +41,7 @@ public function __invoke(ExerciseRunnerEvent $event): void
         //only install if vendor folder not available
         if (!file_exists(sprintf('%s/vendor', $event->getContext()->getReferenceExecutionDirectory()))) {
             $process = $this->processFactory->create(
-                new ProcessInput('composer', ['install', '--no-interaction'], $event->getContext()->getReferenceExecutionDirectory(), []),
+                new ProcessInput('composer', ['install', '--no-interaction'], $event->getContext()->getReferenceExecutionDirectory(), [], []),
             );
 
             try {

src/Process/DockerProcessFactory.php

@@ -40,12 +40,18 @@ public function create(ProcessInput $processInput): Process
             $env[] = $key . '=' . $value;
         }
 
+        $ports = [];
+        foreach ($processInput->getExposedPorts() as $port) {
+            $ports[] = '-p';
+            $ports[] = $port . ':' . $port;
+        }
+
         $env[]  = '-e';
         $env[]  = 'COMPOSER_HOME=/tmp/composer';
 
-        return new Process(
+        $p = new Process(
             [
-                ...$this->baseComposeCommand($mounts, $env),
+                ...$this->baseComposeCommand($mounts, $env, $ports),
                 'runtime',
                 $processInput->getExecutable(),
                 ...$processInput->getArgs(),
@@ -59,14 +65,17 @@ public function create(ProcessInput $processInput): Process
             $processInput->getInput(),
             30,
         );
+
+        return $p;
     }
 
     /**
      * @param array<string> $mounts
      * @param array<string> $env
+     * @param list<string> $ports
      * @return array<string>
      */
-    private function baseComposeCommand(array $mounts, array $env): array
+    private function baseComposeCommand(array $mounts, array $env, array $ports): array
     {
         $dockerPath = $this->executableFinder->find('docker');
         if ($dockerPath === null) {
@@ -85,6 +94,7 @@ private function baseComposeCommand(array $mounts, array $env): array
             getmyuid() . ':' . getmygid(),
             '--rm',
             ...$env,
+            ...$ports,
             '-w',
             '/solution',
             ...array_merge(...array_map(fn($mount) => ['-v', $mount], $mounts)),

src/Process/ProcessInput.php

@@ -7,12 +7,14 @@ class ProcessInput
     /**
      * @param list<string> $args
      * @param array<string, string> $env
+     * @param list<int> $exposedPorts
      */
     public function __construct(
         private string $executable,
         private array $args,
         private string $workingDirectory,
         private array $env,
+        private array $exposedPorts,
         private ?string $input = null,
     ) {}
 
@@ -42,6 +44,14 @@ public function getEnv(): array
         return $this->env;
     }
 
+    /**
+     * @return list<int>
+     */
+    public function getExposedPorts(): array
+    {
+        return $this->exposedPorts;
+    }
+
     public function getInput(): ?string
     {
         return $this->input;