Added library version to parquet created_by metadata (#693)

* Added library version to parquet created_by metadata

* Added composer-runtime-api dependency in order to read parquet library version

composer.json

@@ -18,6 +18,7 @@
         "ext-mbstring": "*",
         "ext-xmlreader": "*",
         "ext-zlib": "*",
+        "composer-runtime-api": "^2.1",
         "amphp/process": "^2",
         "amphp/socket": "^2",
         "doctrine/dbal": "^3.6",

src/lib/parquet/composer.json

@@ -14,6 +14,8 @@
         "php": "~8.1 || ~8.2",
         "ext-bcmath": "*",
         "ext-zlib": "*",
+        "psr/log": "^2.0 || ^3.0",
+        "composer-runtime-api": "^2.1",
         "flow-php/dremel": "1.x-dev",
         "flow-php/snappy": "1.x-dev"
     },

src/lib/parquet/src/Flow/Parquet/Writer.php

@@ -2,6 +2,7 @@
 
 namespace Flow\Parquet;
 
+use Composer\InstalledVersions;
 use Flow\Parquet\Data\DataConverter;
 use Flow\Parquet\Exception\InvalidArgumentException;
 use Flow\Parquet\Exception\RuntimeException;
@@ -108,8 +109,7 @@ public function open(string $path, Schema $schema) : void
         \fwrite($this->stream(), ParquetFile::PARQUET_MAGIC_NUMBER);
         $this->fileOffset = \strlen(ParquetFile::PARQUET_MAGIC_NUMBER);
 
-        $this->metadata = (new Metadata($schema, new RowGroups([]), 0, self::VERSION, 'flow-parquet'));
-
+        $this->initMetadata($schema);
         $this->initGroupBuilder($schema);
     }
 
@@ -141,7 +141,7 @@ public function openForStream($resource, Schema $schema) : void
         \fwrite($this->stream(), ParquetFile::PARQUET_MAGIC_NUMBER);
         $this->fileOffset = \strlen(ParquetFile::PARQUET_MAGIC_NUMBER);
 
-        $this->metadata = (new Metadata($schema, new RowGroups([]), 0, self::VERSION, 'flow-parquet'));
+        $this->initMetadata($schema);
 
         $this->initGroupBuilder($schema);
     }
@@ -211,6 +211,11 @@ private function initGroupBuilder(Schema $schema) : void
         }
     }
 
+    private function initMetadata(Schema $schema) : void
+    {
+        $this->metadata = (new Metadata($schema, new RowGroups([]), 0, self::VERSION, 'flow-php parquet version ' . InstalledVersions::getRootPackage()['pretty_version']));
+    }
+
     private function metadata() : Metadata
     {
         if ($this->metadata === null) {

src/lib/parquet/tests/Flow/Parquet/Tests/Integration/IO/WriterTest.php

@@ -2,6 +2,7 @@
 
 namespace Flow\Parquet\Tests\Integration\IO;
 
+use Composer\InstalledVersions;
 use Faker\Factory;
 use Flow\Parquet\Consts;
 use Flow\Parquet\Exception\InvalidArgumentException;
@@ -24,6 +25,21 @@ public function test_closing_not_open_writer() : void
         $writer->close();
     }
 
+    public function test_created_by_metadata() : void
+    {
+        $writer = new Writer();
+
+        $path = \sys_get_temp_dir() . '/test-writer' . \uniqid('parquet-test-', true) . '.parquet';
+
+        $schema = $this->createSchema();
+        $writer->open($path, $schema);
+        $writer->close();
+
+        $metadata = (new Reader())->read($path)->metadata();
+
+        $this->assertSame('flow-php parquet version ' . InstalledVersions::getRootPackage()['pretty_version'], $metadata->createdBy());
+    }
+
     public function test_opening_already_open_writer() : void
     {
         $writer = new Writer();