Microsoft/vscode
1
0
Fork 0
mirror of https://github.com/microsoft/vscode.git synced 2026-05-02 22:41:31 +01:00
Code Issues Packages Projects Releases Wiki Activity

git: events for git:// text documents

Browse Source
This commit is contained in:
Joao Moreno
2017-01-11 15:34:48 +01:00
parent daa8cce0b8
commit af4aedcf31
1 changed files with 38 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
extensions/git/src/main.ts
View File

@@ -5,13 +5,13 @@
'use strict';
import { scm, ExtensionContext, workspace, Uri, window, Disposable } from 'vscode';
import { scm, ExtensionContext, workspace, Uri, window, Disposable, Event, EventEmitter } from 'vscode';
import * as path from 'path';
import { findGit, Git } from './git';
import { Model } from './model';
import { GitSCMProvider } from './scmProvider';
import { registerCommands } from './commands';
import { anyEvent, throttle } from './util';
import { filterEvent, anyEvent, throttle } from './util';
import * as nls from 'vscode-nls';
import { decorate, debounce } from 'core-decorators';
@@ -19,7 +19,22 @@ nls.config();
class TextDocumentContentProvider {
constructor(private git: Git, private rootPath: string) { }
private listener: Disposable;
private onDidChangeEmitter = new EventEmitter<Uri>();
get onDidChange(): Event<Uri> { return this.onDidChangeEmitter.event; }
private uris = new Set<Uri>();
constructor(private git: Git, private rootPath: string, onGitChange: Event<Uri>) {
this.listener = onGitChange(this.fireChangeEvents, this);
}
private fireChangeEvents(): void {
for (let uri of this.uris) {
this.onDidChangeEmitter.fire(uri);
}
}
async provideTextDocumentContent(uri: Uri): Promise<string> {
const relativePath = path.relative(this.rootPath, uri.fsPath).replace(/\\/g, '/');
@@ -28,28 +43,29 @@ class TextDocumentContentProvider {
const result = await this.git.exec(this.rootPath, ['show', `HEAD:${relativePath}`]);
if (result.exitCode !== 0) {
this.uris.delete(uri);
return '';
}
this.uris.add(uri);
return result.stdout;
} catch (err) {
this.uris.delete(uri);
return '';
}
}
dispose(): void {
this.listener.dispose();
}
}
class Watcher {
private disposables: Disposable[];
private listener: Disposable;
constructor(private model: Model) {
const fsWatcher = workspace.createFileSystemWatcher('**');
const onFSChange = anyEvent(fsWatcher.onDidChange, fsWatcher.onDidCreate, fsWatcher.onDidDelete);
this.disposables = [
fsWatcher,
onFSChange(this.eventuallyUpdateModel, this)
];
constructor(private model: Model, onWorkspaceChange: Event<Uri>) {
this.listener = onWorkspaceChange(this.eventuallyUpdateModel, this);
}
@debounce(1000)
@@ -65,7 +81,7 @@ class Watcher {
}
dispose(): void {
this.disposables.forEach(d => d.dispose());
this.listener.dispose();
}
}
@@ -88,13 +104,20 @@ async function init(disposables: Disposable[]): Promise<void> {
outputChannel.appendLine(`Using git ${info.version} from ${info.path}`);
git.onOutput(str => outputChannel.append(str), null, disposables);
const watcher = new Watcher(model);
const fsWatcher = workspace.createFileSystemWatcher('**');
const onWorkspaceChange = anyEvent(fsWatcher.onDidChange, fsWatcher.onDidCreate, fsWatcher.onDidDelete);
const onGitChange = filterEvent(onWorkspaceChange, uri => /^\.git\//.test(workspace.asRelativePath(uri)));
const watcher = new Watcher(model, onWorkspaceChange);
const textDocumentContentProvider = new TextDocumentContentProvider(git, rootPath, onGitChange);
disposables.push(
registerCommands(model),
scm.registerSCMProvider('git', provider),
workspace.registerTextDocumentContentProvider('git-index', new TextDocumentContentProvider(git, rootPath)),
workspace.registerTextDocumentContentProvider('git-index', textDocumentContentProvider),
textDocumentContentProvider,
outputChannel,
fsWatcher,
watcher
);
}