|
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