89 lines
2.5 KiB
PHP
89 lines
2.5 KiB
PHP
<?php
|
|
|
|
namespace FOQ\ElasticaBundle\Doctrine;
|
|
|
|
use FOQ\ElasticaBundle\Transformer\ElasticaToModelTransformerInterface;
|
|
use Elastica_Document;
|
|
|
|
/**
|
|
* Maps Elastica documents with Doctrine objects
|
|
* This mapper assumes an exact match between
|
|
* elastica documents ids and doctrine object ids
|
|
*/
|
|
abstract class AbstractElasticaToModelTransformer implements ElasticaToModelTransformerInterface
|
|
{
|
|
/**
|
|
* Repository to fetch the objects from
|
|
*/
|
|
protected $objectManager = null;
|
|
|
|
/**
|
|
* Class of the model to map to the elastica documents
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $objectClass = null;
|
|
|
|
/**
|
|
* Optional parameters
|
|
*
|
|
* @var array
|
|
*/
|
|
protected $options = array(
|
|
'hydrate' => true,
|
|
'identifier' => 'id'
|
|
);
|
|
|
|
/**
|
|
* Instanciates a new Mapper
|
|
*
|
|
* @param object $objectManager
|
|
* @param string $objectClass
|
|
* @param array $options
|
|
*/
|
|
public function __construct($objectManager, $objectClass, array $options = array())
|
|
{
|
|
$this->objectManager = $objectManager;
|
|
$this->objectClass = $objectClass;
|
|
$this->options = array_merge($this->options, $options);
|
|
}
|
|
|
|
/**
|
|
* Transforms an array of elastica objects into an array of
|
|
* model objects fetched from the doctrine repository
|
|
*
|
|
* @param array of elastica objects
|
|
* @return array
|
|
**/
|
|
public function transform(array $elasticaObjects)
|
|
{
|
|
$ids = array_map(function($elasticaObject) {
|
|
return $elasticaObject->getId();
|
|
}, $elasticaObjects);
|
|
|
|
$objects = $this->findByIdentifiers($this->objectClass, $this->options['identifier'], $ids, $this->options['hydrate']);
|
|
|
|
$identifierGetter = 'get'.ucfirst($this->options['identifier']);
|
|
|
|
// sort objects in the order of ids
|
|
$idPos = array_flip($ids);
|
|
usort($objects, function($a, $b) use ($idPos, $identifierGetter)
|
|
{
|
|
return $idPos[$a->$identifierGetter()] > $idPos[$b->$identifierGetter()];
|
|
});
|
|
|
|
return $objects;
|
|
}
|
|
|
|
/**
|
|
* Fetches objects by theses identifier values
|
|
*
|
|
* @param string $class the model class
|
|
* @param string $identifierField like 'id'
|
|
* @param array $identifierValues ids values
|
|
* @param mixed $hydrate whether or not to hydrate the objects, false returns arrays
|
|
* @return array of objects or arrays
|
|
*/
|
|
protected abstract function findByIdentifiers($class, $identifierField, array $identifierValues, $hydrate);
|
|
}
|