WIP

Author: IvanChepurnyi

src/Configuration.php

@@ -0,0 +1,79 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL;
+
+use Amp\Mysql\MysqlConfig;
+use JsonSchema\Constraints\Constraint;
+use JsonSchema\Validator;
+use JsonException;
+
+final readonly class Configuration
+{
+    private function __construct(
+        public MysqlConfig $connection,
+        public TableCondition $includeCondition,
+        public TableCondition $excludeCondition,
+    )
+    {
+
+    }
+
+    /**
+     * Creates configuration based on JSON value supported by schema.json
+     *
+     * @throws ConfigurationException|JsonException
+     */
+    public static function fromJSON(string $json): Configuration
+    {
+        $validator = new Validator();
+        $schema = json_decode(
+            file_get_contents(dirname(__DIR__) . DIRECTORY_SEPARATOR .  'schema.json'),
+            flags: JSON_THROW_ON_ERROR
+        );
+        $data = json_decode(
+            $json,
+            flags: JSON_THROW_ON_ERROR
+        );
+        $result = $validator->validate($data, $schema, Constraint::CHECK_MODE_APPLY_DEFAULTS);
+
+        if (($result & Validator::ERROR_DOCUMENT_VALIDATION) === Validator::ERROR_DOCUMENT_VALIDATION) {
+            $errors = array_reduce(
+                $validator->getErrors(),
+                function ($errors, $error) {
+                    $errors[$error['property']] = $error['message'];
+                    return $errors;
+                }
+            );
+
+            throw ConfigurationException::fromErrors($errors);
+        }
+
+
+        return new self(
+            new MysqlConfig(
+                host: $data->connection->host,
+                port: (int) $data->connection->port,
+                user: $data->connection->user,
+                password: $data->connection->password,
+                database: $data->connection->database,
+            ),
+            StaticTableCondition::alwaysTrue(),
+            StaticTableCondition::alwaysFalse(),
+        );
+    }
+
+    public static function fromMySQLConfig(MysqlConfig $config): self
+    {
+        return new self($config, StaticTableCondition::alwaysTrue(), StaticTableCondition::alwaysFalse());
+    }
+
+    public function withIncludeCondition(TableCondition $condition): self
+    {
+
+    }
+
+    public function withExcludeCondition(TableCondition $condition): self
+    {
+
+    }
+}

src/ConfigurationException.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL;
+
+use JsonSchema\Exception\InvalidSchemaException;
+use RuntimeException;
+use Symfony\Component\Console\Output\OutputInterface;
+
+final class ConfigurationException extends RuntimeException implements \Throwable
+{
+    private function __construct(
+        private readonly array $errors
+    ) {
+        parent::__construct('Configuration validation failed');
+    }
+
+    /**
+     * Creates message from errors
+     *
+     * @param string[] $errors
+     */
+    public static function fromErrors(array $errors): self
+    {
+        return new self($errors);
+    }
+
+    public function output(OutputInterface $output): void
+    {
+
+    }
+}

src/ExportTableFactory.php

@@ -2,6 +2,9 @@
 
 namespace EcomDev\MySQL2JSONL;
 
-class ExportTableFactory
+final class ExportTableFactory
 {
+    public function __construct()
+    {
+    }
 }

src/ImportProgressNotifier.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL;
+
+use Symfony\Component\Console\Helper\ProgressBar;
+use Symfony\Component\Console\Output\ConsoleOutputInterface;
+
+final class ImportProgressNotifier implements ProgressNotifier
+{
+    /**
+     * Progress bar per output component
+     *
+     * @var ProgressBar[]
+     */
+    private array $progressBars = [];
+
+    public function __construct(private readonly ConsoleOutputInterface $output)
+    {
+    }
+
+    public function start(string $name, int $total): void
+    {
+        $progressBar = new ProgressBar($this->output, $total);
+        $progressBar->setProgressCharacter('🚀');
+        $progressBar->setBarCharacter('-');
+        $progressBar->setEmptyBarCharacter(' ');
+        $this->progressBars[$name] = $progressBar;
+
+    }
+
+    public function update(string $name, int $current): void
+    {
+        $this->progressBars[$name]->advance($current);
+    }
+
+    public function finish(string $name): void
+    {
+        $this->progressBars[$name]->finish();
+    }
+}

src/ProgressNotifier.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL;
+
+interface ProgressNotifier
+{
+    public function start(string $name, int $total): void;
+
+    public function update(string $name, int $current): void;
+
+    public function finish(string $name): void;
+}

src/Sql/InsertOnDuplicate.php

@@ -2,7 +2,7 @@
 
 namespace EcomDev\MySQL2JSONL\Sql;
 
-class InsertOnDuplicate
+final class InsertOnDuplicate
 {
     public function generate(string $tableName, array $columns, int $rowCount, $onUpdate = []): string
     {

src/StaticTableCondition.php

@@ -0,0 +1,31 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL;
+
+final readonly class StaticTableCondition implements TableCondition
+{
+    private function __construct(private bool $result)
+    {
+    }
+
+    public static function alwaysTrue(): self
+    {
+        return new self(true);
+    }
+
+
+    public static function alwaysFalse(): self
+    {
+        return new self(false);
+    }
+
+    public function isSatisfiedBy(string $tableName, int $rows): bool
+    {
+        return $this->result;
+    }
+
+    public function withCondition(TableCondition $condition): TableCondition
+    {
+        return $this;
+    }
+}

src/TableCondition.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL;
+
+interface TableCondition
+{
+    public function isSatisfiedBy(string $tableName, int $rows): bool;
+
+    public function withCondition(TableCondition $condition): self;
+}

tests/ConfigurationTest.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL;
+
+use Amp\Mysql\MysqlConfig;
+use PHPUnit\Framework\Attributes\Test;
+use PHPUnit\Framework\TestCase;
+
+class ConfigurationTest extends TestCase
+{
+    #[Test]
+    public function createsConfigurationWithOnlyHostAndDatabase()
+    {
+        $this->assertEquals(
+            Configuration::fromMysqlConfig(
+                MysqlConfig::fromAuthority("db", "root", "", "magento")
+            ),
+            Configuration::fromJSON(
+                <<<JSON
+                {
+                  "connection": {
+                    "host": "db",
+                    "database": "magento"
+                  }
+                }
+                JSON
+            )
+        );
+    }
+
+    #[Test]
+    public function reportsErrorOnJsonValidation()
+    {
+        $this->assertConfigException(
+            <<<JSON
+            {
+              "connection": {
+                "database": "magento"
+              }
+            }
+            JSON,
+            ConfigurationException::fromErrors([
+                'connection.host' => 'The property host is required'
+            ])
+        );
+    }
+
+    private function assertConfigException(string $json, ConfigurationException $error): void
+    {
+        $this->expectException(ConfigurationException::class);
+
+        try {
+            Configuration::fromJSON($json);
+        } catch (ConfigurationException $e) {
+            $this->assertEquals($error, $e);
+            throw $e;
+        }
+    }
+}

tests/ExportTableTest.php

@@ -7,6 +7,7 @@
 
 class ExportTableTest extends TestCase
 {
+
     #[Test]
     public function itworks()
     {