aboutsummaryrefslogtreecommitdiff
path: root/packages/server/src/api/git.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/server/src/api/git.ts')
-rw-r--r--packages/server/src/api/git.ts62
1 files changed, 35 insertions, 27 deletions
diff --git a/packages/server/src/api/git.ts b/packages/server/src/api/git.ts
index d32a299..e3e07c7 100644
--- a/packages/server/src/api/git.ts
+++ b/packages/server/src/api/git.ts
@@ -1,5 +1,12 @@
-import { Branch, Hunk, Hunks, LatestCommit, LogCommit, Patch, PatchHeaderData, RequestInfo, ShortBranch, ShortCommit, ShortRepository, ShortTag, ShortTreeEntry, Tree } from "./git_types";
-import { Commit, ConvenientHunk, ConvenientPatch, Object, Oid, Repository, Revwalk, Tag, TreeEntry } from "nodegit";
+import {
+ Branch, Commit,
+ Hunk, Hunks,
+ LatestCommit, LogCommit,
+ Patch, PatchHeaderData,
+ Repository, RequestInfo,
+ ShortBranch, Tag,
+ Tree, TreeEntry
+} from "./git_types";
import { FastifyReply, FastifyRequest } from "fastify";
import { Pack, pack } from "tar-stream";
import { join, parse } from "path";
@@ -8,6 +15,7 @@ import { IncomingMessage } from "http";
import { Route } from "../fastify_types";
import { URL } from "whatwg-url";
import { createGzip } from "zlib";
+import nodegit from "nodegit";
import { pipeline } from "stream";
import { spawn } from "child_process";
import { verifyGitRequest } from "./util";
@@ -58,7 +66,7 @@ function getPatchHeaderData(patch_headers: string[], all_patches: string[]) {
}, <PatchHeaderData>{ indexes: [], lengths: [], last: null });
}
-function getHunks(hunks: ConvenientHunk[], patch_content: string[]) {
+function getHunks(hunks: nodegit.ConvenientHunk[], patch_content: string[]) {
return hunks.reduce((hunks_data: Hunks, hunk, hunk_index) => {
const hunk_header = hunk.header();
const hunk_header_index = patch_content.indexOf(hunk_header.replace(/\n/gu, ""));
@@ -79,7 +87,7 @@ function getHunks(hunks: ConvenientHunk[], patch_content: string[]) {
}, { prev: null, hunks: [] });
}
-function getPatch(patch: ConvenientPatch, too_large: boolean, hunks?: Hunk[]): Patch {
+function getPatch(patch: nodegit.ConvenientPatch, too_large: boolean, hunks?: Hunk[]): Patch {
return {
from: patch.oldFile().path(),
to: patch.newFile().path(),
@@ -118,8 +126,8 @@ function getRequestInfo(req: Request): RequestInfo {
};
}
-async function getTreeEntryLastCommit(repo: Repository, tree_entry: TreeEntry) {
- const walker = Revwalk.create(repo);
+async function getTreeEntryLastCommit(repo: nodegit.Repository, tree_entry: nodegit.TreeEntry) {
+ const walker = nodegit.Revwalk.create(repo);
walker.pushHead();
const raw_commits = await walker.getCommitsUntil(() => true);
@@ -162,7 +170,7 @@ function readDirectory(directory: string) {
});
}
-async function addArchiveEntries(entries: TreeEntry[], repo_name: string, archive: Pack) {
+async function addArchiveEntries(entries: nodegit.TreeEntry[], repo_name: string, archive: Pack) {
for(const tree_entry of entries) {
if(tree_entry.isBlob()) {
const blob = await tree_entry.getBlob();
@@ -175,7 +183,7 @@ async function addArchiveEntries(entries: TreeEntry[], repo_name: string, archiv
}
}
-function getTreeEntries(repo: Repository, entries: TreeEntry[]) {
+function getTreeEntries(repo: nodegit.Repository, entries: nodegit.TreeEntry[]) {
return entries.reduce((acc, entry) => {
return acc.then(result => {
return getTreeEntryLastCommit(repo, entry).then(last_commit => {
@@ -192,7 +200,7 @@ function getTreeEntries(repo: Repository, entries: TreeEntry[]) {
return result;
});
});
- }, Promise.resolve(<ShortTreeEntry[]>[]));
+ }, Promise.resolve(<TreeEntry[]>[]));
}
export class GitAPI {
@@ -204,9 +212,9 @@ export class GitAPI {
async getLog(repo_name: string): Promise<LogCommit[]> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
- const walker: Revwalk = Revwalk.create(repo);
+ const walker: nodegit.Revwalk = nodegit.Revwalk.create(repo);
walker.pushHead();
const raw_commits = await walker.getCommitsUntil(() => true);
@@ -227,7 +235,7 @@ export class GitAPI {
async getRepositoryLastCommit(repo_name: string): Promise<number> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const master_commit = await repo.getMasterCommit();
@@ -247,7 +255,7 @@ export class GitAPI {
});
}
- async getRepositories(): Promise<ShortRepository[] | null> {
+ async getRepositories(): Promise<Repository[] | null> {
const dir_content = await readDirectory(this.base_dir);
if(dir_content.length === 0) {
@@ -270,12 +278,12 @@ export class GitAPI {
});
});
});
- }, Promise.resolve(<ShortRepository[]>[]));
+ }, Promise.resolve(<Repository[]>[]));
}
- async getCommit(repo_name: string, commit_oid: string): Promise<ShortCommit> {
+ async getCommit(repo_name: string, commit_oid: string): Promise<Commit> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const commit = await repo.getCommit(commit_oid);
const diff = (await commit.getDiff())[0];
const all_patches = (await diff.toBuf(1)).toString().split("\n");
@@ -365,7 +373,7 @@ export class GitAPI {
async getTree(repo_name: string, tree_path: string | null): Promise<Tree | null> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const master_commit = await repo.getMasterCommit();
const tree = await master_commit.getTree();
@@ -391,16 +399,16 @@ export class GitAPI {
async doesObjectExist(repo_name: string, id: string): Promise<boolean> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
- return Object.lookup(repo, Oid.fromString(id), Object.TYPE.ANY)
+ return nodegit.Object.lookup(repo, nodegit.Oid.fromString(id), nodegit.Object.TYPE.ANY)
.then(() => true)
.catch(() => false);
}
async doesReadmeExist(repo_name: string): Promise<boolean> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const master_commit = await repo.getMasterCommit();
const tree = await master_commit.getTree();
@@ -412,7 +420,7 @@ export class GitAPI {
async getBranches(repo_name: string): Promise<ShortBranch[]> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const references = await repo.getReferences();
@@ -426,7 +434,7 @@ export class GitAPI {
async getBranch(repo_name: string, branch_id: string): Promise<Branch | null> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const references = await repo.getReferences();
const branches = references.filter(ref => ref.isBranch());
@@ -449,14 +457,14 @@ export class GitAPI {
};
}
- async getTags(repo_name: string): Promise<ShortTag[]> {
+ async getTags(repo_name: string): Promise<Tag[]> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const references = await repo.getReferences();
return Promise.all(references.filter(ref => ref.isTag()).map(async ref => {
- const tagger = (await Tag.lookup(repo, ref.target())).tagger();
+ const tagger = (await nodegit.Tag.lookup(repo, ref.target())).tagger();
return {
name: ref.shorthand(),
@@ -471,7 +479,7 @@ export class GitAPI {
async downloadTagArchive(repo_name: string, tag_name: string, reply: FastifyReply): Promise<void> {
const full_repo_name = addRepoDirSuffix(repo_name);
- const repo = await Repository.openBare(`${this.base_dir}/${full_repo_name}`);
+ const repo = await nodegit.Repository.openBare(`${this.base_dir}/${full_repo_name}`);
const reference = await repo.getReference(tag_name)
.catch(() => {
@@ -482,7 +490,7 @@ export class GitAPI {
return;
}
- const commit = await Commit.lookup(repo, (await reference.peel(Object.TYPE.COMMIT)).id());
+ const commit = await nodegit.Commit.lookup(repo, (await reference.peel(nodegit.Object.TYPE.COMMIT)).id());
const tree = await commit.getTree();
const archive = pack();
generated by cgit v1.2.3-18-g5258 (git 2.32.0) at 2024-11-22 04:04:33 +0000