feat(repos): 添加消息队列分发。BAK

config.yml.example

@@ -1,7 +1,6 @@
 env: dev
 http:
   port: 7122
-
 db:
   postgres:
     host: 192.168.31.194
@@ -9,5 +8,9 @@ db:
     database: fennec
     username: fennec
     password:
+redis:
+  mq:
+    host: localhost
+    port: 6379
 workspaces:
   root: '/Users/ivanli/Projects/fennec/workspaces'

src/app.module.ts

@@ -8,6 +8,7 @@ import { AppService } from './app.service';
 import { ProjectsModule } from './projects/projects.module';
 import { ReposModule } from './repos/repos.module';
 import configuration from './commons/config/configuration';
+import { BullModule } from '@nestjs/bull';
 
 @Module({
   imports: [
@@ -37,6 +38,16 @@ import configuration from './commons/config/configuration';
       }),
       inject: [ConfigService],
     }),
+    BullModule.forRootAsync({
+      imports: [ConfigModule],
+      useFactory: async (configService: ConfigService) => ({
+        redis: {
+          host: configService.get<string>('redis.mq.host', 'localhost'),
+          port: configService.get<number>('redis.mq.port', 6379),
+        },
+      }),
+      inject: [ConfigService],
+    }),
     ProjectsModule,
     ReposModule,
   ],

src/repos/repos.constants.ts

@@ -0,0 +1 @@
+export const WORKSPACE_ACTION = 'workspace-action';

src/repos/repos.module.ts

@@ -4,9 +4,17 @@ import { Project } from '../projects/project.entity';
 import { ReposResolver } from './repos.resolver';
 import { ReposService } from './repos.service';
 import { ConfigModule } from '@nestjs/config';
+import { BullModule } from '@nestjs/bull';
+import { WORKSPACE_ACTION } from './repos.constants';
 
 @Module({
-  imports: [TypeOrmModule.forFeature([Project]), ConfigModule],
+  imports: [
+    TypeOrmModule.forFeature([Project]),
+    ConfigModule,
+    BullModule.registerQueue({
+      name: WORKSPACE_ACTION,
+    }),
+  ],
   providers: [ReposResolver, ReposService],
 })
 export class ReposModule {}

src/repos/workspace-action.consumer.ts

@@ -0,0 +1,8 @@
+import { Process, Processor } from '@nestjs/bull';
+import { WORKSPACE_ACTION } from './repos.constants';
+
+@Processor(WORKSPACE_ACTION)
+export class WorkspaceActionConsumer {
+  @Process()
+  async dispatch() {}
+}

src/repos/workspace-action.model.ts

@@ -0,0 +1,5 @@
+import { WorkspaceActions } from './workspace-actions.enum';
+
+export class WorkspaceAction {
+  action: WorkspaceActions;
+}

src/repos/workspace-actions.enum.ts

@@ -0,0 +1,6 @@
+export enum WorkspaceActions {
+  checkoutBranch = 'checkoutBranch',
+  checkoutCommit = 'checkoutCommit',
+  listLogs = 'listLogs',
+  listBranches = 'listBranches',
+}