|
4 | 4 |
|
5 | 5 | namespace PhpKafka\PhpAvroSchemaGenerator\Merger;
|
6 | 6 |
|
| 7 | +use AvroSchema; |
7 | 8 | use AvroSchemaParseException;
|
8 | 9 | use PhpKafka\PhpAvroSchemaGenerator\Avro\Avro;
|
9 | 10 | use PhpKafka\PhpAvroSchemaGenerator\Exception\SchemaMergerException;
|
10 | 11 | use PhpKafka\PhpAvroSchemaGenerator\Optimizer\OptimizerInterface;
|
11 |
| -use PhpKafka\PhpAvroSchemaGenerator\Optimizer\PrimitiveSchemaOptimizer; |
12 | 12 | use PhpKafka\PhpAvroSchemaGenerator\Registry\SchemaRegistryInterface;
|
13 | 13 | use PhpKafka\PhpAvroSchemaGenerator\Schema\SchemaTemplateInterface;
|
14 | 14 |
|
@@ -65,7 +65,7 @@ public function getResolvedSchemaTemplate(SchemaTemplateInterface $rootSchemaTem
|
65 | 65 | $exceptionThrown = false;
|
66 | 66 |
|
67 | 67 | try {
|
68 |
| - \AvroSchema::parse($rootDefinition); |
| 68 | + AvroSchema::parse($rootDefinition); |
69 | 69 | } catch (AvroSchemaParseException $e) {
|
70 | 70 | if (false === strpos($e->getMessage(), ' is not a schema we know about.')) {
|
71 | 71 | throw $e;
|
@@ -124,14 +124,13 @@ public function merge(
|
124 | 124 | foreach ($registry->getRootSchemas() as $rootSchemaTemplate) {
|
125 | 125 | try {
|
126 | 126 | $resolvedTemplate = $this->getResolvedSchemaTemplate($rootSchemaTemplate);
|
| 127 | + |
127 | 128 | foreach ($this->optimizers as $optimizer) {
|
128 | 129 | $resolvedTemplate = $resolvedTemplate->withSchemaDefinition(
|
129 |
| - $optimizer instanceof PrimitiveSchemaOptimizer ? |
130 |
| - $optimizer->optimize( |
131 |
| - $resolvedTemplate->getSchemaDefinition(), |
132 |
| - $resolvedTemplate->isPrimitive() |
133 |
| - ) : |
134 |
| - $optimizer->optimize($resolvedTemplate->getSchemaDefinition()) |
| 130 | + $optimizer->optimize( |
| 131 | + $resolvedTemplate->getSchemaDefinition(), |
| 132 | + $resolvedTemplate->isPrimitive() |
| 133 | + ) |
135 | 134 | );
|
136 | 135 | }
|
137 | 136 | } catch (SchemaMergerException $e) {
|
|
0 commit comments