feat: add trending and popular user sources

Author: omBratteng

src/entity/PopularPost.ts

@@ -1,18 +1,21 @@
 import { DataSource, ViewColumn, ViewEntity } from 'typeorm';
+import { SourceType } from './Source';
 
 @ViewEntity({
   materialized: true,
   expression: (dataSource: DataSource) =>
     dataSource
       .createQueryBuilder()
-      .select('"sourceId"')
-      .addSelect('"tagsStr"')
-      .addSelect('"createdAt"')
-      .addSelect('upvotes - downvotes r')
+      .select('p."sourceId"')
+      .addSelect('p."tagsStr"')
+      .addSelect('p."createdAt"')
+      .addSelect('p.upvotes - p.downvotes', 'r')
       .from('post', 'p')
+      .innerJoin('source', 's', 's.id = p."sourceId"')
       .where(
-        'not p.private and p."createdAt" > now() - interval \'60 day\' and upvotes > downvotes',
+        'not p.private and p."createdAt" > now() - interval \'60 day\' and p.upvotes > p.downvotes',
       )
+      .andWhere('s.type != :type', { type: SourceType.User })
       .orderBy('r', 'DESC')
       .limit(1000),
 })

src/entity/PopularUserPost.ts

@@ -0,0 +1,34 @@
+import { DataSource, ViewColumn, ViewEntity } from 'typeorm';
+import { SourceType } from './Source';
+
+@ViewEntity({
+  materialized: true,
+  expression: (dataSource: DataSource) =>
+    dataSource
+      .createQueryBuilder()
+      .select('p."sourceId"')
+      .addSelect('p."tagsStr"')
+      .addSelect('p."createdAt"')
+      .addSelect('p.upvotes - p.downvotes', 'r')
+      .from('post', 'p')
+      .innerJoin('source', 's', 's.id = p."sourceId"')
+      .where(
+        'not p.private and p."createdAt" > now() - interval \'60 day\' and p.upvotes > p.downvotes',
+      )
+      .andWhere('s.type = :type', { type: SourceType.User })
+      .orderBy('r', 'DESC')
+      .limit(1000),
+})
+export class PopularUserPost {
+  @ViewColumn()
+  sourceId: string;
+
+  @ViewColumn()
+  tagsStr: string;
+
+  @ViewColumn()
+  createdAt: Date;
+
+  @ViewColumn()
+  r: number;
+}

src/entity/PopularUserSource.ts

@@ -0,0 +1,22 @@
+import { DataSource, ViewColumn, ViewEntity } from 'typeorm';
+import { PopularUserPost } from './PopularUserPost';
+
+@ViewEntity({
+  materialized: true,
+  expression: (dataSource: DataSource) =>
+    dataSource
+      .createQueryBuilder()
+      .select('"sourceId"')
+      .addSelect('avg(r) r')
+      .from(PopularUserPost, 'base')
+      .groupBy('"sourceId"')
+      .having('count(*) > 5')
+      .orderBy('r', 'DESC'),
+})
+export class PopularUserSource {
+  @ViewColumn()
+  sourceId: string;
+
+  @ViewColumn()
+  r: number;
+}

src/entity/TrendingPost.ts

@@ -1,20 +1,24 @@
 import { DataSource, ViewColumn, ViewEntity } from 'typeorm';
+import { SourceType } from './Source';
 
 @ViewEntity({
   materialized: true,
   expression: (dataSource: DataSource) =>
     dataSource
       .createQueryBuilder()
-      .select('"sourceId"')
-      .addSelect('"tagsStr"')
-      .addSelect('"createdAt"')
+      .select('p."sourceId"')
+      .addSelect('p."tagsStr"')
+      .addSelect('p."createdAt"')
       .addSelect(
-        `log(10, upvotes - downvotes) + extract(epoch from ("createdAt" - now() + interval '7 days')) / 200000 r`,
+        `log(10, p.upvotes - p.downvotes) + extract(epoch from (p."createdAt" - now() + interval '7 days')) / 200000`,
+        'r',
       )
       .from('post', 'p')
+      .innerJoin('source', 's', 's.id = p."sourceId"')
       .where(
-        `not p.private and p."createdAt" > now() - interval '7 day' and upvotes > downvotes`,
+        `not p.private and p."createdAt" > now() - interval '7 day' and p.upvotes > p.downvotes`,
       )
+      .andWhere('s.type != :type', { type: SourceType.User })
       .orderBy('r', 'DESC')
       .limit(100),
 })

src/entity/TrendingUserPost.ts

@@ -0,0 +1,37 @@
+import { DataSource, ViewColumn, ViewEntity } from 'typeorm';
+import { SourceType } from './Source';
+
+@ViewEntity({
+  materialized: true,
+  expression: (dataSource: DataSource) =>
+    dataSource
+      .createQueryBuilder()
+      .select('p."sourceId"')
+      .addSelect('p."tagsStr"')
+      .addSelect('p."createdAt"')
+      .addSelect(
+        `log(10, p.upvotes - p.downvotes) + extract(epoch from (p."createdAt" - now() + interval '7 days')) / 200000`,
+        'r',
+      )
+      .from('post', 'p')
+      .innerJoin('source', 's', 's.id = p."sourceId"')
+      .where(
+        `not p.private and p."createdAt" > now() - interval '7 day' and p.upvotes > p.downvotes`,
+      )
+      .andWhere('s.type = :type', { type: SourceType.User })
+      .orderBy('r', 'DESC')
+      .limit(100),
+})
+export class TrendingUserPost {
+  @ViewColumn()
+  sourceId: string;
+
+  @ViewColumn()
+  tagsStr: string;
+
+  @ViewColumn()
+  createdAt: Date;
+
+  @ViewColumn()
+  r: number;
+}

src/entity/TrendingUserSource.ts

@@ -0,0 +1,22 @@
+import { DataSource, ViewColumn, ViewEntity } from 'typeorm';
+import { TrendingUserPost } from './TrendingUserPost';
+
+@ViewEntity({
+  materialized: true,
+  expression: (dataSource: DataSource) =>
+    dataSource
+      .createQueryBuilder()
+      .select('"sourceId"')
+      .addSelect('avg(r) r')
+      .from(TrendingUserPost, 'base')
+      .groupBy('"sourceId"')
+      .having('count(*) > 1')
+      .orderBy('r', 'DESC'),
+})
+export class TrendingUserSource {
+  @ViewColumn()
+  sourceId: string;
+
+  @ViewColumn()
+  r: number;
+}