add single command (#8)

Author: nick-zh

README.md

@@ -11,6 +11,10 @@ Convert a folder with avsc files into json schema:
 ```bash
 ./bin/console convert:avsc-to-json avscFolder jsonOutputFolder
 ```
+Convert a single avsc file to a json schema:
+```bash
+./bin/console convert:single-avsc-to-json avscFolder jsonOutputFolder
+```
 ### Options
 - `--convertOnlyValueSchema` only convert avsc files that end with `value.avsc`
 - `--noDefaultAsRequired` only mark fields with no defaults as required instead of all

src/Command/ConvertSingleAvscToJsonCommand.php

@@ -0,0 +1,66 @@
+<?php
+
+declare(strict_types=1);
+
+namespace PhpKafka\AvscJsonConverter\Command;
+
+use PhpKafka\AvscJsonConverter\Avro\Avro;
+use PhpKafka\AvscJsonConverter\Converter\ConverterInterface;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class ConvertSingleAvscToJsonCommand extends Command
+{
+    private ConverterInterface $converter;
+
+    public function __construct(ConverterInterface $converter, string $name = null)
+    {
+        $this->converter = $converter;
+        parent::__construct($name);
+    }
+
+    protected function configure(): void
+    {
+        $this
+            ->setName('convert:single-avsc-to-json')
+            ->setDescription('Convert avsc schema to json schema')
+            ->addArgument('avscSchema', InputArgument::REQUIRED, 'Avsc schema file path')
+            ->addArgument('jsonSchema', InputArgument::REQUIRED, 'Json schema file path')
+            ->addOption('noDefaultAsRequired', null, InputOption::VALUE_NONE, 'Instead of all fields, only fields with no default are required')
+        ;
+    }
+
+    public function execute(InputInterface $input, OutputInterface $output): ?int
+    {
+        /** @var string $avscSchema */
+        $avscSchema = $input->getArgument('avscSchema');
+
+        /** @var string $jsonSchema */
+        $jsonSchema = $input->getArgument('jsonSchema');
+        $outputDirectory = dirname($jsonSchema);
+
+        $noDefaultAsRequired = (bool) $input->getOption('noDefaultAsRequired');
+
+        if (Avro::FILE_EXTENSION !== pathinfo($avscSchema, PATHINFO_EXTENSION)) {
+            $output->writeln('<error>Input schema is not of type avsc</error>');
+            return -1;
+        }
+
+        $avsc = file_get_contents($avscSchema);
+        $json = $this->converter->convert($avsc, ['markNoDefaultAsRequired' => $noDefaultAsRequired]);
+
+        if (false === file_exists($outputDirectory)) {
+            mkdir($outputDirectory);
+        }
+
+        $fname = $outputDirectory . DIRECTORY_SEPARATOR . $jsonSchema;
+        file_put_contents($fname, $json);
+
+        $output->writeln('Successfully converted avsc schema');
+
+        return 0;
+    }
+}

src/ServiceProvider/CommandServiceProvider.php

@@ -5,6 +5,7 @@
 namespace PhpKafka\AvscJsonConverter\ServiceProvider;
 
 use PhpKafka\AvscJsonConverter\Command\ConvertAvscToJsonCommand;
+use PhpKafka\AvscJsonConverter\Command\ConvertSingleAvscToJsonCommand;
 use PhpKafka\AvscJsonConverter\Converter\AvscToJson;
 use Pimple\Container;
 use Pimple\ServiceProviderInterface;
@@ -20,6 +21,10 @@ public function register(Container $container)
                 $container[AvscToJson::class]
             );
 
+            $commands[ConvertSingleAvscToJsonCommand::class] = new ConvertSingleAvscToJsonCommand(
+                $container[AvscToJson::class]
+            );
+
             return $commands;
         };
     }