wieni/wmsearch

Elasticsearch api

WMSearch

Manages an index with a single document type page, _(*1)

The api allows adding different document types but only page is 'managed'., _(*2)

Elasticsearch support

API

inject wmsearch.api.index, _(*3)

Index

$api->createIndex();, _(*4)

$api->deleteIndex();, _(*5)

Document

$api->addDoc(ElasticEntityInterface $entity); // upsert, _(*6)

$api->delDoc($id);, _(*7)

$api->getDoc($id);, _(*8)

Search

$api->search(QueryInterface) : SearchResult, _(*9)

// Identical to ->search() but strips html from highlights
$api->highlightSearch(QueryInterface) : SearchResult

Misc

$api->health(); // simple http elastic healthcheck, _(*10)

$api->refresh() // reopen lucene index, _(*11)

$api->flush() // fsync the lucene index, _(*12)

JSON

GET /search/json?q=lorem%20ipsum&o=0&a=10, _(*13)

q  string The query
o  int    The offset
a int    Amount of items

Drush

drush wmsp                      # Recreate the current index, removing all documents. Alias for wmsearch:purge
drush wmsq                      # Queue content for indexing. Alias for wmsearch:queue
drush queue:run wmsearch.index  # Index queued content
drush wmsc                      # Create a new index. Alias for wmsearch-index-create
drush wmsri                     # Rename an existing index. Alias for wmsearch-reindex

Config

# The elastic endpoint uri
wmsearch.elastic.endpoint: 'http://localhost:9200'

# Name of the index
wmsearch.elastic.index: 'mysite-staging'

# Serve a quick'n dirty site search on /simple-search
wmsearch.simple_search: false

# Default JSON endpoint
wmsearch.json.path: '/search/json'

# Formatter class for the JSON endpoint
wmsearch.json.formatter.class: 'Drupal\wmsearch\Service\ResultFormatter'

# Query provider for the JSON endpoint
wmsearch.json.query_builder.class: 'Drupal\wmsearch\Service\QueryBuilder'

License

GPL, _(*14)

Examples

ElasticEntityInterface

This assumes wieni/wmmodel or something similar., _(*15)

class Article extends Node implements WmModelInterface, ElasticEntityInterface
{
    use EntityPageTrait;

    public function getElasticTypes()
    {
        return ['page'];
    }

    public function getElasticDocumentCollection($type)
    {
        return 'mymodule.elastic.article.collection';
    }
}

EntityDocumentCollectionInterface

# mymodule.services.yml
services:
    mymodule.elastic.article.collection:
        class: Drupal\mymodule\Service\Elastic\Collection\ArticleCollection

namespace Drupal\mymodule\Service\Elastic\Collection;

use Drupal\wmsearch\Entity\Document\EntityDocumentCollection;
use Drupal\wmsearch\Exception\NotIndexableException;

class ArticleCollection extends EntityDocumentCollection
{
    /** @var \Drupal\mymodule\Entity\Node\Article */
    protected $entity;

    public function toElasticArray($elasticId)
    {
        if (!$this->entity->isPublished()) {
            throw new NotIndexableException();
        }

        return [
            'id' => $this->entity->id(), // this isn't the elasticId
            'title' => $this->entity->getTitle(),
            'url' => $this->entity->toUrl()->toString(),
            'language' => $this->entity->language()->getId(),
            // ...
        ];
    }
}

Programmatically index

$article = $nodeStorage->load(123);
$api->addDoc($dish);

Query

Search, _(*16)

$perPage = 10;
$page = (int) $req->query->get('page');
$input = $req->query->get('q', '');

$query = new PageQuery();
$query->from($perPage * $page)
    ->size($perPage)
    ->setHighlight(1, 120, ['title', 'intro'], '<em>', '</em>')
    ->addMultiMatch($input, ['title', 'intro', 'body']);

$formatter->format($api->highlightSearch($query));

Completion, _(*17)

$query = new PageQuery();
    ->setSource('')
    ->complete($input, 2);

$formatter->format($api->search($query));

TODO

• DocumentInterface examples
• wmmodel implementation + reindex