[WIP] PoC for a Node.JS backend using nodegit

.gitignore

@@ -1,10 +1,13 @@
 *.pyc
 /bin/
 env/
+.env/
 .idea
 *.swp
 tests/repos/build
 *.egg-info
 build/
 dist/
+.vscode/
 .DS_Store
+/repositories

basic.py

@@ -0,0 +1,9 @@
+from klaus import Klaus
+
+repos = [
+    "./repositories/huggingface/moon-landing.git",
+    "./repositories/transformers.git",
+]
+
+app = Klaus(repos, "klaus.py", use_smarthttp=False)
+app.run(debug=True)

klaus/static/klaus.css

@@ -159,7 +159,7 @@ footer a:hover { text-decoration: none; }
 a.commit { color: black !important; }
 
 .tree ul { font-family: monospace; border-top: 1px solid #e0e0e0; }
-.tree li { background-color: #f9f9f9; border: 1px solid #e0e0e0; border-top: 0; }
+.tree li { background-color: white; border: 1px solid #e0e0e0; border-top: 0; }
 .tree li a {
   padding: 5px 7px 6px 7px;
   display: block;

node/.gitignore

@@ -0,0 +1,2 @@
+node_modules/
+dist/

node/app/Context.ts

@@ -0,0 +1,183 @@
+import * as express from 'express';
+import * as Git from 'nodegit';
+import * as hljs from 'highlight.js';
+import { extname } from 'path';
+import { c } from '../lib/Log';
+import { Repo } from './Repo';
+import { Utils } from '../lib/Utils';
+
+
+const DEFAULT_BRANCH = `master`;
+
+interface BreadcrumbPath {
+	dir:   string;
+	href?: string;
+}
+
+export class NotFoundError extends Error {}
+
+
+const repoNameFromRequest = (req: express.Request) => {
+	return req.params.namespace
+		? `${req.params.namespace}/${req.params.repo}`
+		: req.params.repo
+	;
+}
+
+
+export class Context {
+	/**
+	 * Repo id (repo or user/repo)
+	 */
+	repoName:  string;
+	/**
+	 * Branch/commit-sha/tag
+	 */
+	rev:       string;
+	/**
+	 * path is undefined for repo's root
+	 * (only makes sense for tree)
+	 */
+	path?:     string;
+
+	/// After `.initialize()`
+	repo:      Git.Repository;
+	commit:    Git.Commit;
+	/// Other ad hoc data, for convenient access from templates
+	data: Record<string, any> = {};
+
+	constructor(req: express.Request) {
+		/**
+		 * Note: we only support branch names and tag names
+		 * not containing a `/`.
+		 */
+		this.repoName = repoNameFromRequest(req);
+		this.rev = req.params.rev ?? DEFAULT_BRANCH;
+		this.path = req.params[0];
+	}
+
+	async initialize(): Promise<void> {
+		if (await Utils.fileExists(`${Repo.ROOT_REPOS}/${this.repoName}.git`)) {
+			/// bare repo
+			this.repo = await Git.Repository.openBare(`${Repo.ROOT_REPOS}/${this.repoName}.git`);
+		} else if (await Utils.fileExists(`${Repo.ROOT_REPOS}/${this.repoName}/.git`)) {
+			/// non-bare repo
+			this.repo = await Git.Repository.open(`${Repo.ROOT_REPOS}/${this.repoName}/.git`);
+		} else {
+			throw new NotFoundError(`No such repository ${this.repoName}`);
+		}
+
+		try {
+			this.commit = await this.repo.getCommit(this.rev);
+		} catch {
+			try {
+				this.commit = await this.repo.getBranchCommit(this.rev);
+			} catch {
+				throw new NotFoundError(`Invalid rev id`);
+			}
+		};
+	}
+
+	/**
+	 * For the breadcrumbs
+	 */
+	get subpaths(): BreadcrumbPath[] | undefined {
+		if (! this.path) {
+			return undefined;
+		}
+		const parts = this.path.split('/');
+		return parts.map((dir, i) => {
+			const href = (i === parts.length - 1)
+				? undefined
+				: parts.slice(0, i+1).join('/')
+			;
+			return { dir, href };
+		});
+	}
+
+	/**
+	 * For links in templates (e.g. branch_selector)
+	 */
+	get view(): "tree" | "blob" | string {
+		throw new Error(`Implemented by concrete subclass`);
+	}
+}
+
+
+export class CommitContext extends Context {}
+
+
+export class TreeContext extends Context {
+	tree: Git.Tree;
+
+	async initialize() {
+		await super.initialize();
+
+		if (this.path === undefined) {
+			/// "Root" tree
+			this.tree = await this.commit.getTree();
+		} else {
+			const commitTree = await this.commit.getTree();
+			const treeEntry = await commitTree.getEntry(this.path);
+			if (! treeEntry.isTree()) {
+				throw new NotFoundError(`No such tree ${this.path} in repository ${this.repoName}/${this.rev}`);
+			}
+			this.tree = await treeEntry.getTree();
+		}
+	}
+
+	get view() {
+		return `tree`;
+	}
+}
+
+
+export class BlobContext extends Context {
+	blob: Git.Blob;
+
+	async initialize() {
+		await super.initialize();
+
+		if (this.path === undefined) {
+			throw new NotFoundError(`Invalid blob, path is undefined`);
+		} else {
+			const commitTree = await this.commit.getTree();
+			const treeEntry = await commitTree.getEntry(this.path);
+			if (! treeEntry.isBlob()) {
+				throw new NotFoundError(`No such blob ${this.path} in repository ${this.repoName}/${this.rev}`);
+			}
+			this.blob = await treeEntry.getBlob();
+		}
+	}
+
+	get view() {
+		return `blob`;
+	}
+
+	get isBinary(): boolean {
+		return this.blob.isBinary() !== 0;
+	}
+	get isTooLarge(): boolean {
+		return this.blob.rawsize() > 10**9;
+	}
+
+	/**
+	 * Highlight content with hljs,
+	 * and store in this.data.
+	 */
+	renderText() {
+		const ext = Utils.trimPrefix(extname(this.path!), ".");
+		const str = this.blob.toString();
+		if (hljs.getLanguage(ext)) {
+			const res = hljs.highlight(ext, str, true);
+			this.data.code = res.value;
+		} else {
+			/// Fallback to automatic detection.
+			const res = hljs.highlightAuto(str);
+			this.data.code = res.value;
+		}
+		const n_lines = str.split('\n').length;
+		this.data.line_gutter = Utils.range(1, n_lines+1).join("\n");
+	}
+}
+

node/app/Repo.ts

@@ -0,0 +1,56 @@
+import * as Git from 'nodegit';
+import * as path from 'path';
+import { c } from '../lib/Log';
+import __rootDir from '../lib/RootDirFinder';
+import { Utils } from '../lib/Utils';
+
+
+/**
+ * Helpers for our repos.
+ */
+export namespace Repo {
+	export const ROOT_REPOS = __rootDir+`/repositories`;
+
+	export function name(repo: Git.Repository) {
+		const rel = path.relative(ROOT_REPOS, repo.path());
+		if (rel.endsWith(`/.git`)) {
+			/// non-bare repo
+			return Utils.trimSuffix(rel, `/.git`);
+		} else {
+			/// bare repo
+			return Utils.trimSuffix(rel, '.git');
+		}
+	}
+
+	export async function refs(repo: Git.Repository): Promise<{
+		tags: string[];
+		branches: string[];
+	}> {
+		const tags = await Git.Tag.list(repo);
+		const branches = (await repo.getReferences())
+			.filter(x => x.isBranch())
+			.map(x => x.shorthand())
+		;
+		return { tags, branches };
+	}
+
+	export async function numOfCommits(
+		repo: Git.Repository,
+		before: Git.Commit
+	): Promise<number> {
+		const revWalk = repo.createRevWalk();
+		revWalk.push(before.id());
+		let i = 0;
+		/// ^^ Include `before` in the count.
+		while (true) {
+			try {
+				i++;
+			} catch(err) {
+				if (err.errno === Git.Error.CODE.ITEROVER) {
+					return i;
+				}
+				throw err;
+			}
+		}
+	}
+}