Skip to content

Commit e84ff76

Browse files
committed
refactor(database): switch convertQueriesToDatabase to Method enum
Replace Query::TYPE_* string constants (removed upstream in 0.3.x) with Method enum cases. Behaviour unchanged; the GroupByTimeBucket case is the new name for the deferred groupByInterval/intervalGroupBy bucket — still a no-op for the Database adapter since it has no time-bucketed aggregation path.
1 parent 377b639 commit e84ff76

1 file changed

Lines changed: 19 additions & 21 deletions

File tree

src/Usage/Adapter/Database.php

Lines changed: 19 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,10 @@
66
use Utopia\Database\Document;
77
use Utopia\Database\Exception\Duplicate as DuplicateException;
88
use Utopia\Database\Query as DatabaseQuery;
9+
use Utopia\Query\Method;
10+
use Utopia\Query\Query;
911
use Utopia\Usage\Metric;
1012
use Utopia\Usage\Usage;
11-
use Utopia\Usage\UsageQuery;
12-
use Utopia\Query\Query;
1313

1414
class Database extends SQL
1515
{
@@ -380,25 +380,25 @@ private function convertQueriesToDatabase(array $queries): array
380380
$values = $query->getValues();
381381

382382
switch ($method) {
383-
case Query::TYPE_EQUAL:
383+
case Method::Equal:
384384
/** @var array<array<int|string, mixed>|bool|float|int|string> $values */
385385
$dbQueries[] = DatabaseQuery::equal($attribute, $values);
386386
break;
387-
case Query::TYPE_GREATER:
387+
case Method::GreaterThan:
388388
if (!empty($values)) {
389389
/** @var bool|float|int|string $value */
390390
$value = $values[0];
391391
$dbQueries[] = DatabaseQuery::greaterThan($attribute, $value);
392392
}
393393
break;
394-
case Query::TYPE_LESSER:
394+
case Method::LessThan:
395395
if (!empty($values)) {
396396
/** @var bool|float|int|string $value */
397397
$value = $values[0];
398398
$dbQueries[] = DatabaseQuery::lessThan($attribute, $value);
399399
}
400400
break;
401-
case Query::TYPE_BETWEEN:
401+
case Method::Between:
402402
if (count($values) >= 2) {
403403
/** @var bool|float|int|string $start */
404404
$start = $values[0];
@@ -407,22 +407,22 @@ private function convertQueriesToDatabase(array $queries): array
407407
$dbQueries[] = DatabaseQuery::between($attribute, $start, $end);
408408
}
409409
break;
410-
case Query::TYPE_CONTAINS:
410+
case Method::Contains:
411411
/** @var array<array<int|string, mixed>|bool|float|int|string> $values */
412412
$dbQueries[] = DatabaseQuery::contains($attribute, $values);
413413
break;
414-
case Query::TYPE_NOT_EQUAL:
414+
case Method::NotEqual:
415415
if (!empty($values)) {
416416
/** @var bool|float|int|string $value */
417417
$value = $values[0];
418418
$dbQueries[] = DatabaseQuery::notEqual($attribute, $value);
419419
}
420420
break;
421-
case Query::TYPE_NOT_CONTAINS:
421+
case Method::NotContains:
422422
/** @var array<array<int|string, mixed>|bool|float|int|string> $values */
423423
$dbQueries[] = DatabaseQuery::notContains($attribute, $values);
424424
break;
425-
case Query::TYPE_NOT_BETWEEN:
425+
case Method::NotBetween:
426426
if (count($values) >= 2) {
427427
/** @var bool|float|int|string $start */
428428
$start = $values[0];
@@ -431,54 +431,52 @@ private function convertQueriesToDatabase(array $queries): array
431431
$dbQueries[] = DatabaseQuery::notBetween($attribute, $start, $end);
432432
}
433433
break;
434-
case Query::TYPE_STARTS_WITH:
434+
case Method::StartsWith:
435435
if (!empty($values) && is_string($values[0])) {
436436
$dbQueries[] = DatabaseQuery::startsWith($attribute, $values[0]);
437437
}
438438
break;
439-
case Query::TYPE_ENDS_WITH:
439+
case Method::EndsWith:
440440
if (!empty($values) && is_string($values[0])) {
441441
$dbQueries[] = DatabaseQuery::endsWith($attribute, $values[0]);
442442
}
443443
break;
444-
case Query::TYPE_LESSER_EQUAL:
444+
case Method::LessThanEqual:
445445
if (!empty($values)) {
446446
/** @var bool|float|int|string $value */
447447
$value = $values[0];
448448
$dbQueries[] = DatabaseQuery::lessThanEqual($attribute, $value);
449449
}
450450
break;
451-
case Query::TYPE_GREATER_EQUAL:
451+
case Method::GreaterThanEqual:
452452
if (!empty($values)) {
453453
/** @var bool|float|int|string $value */
454454
$value = $values[0];
455455
$dbQueries[] = DatabaseQuery::greaterThanEqual($attribute, $value);
456456
}
457457
break;
458-
case Query::TYPE_ORDER_DESC:
458+
case Method::OrderDesc:
459459
$dbQueries[] = DatabaseQuery::orderDesc($attribute);
460460
break;
461-
case Query::TYPE_ORDER_ASC:
461+
case Method::OrderAsc:
462462
$dbQueries[] = DatabaseQuery::orderAsc($attribute);
463463
break;
464-
case Query::TYPE_LIMIT:
464+
case Method::Limit:
465465
if (!empty($values)) {
466466
/** @var int|string $val */
467467
$val = $values[0] ?? 0;
468468
$dbQueries[] = DatabaseQuery::limit((int) $val);
469469
}
470470
break;
471-
case Query::TYPE_OFFSET:
471+
case Method::Offset:
472472
if (!empty($values)) {
473473
/** @var int|string $val */
474474
$val = $values[0] ?? 0;
475475
$dbQueries[] = DatabaseQuery::offset((int) $val);
476476
}
477477
break;
478478

479-
case UsageQuery::TYPE_GROUP_BY_INTERVAL:
480-
// groupByInterval is not supported by the Database adapter.
481-
// Silently skip — callers get raw (non-aggregated) results.
479+
case Method::GroupByTimeBucket:
482480
break;
483481
}
484482
}

0 commit comments

Comments
 (0)