Deploy using repository url complete (#58)

src/controller/deploy.ts

@@ -25,9 +25,6 @@ export const deploy = catchAsync(
 		next: NextFunction
 	) => {
 		try {
-			// TODO: Implement repository
-			// req.body.resourceType == 'Repository'
-
 			const application = Applications[req.body.suffix];
 
 			// Check if the application exists and it is stored

src/controller/repository.ts

@@ -0,0 +1,147 @@
+import { NextFunction, Request, Response } from 'express';
+import { promises as fs } from 'fs';
+import { join } from 'path';
+import { Application, Applications, Resource } from '../app';
+import AppError from '../utils/appError';
+import { appsDirectory } from '../utils/config';
+import { exec } from '../utils/exec';
+import { catchAsync } from './catch';
+
+// TODO: Isn't this available inside protocol package? We MUST reuse it
+type FetchFilesFromRepoBody = {
+	branch: string;
+	url: string;
+};
+
+// TODO: Isn't this available inside protocol package? We MUST reuse it
+type FetchBranchListBody = {
+	url: string;
+};
+
+const dirName = (gitUrl: string): string =>
+	String(gitUrl.split('/').pop()).replace('.git', '');
+
+const deleteRepoFolderIfExist = async <Path extends string>(
+	path: Path,
+	url: string
+): Promise<void> => {
+	const folder = dirName(url);
+	const repoFilePath = join(path, folder);
+
+	await fs.rm(repoFilePath, { recursive: true, force: true });
+};
+
+export const fetchFilesFromRepo = catchAsync(
+	async (
+		req: Omit<Request, 'body'> & { body: FetchFilesFromRepoBody },
+		res: Response,
+		next: NextFunction
+	) => {
+		const { branch, url } = req.body;
+		const resource: Resource = {
+			id: '',
+			path: '',
+			jsons: []
+		};
+
+		try {
+			await deleteRepoFolderIfExist(appsDirectory, url);
+		} catch (err) {
+			next(
+				new AppError(
+					'error occurred in deleting repository directory',
+					500
+				)
+			);
+		}
+
+		try {
+			// Clone the repository into the specified directory
+			await exec(
+				`git clone --single-branch --depth=1 --branch ${branch} ${url} ${join(
+					appsDirectory,
+					dirName(url)
+				)}`
+			);
+		} catch (err) {
+			return next(
+				new AppError('Error occurred while cloning the repository', 500)
+			);
+		}
+
+		const id = dirName(req.body.url);
+
+		resource.id = id;
+		resource.path = join(appsDirectory, id);
+
+		// Create a new Application instance and assign the resource to it
+		const application = new Application();
+		application.resource = Promise.resolve(resource);
+
+		Applications[id] = application;
+
+		return res.status(201).send({ id });
+	}
+);
+
+export const fetchBranchList = catchAsync(
+	async (
+		req: Omit<Request, 'body'> & { body: FetchBranchListBody },
+		res: Response,
+		next: NextFunction
+	) => {
+		try {
+			const { url } = req.body;
+
+			// list remote branches for the repository
+			const { stdout } = await exec(`git ls-remote --heads ${url}`);
+
+			// Parse branches from the command output
+			const branches = stdout
+				.trim()
+				.split('\n')
+				.map(line => line.split('refs/heads/')[1])
+				.filter(Boolean);
+
+			return res.status(200).json({ branches });
+		} catch (err) {
+			next(new AppError('Error fetching branch list', 500));
+		}
+	}
+);
+
+export const fetchFileList = catchAsync(
+	async (
+		req: Omit<Request, 'body'> & { body: FetchFilesFromRepoBody },
+		res: Response,
+		next: NextFunction
+	) => {
+		const { url, branch } = req.body;
+		const repoDir = dirName(url);
+		const repoPath = `${appsDirectory}/${repoDir}`;
+
+		try {
+			// Delete existing repo folder if it exists
+			await deleteRepoFolderIfExist(appsDirectory, url);
+
+			// Clone the repository
+			await exec(`git clone ${url} ${repoPath} --depth=1 --no-checkout`);
+
+			// List files in the specified branch
+			const { stdout } = await exec(
+				`cd ${repoPath} && git ls-tree -r ${branch} --name-only`
+			);
+
+			const files = stdout.trim().split('\n').filter(Boolean);
+
+			// Clean up the cloned repository
+			await exec(`rm -r ${repoPath}`);
+
+			return res.status(200).json({ files });
+		} catch (err) {
+			return next(
+				new AppError('Error fetching file list from repository', 500)
+			);
+		}
+	}
+);