feat: Prejudice.relatedBooksを追加

src/prejudices/dto/resolve-related-books.dto.ts

@@ -0,0 +1,16 @@
+import {ArgsType, Field} from '@nestjs/graphql';
+
+import {BookOrder, BookOrderField} from '~/books/books.entities';
+import {OffsetPaginationArgs, OrderDirection} from '~/common/common.entities';
+
+@ArgsType()
+export class ResolveRelatedBooksArgs extends OffsetPaginationArgs {
+  @Field(() => BookOrder, {
+    defaultValue: {
+      direction: OrderDirection.DESC,
+      field: BookOrderField.TITLE,
+    },
+    nullable: true,
+  })
+  orderBy!: BookOrder;
+}

src/prejudices/prejudices.cypher.ts

@@ -60,6 +60,11 @@ export const CYPHER_GET_PREJUDICE_RELATED_BOOKS_ORDERBY_TITLE_AT_ASC =
 export const CYPHER_GET_PREJUDICE_RELATED_BOOKS_ORDERBY_TITLE_AT_DESC =
   getRelatedBooks('title', 'DESC');
 
+export const CYPHER_COUNT_PREJUDICE_RELATED_BOOKS = `
+  MATCH (:Prejudice {id: $id})-[:RELATED_BOOK]->(b:Book)
+  RETURN count(b) AS count
+`;
+
 export const CYPHER_CREATE_PREJUDICE = `
   MATCH (pu:User {id: $posted})
   MATCH (ru:User {id: $received})

src/prejudices/prejudices.resolver.ts

@@ -22,13 +22,15 @@ import {
   PostPrejudiceArgs,
   PostPrejudicePayload,
 } from './dto/post-prejudice.dto';
+import {ResolveRelatedBooksArgs} from './dto/resolve-related-books.dto';
 
 import {UserEntity} from '~/users/users.entities';
 import {UsersService} from '~/users/users.service';
 import {SettingsService} from '~/settings/settings.service';
 import {GraphQLJwtGuard} from '~/auth/graphql-jwt.guard';
 import {Viewer, ViewerType} from '~/auth/viewer.decorator';
 import {AnswerEntity} from '~/answers/answers.entities';
+import {BookArray} from '~/books/books.entities';
 
 @Resolver(() => PrejudiceEntity)
 export class PrejudicesResolver {
@@ -84,22 +86,19 @@ export class PrejudicesResolver {
     return this.prejudicesService.resolveAnswer(id);
   }
 
-  /*
-  @ResolveField('relatedBooks')
+  @ResolveField(() => BookArray, {name: 'relatedBooks'})
   async getRelatedBooks(
     @Parent() {id}: PrejudiceEntity,
-    @Args('skip') skip: number,
-    @Args('limit') limit: number,
-    @Args('orderBy') orderBy: BookOrder,
-  ): Promise<BookConnection> {
+    @Args() {skip, limit, orderBy}: ResolveRelatedBooksArgs,
+  ): Promise<BookArray> {
     const nodes = await this.prejudicesService.resolveRelatedBooks(id, {
       skip,
       limit,
       orderBy,
     });
-    return {nodes};
+    const totalCount = await this.prejudicesService.countRelatedBooks(id);
+    return {nodes, totalCount};
   }
-  */
 
   @Query(() => PrejudiceEntity, {name: 'prejudice'})
   async getPrejudiceById(

src/prejudices/prejudices.service.ts

@@ -14,6 +14,7 @@ import {
   CYPHER_RESOLVE_PREJUDICE_TITLE,
   CYPHER_RESOLVE_PREJUDICE_CREATED_AT,
   CYPHER_RESOLVE_PREJUDICE_NUMBER,
+  CYPHER_COUNT_PREJUDICE_RELATED_BOOKS,
 } from './prejudices.cypher';
 import {PrejudiceEntity} from './prejudices.entities';
 
@@ -94,6 +95,16 @@ export class PrejudicesService {
       );
   }
 
+  async countRelatedBooks(id: string) {
+    const result = await this.neo4jService.read(
+      CYPHER_COUNT_PREJUDICE_RELATED_BOOKS,
+      {id},
+    );
+    if (result.records.length !== 1)
+      throw new Error('something broken with neo4j');
+    return result.records[0].get('count').toNumber();
+  }
+
   async getById(id: string): Promise<PrejudiceEntity | null> {
     const result = await this.neo4jService.read(CYPHER_GET_PREJUDICE_BY_ID, {
       id,