Adding prettier changes
Signed-off-by: Balasundaram <balabtech@hotmail.com>
This commit is contained in:
Balasundaram
+156
-133
@@ -19,156 +19,179 @@ import { Gitlab } from '@gitbeaker/node';
|
||||
import path from 'path';
|
||||
import globby from 'globby';
|
||||
import { CommitAction } from '@gitbeaker/core/dist/types/services/Commits';
|
||||
import { CreateMergeRequestOptions } from '@gitbeaker/core/dist/types/services/MergeRequests';
|
||||
import { CreateMergeRequestOptions } from '@gitbeaker/core/dist/types/services/MergeRequests';
|
||||
import { ScmIntegrationRegistry } from '@backstage/integration';
|
||||
import { InputError } from '@backstage/errors';
|
||||
import { parseRepoUrl } from './util';
|
||||
|
||||
export type GitlabMergeRequestActionInput = {
|
||||
projectid: string;
|
||||
repoUrl: string;
|
||||
title: string;
|
||||
description: string;
|
||||
destinationBranch: string;
|
||||
targetPath: string;
|
||||
};
|
||||
projectid: string;
|
||||
repoUrl: string;
|
||||
title: string;
|
||||
description: string;
|
||||
destinationBranch: string;
|
||||
targetPath: string;
|
||||
};
|
||||
|
||||
export const createPublishGitlabMergeRequestAction = (options: {
|
||||
integrations: ScmIntegrationRegistry;
|
||||
}) => {
|
||||
const { integrations } = options;
|
||||
integrations: ScmIntegrationRegistry;
|
||||
}) => {
|
||||
const { integrations } = options;
|
||||
|
||||
return createTemplateAction<GitlabMergeRequestActionInput>({
|
||||
id: 'publish:gitlab-merge-request',
|
||||
schema: {
|
||||
input: {
|
||||
required: ['projectid', 'repoUrl', 'targetPath'],
|
||||
type: 'object',
|
||||
properties: {
|
||||
repoUrl: {
|
||||
type: 'string',
|
||||
title: 'Repository Location',
|
||||
description: `Accepts the format 'gitlab.com/group_name/project_name' where 'project_name' is the repository name and 'group_name' is a group or username`,
|
||||
},
|
||||
projectid: {
|
||||
type: 'string',
|
||||
title: 'projectid',
|
||||
description: 'Project ID of the Gitlab Project',
|
||||
},
|
||||
title: {
|
||||
type: 'string',
|
||||
title: 'Merge Request Name',
|
||||
description: 'The name for the merge request',
|
||||
},
|
||||
description: {
|
||||
type: 'string',
|
||||
title: 'Merge Request Description',
|
||||
description: 'The description of the merge request',
|
||||
},
|
||||
destinationBranch: {
|
||||
type: 'string',
|
||||
title: 'Destination Branch name',
|
||||
description: 'The description of the merge request',
|
||||
},
|
||||
targetPath: {
|
||||
type: 'string',
|
||||
title: 'Repository Subdirectory',
|
||||
description: 'Subdirectory of repository to apply changes to',
|
||||
}
|
||||
},
|
||||
},
|
||||
output: {
|
||||
type: 'object',
|
||||
properties: {
|
||||
projectid : {
|
||||
title: 'Gitlab Project id',
|
||||
type: 'string',
|
||||
},
|
||||
mergeRequestURL: {
|
||||
title: 'MergeRequest(MR) URL',
|
||||
type: 'string',
|
||||
description: 'Link to the merge request in GitLab',
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
async handler(ctx) {
|
||||
const repoUrl = ctx.input.repoUrl;
|
||||
const { host } = parseRepoUrl(repoUrl, integrations);
|
||||
const integrationConfig = integrations.gitlab.byHost(host);
|
||||
return createTemplateAction<GitlabMergeRequestActionInput>({
|
||||
id: 'publish:gitlab-merge-request',
|
||||
schema: {
|
||||
input: {
|
||||
required: ['projectid', 'repoUrl', 'targetPath'],
|
||||
type: 'object',
|
||||
properties: {
|
||||
repoUrl: {
|
||||
type: 'string',
|
||||
title: 'Repository Location',
|
||||
description: `Accepts the format 'gitlab.com/group_name/project_name' where 'project_name' is the repository name and 'group_name' is a group or username`,
|
||||
},
|
||||
projectid: {
|
||||
type: 'string',
|
||||
title: 'projectid',
|
||||
description: 'Project ID of the Gitlab Project',
|
||||
},
|
||||
title: {
|
||||
type: 'string',
|
||||
title: 'Merge Request Name',
|
||||
description: 'The name for the merge request',
|
||||
},
|
||||
description: {
|
||||
type: 'string',
|
||||
title: 'Merge Request Description',
|
||||
description: 'The description of the merge request',
|
||||
},
|
||||
destinationBranch: {
|
||||
type: 'string',
|
||||
title: 'Destination Branch name',
|
||||
description: 'The description of the merge request',
|
||||
},
|
||||
targetPath: {
|
||||
type: 'string',
|
||||
title: 'Repository Subdirectory',
|
||||
description: 'Subdirectory of repository to apply changes to',
|
||||
},
|
||||
},
|
||||
},
|
||||
output: {
|
||||
type: 'object',
|
||||
properties: {
|
||||
projectid: {
|
||||
title: 'Gitlab Project id',
|
||||
type: 'string',
|
||||
},
|
||||
mergeRequestURL: {
|
||||
title: 'MergeRequest(MR) URL',
|
||||
type: 'string',
|
||||
description: 'Link to the merge request in GitLab',
|
||||
},
|
||||
},
|
||||
},
|
||||
},
|
||||
async handler(ctx) {
|
||||
const repoUrl = ctx.input.repoUrl;
|
||||
const { host } = parseRepoUrl(repoUrl, integrations);
|
||||
const integrationConfig = integrations.gitlab.byHost(host);
|
||||
|
||||
let actions: CommitAction[] = [];
|
||||
const formatedTimestamp = ()=> {
|
||||
const d = new Date()
|
||||
const date = d.toISOString().split('T')[0];
|
||||
const time = d.toTimeString().split(' ')[0].replace(/:/g, "_");
|
||||
return `${date}_${time}`
|
||||
}
|
||||
const destinationBranch = ctx.input.destinationBranch? ctx.input.destinationBranch + formatedTimestamp(): `backstage_${formatedTimestamp()}`;
|
||||
const actions: CommitAction[] = [];
|
||||
const formatedTimestamp = () => {
|
||||
const d = new Date();
|
||||
const date = d.toISOString().split('T')[0];
|
||||
const time = d.toTimeString().split(' ')[0].replace(/:/g, '_');
|
||||
return `${date}_${time}`;
|
||||
};
|
||||
const destinationBranch = ctx.input.destinationBranch
|
||||
? ctx.input.destinationBranch + formatedTimestamp()
|
||||
: `backstage_${formatedTimestamp()}`;
|
||||
|
||||
if (!integrationConfig) {
|
||||
throw new InputError(
|
||||
`No matching integration configuration for host ${host}, please check your integrations config`,
|
||||
);
|
||||
}
|
||||
if (!integrationConfig) {
|
||||
throw new InputError(
|
||||
`No matching integration configuration for host ${host}, please check your integrations config`,
|
||||
);
|
||||
}
|
||||
|
||||
if (!integrationConfig.config.token) {
|
||||
throw new InputError(`No token available for host ${host}`);
|
||||
}
|
||||
if (!integrationConfig.config.token) {
|
||||
throw new InputError(`No token available for host ${host}`);
|
||||
}
|
||||
|
||||
const api = new Gitlab({
|
||||
host: integrationConfig.config.baseUrl,
|
||||
token: integrationConfig.config.token,
|
||||
});
|
||||
const api = new Gitlab({
|
||||
host: integrationConfig.config.baseUrl,
|
||||
token: integrationConfig.config.token,
|
||||
});
|
||||
|
||||
const fileRoot = ctx.workspacePath;
|
||||
const localFilePaths = await globby([`${ctx.input.targetPath}'/**'`], {
|
||||
cwd: fileRoot,
|
||||
gitignore: true,
|
||||
dot: true,
|
||||
});
|
||||
const fileRoot = ctx.workspacePath;
|
||||
const localFilePaths = await globby([`${ctx.input.targetPath}'/**'`], {
|
||||
cwd: fileRoot,
|
||||
gitignore: true,
|
||||
dot: true,
|
||||
});
|
||||
|
||||
const fileContents = await Promise.all(
|
||||
localFilePaths.map(p => readFile(path.resolve(fileRoot, p))),
|
||||
);
|
||||
const fileContents = await Promise.all(
|
||||
localFilePaths.map(p => readFile(path.resolve(fileRoot, p))),
|
||||
);
|
||||
|
||||
const repoFilePaths = localFilePaths.map(repoFilePath => {
|
||||
return repoFilePath;
|
||||
});
|
||||
const repoFilePaths = localFilePaths.map(repoFilePath => {
|
||||
return repoFilePath;
|
||||
});
|
||||
|
||||
for(let i=0; i<repoFilePaths.length;i++) {
|
||||
actions.push({ action:'create', filePath:repoFilePaths[i], content: fileContents[i].toString()});
|
||||
}
|
||||
for (let i = 0; i < repoFilePaths.length; i++) {
|
||||
actions.push({
|
||||
action: 'create',
|
||||
filePath: repoFilePaths[i],
|
||||
content: fileContents[i].toString(),
|
||||
});
|
||||
}
|
||||
|
||||
const defaultBranch: any = await api.Projects.show(
|
||||
ctx.input.projectid,
|
||||
).then(projectJSON => {
|
||||
return projectJSON?.default_branch;
|
||||
});
|
||||
|
||||
const defaultBranch: any = await api.Projects.show(ctx.input.projectid).then((projectJSON) => {
|
||||
return projectJSON?.default_branch;
|
||||
});
|
||||
try {
|
||||
await api.Branches.create(
|
||||
ctx.input.projectid,
|
||||
destinationBranch,
|
||||
defaultBranch,
|
||||
).then(branchResponse => {
|
||||
return branchResponse;
|
||||
});
|
||||
} catch (e) {
|
||||
throw new InputError(`The branch creation failed ${e}`);
|
||||
}
|
||||
|
||||
try {
|
||||
await api.Branches.create(ctx.input.projectid, destinationBranch, defaultBranch).then((branchResponse) => {
|
||||
return branchResponse;
|
||||
});
|
||||
} catch(e) {
|
||||
throw new InputError(`The branch creation failed ` + e);
|
||||
}
|
||||
try {
|
||||
await api.Commits.create(
|
||||
ctx.input.projectid,
|
||||
destinationBranch,
|
||||
ctx.input.title,
|
||||
actions,
|
||||
);
|
||||
} catch (e) {
|
||||
throw new InputError(
|
||||
`Committing the changes to ${destinationBranch} failed ${e}`,
|
||||
);
|
||||
}
|
||||
|
||||
try {
|
||||
await api.Commits.create(ctx.input.projectid, destinationBranch, ctx.input.title, actions);
|
||||
} catch(e) {
|
||||
throw new InputError(`Committing the changes to ` + destinationBranch + ` failed ` + e);
|
||||
}
|
||||
|
||||
try {
|
||||
let mergeRequestUrl: any = await api.MergeRequests.create(ctx.input.projectid, destinationBranch, defaultBranch, ctx.input.title, { description: ctx.input.description }).then((mergeRequest) => {
|
||||
return mergeRequest.web_url
|
||||
});
|
||||
ctx.output('projectid', ctx.input.projectid);
|
||||
ctx.output('mergeRequestUrl', mergeRequestUrl);
|
||||
}
|
||||
catch(e) {
|
||||
throw new InputError(`Merge request creation failed` + e);
|
||||
}
|
||||
},
|
||||
});
|
||||
};
|
||||
try {
|
||||
const mergeRequestUrl: any = await api.MergeRequests.create(
|
||||
ctx.input.projectid,
|
||||
destinationBranch,
|
||||
defaultBranch,
|
||||
ctx.input.title,
|
||||
{ description: ctx.input.description },
|
||||
).then(mergeRequest => {
|
||||
return mergeRequest.web_url;
|
||||
});
|
||||
ctx.output('projectid', ctx.input.projectid);
|
||||
ctx.output('mergeRequestUrl', mergeRequestUrl);
|
||||
} catch (e) {
|
||||
throw new InputError(`Merge request creation failed${e}`);
|
||||
}
|
||||
},
|
||||
});
|
||||
};
|
||||
|
||||
Reference in New Issue
Block a user