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'

package-lock.json

@@ -9087,6 +9087,14 @@
         }
       }
     },
+    "mkdirp": {
+      "version": "0.5.5",
+      "resolved": "https://registry.npmjs.org/mkdirp/-/mkdirp-0.5.5.tgz",
+      "integrity": "sha512-NKmAlESf6jMGym1++R0Ra7wvhV+wFW63FaSOFPwRahvea0gMUcGUhVeAg/0BC0wiv9ih5NYPB1Wn1UEI1/L+xQ==",
+      "requires": {
+        "minimist": "^1.2.5"
+      }
+    },
     "moment": {
       "version": "2.29.1",
       "resolved": "https://registry.npmjs.org/moment/-/moment-2.29.1.tgz",
@@ -9118,16 +9126,6 @@
         "on-finished": "^2.3.0",
         "type-is": "^1.6.4",
         "xtend": "^4.0.0"
-      },
-      "dependencies": {
-        "mkdirp": {
-          "version": "0.5.5",
-          "resolved": "https://registry.npmjs.org/mkdirp/-/mkdirp-0.5.5.tgz",
-          "integrity": "sha512-NKmAlESf6jMGym1++R0Ra7wvhV+wFW63FaSOFPwRahvea0gMUcGUhVeAg/0BC0wiv9ih5NYPB1Wn1UEI1/L+xQ==",
-          "requires": {
-            "minimist": "^1.2.5"
-          }
-        }
       }
     },
     "multimatch": {
@@ -9491,14 +9489,6 @@
             "minipass": "^2.9.0"
           }
         },
-        "mkdirp": {
-          "version": "0.5.5",
-          "resolved": "https://registry.npmjs.org/mkdirp/-/mkdirp-0.5.5.tgz",
-          "integrity": "sha512-NKmAlESf6jMGym1++R0Ra7wvhV+wFW63FaSOFPwRahvea0gMUcGUhVeAg/0BC0wiv9ih5NYPB1Wn1UEI1/L+xQ==",
-          "requires": {
-            "minimist": "^1.2.5"
-          }
-        },
         "rimraf": {
           "version": "2.7.1",
           "resolved": "https://registry.npmjs.org/rimraf/-/rimraf-2.7.1.tgz",

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/projects/dtos/create-project.input.ts

@@ -3,7 +3,6 @@ import {
   IsOptional,
   IsString,
   IsUrl,
-  Matches,
   MaxLength,
   MinLength,
 } from 'class-validator';
@@ -20,9 +19,7 @@ export class CreateProjectInput {
   @MinLength(2)
   comment: string;
 
-  @Matches(
+  @IsUrl({ protocols: ['ssh'] })
-    /^(?:ssh:\/\/)?(?:[\w\d-_]+@)(?:[\w\d-_]+\.)*\w{2,10}(?::\d{1,5})?(?:\/[\w\d-_.]+)*/,
-  )
   @MaxLength(256)
   sshUrl: string;
 

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/repos.resolver.ts

@@ -13,7 +13,7 @@ export class ReposResolver {
     return await this.service.listLogs(dto);
   }
   @Query(() => BranchList)
-  async listBranches(
+  async ListBranchesArgs(
     @Args('listBranchesArgs') dto: ListBranchesArgs,
   ): Promise<BranchList> {
     return await this.service.listBranches(dto).then((data) => {

src/repos/repos.service.spec.ts

@@ -75,7 +75,7 @@ describe('ReposService', () => {
     it('should be checkout', async () => {
       await service.checkoutBranch(getTest1Project(), 'master');
       const filePath = join(
-        service.getWorkspaceRoot(getTest1Project(), 'master'),
+        service.getWorkspaceRoot(getTest1Project()),
         'README.md',
       );
       const text = await readFile(filePath, { encoding: 'utf-8' });
@@ -86,7 +86,7 @@ describe('ReposService', () => {
       await service.checkoutBranch(getTest1Project(), 'branch-a');
       await service.checkoutBranch(getTest1Project(), 'branch-b');
       const filePath = join(
-        service.getWorkspaceRoot(getTest1Project(), 'branch-b'),
+        service.getWorkspaceRoot(getTest1Project()),
         'branch-b.md',
       );
       const text = await readFile(filePath, { encoding: 'utf-8' });
@@ -100,7 +100,7 @@ describe('ReposService', () => {
     it('checkout the specified version', async () => {
       await service.checkoutBranch(getTest1Project(), 'master');
       const filePath = join(
-        service.getWorkspaceRoot(getTest1Project(), 'master'),
+        service.getWorkspaceRoot(getTest1Project()),
         'README.md',
       );
       const text = await readFile(filePath, { encoding: 'utf-8' });
@@ -112,7 +112,7 @@ describe('ReposService', () => {
     it('should be checkout', async () => {
       await service.checkoutCommit(getTest1Project(), '498c782685');
       const filePath = join(
-        service.getWorkspaceRoot(getTest1Project(), '498c782685'),
+        service.getWorkspaceRoot(getTest1Project()),
         'README.md',
       );
       const text = await readFile(filePath, { encoding: 'utf-8' });
@@ -121,7 +121,7 @@ describe('ReposService', () => {
     it('should be checkout right commit', async () => {
       await service.checkoutCommit(getTest1Project(), '7f7123fe5b');
       const filePath = join(
-        service.getWorkspaceRoot(getTest1Project(), '7f7123fe5b'),
+        service.getWorkspaceRoot(getTest1Project()),
         'README.md',
       );
       const text = await readFile(filePath, { encoding: 'utf-8' });

src/repos/repos.service.ts

@@ -19,11 +19,10 @@ export class ReposService {
     private readonly configService: ConfigService,
   ) {}
 
-  getWorkspaceRoot(project: Project, subDir = ''): string {
+  getWorkspaceRoot(project: Project): string {
     return join(
       this.configService.get<string>('workspaces.root'),
       project.name,
-      encodeURIComponent(subDir),
     );
   }
 
@@ -31,14 +30,14 @@ export class ReposService {
     // TODO:  获取锁，失败抛错。
   }
 
-  async getGit(project: Project, subDir = 'default') {
+  async getGit(project: Project) {
-    const workspaceRoot = this.getWorkspaceRoot(project, subDir);
+    const workspaceRoot = this.getWorkspaceRoot(project);
     await this.lockWorkspace(workspaceRoot);
 
     const firstInit = await access(workspaceRoot, F_OK)
       .then(() => false)
       .catch(async () => {
-        await mkdir(workspaceRoot, { recursive: true });
+        await mkdir(workspaceRoot);
         return true;
       });
     const git = gitP(workspaceRoot);
@@ -70,7 +69,7 @@ export class ReposService {
   }
 
   async checkoutBranch(project: Project, branch: string) {
-    const git = await this.getGit(project, branch);
+    const git = await this.getGit(project);
     try {
       await git.fetch(DEFAULT_REMOTE_NAME, branch);
     } catch (err) {
@@ -88,7 +87,7 @@ export class ReposService {
   }
 
   async checkoutCommit(project: Project, commitNumber: string) {
-    const git = await this.getGit(project, commitNumber);
+    const git = await this.getGit(project);
     try {
       await git.fetch(DEFAULT_REMOTE_NAME);
     } catch (err) {

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',
+}