Skip to content

Commit 813a4a5

Browse files
committed
Fix previous commits
1 parent 7682d5a commit 813a4a5

File tree

5 files changed

+31
-18
lines changed

5 files changed

+31
-18
lines changed

Client.php

+2-2
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,11 @@
22

33
namespace FOS\ElasticaBundle;
44

5-
use FOS\ElasticaBundle\Elastica\LoggingClient;
5+
use FOS\ElasticaBundle\Elastica\Client as BaseClient;
66

77
/**
88
* @deprecated Use \FOS\ElasticaBundle\Elastica\LoggingClient
99
*/
10-
class Client extends LoggingClient
10+
class Client extends BaseClient
1111
{
1212
}

DependencyInjection/Configuration.php

+4-4
Original file line numberDiff line numberDiff line change
@@ -183,11 +183,11 @@ protected function getTypesNode()
183183
->beforeNormalization()
184184
->ifTrue(function($v) { return isset($v['mappings']); })
185185
->then(function($v) {
186-
$v['properties'] = $v['mappings'];
187-
unset($v['mappings']);
186+
$v['properties'] = $v['mappings'];
187+
unset($v['mappings']);
188188

189-
return $v;
190-
})
189+
return $v;
190+
})
191191
->end()
192192
->children()
193193
->scalarNode('index_analyzer')->end()

DependencyInjection/FOSElasticaExtension.php

+18-4
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@ public function load(array $configs, ContainerBuilder $container)
7272
$container->setAlias('fos_elastica.index', sprintf('fos_elastica.index.%s', $config['default_index']));
7373

7474
$this->loadIndexManager($container);
75+
$this->loadResetter($container);
7576

7677
$this->createDefaultManagerAlias($config['default_manager'], $container);
7778
}
@@ -132,7 +133,7 @@ private function loadIndexes(array $indexes, ContainerBuilder $container)
132133
$indexDef = new DefinitionDecorator('fos_elastica.index_prototype');
133134
$indexDef->replaceArgument(0, $indexName);
134135

135-
if ($index['client']) {
136+
if (isset($index['client'])) {
136137
$client = $this->getClient($index['client']);
137138
$indexDef->setFactoryService($client);
138139
}
@@ -146,7 +147,7 @@ private function loadIndexes(array $indexes, ContainerBuilder $container)
146147
'settings' => $index['settings']
147148
),
148149
'elasticsearch_name' => $indexName,
149-
'index' => $reference,
150+
'reference' => $reference,
150151
'name' => $name,
151152
'type_prototype' => isset($index['type_prototype']) ? $index['type_prototype'] : array(),
152153
'use_alias' => $index['use_alias'],
@@ -220,7 +221,9 @@ private function loadTypes(array $types, ContainerBuilder $container, array $ind
220221
'_timestamp',
221222
'_ttl',
222223
) as $field) {
223-
$this->indexConfigs[$indexName]['config']['properties'][$name][$field] = $type[$field];
224+
if (array_key_exists($field, $type)) {
225+
$this->indexConfigs[$indexName]['config']['properties'][$name][$field] = $type[$field];
226+
}
224227
}
225228

226229
if (!empty($type['dynamic_templates'])) {
@@ -390,7 +393,7 @@ private function loadObjectPersister(array $typeConfig, Definition $typeDef, Con
390393

391394
if ($this->serializerConfig) {
392395
$abstractId = 'fos_elastica.object_serializer_persister';
393-
$callbackId = sprintf('%s.%s.serializer.callback', $this->indexConfigs[$indexName]['index'], $typeName);
396+
$callbackId = sprintf('%s.%s.serializer.callback', $this->indexConfigs[$indexName]['reference'], $typeName);
394397
$arguments[] = array(new Reference($callbackId), 'serialize');
395398
} else {
396399
$abstractId = 'fos_elastica.object_persister';
@@ -622,4 +625,15 @@ private function getClient($clientName)
622625

623626
return $this->clients[$clientName]['reference'];
624627
}
628+
629+
/**
630+
* Loads the resetter
631+
*
632+
* @param \Symfony\Component\DependencyInjection\ContainerBuilder $container
633+
*/
634+
private function loadResetter(ContainerBuilder $container)
635+
{
636+
$resetterDef = $container->getDefinition('fos_elastica.resetter');
637+
$resetterDef->replaceArgument(0, $this->indexConfigs);
638+
}
625639
}

Resources/config/config.xml

+6-7
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
66

77
<parameters>
8-
<parameter key="fos_elastica.client.class">FOS\ElasticaBundle\Elastica\LoggingClient</parameter>
8+
<parameter key="fos_elastica.client.class">FOS\ElasticaBundle\Elastica\Client</parameter>
99
<parameter key="fos_elastica.logger.class">FOS\ElasticaBundle\Logger\ElasticaLogger</parameter>
1010
<parameter key="fos_elastica.data_collector.class">FOS\ElasticaBundle\DataCollector\ElasticaDataCollector</parameter>
1111
<parameter key="fos_elastica.property_accessor.class">Symfony\Component\PropertyAccess\PropertyAccessor</parameter>
@@ -15,7 +15,11 @@
1515
<service id="fos_elastica.client_prototype" class="%fos_elastica.client.class%" abstract="true">
1616
<argument type="collection" /> <!-- configuration -->
1717
<argument /> <!-- callback -->
18-
<argument type="service" id="fos_elastica.transformer.combined" />
18+
</service>
19+
20+
<service id="fos_elastica.data_collector" class="%fos_elastica.data_collector.class%">
21+
<tag name="data_collector" template="FOSElasticaBundle:Collector:elastica" id="elastica" />
22+
<argument type="service" id="fos_elastica.logger" />
1923
</service>
2024

2125
<service id="fos_elastica.logger" class="%fos_elastica.logger.class%">
@@ -24,11 +28,6 @@
2428
<tag name="monolog.logger" channel="elastica" />
2529
</service>
2630

27-
<service id="fos_elastica.data_collector" class="%fos_elastica.data_collector.class%" public="true">
28-
<tag name="data_collector" template="FOSElasticaBundle:Collector:elastica" id="elastica" />
29-
<argument type="service" id="fos_elastica.logger" />
30-
</service>
31-
3231
<service id="fos_elastica.property_accessor" class="%fos_elastica.property_accessor.class%" />
3332
</services>
3433
</container>

Tests/Elastica/LoggingClientTest.php Tests/Elastica/ClientTest.php

+1-1
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ public function testRequestsAreLogged()
2828
$this->isType('array')
2929
);
3030

31-
$client = $this->getMockBuilder('FOS\ElasticaBundle\Elastica\LoggingClient')
31+
$client = $this->getMockBuilder('FOS\ElasticaBundle\Elastica\Client')
3232
->setMethods(array('getConnection'))
3333
->getMock();
3434

0 commit comments

Comments
 (0)