Skip to content

Commit f753dd7

Browse files
committed
chore: update mago to the latest version
1 parent 9510dd4 commit f753dd7

File tree

581 files changed

+1684
-104
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

581 files changed

+1684
-104
lines changed

mago.toml

Lines changed: 118 additions & 66 deletions
Original file line numberDiff line numberDiff line change
@@ -4,76 +4,81 @@ php-version = "8.2.0"
44

55
[source]
66
paths = [
7-
"src/adapter/etl-adapter-avro/src/Flow",
8-
"src/adapter/etl-adapter-avro/tests/Flow",
9-
"src/adapter/etl-adapter-chartjs/src/Flow",
10-
"src/adapter/etl-adapter-chartjs/tests/Flow",
11-
"src/adapter/etl-adapter-csv/src/Flow",
12-
"src/adapter/etl-adapter-csv/tests/Flow",
13-
"src/adapter/etl-adapter-doctrine/src/Flow",
14-
"src/adapter/etl-adapter-doctrine/tests/Flow",
15-
"src/adapter/etl-adapter-elasticsearch/src/Flow",
16-
"src/adapter/etl-adapter-elasticsearch/tests/Flow",
17-
"src/adapter/etl-adapter-excel/src/Flow",
18-
"src/adapter/etl-adapter-excel/tests/Flow",
19-
"src/adapter/etl-adapter-google-sheet/src/Flow",
20-
"src/adapter/etl-adapter-google-sheet/tests/Flow",
21-
"src/adapter/etl-adapter-http/src/Flow",
22-
"src/adapter/etl-adapter-http/tests/Flow",
23-
"src/adapter/etl-adapter-json/src/Flow",
24-
"src/adapter/etl-adapter-json/tests/Flow",
25-
"src/adapter/etl-adapter-logger/src/Flow",
26-
"src/adapter/etl-adapter-logger/tests/Flow",
27-
"src/adapter/etl-adapter-meilisearch/src/Flow",
28-
"src/adapter/etl-adapter-meilisearch/tests/Flow",
29-
"src/adapter/etl-adapter-parquet/src/Flow",
30-
"src/adapter/etl-adapter-parquet/tests/Flow",
31-
"src/adapter/etl-adapter-text/src/Flow",
32-
"src/adapter/etl-adapter-text/tests/Flow",
33-
"src/adapter/etl-adapter-xml/src/Flow",
34-
"src/adapter/etl-adapter-xml/tests/Flow",
35-
"src/bridge/filesystem/async-aws/src/Flow",
36-
"src/bridge/filesystem/async-aws/tests/Flow",
37-
"src/bridge/filesystem/azure/src/Flow",
38-
"src/bridge/filesystem/azure/tests/Flow",
39-
"src/bridge/monolog/http/src/Flow",
40-
"src/bridge/monolog/http/tests/Flow",
41-
"src/bridge/openapi/specification/src/Flow",
42-
"src/bridge/openapi/specification/tests/Flow",
43-
"src/bridge/symfony/http-foundation/src/Flow",
44-
"src/bridge/symfony/http-foundation/tests/Flow",
45-
"src/cli/src/Flow",
46-
"src/cli/tests/Flow",
47-
"src/core/etl/src/Flow",
48-
"src/core/etl/tests/Flow",
49-
"src/lib/array-dot/src/Flow",
50-
"src/lib/array-dot/tests/Flow",
51-
"src/lib/azure-sdk/src/Flow",
52-
"src/lib/azure-sdk/tests/Flow",
53-
"src/lib/doctrine-dbal-bulk/src/Flow",
54-
"src/lib/doctrine-dbal-bulk/tests/Flow",
55-
"src/lib/dremel/src/Flow",
56-
"src/lib/dremel/tests/Flow",
57-
"src/lib/filesystem/src/Flow",
58-
"src/lib/filesystem/tests/Flow",
59-
"src/lib/parquet-viewer/src/Flow",
60-
"src/lib/parquet-viewer/tests/Flow",
61-
"src/lib/parquet/src/Flow",
62-
"src/lib/parquet/tests/Flow",
63-
"src/lib/snappy/src/Flow",
64-
"src/lib/snappy/tests/Flow",
7+
# "src/adapter/etl-adapter-avro/src/Flow",
8+
## "src/adapter/etl-adapter-avro/tests/Flow",
9+
# "src/adapter/etl-adapter-chartjs/src/Flow",
10+
## "src/adapter/etl-adapter-chartjs/tests/Flow",
11+
# "src/adapter/etl-adapter-csv/src/Flow",
12+
## "src/adapter/etl-adapter-csv/tests/Flow",
13+
# "src/adapter/etl-adapter-doctrine/src/Flow",
14+
## "src/adapter/etl-adapter-doctrine/tests/Flow",
15+
# "src/adapter/etl-adapter-elasticsearch/src/Flow",
16+
## "src/adapter/etl-adapter-elasticsearch/tests/Flow",
17+
# "src/adapter/etl-adapter-excel/src/Flow",
18+
## "src/adapter/etl-adapter-excel/tests/Flow",
19+
# "src/adapter/etl-adapter-google-sheet/src/Flow",
20+
## "src/adapter/etl-adapter-google-sheet/tests/Flow",
21+
# "src/adapter/etl-adapter-http/src/Flow",
22+
## "src/adapter/etl-adapter-http/tests/Flow",
23+
# "src/adapter/etl-adapter-json/src/Flow",
24+
## "src/adapter/etl-adapter-json/tests/Flow",
25+
# "src/adapter/etl-adapter-logger/src/Flow",
26+
## "src/adapter/etl-adapter-logger/tests/Flow",
27+
# "src/adapter/etl-adapter-meilisearch/src/Flow",
28+
## "src/adapter/etl-adapter-meilisearch/tests/Flow",
29+
# "src/adapter/etl-adapter-parquet/src/Flow",
30+
## "src/adapter/etl-adapter-parquet/tests/Flow",
31+
# "src/adapter/etl-adapter-text/src/Flow",
32+
## "src/adapter/etl-adapter-text/tests/Flow",
33+
# "src/adapter/etl-adapter-xml/src/Flow",
34+
## "src/adapter/etl-adapter-xml/tests/Flow",
35+
# "src/bridge/filesystem/async-aws/src/Flow",
36+
## "src/bridge/filesystem/async-aws/tests/Flow",
37+
# "src/bridge/filesystem/azure/src/Flow",
38+
## "src/bridge/filesystem/azure/tests/Flow",
39+
# "src/bridge/monolog/http/src/Flow",
40+
## "src/bridge/monolog/http/tests/Flow",
41+
# "src/bridge/openapi/specification/src/Flow",
42+
## "src/bridge/openapi/specification/tests/Flow",
43+
# "src/bridge/symfony/http-foundation/src/Flow",
44+
## "src/bridge/symfony/http-foundation/tests/Flow",
45+
# "src/cli/src/Flow",
46+
## "src/cli/tests/Flow",
47+
# "src/core/etl/src/Flow",
48+
## "src/core/etl/tests/Flow",
49+
# "src/lib/array-dot/src/Flow",
50+
## "src/lib/array-dot/tests/Flow",
51+
# "src/lib/azure-sdk/src/Flow",
52+
## "src/lib/azure-sdk/tests/Flow",
53+
# "src/lib/doctrine-dbal-bulk/src/Flow",
54+
## "src/lib/doctrine-dbal-bulk/tests/Flow",
55+
# "src/lib/dremel/src/Flow",
56+
## "src/lib/dremel/tests/Flow",
57+
# "src/lib/filesystem/src/Flow",
58+
## "src/lib/filesystem/tests/Flow",
59+
# "src/lib/parquet-viewer/src/Flow",
60+
## "src/lib/parquet-viewer/tests/Flow",
61+
# "src/lib/parquet/src/Flow",
62+
## "src/lib/parquet/tests/Flow",
63+
# "src/lib/snappy/src/Flow",
64+
## "src/lib/snappy/tests/Flow",
6565
"src/lib/types/src/Flow",
66-
"src/lib/types/tests/Flow",
67-
"src/tools/documentation/src/Flow",
68-
"src/tools/documentation/tests/Flow"
66+
# "src/lib/types/tests/Flow",
67+
# "src/tools/documentation/src/Flow",
68+
## "src/tools/documentation/tests/Flow"
6969
]
7070
includes = [
7171
"vendor",
72-
"tools/phpunit/vendor"
73-
]
74-
excludes = [
75-
"src/lib/parquet/src/Flow/Parquet/ThriftModel"
72+
"tools/phpunit/vendor",
73+
"src/core/etl/src/Flow",
74+
"src/tools/documentation/src",
75+
"src/lib/parquet/src/Flow/Parquet/BinaryReader",
76+
"src/lib/parquet/src/Flow/Parquet/BinaryReader",
77+
"src/lib/parquet/src/Flow/Parquet/Data",
78+
"src/lib/parquet/src/Flow/Parquet/ThriftModel",
79+
"src/lib/parquet/src/Flow/Parquet/Thrift"
7680
]
81+
excludes = []
7782

