Added composer.json to each example and make it standalone downloadable project

Author: norberttech

composer.json

@@ -25,6 +25,7 @@
         "coduo/php-humanizer": "^5.0",
         "doctrine/dbal": "^3.6 || ^4.0",
         "elasticsearch/elasticsearch": "^7.6|^8.0",
+        "flow-php/etl-adapter-csv": "1.x-dev",
         "google/apiclient": "^2.13",
         "halaxa/json-machine": "^1.1",
         "meilisearch/meilisearch-php": "^1.11",
@@ -50,17 +51,17 @@
         "php-http/curl-client": "^2.2",
         "php-http/mock-client": "^1.5",
         "ramsey/uuid": "^4.5",
-        "symfony/http-client": "^5.4.47 || ^6.4 || ^7.0",
         "symfony/cache": "^6.2 || ^7.0",
         "symfony/dotenv": "^6.2 || ^7.0",
         "symfony/finder": "^6.3 || ^7.0",
+        "symfony/http-client": "^5.4.47 || ^6.4 || ^7.0",
+        "symfony/process": "^7.2",
         "symfony/uid": "^6.3 || ^7.0"
     },
     "replace": {
         "flow-php/array-dot": "self.version",
         "flow-php/azure-sdk": "self.version",
         "flow-php/doctrine-dbal-bulk": "self.version",
-        "flow-php/doctrine-dbal-bulk-tools": "self.version",
         "flow-php/dremel": "self.version",
         "flow-php/etl": "self.version",
         "flow-php/etl-adapter-avro": "self.version",

composer.lock

@@ -4,3 +4,4 @@ output/*
 compose.yml
 var
 .env
+composer.lock

examples/.gitignore

@@ -0,0 +1,65 @@
+#!/usr/bin/env php
+<?php
+
+declare(strict_types=1);
+
+require __DIR__ . '/../vendor/autoload.php';
+
+use function Flow\Filesystem\DSL\{fstab, path, protocol};
+use Flow\ETL\Dataset\Statistics\HighResolutionTime;
+use Symfony\Component\Console\Input\{ArgvInput, InputDefinition, InputOption};
+use Symfony\Component\Console\Output\ConsoleOutput;
+use Symfony\Component\Console\Style\SymfonyStyle;
+use Symfony\Component\Finder\Finder;
+
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
+    print PHP_EOL . 'This script cannot be run in PHAR, please use CLI approach.' . PHP_EOL;
+
+    exit(1);
+}
+
+if (false === \in_array(PHP_SAPI, ['cli', 'phpdbg', 'embed'], true)) {
+    print PHP_EOL . 'This script may only be invoked from a command line, got "' . PHP_SAPI . '"' . PHP_EOL;
+
+    exit(1);
+}
+
+\ini_set('memory_limit', -1);
+
+$finder = new Finder();
+$finder->in(__DIR__ . '/topics')
+    ->files()
+    ->name('*.php');
+
+$output = new ConsoleOutput();
+$intput = new ArgvInput(definition: new InputDefinition(
+    [
+        new InputOption(name: 'composer-update', shortcut: 'u', mode: InputOption::VALUE_NONE),
+        new InputOption(name: 'composer-archive', shortcut: 'a', mode: InputOption::VALUE_NONE),
+    ]
+));
+$style = new SymfonyStyle($intput, $output);
+$style->setDecorated(true);
+
+$style->title('Cleaning Flow PHP Examples');
+
+$fs = fstab()->for(protocol('file'));
+
+foreach ($finder as $file) {
+
+    if ($file->getBasename() !== 'code.php') {
+        continue;
+    }
+
+    $start = HighResolutionTime::now();
+
+    $style->info("Removing vendor folder: {$file->getRelativePathname()}");
+
+    $vendorPath = path($file->getPath() . '/vendor');
+
+    if ($fs->status($vendorPath)?->isDirectory()) {
+        $fs->rm(path($file->getPath() . '/vendor'));
+    }
+}
+
+$style->success('Vendor folders remove from all examples');

examples/autoload.php

@@ -5,6 +5,10 @@
 
 require __DIR__ . '/../vendor/autoload.php';
 
+use Flow\ETL\Dataset\Statistics\HighResolutionTime;
+use Symfony\Component\Console\Input\{ArgvInput, InputDefinition, InputOption};
+use Symfony\Component\Console\Output\ConsoleOutput;
+use Symfony\Component\Console\Style\SymfonyStyle;
 use Symfony\Component\Finder\Finder;
 
 if ($_ENV['FLOW_PHAR_APP'] ?? false) {
@@ -21,23 +25,60 @@
 
 \ini_set('memory_limit', -1);
 
-print "Running all available examples.\n";
-
 $finder = new Finder();
 $finder->in(__DIR__ . '/topics')
     ->files()
     ->name('*.php');
 
+$output = new ConsoleOutput();
+$intput = new ArgvInput(definition: new InputDefinition(
+    [
+        new InputOption(name: 'composer-update', shortcut: 'u', mode: InputOption::VALUE_NONE),
+        new InputOption(name: 'composer-archive', shortcut: 'a', mode: InputOption::VALUE_NONE),
+    ]
+));
+$style = new SymfonyStyle($intput, $output);
+$style->setDecorated(true);
+
+$style->title('Running Flow PHP Examples');
+
 foreach ($finder as $file) {
-    print "\nExample: {$file->getRelativePathname()}\n";
 
-    try {
-        if ($file->getBasename() === 'code.php') {
-            include $file->getRealPath();
-        }
-    } catch (Exception $e) {
-        print "Example failed: {$e->getMessage()}\n";
+    if ($file->getBasename() !== 'code.php') {
+        continue;
+    }
+
+    $start = HighResolutionTime::now();
+
+    $style->info("Running example: {$file->getRelativePathname()}");
+
+    $style->note(($intput->getOption('composer-update') ? 'Updating' : 'Installing') . ' composer dependencies');
+    $composerProcess = new Symfony\Component\Process\Process(['composer', $intput->getOption('composer-update') ? 'update' : 'install'], $file->getPath());
+    $composerProcess->run();
+    $style->info('Composer install finished');
+
+    if (!$composerProcess->isSuccessful()) {
+        print "Composer install failed: {$composerProcess->getErrorOutput()}\n";
 
         exit(1);
     }
+
+    $codeProcess = new Symfony\Component\Process\Process(['php', $file->getRealPath()]);
+    $codeProcess->run();
+
+    if (!$codeProcess->isSuccessful()) {
+        print "Example failed: {$codeProcess->getOutput()}\n";
+
+        exit(1);
+    }
+    $end = HighResolutionTime::now();
+
+    $style->success('Example finished in ' . $start->diff($end)->toSeconds() . ' seconds');
+
+    if ($intput->getOption('composer-update')) {
+        $style->note('Generating composer archive');
+        $composerProcess = new Symfony\Component\Process\Process(['composer', 'archive', '--format', 'zip', '--file', 'flow_php_example'], $file->getPath());
+        $composerProcess->run();
+        $style->info('Composer archive generated');
+    }
 }

examples/clean.php

@@ -4,7 +4,7 @@
 
 use function Flow\ETL\DSL\{average, data_frame, from_rows, int_entry, ref, row, rows, to_stream};
 
-require __DIR__ . '/../../../autoload.php';
+require __DIR__ . '/vendor/autoload.php';
 
 data_frame()
     ->from(from_rows(rows(

examples/run.php

@@ -0,0 +1,9 @@
+{
+  "name": "flow-php/examples",
+  "description": "Flow PHP - Examples",
+  "license": "MIT",
+  "type": "library",
+  "require": {
+    "flow-php/etl": "1.x-dev"
+  }
+}

examples/topics/aggregations/average/code.php

@@ -4,7 +4,7 @@
 
 use function Flow\ETL\DSL\{data_frame, first, from_rows, int_entry, ref, row, rows, to_stream};
 
-require __DIR__ . '/../../../autoload.php';
+require __DIR__ . '/vendor/autoload.php';
 
 data_frame()
     ->from(from_rows(rows(