提交 4c302f92 编写于 作者: J Joao Moreno

scm api: getOriginalResource

上级 16f4dc86
......@@ -6,6 +6,7 @@
'use strict';
import { scm, ExtensionContext, workspace } from 'vscode';
import * as path from 'path';
import { findGit, Git } from './git';
export function log(...args: any[]): void {
......@@ -36,7 +37,9 @@ export function activate(context: ExtensionContext): any {
const contentProvider = workspace.registerTextDocumentContentProvider('git-index', {
provideTextDocumentContent: uri => {
return git.exec(workspace.rootPath, ['show', uri.fsPath]).then(result => {
const relativePath = path.relative(workspace.rootPath, uri.fsPath);
return git.exec(workspace.rootPath, ['show', `HEAD:${relativePath}`]).then(result => {
if (result.exitCode !== 0) {
return null;
}
......
......@@ -94,7 +94,7 @@ declare module 'vscode' {
commitCommand?: string;
clickCommand?: string;
dragCommand?: string;
getOriginalResource?(uri: Uri): Uri | Thenable<Uri>;
getOriginalResource?(uri: Uri, token: CancellationToken): Uri | Thenable<Uri>;
}
export interface SCMProvider extends Disposable {
......
......@@ -229,6 +229,8 @@ export abstract class MainProcessExtensionServiceShape {
}
export abstract class MainThreadSCMShape {
$register(id: string, registerOriginalResourceProvider: boolean): void { throw ni(); }
$unregister(id: string): void { throw ni(); }
}
// -- extension host
......@@ -359,6 +361,7 @@ export abstract class ExtHostTerminalServiceShape {
}
export abstract class ExtHostSCMShape {
$getBaselineResource(id: string, uri: URI): TPromise<URI> { throw ni(); }
}
// --- proxy identifiers
......@@ -382,7 +385,7 @@ export const MainContext = {
MainThreadTerminalService: createMainId<MainThreadTerminalServiceShape>('MainThreadTerminalService', MainThreadTerminalServiceShape),
MainThreadWorkspace: createMainId<MainThreadWorkspaceShape>('MainThreadWorkspace', MainThreadWorkspaceShape),
MainProcessExtensionService: createMainId<MainProcessExtensionServiceShape>('MainProcessExtensionService', MainProcessExtensionServiceShape),
MainThreadSCM: createMainId('MainThreadSCM', MainThreadSCMShape)
MainThreadSCM: createMainId<MainThreadSCMShape>('MainThreadSCM', MainThreadSCMShape)
};
export const ExtHostContext = {
......
......@@ -4,31 +4,45 @@
*--------------------------------------------------------------------------------------------*/
'use strict';
import URI from 'vs/base/common/uri';
import { TPromise } from 'vs/base/common/winjs.base';
import { asWinJsPromise } from 'vs/base/common/async';
import { IThreadService } from 'vs/workbench/services/thread/common/threadService';
import { SCMProvider, SCMDelegate, SCMResourceGroup } from 'vscode';
import { MainContext, MainThreadSCMShape } from './extHost.protocol';
export class ExtHostSCMProvider implements SCMProvider {
class ExtHostSCMProvider implements SCMProvider {
private static ID_GEN = 0;
private _id: number = ExtHostSCMProvider.ID_GEN++;
static Providers: { [id: string]: ExtHostSCMProvider; } = Object.create(null);
constructor(
private _proxy: MainThreadSCMShape,
private _id: string,
private _delegate: SCMDelegate
) { }
) {
if (ExtHostSCMProvider.Providers[_id]) {
throw new Error('provider already exists');
}
get id(): number {
ExtHostSCMProvider.Providers[_id] = this;
_proxy.$register(this._id, !!this._delegate.getOriginalResource);
}
get id(): string {
return this._id;
}
createResourceGroup(id: string, label: string): SCMResourceGroup {
// throw new Error('JOAO not implemented');
return null;
throw new Error('JOAO not implemented');
}
getBaselineResource(uri: URI): TPromise<URI> {
return asWinJsPromise(token => this._delegate.getOriginalResource(uri, token));
}
dispose(): void {
// todo
this._proxy.$unregister(this._id);
delete ExtHostSCMProvider.Providers[this.id];
}
}
......@@ -40,7 +54,17 @@ export class ExtHostSCM {
this._proxy = threadService.get(MainContext.MainThreadSCM);
}
createSCMProvider(id: string, delegate: SCMDelegate): ExtHostSCMProvider {
return new ExtHostSCMProvider(this._proxy, delegate);
createSCMProvider(id: string, delegate: SCMDelegate): SCMProvider {
return new ExtHostSCMProvider(this._proxy, id, delegate);
}
$getBaselineResource(id: string, uri: URI): TPromise<URI> {
const provider = ExtHostSCMProvider.Providers[id];
if (!provider) {
return TPromise.as(null);
}
return provider.getBaselineResource(uri);
}
}
......@@ -4,22 +4,52 @@
*--------------------------------------------------------------------------------------------*/
'use strict';
import { IDisposable, dispose } from 'vs/base/common/lifecycle';
import { IDisposable, dispose, combinedDisposable } from 'vs/base/common/lifecycle';
import { IThreadService } from 'vs/workbench/services/thread/common/threadService';
import { MainThreadSCMShape } from './extHost.protocol';
import { ISCMService } from 'vs/workbench/services/scm/common/scm';
import { ExtHostContext, MainThreadSCMShape, ExtHostSCMShape } from './extHost.protocol';
export class MainThreadSCM extends MainThreadSCMShape {
private _toDispose: IDisposable;
private toDispose: IDisposable;
private proxy: ExtHostSCMShape;
private providers: { [id: string]: IDisposable; } = Object.create(null);
constructor(
@IThreadService threadService: IThreadService
@IThreadService threadService: IThreadService,
@ISCMService private scmService: ISCMService
) {
super();
// const proxy = threadService.get(ExtHostContext.ExtHostSCM);
this.proxy = threadService.get(ExtHostContext.ExtHostSCM);
}
$register(id: string, registerOriginalResourceProvider: boolean): void {
const disposables = [];
if (registerOriginalResourceProvider) {
const baselineProvider = this.scmService.registerBaselineResourceProvider({
getBaselineResource: uri => this.proxy.$getBaselineResource(id, uri)
});
disposables.push(baselineProvider);
}
this.providers[id] = combinedDisposable(disposables);
}
$unregister(id: string): void {
const provider = this.providers[id];
if (!provider) {
return;
}
provider.dispose();
delete this.providers[id];
}
dispose(): void {
this._toDispose = dispose(this._toDispose);
this.toDispose = dispose(this.toDispose);
}
}
......@@ -11,9 +11,7 @@ import { registerSingleton } from 'vs/platform/instantiation/common/extensions';
import { SyncActionDescriptor } from 'vs/platform/actions/common/actions';
import { Registry } from 'vs/platform/platform';
import { CloneAction } from './gitActions';
import { GitContentProvider } from '../common/gitContentProvider';
import { IWorkbenchActionRegistry, Extensions as WorkbenchActionExtensions } from 'vs/workbench/common/actionRegistry';
import { IWorkbenchContributionsRegistry, Extensions as WorkbenchExtensions } from 'vs/workbench/common/contributions';
registerContributions();
......@@ -24,6 +22,3 @@ const category = localize('git', "Git");
Registry.as<IWorkbenchActionRegistry>(WorkbenchActionExtensions.WorkbenchActions)
.registerWorkbenchAction(new SyncActionDescriptor(CloneAction, CloneAction.ID, CloneAction.LABEL), 'Git: Clone', category);
Registry.as<IWorkbenchContributionsRegistry>(WorkbenchExtensions.Workbench)
.registerWorkbenchContribution(GitContentProvider);
\ No newline at end of file
......@@ -59,7 +59,7 @@ class DirtyDiffModelDecorator {
private decorations: string[];
private baselineModel: common.IModel;
private diffDelayer: ThrottledDelayer<void>;
private diffDelayer: ThrottledDelayer<common.IChange[]>;
private toDispose: IDisposable[];
constructor(
......@@ -73,7 +73,7 @@ class DirtyDiffModelDecorator {
@ITextModelResolverService private textModelResolverService: ITextModelResolverService
) {
this.decorations = [];
this.diffDelayer = new ThrottledDelayer<void>(200);
this.diffDelayer = new ThrottledDelayer<common.IChange[]>(200);
this.toDispose = [];
this.triggerDiff();
this.toDispose.push(model.onDidChangeContent(() => this.triggerDiff()));
......@@ -82,18 +82,24 @@ class DirtyDiffModelDecorator {
@memoize
private get originalURIPromise(): winjs.TPromise<URI> {
return this.scmService.getBaselineResource(this.uri)
.then(originalUri => this.textModelResolverService.createModelReference(originalUri)
.then(ref => {
this.baselineModel = ref.object.textEditorModel;
.then(originalUri => {
if (!originalUri) {
return null;
}
return this.textModelResolverService.createModelReference(originalUri)
.then(ref => {
this.baselineModel = ref.object.textEditorModel;
this.toDispose.push(ref);
this.toDispose.push(ref.object.textEditorModel.onDidChangeContent(() => this.triggerDiff()));
this.toDispose.push(ref);
this.toDispose.push(ref.object.textEditorModel.onDidChangeContent(() => this.triggerDiff()));
return originalUri;
}));
return originalUri;
});
});
}
private triggerDiff(): winjs.Promise {
private triggerDiff(): winjs.TPromise<void> {
if (!this.diffDelayer) {
return winjs.TPromise.as(null);
}
......@@ -113,13 +119,13 @@ class DirtyDiffModelDecorator {
});
}
private diff(): winjs.Promise {
private diff(): winjs.TPromise<common.IChange[]> {
return this.originalURIPromise.then(originalURI => {
if (!this.model || this.model.isDisposed()) {
if (!this.model || this.model.isDisposed() || !originalURI) {
return winjs.TPromise.as<any>([]); // disposed
}
this.editorWorkerService.computeDirtyDiff(originalURI, this.model.uri, true);
return this.editorWorkerService.computeDirtyDiff(originalURI, this.model.uri, true);
});
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册