Class CommitManager

extensions/github1s/src/repository/commit-manager.ts:67–239

}

export class CommitManager {
	private static instancesMap = new Map<string, CommitManager>();
	private static _commitMap = new Map<string, Commit>(); // commitSha -> CommitWithDirection
	// if `previous` or `next` is null, it means this is an end node
	private static _relationMap = new Map<string, Map<string, { previous?: string | null; next?: string | null }>>();

	private _latestCommitSha: string | null = null;
	private _currentPage = 1;
	private _pageSize = 100;

	public static getInstance(scheme: string, repo: string, from: string, filePath: string) {
		const mapKey = `${scheme} ${repo} ${from} ${filePath}`;
		if (!CommitManager.instancesMap.has(mapKey)) {
			CommitManager.instancesMap.set(mapKey, new CommitManager(scheme, repo, from, filePath));
		}
		return CommitManager.instancesMap.get(mapKey)!;
	}

	private constructor(
		private _scheme: string,
		private _repo: string,
		private _from: string,
		private _filePath: string,
	) {}

	// link two commitSha
	private linkCommitShas(previousCommitSha: string | null, nextCommitSha: string | null) {
		if (!CommitManager._relationMap.has(this._filePath)) {
			CommitManager._relationMap.set(this._filePath, new Map());
		}
		const relation = CommitManager._relationMap.get(this._filePath)!;
		if (previousCommitSha) {
			!relation.has(previousCommitSha) && relation.set(previousCommitSha, {});
			relation.get(previousCommitSha)!.next = nextCommitSha;
		}
		if (nextCommitSha) {
			!relation.has(nextCommitSha) && relation.set(nextCommitSha, {});
			relation.get(nextCommitSha)!.previous = previousCommitSha;
		}
	}

	// construct commit list with commit relations
	private resolveCommitList() {
		const commitList: Commit[] = [];
		const relation = CommitManager._relationMap.get(this._filePath);
		let currentCommitSha: string | undefined | null = this._latestCommitSha;
		while (currentCommitSha && CommitManager._commitMap.has(currentCommitSha)) {
			const commit = CommitManager._commitMap.get(currentCommitSha)!;
			commitList.push(commit);
			currentCommitSha = relation?.get(commit.sha)?.previous;
		}
		return commitList;
	}

	getList = reuseable(async (forceUpdate: boolean = false): Promise<Commit[]> => {
		const hasMore = await this.hasMore();
		const commitList = this.resolveCommitList();
		const shouldLoadMore = hasMore && commitList.length < this._pageSize;