Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix: advanced search using amount range returns no results for multipayment #502

Merged
Show file tree
Hide file tree
Changes from 8 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
46 changes: 46 additions & 0 deletions app/Services/Search/Concerns/FiltersMultiPaymentValueRange.php
@@ -0,0 +1,46 @@
<?php

declare(strict_types=1);

namespace App\Services\Search\Concerns;

use Illuminate\Database\Eloquent\Builder;

trait FiltersMultiPaymentValueRange
{
/**
* @param Builder $query
* @param string|int|null $from
* @param string|int|null $to
* @param bool $useSatoshi
*
* @return Builder
*/
private function queryMultiPaymentValueRange(Builder $query, $from, $to, bool $useSatoshi = true): Builder
{
if (is_null($from) && is_null($to)) {
return $query;
}

$query->where('amount', '=', 0);

$query->whereExists(function (\Illuminate\Database\Query\Builder $qq) use ($useSatoshi, $to, $from): void {
marianogoldman marked this conversation as resolved.
Show resolved Hide resolved
$qq->selectRaw('i.id')
->fromRaw("( SELECT id, (jsonb_array_elements(asset -> 'payments') ->> 'amount')::bigint am FROM transactions t WHERE t.id = id ) i")
->whereRaw('i.id = transactions.id')
->groupBy('i.id')
->when(! is_null($from) && $from > 0, function ($q) use ($useSatoshi, $from): void {
$q->havingRaw('sum(am) >= ?', [
(int) $from * ($useSatoshi ? 1e8 : 1),
]);
})
->when(! is_null($to) && $to > 0, function ($q) use ($useSatoshi, $to): void {
$q->havingRaw('sum(am) <= ?', [
(int) $to * ($useSatoshi ? 1e8 : 1),
]);
});
});

return $query;
}
}
14 changes: 12 additions & 2 deletions app/Services/Search/TransactionSearch.php
Expand Up @@ -42,6 +42,7 @@
use App\Models\Scopes\VoteScope;
use App\Models\Transaction;
use App\Services\Search\Concerns\FiltersDateRange;
use App\Services\Search\Concerns\FiltersMultiPaymentValueRange;
use App\Services\Search\Concerns\FiltersValueRange;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Arr;
Expand All @@ -50,6 +51,7 @@ final class TransactionSearch implements Search
{
use FiltersDateRange;
use FiltersValueRange;
use FiltersMultiPaymentValueRange;

private array $scopes = [
'businessEntityRegistration' => BusinessEntityRegistrationScope::class,
Expand Down Expand Up @@ -91,22 +93,29 @@ final class TransactionSearch implements Search

public function search(array $parameters): Builder
{
$query = Transaction::query();
$query = Transaction::query();
$isMultiPayment = false;

if (Arr::has($parameters, 'transactionType')) {
if (Arr::get($parameters, 'transactionType') !== 'all') {
$scopeClass = $this->scopes[$parameters['transactionType']];

/* @var \Illuminate\Database\Eloquent\Model */
$query = $query->withScope($scopeClass);

$isMultiPayment = $scopeClass === MultiPaymentScope::class;
}
}

if (! is_null(Arr::get($parameters, 'term'))) {
$query->where('id', $parameters['term']);
}

$this->queryValueRange($query, 'amount', Arr::get($parameters, 'amountFrom'), Arr::get($parameters, 'amountTo'));
if ($isMultiPayment) {
$this->queryMultiPaymentValueRange($query, Arr::get($parameters, 'amountFrom'), Arr::get($parameters, 'amountTo'));
} else {
$this->queryValueRange($query, 'amount', Arr::get($parameters, 'amountFrom'), Arr::get($parameters, 'amountTo'));
}

$this->queryValueRange($query, 'fee', Arr::get($parameters, 'feeFrom'), Arr::get($parameters, 'feeTo'));

Expand All @@ -116,6 +125,7 @@ public function search(array $parameters): Builder
$query->where('vendor_field', $parameters['smartBridge']);
}

// $query->dump();
return $query;
}
}
20 changes: 10 additions & 10 deletions config/explorer.php
Expand Up @@ -12,29 +12,29 @@
'alias' => env('EXPLORER_NETWORK_ALIAS', 'mainnet'),
'currency' => env('EXPLORER_NETWORK_CURRENCY', 'ARK'),
'currencySymbol' => env('EXPLORER_NETWORK_CURRENCY_SYMBOL', 'Ѧ'),
'confirmations' => env('EXPLORER_NETWORK_CONFIRMATIONS', 51),
'confirmations' => intval(env('EXPLORER_NETWORK_CONFIRMATIONS', 51)),
'knownWallets' => env('EXPLORER_NETWORK_KNOWN_WALLETS', 'https://raw.githubusercontent.com/ArkEcosystem/common/master/mainnet/known-wallets-extended.json'),
'canBeExchanged' => env('EXPLORER_NETWORK_CAN_BE_EXCHANGED', true),
'usesMarketsquare' => env('EXPLORER_NETWORK_USES_MARKETSQUARE', false),
'epoch' => env('EXPLORER_NETWORK_EPOCH', '2017-03-21T13:00:00.000Z'),
'delegateCount' => env('EXPLORER_NETWORK_DELEGATE_COUNT', 51),
'blockTime' => env('EXPLORER_NETWORK_BLOCK_TIME', 8),
'blockReward' => env('EXPLORER_NETWORK_BLOCK_REWARD', 2),
'base58Prefix' => env('EXPLORER_NETWORK_BASE58_PREFIX', 23),
'delegateCount' => intval(env('EXPLORER_NETWORK_DELEGATE_COUNT', 51)),
'blockTime' => intval(env('EXPLORER_NETWORK_BLOCK_TIME', 8)),
'blockReward' => intval(env('EXPLORER_NETWORK_BLOCK_REWARD', 2)),
'base58Prefix' => intval(env('EXPLORER_NETWORK_BASE58_PREFIX', 23)),
],
'development' => [
'name' => env('EXPLORER_NETWORK_NAME', 'ARK Development Network'),
'alias' => env('EXPLORER_NETWORK_ALIAS', 'devnet'),
'currency' => env('EXPLORER_NETWORK_CURRENCY', 'DARK'),
'currencySymbol' => env('EXPLORER_NETWORK_CURRENCY_SYMBOL', 'DѦ'),
'confirmations' => env('EXPLORER_NETWORK_CONFIRMATIONS', 51),
'confirmations' => intval(env('EXPLORER_NETWORK_CONFIRMATIONS', 51)),
'canBeExchanged' => env('EXPLORER_NETWORK_CAN_BE_EXCHANGED', false),
'usesMarketsquare' => env('EXPLORER_NETWORK_USES_MARKETSQUARE', false),
'epoch' => env('EXPLORER_NETWORK_EPOCH', '2017-03-21T13:00:00.000Z'),
'delegateCount' => env('EXPLORER_NETWORK_DELEGATE_COUNT', 51),
'blockTime' => env('EXPLORER_NETWORK_BLOCK_TIME', 8),
'blockReward' => env('EXPLORER_NETWORK_BLOCK_REWARD', 2),
'base58Prefix' => env('EXPLORER_NETWORK_BASE58_PREFIX', 30),
'delegateCount' => intval(env('EXPLORER_NETWORK_DELEGATE_COUNT', 51)),
'blockTime' => intval(env('EXPLORER_NETWORK_BLOCK_TIME', 8)),
'blockReward' => intval(env('EXPLORER_NETWORK_BLOCK_REWARD', 2)),
'base58Prefix' => intval(env('EXPLORER_NETWORK_BASE58_PREFIX', 30)),
],
],

