kvazar/crawler
1
0
Fork 0
mirror of https://github.com/kvazar-network/crawler.git synced 2025-08-26 14:32:02 +00:00
Code Issues Projects Releases Wiki Activity

use kevaGroupFilter as tmp solution for #10

Browse Source
This commit is contained in:
ghost 2024-02-26 11:24:24 +02:00
parent d6c6f0e870
commit ab7c76abbd
2 changed files with 44 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
composer.json
View File

@ -3,7 +3,7 @@
"description": "KVAZAR Index Crawler", "description": "KVAZAR Index Crawler",
"type": "project", "type": "project",
"require": { "require": {
"kevachat/kevacoin": "^1.6", "kevachat/kevacoin": "^1.10",
"kvazar/crypto": "dev-main", "kvazar/crypto": "dev-main",
"kvazar/index": "dev-main" "kvazar/index": "dev-main"
}, },

85
src/index.php
View File

@ -273,49 +273,62 @@ for ($block = $state + 1; $block <= $blocks; $block++)
// Operation ID required to continue // Operation ID required to continue
if (empty($asm[0])) if (empty($asm[0]))
{ {
continue; exit(
sprintf(
_('Undefined operation of transaction "%s" in block "%d"!'),
$transaction,
$block
)
);
} }
// Detect key / value // Detect key / value
switch ($asm[0]) { switch ($asm[0]) {
case 'OP_KEVA_PUT': case 'OP_KEVA_PUT':
if (empty($asm[1]) || empty($asm[2]) || empty($asm[3]))
{
continue 2;
}
$namespace = \Kvazar\Crypto\Base58::encode(
$asm[1], false, 0, false
);
$key = \Kvazar\Crypto\Kevacoin::decode(
$asm[2]
);
$value = \Kvazar\Crypto\Kevacoin::decode(
$asm[3]
);
break;
case 'OP_KEVA_NAMESPACE': case 'OP_KEVA_NAMESPACE':
if (empty($asm[1]) || empty($asm[2])) // Namespace info required to continue
if (empty($asm[1]))
{ {
continue 2; exit(
sprintf(
_('Undefined namespace of transaction "%s" in block "%d"!'),
$transaction,
$block
)
);
} }
// Decode namespace
$namespace = \Kvazar\Crypto\Base58::encode( $namespace = \Kvazar\Crypto\Base58::encode(
$asm[1], false, 0, false $asm[1],
false,
0,
false
); );
$key = '_KEVA_NS_'; // Find all data by namespace
foreach ((array) $kevacoin->kevaGroupFilter( // @TODO complete \Kvazar\Crypto\Kevacoin to decode tx faster
$value = \Kvazar\Crypto\Kevacoin::decode( $namespace
$asm[2] ) as $record)
{
// Get current block transactions only
if ($record['height'] == $block)
{
// Register new transaction
$index->add(
$raw['time'],
$raw['size'],
$block,
$namespace,
$raw['txid'],
$asm[0],
$record['key'],
$record['value']
); );
}
}
break; break;
@ -326,33 +339,19 @@ for ($block = $state + 1; $block <= $blocks; $block++)
case 'OP_DUP': case 'OP_DUP':
case 'OP_NOP': case 'OP_NOP':
continue 2;
break; break;
default: default:
exit( exit(
sprintf( sprintf(
_('Undefined operation "%s" of transaction "%s" in block "%d"!'), _('Unknown operation "%s" of transaction "%s" in block "%d"!'),
$asm[0], $asm[0],
$transaction, $transaction,
$block $block
) )
); );
} }
// Add index record
$index->add(
$raw['time'],
$raw['size'],
$block,
$namespace,
$raw['txid'],
$asm[0],
$key,
$value
);
} }
} }