refactor: Use limit to prevent fetching all records

This commit is contained in:
Faruk AYDIN
2023-06-06 11:41:02 +02:00
committed by Ali BARIN
parent 75d5c0e356
commit 0784a2d4d0
3 changed files with 4 additions and 2 deletions

View File

@@ -91,6 +91,7 @@ class Flow extends Base {
async lastInternalId() { async lastInternalId() {
const lastExecution = await this.$relatedQuery('executions') const lastExecution = await this.$relatedQuery('executions')
.orderBy('created_at', 'desc') .orderBy('created_at', 'desc')
.limit(1)
.first(); .first();
return lastExecution ? (lastExecution as Execution).internalId : null; return lastExecution ? (lastExecution as Execution).internalId : null;

View File

@@ -117,6 +117,7 @@ class Step extends Base {
async getLastExecutionStep() { async getLastExecutionStep() {
const lastExecutionStep = await this.$relatedQuery('executionSteps') const lastExecutionStep = await this.$relatedQuery('executionSteps')
.orderBy('created_at', 'desc') .orderBy('created_at', 'desc')
.limit(1)
.first(); .first();
return lastExecutionStep; return lastExecutionStep;

View File

@@ -102,7 +102,7 @@ class User extends Base {
to: 'users.id', to: 'users.id',
}, },
filter(builder: ExtendedQueryBuilder<UsageData>) { filter(builder: ExtendedQueryBuilder<UsageData>) {
builder.orderBy('created_at', 'desc').first(); builder.orderBy('created_at', 'desc').limit(1).first();
}, },
}, },
subscriptions: { subscriptions: {
@@ -121,7 +121,7 @@ class User extends Base {
to: 'users.id', to: 'users.id',
}, },
filter(builder: ExtendedQueryBuilder<Subscription>) { filter(builder: ExtendedQueryBuilder<Subscription>) {
builder.orderBy('created_at', 'desc').first(); builder.orderBy('created_at', 'desc').limit(1).first();
}, },
}, },
}); });