aboutsummaryrefslogtreecommitdiff
path: root/packages/server/src/git/tree_entry.ts
blob: 84f36ddc4b77757f3c29eed28788373081c3c2e6 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
import { Commit } from "./commit";
import { Revwalk as NodeGitRevwalk, TreeEntry as NodeGitTreeEntry } from "nodegit";
import { Repository } from "./repository";
import { dirname } from "path";
import { findAsync } from "./misc";
import { Tree } from "./tree";
import { Blob } from "./blob";
import { createError, TreeError } from "./error";

/**
 * The core structure of a tree entry
 */
export abstract class BaseTreeEntry {
	protected _owner: Repository;

	public ng_tree_entry: NodeGitTreeEntry;
	public path: string;

	/**
	 * @param owner - The repository which the tree entry is in
	 * @param entry - An instance of a Nodegit tree entry
	 */
	constructor(owner: Repository, entry: NodeGitTreeEntry) {
		this.ng_tree_entry = entry;
		this._owner = owner;

		this.path = entry.path();
	}

	/**
	 * Returns the tree entry's latest commit
	 *
	 * @returns An instance of a commit
	 */
	public async latestCommit(): Promise<Commit> {
		const rev_walk = NodeGitRevwalk.create(this._owner.ng_repository);
		rev_walk.pushRef(`refs/heads/${this._owner.branch_name}`);

		const commits = await rev_walk.getCommitsUntil(() => true);

		const latest_commit = await findAsync(commits, async commit => {
			const diff = await commit.getDiff();
			const patches = await diff[0].patches();

			return Boolean(this instanceof TreeEntry
				? patches.find(patch => dirname(patch.newFile().path()).startsWith(this.path))
				: patches.find(patch => patch.newFile().path() === this.path));
		});

		if(!latest_commit) {
			throw(createError(TreeError, 500, `Failed to get the latest commit of tree entry '${this.path}'!`));
		}

		return new Commit(this._owner, latest_commit);
	}
}

/**
 * A representation of a tree entry that's a tree
 */
export class TreeEntry extends BaseTreeEntry {
	/**
	 * Returns the tree of the tree entry
	 *
	 * @returns An instance of a tree
	 */
	public async tree(): Promise<Tree> {
		return new Tree(this._owner, await this.ng_tree_entry.getTree());
	}
}

/**
 * A representation of a tree entry that's a blob
 */
export class BlobTreeEntry extends BaseTreeEntry {
	/**
	 * Returns the blob of the blob tree entry
	 *
	 * @returns An instance of a blob
	 */
	public async blob(): Promise<Blob> {
		return new Blob(this);
	}
}

/**
 * A factory which creates a tree entry
 *
 * @param owner - The repository that the tree entry is in
 * @param entry - An instance of a Nodegit tree entry
 * @returns An instance of a tree entry
 */
export function createTreeEntry(owner: Repository, entry: NodeGitTreeEntry): BaseTreeEntry {
	return entry.isBlob()
		? new BlobTreeEntry(owner, entry)
		: new TreeEntry(owner, entry);
}