7883
[formatter]
7984
print-width = 140
@@ -140,4 +145,51 @@ find-unused-expressions = false
140145
analyze-dead-code = false
141146
check-throws = false
142147
allow-possibly-undefined-array-keys = true
143-
perform-heuristic-checks = true
148+
perform-heuristic-checks = true
149+
ignore = [
150+
#"mixed-operand",
151+
# "mixed-argument",
152+
# "mixed-method-access",
153+
# "mixed-property-type-coercion",
154+
# "less-specific-argument",
155+
# "possibly-invalid-argument",
156+
# "possibly-null-argument",
157+
# "mixed-array-access",
158+
# "non-existent-method",
159+
# "invalid-argument",
160+
# "possible-method-access-on-null",
161+
# "less-specific-nested-argument-type",
162+
# "possibly-false-argument",
163+
# "invalid-return-statement",
164+
# "invalid-property-assignment-value",
165+
# "mixed-return-statement",
166+
# "no-value",
167+
# "invalid-method-access",
168+
# "invalid-operand",
169+
# "mixed-array-index",
170+
# "invalid-iterator",
171+
# "nullable-return-statement",
172+
# "invalid-property-write",
173+
# "less-specific-nested-return-statement",
174+
# "less-specific-return-statement",
175+
# "incompatible-parameter-type",
176+
# "mismatched-array-index",
177+
# "non-existent-function",
178+
# "too-few-arguments",
179+
# "unknown-iterator-type",
180+
# "null-argument",
181+
# "too-many-arguments",
182+
# "invalid-type-cast",
183+
# "missing-template-parameter",
184+
# "never-return",
185+
# "template-constraint-violation",
186+
# "array-to-string-conversion",
187+
# "falsable-return-statement",
188+
# "interface-instantiation",
189+
# "invalid-array-access",
190+
# "invalid-yield-value-type",
191+
# "match-not-exhaustive",
192+
# "mixed-property-access",
193+
# "non-existent-class-like",
194+
# "unknown-match-subject-type",
195+
]

