fix: support ansi chars

EMS/core-bundle/src/Command/JobOutput.php

@@ -28,8 +28,71 @@ public function doWrite(string $message, bool $newline): void
     {
         $job = $this->jobRepository->findById($this->jobId);
         $job->setStatus($message);
-        $job->setOutput($job->getOutput().$this->getFormatter()->format($message).($newline ? PHP_EOL : ''));
+        $job->setOutput(self::concatenateAnsiString($job->getOutput() ?? '', $this->getFormatter()->format($message)).($newline ? PHP_EOL : ''));
 
         $this->jobRepository->save($job);
     }
+
+    public static function concatenateAnsiString(string $left, string $right): string
+    {
+        $pos = \strrpos($left, "\n");
+        if (false === $pos) {
+            $content = '';
+            $lastLine = $left;
+        } else {
+            $content = \substr($left, 0, $pos + 1);
+            $lastLine = \substr($left, $pos + 1);
+        }
+        $lines = \explode("\n", $right);
+        $first = true;
+        foreach ($lines as $line) {
+            if ($first) {
+                $first = false;
+            } else {
+                $content .= "\n";
+            }
+            $content .= self::concatenateAnsiLines($lastLine, $line);
+        }
+
+        return $content.$lastLine;
+    }
+
+    private static function concatenateAnsiLines(string &$lastLine, string $newLine): string
+    {
+        $newLine = preg_replace("/.\x08/", '', $newLine);
+        \preg_match_all("/\e\[(?P<backspace>[0-9]+)D/", $newLine, $matches, PREG_OFFSET_CAPTURE);
+        if (!empty($matches['backspace'])) {
+            $line = '';
+            $cursor = 0;
+            foreach ($matches['backspace'] as $backspace) {
+                $count = (int) $backspace[0];
+                $line  .= \substr($newLine, $cursor, $backspace[1] - 2);
+                $line = \substr($line, 0, strlen($line) - $count);
+                $cursor = $backspace[1] + strlen($backspace[0]) + 1;
+            }
+            $newLine = $line . \substr($newLine, $cursor);
+        }
+
+        \preg_match_all("/\e\[(?P<column>[0-9]+)G/", $newLine, $matches, PREG_OFFSET_CAPTURE);
+        $cursor = 0;
+        foreach ($matches['column'] as $column) {
+            $lastLine .= substr($newLine, $cursor, $column[1] - 2);
+            $position = (int) $column[0];
+            if ($position > \strlen($lastLine)) {
+                $lastLine = \str_pad($lastLine, $position - 1, ' ', STR_PAD_RIGHT);
+            } else {
+                $lastLine = \substr($lastLine, $cursor, $position - 1 );
+            }
+            $endOfLine = \substr($newLine, $column[1] + \strlen($column[0]) + 1);
+            $cursor = $column[1] - 1;
+        }
+        if (!empty($matches['column'])) {
+            $newLine = $endOfLine;
+        }
+
+        $output = $lastLine;
+        $lastLine = $newLine;
+
+        return $output;
+    }
 }

EMS/core-bundle/src/Service/JobService.php

@@ -161,7 +161,7 @@ public function start(Job $job): JobOutput
         $this->repository->save($job);
 
         $output = new JobOutput($this->repository, $job->getId());
-        $output->setDecorated(false);
+        $output->setDecorated(true);
         $output->writeln('Job ready to be launch');
 
         return $output;

EMS/core-bundle/tests/Unit/Core/Command/JobOutputTest.php

@@ -0,0 +1,39 @@
+<?php
+
+declare(strict_types=1);
+
+namespace EMS\CoreBundle\Tests\Unit\Core\Command;
+
+use EMS\CoreBundle\Command\JobOutput;
+use PHPUnit\Framework\TestCase;
+
+class JobOutputTest extends TestCase
+{
+    public function testSimpleConcatenation(): void
+    {
+        self::assertEquals("foobar", JobOutput::concatenateAnsiString('foo','bar'));
+        self::assertEquals("foo\nbar", JobOutput::concatenateAnsiString("foo\n",'bar'));
+        self::assertEquals("foo\n", JobOutput::concatenateAnsiString("foo\nbar","\e[1G"));
+        self::assertEquals("foo\n", JobOutput::concatenateAnsiString("foo\nbar","Toto\e[1G"));
+        self::assertEquals("foo\nb", JobOutput::concatenateAnsiString("foo\nbar","\e[2G"));
+        self::assertEquals("foo\nbar      ", JobOutput::concatenateAnsiString("foo\nbar","\e[10G"));
+        self::assertEquals("foo\nYes", JobOutput::concatenateAnsiString("foo\nbar","Toto\e[1GNo\e[1GYes"));
+        self::assertEquals("couille", JobOutput::concatenateAnsiString("","coq\x08uille"));
+        self::assertEquals("couille", JobOutput::concatenateAnsiString("","coq\033[1Duille"));
+        self::assertEquals("cuille", JobOutput::concatenateAnsiString("","coq\033[2Duille"));
+    }
+
+    public function testProgressBar(): void
+    {
+        $output = '';
+        $rewind = "\e[1G";
+        $output = JobOutput::concatenateAnsiString($output,'[>-----------------]');
+        self::assertEquals('[>-----------------]', $output);
+        $output = JobOutput::concatenateAnsiString($output, $rewind);
+        $output = JobOutput::concatenateAnsiString($output,'[=>----------------]');
+        self::assertEquals('[=>----------------]', $output);
+        $output = JobOutput::concatenateAnsiString($output, $rewind);
+        $output = JobOutput::concatenateAnsiString($output,'[==>---------------]');
+        self::assertEquals('[==>---------------]', $output);
+    }
+}