Expand Down
37 changes: 31 additions & 6 deletions tests/Unit/Services/Search/TransactionSearchTest.php
Expand Up @@ -2,6 +2,8 @@

declare(strict_types=1);

use App\Enums\CoreTransactionTypeEnum;
use App\Enums\TransactionTypeGroupEnum;
use App\Models\Transaction;
use App\Services\Search\TransactionSearch;

Expand Down Expand Up @@ -84,7 +86,7 @@
expect($result->get())->toHaveCount(10);
});

it('should search for blocks by amount minimum', function () {
it('should search for transactions by amount minimum', function () {
Transaction::factory(10)->create(['amount' => 1000 * 1e8]);
Transaction::factory(10)->create(['amount' => 2000 * 1e8]);

Expand All @@ -95,7 +97,7 @@
expect($result->get())->toHaveCount(10);
});

it('should search for blocks by amount maximum', function () {
it('should search for transactions by amount maximum', function () {
Transaction::factory(10)->create(['amount' => 1000 * 1e8]);
Transaction::factory(10)->create(['amount' => 2000 * 1e8]);

Expand All @@ -106,7 +108,7 @@
expect($result->get())->toHaveCount(10);
});

it('should search for blocks by amount range', function () {
it('should search for transactions by amount range', function () {
Transaction::factory(10)->create(['amount' => 1000 * 1e8]);
Transaction::factory(10)->create(['amount' => 2000 * 1e8]);

Expand All @@ -118,7 +120,30 @@
expect($result->get())->toHaveCount(10);
});

it('should search for blocks by fee minimum', function () {
it('should search for multipayment transactions by amount range', function () {
marianogoldman marked this conversation as resolved.
Show resolved Hide resolved
Transaction::factory()->create([
'type_group' => TransactionTypeGroupEnum::CORE,
'type' => CoreTransactionTypeEnum::MULTI_PAYMENT,
'amount' => 0,
'asset' => [
'payments' => [
['amount' => 750 * 1e8, 'recipientId' => 'D61mfSggzbvQgTUe6JhYKH2doHaqJ3Dyib'],
['amount' => 251 * 1e8, 'recipientId' => 'DFJ5Z51F1euNNdRUQJKQVdG4h495LZkc6T'],
],
],
]);
Transaction::factory()->create(['amount' => 2000 * 1e8]);

$result = (new TransactionSearch())->search([
'transactionType' => 'multiPayment',
'amountFrom' => 900,
'amountTo' => 1100,
]);

expect($result->get())->toHaveCount(1);
});

it('should search for transactions by fee minimum', function () {
Transaction::factory(10)->create(['fee' => 1000 * 1e8]);
Transaction::factory(10)->create(['fee' => 2000 * 1e8]);

Expand All @@ -129,7 +154,7 @@
expect($result->get())->toHaveCount(10);
});

it('should search for blocks by fee maximum', function () {
it('should search for transactions by fee maximum', function () {
Transaction::factory(10)->create(['fee' => 1000 * 1e8]);
Transaction::factory(10)->create(['fee' => 2000 * 1e8]);

Expand All @@ -140,7 +165,7 @@
expect($result->get())->toHaveCount(10);
});

it('should search for blocks by fee range', function () {
it('should search for transactions by fee range', function () {
Transaction::factory(10)->create(['fee' => 1000 * 1e8]);
Transaction::factory(10)->create(['fee' => 2000 * 1e8]);

Expand Down