src/adapter/etl-adapter-avro/src/Flow/ETL/Adapter/Avro/FlixTech/AvroExtractor.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,13 @@ public function __construct(private readonly Path $path)
1919
throw new RuntimeException('Avro integration was abandoned due to lack of availability of good Avro libraries.');
2020
}
2121

22+
#[\Override]
2223
public function extract(FlowContext $context) : \Generator
2324
{
2425
yield;
2526
}
2627

28+
#[\Override]
2729
public function source() : Path
2830
{
2931
return $this->path;

src/adapter/etl-adapter-avro/src/Flow/ETL/Adapter/Avro/FlixTech/AvroLoader.php

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,18 @@ public function __construct(
2323
$this->path = $path->setOptionWhenEmpty(Option::CONTENT_TYPE->value, ContentType::AVRO);
2424
}
2525

26+
#[\Override]
2627
public function closure(FlowContext $context) : void
2728
{
2829
}
2930

31+
#[\Override]
3032
public function destination() : Path
3133
{
3234
return $this->path;
3335
}
3436

37+
#[\Override]
3538
public function load(Rows $rows, FlowContext $context) : void
3639
{
3740
}

src/adapter/etl-adapter-avro/tests/Flow/ETL/Adapter/Avro/Tests/Integration/AvroTest.php

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212

1313
final class AvroTest extends FlowTestCase
1414
{
15+
#[\Override]
1516
protected function setUp() : void
1617
{
1718
self::markTestSkipped('Avro integration was abandoned due to lack of availability of good Avro libraries.');

src/adapter/etl-adapter-chartjs/src/Flow/ETL/Adapter/ChartJS/Chart/BarChart.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ public function __construct(
3737
) {
3838
}
3939

40+
#[\Override]
4041
public function collect(Rows $rows) : void
4142
{
4243
foreach ($rows as $row) {
@@ -59,6 +60,7 @@ public function collect(Rows $rows) : void
5960
/**
6061
* @return array<array-key, mixed>
6162
*/
63+
#[\Override]
6264
public function data() : array
6365
{
6466
$data = [
@@ -87,6 +89,7 @@ function (array $dataset) : array {
8789
/**
8890
* @param array<array-key, mixed> $options
8991
*/
92+
#[\Override]
9093
public function setDatasetOptions(Reference $dataset, array $options) : self
9194
{
9295
$this->datasetOptions[$dataset->name()] = $options;
@@ -97,6 +100,7 @@ public function setDatasetOptions(Reference $dataset, array $options) : self
97100
/**
98101
* @param array<array-key, mixed> $options
99102
*/
103+
#[\Override]
100104
public function setOptions(array $options) : self
101105
{
102106
$this->options = $options;

src/adapter/etl-adapter-chartjs/src/Flow/ETL/Adapter/ChartJS/Chart/LineChart.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ public function __construct(
3737
) {
3838
}
3939

40+
#[\Override]
4041
public function collect(Rows $rows) : void
4142
{
4243
foreach ($rows as $row) {
@@ -59,6 +60,7 @@ public function collect(Rows $rows) : void
5960
/**
6061
* @return array<array-key, mixed>
6162
*/
63+
#[\Override]
6264
public function data() : array
6365
{
6466
$data = [
@@ -87,6 +89,7 @@ function (array $dataset) : array {
8789
/**
8890
* @param array<array-key, mixed> $options
8991
*/
92+
#[\Override]
9093
public function setDatasetOptions(Reference $dataset, array $options) : self
9194
{
9295
$this->datasetOptions[$dataset->name()] = $options;
@@ -97,6 +100,7 @@ public function setDatasetOptions(Reference $dataset, array $options) : self
97100
/**
98101
* @param array<array-key, mixed> $options
99102
*/
103+
#[\Override]
100104
public function setOptions(array $options) : self
101105
{
102106
$this->options = $options;

src/adapter/etl-adapter-chartjs/src/Flow/ETL/Adapter/ChartJS/Chart/PieChart.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@ public function __construct(
3535
) {
3636
}
3737

38+
#[\Override]
3839
public function collect(Rows $rows) : void
3940
{
4041
foreach ($rows as $row) {
@@ -56,6 +57,7 @@ public function collect(Rows $rows) : void
5657
/**
5758
* @return array<array-key, mixed>
5859
*/
60+
#[\Override]
5961
public function data() : array
6062
{
6163
$labels = [];
@@ -88,6 +90,7 @@ public function data() : array
8890
/**
8991
* @param array<array-key, mixed> $options
9092
*/
93+
#[\Override]
9194
public function setDatasetOptions(Reference $dataset, array $options) : self
9295
{
9396
$this->datasetOptions[$dataset->name()] = $options;
@@ -98,6 +101,7 @@ public function setDatasetOptions(Reference $dataset, array $options) : self
98101
/**
99102
* @param array<array-key, mixed> $options
100103
*/
104+
#[\Override]
101105
public function setOptions(array $options) : self
102106
{
103107
$this->options = $options;

src/adapter/etl-adapter-chartjs/src/Flow/ETL/Adapter/ChartJS/ChartJSLoader.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ public function __construct(private readonly Chart $type)
2424
$this->template = \Flow\Filesystem\DSL\path(__DIR__ . '/Resources/template/full_page.html');
2525
}
2626

27+
#[\Override]
2728
public function closure(FlowContext $context) : void
2829
{
2930
if ($this->output === null && $this->outputVar === null) {
@@ -58,6 +59,7 @@ public function closure(FlowContext $context) : void
5859
}
5960
}
6061

62+
#[\Override]
6163
public function load(Rows $rows, FlowContext $context) : void
6264
{
6365
if (!$rows->count()) {

src/adapter/etl-adapter-csv/src/Flow/ETL/Adapter/CSV/CSVExtractor.php

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ public function __construct(private readonly Path $path)
3939
$this->resetLimit();
4040
}
4141

42+
#[\Override]
4243
public function extract(FlowContext $context) : \Generator
4344
{
4445
$shouldPutInputIntoRows = $context->config->shouldPutInputIntoRows();
@@ -97,6 +98,7 @@ public function extract(FlowContext $context) : \Generator
9798
}
9899
}
99100

101+
#[\Override]
100102
public function source() : Path
101103
{
102104
return $this->path;

src/adapter/etl-adapter-csv/src/Flow/ETL/Adapter/CSV/CSVLoader.php

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,16 +31,19 @@ public function __construct(Path $path)
3131
$this->path = $path->setOptionWhenEmpty(Option::CONTENT_TYPE, ContentType::CSV);
3232
}
3333

34+
#[\Override]
3435
public function closure(FlowContext $context) : void
3536
{
3637
$context->streams()->closeStreams($this->path);
3738
}
3839

40+
#[\Override]
3941
public function destination() : Path
4042
{
4143
return $this->path;
4244
}
4345

46+
#[\Override]
4447
public function load(Rows $rows, FlowContext $context) : void
4548
{
4649
if (!$rows->count()) {

0 commit comments

Comments
 (0)