CakePHP ElasticsearchBehavior

gistfile1.txt

<?php

class ElasticsearchBehavior extends ModelBehavior {

	public function beforeFind(Model $Model, $query) {
		if(!empty($query['conditions']['elastic'])) {
			$Model->switchToElastic();
			unset($query['conditions']['elastic']);
		}

		return $query;
	}

	public function afterFind(Model $Model, $results, $primary = false) {
		if($Model->isElastic()) {
			$Model->esNormalize($results);
			$Model->switchToDatabase();
		}

		return $results;
	}

	public function afterSave(Model $Model, $created, $options = []) {
		$esData = $Model->esDenormalize($Model->data);
		$esModel = new $Model->alias();
		$esModel->switchToElastic();
		$esModel->create();
		$esModel->save($esData, ['callbacks' => 'false']);
		$esModel->switchToDatabase();
	}
}