feat(graphql): add subject topics (#718)

Author: everpcpc

lib/graphql/schema.gen.graphql

@@ -132,6 +132,7 @@ type Subject {
   series_entry: Int!
   summary: String!
   tags(limit: Int = 0): [SubjectTag!]
+  topics(limit: Int! = 10, offset: Int! = 0): [SubjectTopic!]
   type: Int!
   volumes: Int!
 }
@@ -195,6 +196,17 @@ type SubjectTag {
   name: String!
 }
 
+type SubjectTopic {
+  created_at: Int!
+  creator: User!
+  display: Int!
+  id: Int!
+  replies: Int!
+  state: Int!
+  title: String!
+  updated_at: Int!
+}
+
 type User {
   avatar: Avatar!
   id: Int!

lib/graphql/types/subject.ts

@@ -10,13 +10,16 @@ import {
   PersonSubjectsRepo,
   SubjectRelationRepo,
   SubjectRepo,
+  SubjectTopicRepo,
 } from '@app/lib/orm/index.ts';
 import { subjectCover } from '@app/lib/response.ts';
 import { platforms } from '@app/lib/subject/index.ts';
+import { ListTopicDisplays } from '@app/lib/topic/display.ts';
 
 import { convertCharacter } from './character.ts';
 import { InfoboxItem } from './common.ts';
 import { convertPerson } from './person.ts';
+import { convertUser } from './user.ts';
 
 const Episode = objectType({
   name: 'Episode',
@@ -127,6 +130,22 @@ const SubjectAirtime = objectType({
   },
 });
 
+const SubjectTopic = objectType({
+  name: 'SubjectTopic',
+  definition(t) {
+    t.nonNull.int('id');
+    t.nonNull.field('creator', {
+      type: 'User',
+    });
+    t.nonNull.string('title');
+    t.nonNull.int('created_at');
+    t.nonNull.int('updated_at');
+    t.nonNull.int('replies');
+    t.nonNull.int('state');
+    t.nonNull.int('display');
+  },
+});
+
 const Subject = objectType({
   name: 'Subject',
   definition(t) {
@@ -321,6 +340,34 @@ const Subject = objectType({
         });
       },
     });
+    t.list.nonNull.field('topics', {
+      type: SubjectTopic,
+      args: {
+        limit: nonNull(intArg({ default: 10 })),
+        offset: nonNull(intArg({ default: 0 })),
+      },
+      async resolve(
+        parent: { id: number },
+        { limit, offset }: { limit: number; offset: number },
+        { auth: u }: Context,
+      ) {
+        let query = SubjectTopicRepo.createQueryBuilder('t')
+          .innerJoinAndMapOne('t.creator', entity.User, 'u', 'u.id = t.creatorID')
+          .where('t.parentID = :id', { id: parent.id });
+        const displays = ListTopicDisplays(u);
+        if (displays.length > 0) {
+          query = query.andWhere('t.display IN (:...displays)', { displays });
+        }
+        const topics = await query
+          .orderBy('t.createdAt', 'DESC')
+          .skip(offset)
+          .take(limit)
+          .getMany();
+        return topics.map((t) => {
+          return convertTopic(t);
+        });
+      },
+    });
   },
 });
 
@@ -410,6 +457,19 @@ export function convertSubject(subject: entity.Subject) {
   };
 }
 
+export function convertTopic(topic: entity.SubjectTopic) {
+  return {
+    id: topic.id,
+    creator: convertUser(topic.creator),
+    title: topic.title,
+    created_at: topic.createdAt,
+    updated_at: topic.updatedAt,
+    replies: topic.replies,
+    state: topic.state,
+    display: topic.display,
+  };
+}
+
 const SubjectByIDQuery = extendType({
   type: 'Query',
   definition(t) {

lib/graphql/types/user.ts

@@ -2,6 +2,7 @@ import { extendType, objectType } from 'nexus';
 
 import { imageDomain } from '@app/lib/config.ts';
 import type { Context } from '@app/lib/graphql/context.ts';
+import type * as entity from '@app/lib/orm/entity/index.ts';
 import type { IUser } from '@app/lib/orm/index.ts';
 import { fetchUser } from '@app/lib/orm/index.ts';
 import { avatar } from '@app/lib/response.ts';
@@ -37,6 +38,15 @@ const User = objectType({
   },
 });
 
+export function convertUser(user: entity.User) {
+  return {
+    id: user.id,
+    username: user.username,
+    nickname: user.nickname,
+    avatar: avatar(user.avatar),
+  };
+}
+
 const GetCurrentUser = extendType({
   type: 'Query',
   definition(t) {

lib/orm/entity/group.ts

@@ -2,6 +2,8 @@ import { Column, Entity, Index, PrimaryGeneratedColumn } from 'typeorm';
 
 import { BooleanTransformer, htmlEscapedString } from '@app/lib/orm/transformer.ts';
 
+import type { User } from './user';
+
 @Entity('chii_groups', { schema: 'bangumi' })
 export class Group {
   @PrimaryGeneratedColumn({ type: 'smallint', name: 'grp_id', unsigned: true })
@@ -139,6 +141,8 @@ export class GroupTopic {
     default: () => "'1'",
   })
   display!: number;
+
+  creator!: User;
 }
 
 @Index('pss_topic_id', ['topicID'], {})
@@ -179,4 +183,6 @@ export class GroupPost {
     default: () => "'0'",
   })
   dateline!: number;
+
+  creator!: User;
 }

lib/orm/entity/subject.ts

@@ -2,6 +2,8 @@ import { Column, Entity, Index, PrimaryColumn, PrimaryGeneratedColumn } from 'ty
 
 import { BooleanTransformer, htmlEscapedString, UnixTimestamp } from '@app/lib/orm/transformer.ts';
 
+import type { User } from './user.ts';
+
 @Index('subject_name_cn', ['nameCN'], {})
 @Index('subject_platform', ['platform'], {})
 @Index('subject_creator', ['subjectCreator'], {})
@@ -428,6 +430,8 @@ export class SubjectTopic {
     default: () => "'1'",
   })
   display!: number;
+
+  creator!: User;
 }
 
 @Index('pss_topic_id', ['topicID'], {})
@@ -455,6 +459,8 @@ export class SubjectPost {
 
   @Column('int', { name: 'sbj_pst_dateline', unsigned: true, default: 0 })
   dateline!: number;
+
+  creator!: User;
 }
 
 @Index('interest_collect_dateline', ['collectDateline'], {})

lib/orm/unused/ChiiSubjectTopics.ts.tmp

@@ -116,7 +116,7 @@ export async function createServer(
     schema,
     path: '/v0/graphql',
     graphiql: false,
-    queryDepth: 4,
+    queryDepth: 5,
     allowBatchedQueries: true,
     context: async (request: FastifyRequest): Promise<Context> => {
       const a = await auth.byHeader(request.headers.authorization);

lib/server.ts

@@ -221,4 +221,29 @@ describe('subject', () => {
 
     expect(res).toMatchSnapshot();
   });
+
+  test('should subject topics', async () => {
+    const res = await testClient.query(gql`
+      query {
+        subject(id: 12) {
+          topics(limit: 1) {
+            id
+            creator {
+              id
+              username
+              nickname
+            }
+            created_at
+            updated_at
+            title
+            replies
+            state
+            display
+          }
+        }
+      }
+    `);
+
+    expect(res).toMatchSnapshot();
+  });
 });