Change detection of PHAR in examples (#565)

flow-php · Oct 11, 2023 · 5489ae0 · 5489ae0
1 parent 9481f97
commit 5489ae0
Show file tree

Hide file tree

Showing 37 changed files with 44 additions and 42 deletions.
diff --git a/build/runtime.php b/build/runtime.php
@@ -22,6 +22,8 @@
     exit(1);
 }
 
+$_ENV['FLOW_PHAR_APP'] = 1;
+
 \ini_set('memory_limit', -1);
 
 (new SingleCommandApplication())

diff --git a/examples/bootstrap.php b/examples/bootstrap.php
@@ -1,6 +1,6 @@
 <?php declare(strict_types=1);
 
-if ('' === \Phar::running(false)) {
+if (!($_ENV['FLOW_PHAR_APP'] ?? false)) {
     require __DIR__ . '/../vendor/autoload.php';
 }
 

diff --git a/examples/topics/aggregations/power_plant.php b/examples/topics/aggregations/power_plant.php
@@ -46,7 +46,7 @@
     ->withEntry('consumption', concat(ref('consumption'), lit('%')))
     ->write(To::output(truncate: false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/aggregations/power_plant_bar_chart.php b/examples/topics/aggregations/power_plant_bar_chart.php
@@ -51,7 +51,7 @@
         )
     );
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/async/bootstrap.php b/examples/topics/async/bootstrap.php
@@ -1,7 +1,7 @@
 <?php declare(strict_types=1);
 
-if ('' !== \Phar::running(false)) {
-    print 'This example cannot be run in PHAR, please use CLI approach.';
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
+    print "This example cannot be run in PHAR, please use CLI approach.\n";
 
     exit(1);
 }

diff --git a/examples/topics/db/db_clean.php b/examples/topics/db/db_clean.php
@@ -1,8 +1,8 @@
 #!/usr/bin/env php
 <?php
 
-if ('' !== \Phar::running(false)) {
-    print 'This example cannot be run in PHAR, please use CLI approach.';
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
+    print "This example cannot be run in PHAR, please use CLI approach.\n";
 
     exit(1);
 }

diff --git a/examples/topics/db/db_source.php b/examples/topics/db/db_source.php
@@ -1,8 +1,8 @@
 #!/usr/bin/env php
 <?php
 
-if ('' !== \Phar::running(false)) {
-    print 'This example cannot be run in PHAR, please use CLI approach.';
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
+    print "This example cannot be run in PHAR, please use CLI approach.\n";
 
     exit(1);
 }

diff --git a/examples/topics/db/db_to_db_sync.php b/examples/topics/db/db_to_db_sync.php
@@ -1,7 +1,7 @@
 <?php declare(strict_types=1);
 
-if ('' !== \Phar::running(false)) {
-    print 'This example cannot be run in PHAR, please use CLI approach.';
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
+    print "This example cannot be run in PHAR, please use CLI approach.\n";
 
     exit(1);
 }

diff --git a/examples/topics/fs/remote/json_remote_stream.php b/examples/topics/fs/remote/json_remote_stream.php
@@ -1,7 +1,7 @@
 <?php declare(strict_types=1);
 
-if ('' !== \Phar::running(false)) {
-    print 'This example cannot be run in PHAR, please use CLI approach.';
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
+    print "This example cannot be run in PHAR, please use CLI approach.\n";
 
     exit(1);
 }

diff --git a/examples/topics/fs/remote/json_remote_stream_glob.php b/examples/topics/fs/remote/json_remote_stream_glob.php
@@ -1,7 +1,7 @@
 <?php declare(strict_types=1);
 
-if ('' !== \Phar::running(false)) {
-    print 'This example cannot be run in PHAR, please use CLI approach.';
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
+    print "This example cannot be run in PHAR, please use CLI approach.\n";
 
     exit(1);
 }

diff --git a/examples/topics/http/psr_http_dynamic.php b/examples/topics/http/psr_http_dynamic.php
@@ -39,7 +39,7 @@ public function create(?Message\ResponseInterface $previousResponse = null) : ?M
     ->select('name', 'html_url', 'blog')
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/join/left_anti/left_anti_join.php b/examples/topics/join/left_anti/left_anti_join.php
@@ -39,7 +39,7 @@
     )
     ->write(To::output());
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/join/left_anti/left_anti_join_each.php b/examples/topics/join/left_anti/left_anti_join_each.php
@@ -78,7 +78,7 @@ private function findRowsInDatabase(Rows $rows) : Rows
     )
     ->write(To::output());
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/aggregate.php b/examples/topics/transformations/aggregate.php
@@ -26,7 +26,7 @@
     ->aggregate(Aggregation::sum(ref('a')))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/array_expand.php b/examples/topics/transformations/array_expand.php
