Mirrors/unleash.unleash
1
0
Fork 0
mirror of https://github.com/Unleash/unleash.git synced 2025-10-27 11:02:16 +01:00
Code Issues Projects Releases Wiki Activity

chore(1-3293): add new method for monthly aggregate of traffic data

Browse Source
This commit is contained in:
Thomas Heartman 2025-01-24 14:42:27 +01:00
parent 6fe1d9f1a7
commit 6079114217
No known key found for this signature in database
GPG Key ID: BD1F880DAED1EE78
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/lib/features/traffic-data-usage/traffic-data-usage-store.ts
View File

@ -1,4 +1,4 @@
import { endOfMonth, startOfMonth } from 'date-fns'; import { endOfMonth, startOfMonth, subMonths } from 'date-fns';
import type { Db } from '../../db/db'; import type { Db } from '../../db/db';
import type { Logger, LogProvider } from '../../logger'; import type { Logger, LogProvider } from '../../logger';
import type { import type {
@ -112,8 +112,9 @@ export class TrafficDataUsageStore implements ITrafficDataUsageStore {
); );
} }
async getTrafficDataForMonthRange( async getMonthlyTrafficDataUsageForPeriod(
monthsBack: number, from: Date,
to: Date,
): Promise<IStatMonthlyTrafficUsage[]> { ): Promise<IStatMonthlyTrafficUsage[]> {
const rows = await this.db(TABLE) const rows = await this.db(TABLE)
.select( .select(
@ -122,10 +123,8 @@ export class TrafficDataUsageStore implements ITrafficDataUsageStore {
this.db.raw(`to_char(day, 'YYYY-MM') AS month`), this.db.raw(`to_char(day, 'YYYY-MM') AS month`),
this.db.raw(`SUM(count) AS count`), this.db.raw(`SUM(count) AS count`),
) )
.whereRaw( .where('day', '>=', from)
`day >= date_trunc('month', CURRENT_DATE) - make_interval(months := ?)`, .andWhere('day', '<=', to)
[monthsBack],
)
.groupBy([ .groupBy([
'traffic_group', 'traffic_group',
this.db.raw(`to_char(day, 'YYYY-MM')`), this.db.raw(`to_char(day, 'YYYY-MM')`),
@ -144,4 +143,12 @@ export class TrafficDataUsageStore implements ITrafficDataUsageStore {
}), }),
); );
} }
async getTrafficDataForMonthRange(
monthsBack: number,
): Promise<IStatMonthlyTrafficUsage[]> {
const to = endOfMonth(new Date());
const from = startOfMonth(subMonths(to, monthsBack));
return this.getMonthlyTrafficDataUsageForPeriod(from, to);
}
} }