kvazar/index-php
1
0
Fork 0
mirror of https://github.com/kvazar-network/index-php.git synced 2025-01-22 12:54:15 +00:00
Code Issues Projects Releases Wiki Activity

add init methods

Browse Source
This commit is contained in:
ghost 2024-02-12 15:36:13 +02:00
parent a178130500
commit 777d98c6a0
1 changed files with 67 additions and 35 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
src/Manticore.php
View File

@ -4,20 +4,22 @@ declare(strict_types=1);
namespace Kvazar\Index; namespace Kvazar\Index;
use Manticoresearch\Client;
use Manticoresearch\Index;
class Manticore class Manticore
{ {
private \Manticoresearch\Client $_client; private \Manticoresearch\Client $_client;
private \Manticoresearch\Index $_index;
private $_index;
public function __construct( public function __construct(
?string $name = 'kvazar', ?string $name = 'kvazar',
?array $meta = [],
?string $host = '127.0.0.1', ?string $host = '127.0.0.1',
?int $port = 9308, ?int $port = 9308
?bool $drop = false
) )
{ {
$this->_client = new \Manticoresearch\Client( $this->_client = new Client(
[ [
'host' => $host, 'host' => $host,
'port' => $port, 'port' => $port,
@ -28,15 +30,6 @@ class Manticore
$name $name
); );
if ($drop)
{
$this->_index->drop(
true
);
}
if (!$this->_index->status())
{
$this->_index->create( $this->_index->create(
[ [
'block' => 'block' =>
@ -47,7 +40,7 @@ class Manticore
[ [
'type' => 'text' 'type' => 'text'
], ],
'txid' => 'transaction' =>
[ [
'type' => 'text' 'type' => 'text'
], ],
@ -59,8 +52,47 @@ class Manticore
[ [
'type' => 'text' 'type' => 'text'
] ]
] ],
$meta,
true
); );
} }
public function add(
int $block,
string $namespace,
string $transaction,
string $key,
string $value
): int
{
$crc32transaction = crc32(
$transaction
);
if (!$this->_index->getDocumentById($crc32transaction))
{
$this->_index->addDocument(
[
'block' => $block,
'namespace' => $namespace,
'transaction' => $transaction,
'key' => $key,
'value' => $value
],
$crc32transaction
);
}
return $crc32transaction;
}
public function drop(
?bool $silent = false
)
{
return $this->_index->drop(
$silent
);
} }
} }