@@ -23,7 +23,7 @@
     ->withEntry('expanded', array_expand(ref('array')))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/array_unpack.php b/examples/topics/transformations/array_unpack.php
@@ -23,7 +23,7 @@
     ->withEntry('unpacked', ref('array')->unpack())
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/filter_divide.php b/examples/topics/transformations/filter_divide.php
@@ -24,7 +24,7 @@
     ->withEntry('new_b', ref('b')->multiply(lit(2))->multiply(lit(5)))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/filter_mod.php b/examples/topics/transformations/filter_mod.php
@@ -23,7 +23,7 @@
     ->filter(ref('b')->mod(lit(2))->equals(lit(0)))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/group_by.php b/examples/topics/transformations/group_by.php
@@ -25,7 +25,7 @@
     ->groupBy(ref('a'))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/literals.php b/examples/topics/transformations/literals.php
@@ -21,7 +21,7 @@
     ->withEntry('number', lit(1))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/math.php b/examples/topics/transformations/math.php
@@ -23,7 +23,7 @@
     ->withEntry('d', ref('b')->minus(ref('a')))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/size.php b/examples/topics/transformations/size.php
@@ -21,7 +21,7 @@
     ->withEntry('array_size', ref('array')->size())
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/sort.php b/examples/topics/transformations/sort.php
@@ -14,7 +14,7 @@
     ->sortBy(ref('id')->desc())
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/when_null.php b/examples/topics/transformations/when_null.php
@@ -28,7 +28,7 @@
     )
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/transformations/when_odd.php b/examples/topics/transformations/when_odd.php
@@ -24,7 +24,7 @@
     )
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/csv_read.php b/examples/topics/types/csv/csv_read.php
@@ -17,7 +17,7 @@
     ->drop(col('row'))
     ->limit(10_000);
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/csv_read_partitioned.php b/examples/topics/types/csv/csv_read_partitioned.php
@@ -20,7 +20,7 @@
     ->sortBy(ref('id'))
     ->write(To::output());
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/csv_read_partitioned_filter.php b/examples/topics/types/csv/csv_read_partitioned_filter.php
@@ -21,7 +21,7 @@
     ->sortBy(ref('id'))
     ->write(To::output());
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/csv_to_avro.php b/examples/topics/types/csv/csv_to_avro.php
@@ -19,7 +19,7 @@
     ->rename('last name', 'last_name')
     ->write(Avro::to(__FLOW_OUTPUT__ . '/dataset.avro'));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/csv_to_json.php b/examples/topics/types/csv/csv_to_json.php
@@ -19,7 +19,7 @@
     ->drop(col('row'))
     ->write(Json::to(__FLOW_OUTPUT__ . '/dataset.json'));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/csv_to_parquet_100k.php b/examples/topics/types/csv/csv_to_parquet_100k.php
@@ -18,7 +18,7 @@
     ->drop(col('row'))
     ->write(Parquet::to(__FLOW_OUTPUT__ . '/dataset_100k.parquet', 100_000));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/csv_to_parquet_10k.php b/examples/topics/types/csv/csv_to_parquet_10k.php
@@ -18,7 +18,7 @@
     ->drop(col('row'))
     ->write(Parquet::to(__FLOW_OUTPUT__ . '/dataset_10k.parquet', 10_000));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/php_to_csv.php b/examples/topics/types/csv/php_to_csv.php
@@ -20,7 +20,7 @@
     ->drop(col('row'))
     ->write(CSV::to(__FLOW_OUTPUT__ . '/dataset.csv'));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/php_to_csv_and_json.php b/examples/topics/types/csv/php_to_csv_and_json.php
@@ -22,7 +22,7 @@
     ->write(CSV::to(__FLOW_OUTPUT__ . '/dataset.csv'))
     ->write(Json::to(__FLOW_OUTPUT__ . '/dataset.json'));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/csv/php_to_csv_partition.php b/examples/topics/types/csv/php_to_csv_partition.php
@@ -22,7 +22,7 @@
     ->partitionBy('country_code', 't_shirt_color')
     ->write(CSV::to(__FLOW_OUTPUT__ . '/partitioned'));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/xml/reading.php b/examples/topics/types/xml/reading.php
@@ -12,7 +12,7 @@
     ->read(XML::from(__FLOW_DATA__ . '/simple_items.xml', 'root/items/item'))
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }
 

diff --git a/examples/topics/types/xml/salaries.php b/examples/topics/types/xml/salaries.php
@@ -25,7 +25,7 @@
     ->rename('department_salary_sum', 'total_monthly_salaries')
     ->write(To::output(false));
 
-if ('' !== \Phar::running(false)) {
+if ($_ENV['FLOW_PHAR_APP'] ?? false) {
     return $flow;
 }