refactor: change queue to generated service

Author: coder2000

packages/server/src/modules/app/app.module.ts

@@ -19,10 +19,7 @@ import { TypeOrmPinoLogger } from './TypeOrmPinoLogger';
   imports: [
     ConfigModule.forRoot(),
     TypeOrmModule.forRootAsync({
-      imports: [
-        LoggerModule.forRoot({ pinoHttp: { level: 'debug' } }),
-        ConfigModule,
-      ],
+      imports: [LoggerModule.forRoot({ pinoHttp: { level: 'debug' } }), ConfigModule],
       inject: [PinoLogger, ConfigService],
       useFactory: (logger: PinoLogger, config: ConfigService) => {
         logger.setContext('TypeOrm');

packages/server/src/modules/podcast/podcast.module.ts

@@ -3,31 +3,33 @@ import { NestjsQueryGraphQLModule } from '@nestjs-query/query-graphql';
 import { NestjsQueryTypeOrmModule } from '@nestjs-query/query-typeorm';
 import { LoggerModule } from 'nestjs-pino';
 
-import { QueueModule } from '@modules/queue';
 import { AuthorModule } from '@modules/author';
 import { EpisodeModule } from '@modules/episode';
 import { PodcastEntity } from '@entities/podcast.entity';
 import { PodcastDto } from '@dto/podcast.dto';
+import { QueueEntity } from '@entities/queue.entity';
 import { PodcastService } from './podcast.service';
 
 @Module({
   imports: [
     NestjsQueryGraphQLModule.forFeature({
-      imports: [NestjsQueryTypeOrmModule.forFeature([PodcastEntity])],
+      imports: [
+        NestjsQueryTypeOrmModule.forFeature([PodcastEntity]),
+        NestjsQueryTypeOrmModule.forFeature([QueueEntity]),
+        AuthorModule,
+        EpisodeModule,
+      ],
       resolvers: [
         {
           DTOClass: PodcastDto,
           EntityClass: PodcastEntity,
+          ServiceClass: PodcastService,
           create: { disabled: true },
         },
       ],
+      services: [PodcastService],
     }),
     LoggerModule.forRoot(),
-    QueueModule,
-    AuthorModule,
-    EpisodeModule,
   ],
-  providers: [PodcastService],
-  exports: [PodcastService],
 })
 export class PodcastModule {}

packages/server/src/modules/podcast/podcast.service.ts

@@ -2,7 +2,7 @@ import Parser from 'rss-parser';
 
 import { InjectRepository } from '@nestjs/typeorm';
 import { Cron } from '@nestjs/schedule';
-import { QueryService } from '@nestjs-query/core';
+import { InjectQueryService, QueryService } from '@nestjs-query/core';
 import { TypeOrmQueryService } from '@nestjs-query/query-typeorm';
 import { PinoLogger } from 'nestjs-pino';
 import { Repository } from 'typeorm';
@@ -11,7 +11,6 @@ import { PodcastEntity } from '@entities/podcast.entity';
 import { QueueEntity } from '@entities/queue.entity';
 import { AuthorService } from '@modules/author';
 import { EpisodeService } from '@modules/episode';
-import { QueueService } from '@modules/queue';
 
 @QueryService(PodcastEntity)
 export class PodcastService extends TypeOrmQueryService<PodcastEntity> {
@@ -20,7 +19,8 @@ export class PodcastService extends TypeOrmQueryService<PodcastEntity> {
   constructor(
     @InjectRepository(PodcastEntity)
     private podcastRepository: Repository<PodcastEntity>,
-    private queueService: QueueService,
+    @InjectQueryService(QueueEntity)
+    private queueService: QueryService<QueueEntity>,
     private authorService: AuthorService,
     private episodeService: EpisodeService,
     private readonly logger: PinoLogger,

packages/server/src/modules/queue/queue.module.ts

@@ -2,7 +2,6 @@ import { Module } from '@nestjs/common';
 import { NestjsQueryGraphQLModule } from '@nestjs-query/query-graphql';
 import { NestjsQueryTypeOrmModule } from '@nestjs-query/query-typeorm';
 import { QueueEntity } from '@entities/queue.entity';
-import { QueueService } from './queue.service';
 
 @Module({
   imports: [
@@ -12,14 +11,10 @@ import { QueueService } from './queue.service';
         {
           DTOClass: QueueEntity,
           EntityClass: QueueEntity,
-          ServiceClass: QueueService,
           update: { disabled: true },
         },
       ],
-      services: [QueueService],
     }),
   ],
-  providers: [QueueService],
-  exports: [QueueService],
 })
 export class QueueModule {}