diff options
-rw-r--r-- | server/models/video/video-channel.ts | 37 | ||||
-rw-r--r-- | server/tests/api/server/stats.ts | 3 |
2 files changed, 21 insertions, 19 deletions
diff --git a/server/models/video/video-channel.ts b/server/models/video/video-channel.ts index 9e461b6ca..132c8f021 100644 --- a/server/models/video/video-channel.ts +++ b/server/models/video/video-channel.ts | |||
@@ -434,42 +434,41 @@ export class VideoChannelModel extends Model<Partial<AttributesOnly<VideoChannel | |||
434 | 434 | ||
435 | static async getStats () { | 435 | static async getStats () { |
436 | 436 | ||
437 | function getActiveVideoChannels (days: number) { | 437 | function getLocalVideoChannelStats (days?: number) { |
438 | const options = { | 438 | const options = { |
439 | type: QueryTypes.SELECT as QueryTypes.SELECT, | 439 | type: QueryTypes.SELECT as QueryTypes.SELECT, |
440 | raw: true | 440 | raw: true |
441 | } | 441 | } |
442 | 442 | ||
443 | const videoJoin = days | ||
444 | ? `INNER JOIN "video" AS "Videos" ON "VideoChannelModel"."id" = "Videos"."channelId" ` + | ||
445 | `AND ("Videos"."publishedAt" > Now() - interval '${days}d')` | ||
446 | : '' | ||
447 | |||
443 | const query = ` | 448 | const query = ` |
444 | SELECT COUNT(DISTINCT("VideoChannelModel"."id")) AS "count" | 449 | SELECT COUNT(DISTINCT("VideoChannelModel"."id")) AS "count" |
445 | FROM "videoChannel" AS "VideoChannelModel" | 450 | FROM "videoChannel" AS "VideoChannelModel" |
446 | INNER JOIN "video" AS "Videos" | 451 | ${videoJoin} |
447 | ON "VideoChannelModel"."id" = "Videos"."channelId" | 452 | INNER JOIN "account" AS "Account" ON "VideoChannelModel"."accountId" = "Account"."id" |
448 | AND ("Videos"."publishedAt" > Now() - interval '${days}d') | 453 | INNER JOIN "actor" AS "Account->Actor" ON "Account"."actorId" = "Account->Actor"."id" |
449 | INNER JOIN "account" AS "Account" | 454 | AND "Account->Actor"."serverId" IS NULL` |
450 | ON "VideoChannelModel"."accountId" = "Account"."id" | ||
451 | INNER JOIN "actor" AS "Account->Actor" | ||
452 | ON "Account"."actorId" = "Account->Actor"."id" | ||
453 | AND "Account->Actor"."serverId" IS NULL | ||
454 | LEFT OUTER JOIN "server" AS "Account->Actor->Server" | ||
455 | ON "Account->Actor"."serverId" = "Account->Actor->Server"."id"` | ||
456 | 455 | ||
457 | return VideoChannelModel.sequelize.query<{ count: string }>(query, options) | 456 | return VideoChannelModel.sequelize.query<{ count: string }>(query, options) |
458 | .then(r => parseInt(r[0].count, 10)) | 457 | .then(r => parseInt(r[0].count, 10)) |
459 | } | 458 | } |
460 | 459 | ||
461 | const totalLocalVideoChannels = await VideoChannelModel.count() | 460 | const totalLocalVideoChannels = await getLocalVideoChannelStats() |
462 | const totalLocalDailyActiveVideoChannels = await getActiveVideoChannels(1) | 461 | const totalLocalDailyActiveVideoChannels = await getLocalVideoChannelStats(1) |
463 | const totalLocalWeeklyActiveVideoChannels = await getActiveVideoChannels(7) | 462 | const totalLocalWeeklyActiveVideoChannels = await getLocalVideoChannelStats(7) |
464 | const totalLocalMonthlyActiveVideoChannels = await getActiveVideoChannels(30) | 463 | const totalLocalMonthlyActiveVideoChannels = await getLocalVideoChannelStats(30) |
465 | const totalHalfYearActiveVideoChannels = await getActiveVideoChannels(180) | 464 | const totalLocalHalfYearActiveVideoChannels = await getLocalVideoChannelStats(180) |
466 | 465 | ||
467 | return { | 466 | return { |
468 | totalLocalVideoChannels, | 467 | totalLocalVideoChannels, |
469 | totalLocalDailyActiveVideoChannels, | 468 | totalLocalDailyActiveVideoChannels, |
470 | totalLocalWeeklyActiveVideoChannels, | 469 | totalLocalWeeklyActiveVideoChannels, |
471 | totalLocalMonthlyActiveVideoChannels, | 470 | totalLocalMonthlyActiveVideoChannels, |
472 | totalHalfYearActiveVideoChannels | 471 | totalLocalHalfYearActiveVideoChannels |
473 | } | 472 | } |
474 | } | 473 | } |
475 | 474 | ||
diff --git a/server/tests/api/server/stats.ts b/server/tests/api/server/stats.ts index 83b0e73d6..942cbeaa4 100644 --- a/server/tests/api/server/stats.ts +++ b/server/tests/api/server/stats.ts | |||
@@ -131,6 +131,7 @@ describe('Test stats (excluding redundancy)', function () { | |||
131 | { | 131 | { |
132 | const data = await server.stats.get() | 132 | const data = await server.stats.get() |
133 | 133 | ||
134 | expect(data.totalLocalVideoChannels).to.equal(2) | ||
134 | expect(data.totalLocalDailyActiveVideoChannels).to.equal(1) | 135 | expect(data.totalLocalDailyActiveVideoChannels).to.equal(1) |
135 | expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(1) | 136 | expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(1) |
136 | expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(1) | 137 | expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(1) |
@@ -146,6 +147,7 @@ describe('Test stats (excluding redundancy)', function () { | |||
146 | 147 | ||
147 | const data = await server.stats.get() | 148 | const data = await server.stats.get() |
148 | 149 | ||
150 | expect(data.totalLocalVideoChannels).to.equal(3) | ||
149 | expect(data.totalLocalDailyActiveVideoChannels).to.equal(1) | 151 | expect(data.totalLocalDailyActiveVideoChannels).to.equal(1) |
150 | expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(1) | 152 | expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(1) |
151 | expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(1) | 153 | expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(1) |
@@ -156,6 +158,7 @@ describe('Test stats (excluding redundancy)', function () { | |||
156 | 158 | ||
157 | const data = await server.stats.get() | 159 | const data = await server.stats.get() |
158 | 160 | ||
161 | expect(data.totalLocalVideoChannels).to.equal(3) | ||
159 | expect(data.totalLocalDailyActiveVideoChannels).to.equal(2) | 162 | expect(data.totalLocalDailyActiveVideoChannels).to.equal(2) |
160 | expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(2) | 163 | expect(data.totalLocalWeeklyActiveVideoChannels).to.equal(2) |
161 | expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(2) | 164 | expect(data.totalLocalMonthlyActiveVideoChannels).to.equal(2) |