Skip to content
This repository was archived by the owner on Dec 12, 2021. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ class Post extends Model implements TypesenseSearch

public function getCollectionSchema(): array {
return [
'name' => $this->getTable(),
'name' => $this->searchableAs(),
'fields' => [
[
'name' => 'title',
Expand Down
14 changes: 4 additions & 10 deletions composer.json
Original file line number Diff line number Diff line change
Expand Up @@ -34,18 +34,12 @@
}
},
"require": {
"php": "~7.2",
"laravel/scout": "7.*|^8.0",
"illuminate/bus": "^6.0|^7.0",
"illuminate/contracts": "^6.0|^7.0",
"illuminate/database": "^6.0|^7.0",
"illuminate/pagination": "^6.0|^7.0",
"illuminate/queue": "^6.0|^7.0",
"illuminate/support": "^6.0|^7.0",
"devloopsnet/typesens-php": "^2.0"
"php": ">=7.4",
"laravel/scout": "^8.0",
"typesense/typesense-php": "^4.0"
},
"suggest": {
"devloopsnet/typesens-php": "Required to use the Typesense php client."
"typesense/typesense-php": "Required to use the Typesense php client."
},
"require-dev": {
"phpunit/phpunit": "^8.0|^9.0",
Expand Down
36 changes: 17 additions & 19 deletions src/Engines/TypesenseSearchEngine.php
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
use Illuminate\Database\Eloquent\Model;
use Devloops\LaravelTypesense\Typesense;
use GuzzleHttp\Exception\GuzzleException;
use Devloops\Typesence\Exceptions\TypesenseClientError;
use Typesense\Exceptions\TypesenseClientError;

/**
* Class TypesenseSearchEngine
Expand Down Expand Up @@ -76,7 +76,7 @@ public function search(Builder $builder)
[
'q' => $builder->query,
'query_by' => implode(',', $builder->model->typesenseQueryBy()),
'fiter_by' => $this->filters($builder),
'filter_by' => $this->filters($builder),
'per_page' => $builder->limit,
'page' => 1,
]
Expand All @@ -90,14 +90,16 @@ public function search(Builder $builder)
public function paginate(Builder $builder, $perPage, $page)
{
return $this->performSearch(
$builder,
[
'q' => $builder->query,
'query_by' => implode(',', $builder->model->typesenseQueryBy()),
'fiter_by' => $this->filters($builder),
'per_page' => $builder->limit,
'page' => 1,
]
$builder,
array_filter(
[
'q' => $builder->query,
'query_by' => implode(',', $builder->model->typesenseQueryBy()),
'filter_by' => $this->filters($builder),
'per_page' => $perPage,
'page' => $page,
]
)
);
}

Expand All @@ -106,7 +108,7 @@ public function paginate(Builder $builder, $perPage, $page)
* @param array $options
*
* @return array|mixed
* @throws \Devloops\Typesence\Exceptions\TypesenseClientError
* @throws \Typesense\Exceptions\TypesenseClientError
* @throws \GuzzleHttp\Exception\GuzzleException
*/
protected function performSearch(Builder $builder, array $options = [])
Expand All @@ -129,15 +131,15 @@ protected function performSearch(Builder $builder, array $options = [])
/**
* @param \Laravel\Scout\Builder $builder
*
* @return array
* @return string
*/
protected function filters(Builder $builder): array
protected function filters(Builder $builder): string
{
return collect($builder->wheres)->map(
static function ($value, $key) {
return $key . ':=' . $value;
}
)->values()->all();
)->values()->implode(' && ');
}

/**
Expand Down Expand Up @@ -188,11 +190,7 @@ public function getTotalCount($results): int
public function flush($model): void
{
$collection = $this->typesense->getCollectionIndex($model);
try {
$collection->delete();
} catch (TypesenseClientError $e) {
} catch (GuzzleException $e) {
}
$collection->delete();
}

}
52 changes: 22 additions & 30 deletions src/Typesense.php
Original file line number Diff line number Diff line change
@@ -1,15 +1,13 @@
<?php


namespace Devloops\LaravelTypesense;


use Devloops\Typesence\Client;
use Devloops\Typesence\Document;
use Devloops\Typesence\Collection;
use Typesense\Client;
use Typesense\Document;
use Typesense\Collection;
use GuzzleHttp\Exception\GuzzleException;
use Devloops\Typesence\Exceptions\ObjectNotFound;
use Devloops\Typesence\Exceptions\TypesenseClientError;
use Typesense\Exceptions\ObjectNotFound;
use Typesense\Exceptions\TypesenseClientError;

/**
* Class Typesense
Expand All @@ -22,22 +20,22 @@ class Typesense
{

/**
* @var \Devloops\Typesence\Client
* @var \Typesense\Client
*/
private $client;

/**
* Typesense constructor.
*
* @param \Devloops\Typesence\Client $client
* @param \Typesense\Client $client
*/
public function __construct(Client $client)
{
$this->client = $client;
}

/**
* @return \Devloops\Typesence\Client
* @return \Typesense\Client
*/
public function getClient(): Client
{
Expand All @@ -47,13 +45,13 @@ public function getClient(): Client
/**
* @param \Illuminate\Database\Eloquent\Model|\Devloops\LaravelTypesense\Interfaces\TypesenseSearch $model
*
* @return \Devloops\Typesence\Collection
* @throws \Devloops\Typesence\Exceptions\TypesenseClientError
* @return \Typesense\Collection
* @throws \Typesense\Exceptions\TypesenseClientError
* @throws \GuzzleHttp\Exception\GuzzleException
*/
private function createCollectionFromModel($model): Collection
private function getOrCreateCollectionFromModel($model): Collection
{
$index = $this->client->getCollections()->{$model->getTable()};
$index = $this->client->getCollections()->{$model->searchableAs()};
try {
$index->retrieve();

Expand All @@ -64,28 +62,26 @@ private function createCollectionFromModel($model): Collection
);

return $this->client->getCollections()->{$model->getTable()};
} catch (TypesenseClientError $exception) {
throw $exception;
}
}

/**
* @param \Illuminate\Database\Eloquent\Model $model
*
* @return \Devloops\Typesence\Collection
* @throws \Devloops\Typesence\Exceptions\TypesenseClientError
* @return \Typesense\Collection
* @throws \Typesense\Exceptions\TypesenseClientError
* @throws \GuzzleHttp\Exception\GuzzleException
*/
public function getCollectionIndex($model): Collection
{
return $this->createCollectionFromModel($model);
return $this->getOrCreateCollectionFromModel($model);
}

/**
* @param \Devloops\Typesence\Collection $collectionIndex
* @param \Typesense\Collection $collectionIndex
* @param $array
*
* @throws \Devloops\Typesence\Exceptions\TypesenseClientError
* @throws \Typesense\Exceptions\TypesenseClientError
* @throws \GuzzleHttp\Exception\GuzzleException
*/
public function upsertDocument(Collection $collectionIndex, $array): void
Expand All @@ -101,26 +97,22 @@ public function upsertDocument(Collection $collectionIndex, $array): void
$collectionIndex->getDocuments()->create($array);
} catch (ObjectNotFound $e) {
$collectionIndex->getDocuments()->create($array);
} catch (TypesenseClientError $e) {
} catch (GuzzleException $e) {
}
}

/**
* @param \Devloops\Typesence\Collection $collectionIndex
* @param $modelId
* @param \Typesense\Collection $collectionIndex
* @param int $modelId
* @throws GuzzleException
* @throws TypesenseClientError
*/
public function deleteDocument(Collection $collectionIndex, $modelId): void
{
/**
* @var $document Document
*/
$document = $collectionIndex->getDocuments()[(string)$modelId];
try {
$document->delete();
} catch (TypesenseClientError $e) {
} catch (GuzzleException $e) {
}
$document->delete();
}

}
2 changes: 1 addition & 1 deletion src/TypesenseServiceProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

namespace Devloops\LaravelTypesense;

use Devloops\Typesence\Client;
use Typesense\Client;
use Laravel\Scout\EngineManager;
use Illuminate\Support\ServiceProvider;
use Devloops\LaravelTypesense\Engines\TypesenseSearchEngine;
Expand Down