3 Commits

5 changed files with 35 additions and 21 deletions

26
package-lock.json generated
View File

@@ -9087,14 +9087,6 @@
} }
} }
}, },
"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": { "moment": {
"version": "2.29.1", "version": "2.29.1",
"resolved": "https://registry.npmjs.org/moment/-/moment-2.29.1.tgz", "resolved": "https://registry.npmjs.org/moment/-/moment-2.29.1.tgz",
@@ -9126,6 +9118,16 @@
"on-finished": "^2.3.0", "on-finished": "^2.3.0",
"type-is": "^1.6.4", "type-is": "^1.6.4",
"xtend": "^4.0.0" "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": { "multimatch": {
@@ -9489,6 +9491,14 @@
"minipass": "^2.9.0" "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": { "rimraf": {
"version": "2.7.1", "version": "2.7.1",
"resolved": "https://registry.npmjs.org/rimraf/-/rimraf-2.7.1.tgz", "resolved": "https://registry.npmjs.org/rimraf/-/rimraf-2.7.1.tgz",

View File

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

View File

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

View File

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

View File

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