/*--------------------------------------------------------------------------------------------- * Copyright (c) Microsoft Corporation. All rights reserved. * Licensed under the MIT License. See License.txt in the project root for license information. *--------------------------------------------------------------------------------------------*/ import { Emitter, Event, PauseableEmitter } from 'vs/base/common/event'; import { IDisposable, dispose } from 'vs/base/common/lifecycle'; import { keys } from 'vs/base/common/map'; import { CommandsRegistry } from 'vs/platform/commands/common/commands'; import { ConfigurationTarget, IConfigurationService } from 'vs/platform/configuration/common/configuration'; import { ContextKeyExpr, IContext, IContextKey, IContextKeyChangeEvent, IContextKeyService, IContextKeyServiceTarget, IReadableSet, SET_CONTEXT_COMMAND_ID } from 'vs/platform/contextkey/common/contextkey'; import { KeybindingResolver } from 'vs/platform/keybinding/common/keybindingResolver'; const KEYBINDING_CONTEXT_ATTR = 'data-keybinding-context'; export class Context implements IContext { protected _parent: Context | null; protected _value: { [key: string]: any; }; protected _id: number; constructor(id: number, parent: Context | null) { this._id = id; this._parent = parent; this._value = Object.create(null); this._value['_contextId'] = id; } public setValue(key: string, value: any): boolean { // console.log('SET ' + key + ' = ' + value + ' ON ' + this._id); if (this._value[key] !== value) { this._value[key] = value; return true; } return false; } public removeValue(key: string): boolean { // console.log('REMOVE ' + key + ' FROM ' + this._id); if (key in this._value) { delete this._value[key]; return true; } return false; } public getValue(key: string): T | undefined { const ret = this._value[key]; if (typeof ret === 'undefined' && this._parent) { return this._parent.getValue(key); } return ret; } collectAllValues(): { [key: string]: any; } { let result = this._parent ? this._parent.collectAllValues() : Object.create(null); result = { ...result, ...this._value }; delete result['_contextId']; return result; } } class NullContext extends Context { static readonly INSTANCE = new NullContext(); constructor() { super(-1, null); } public setValue(key: string, value: any): boolean { return false; } public removeValue(key: string): boolean { return false; } public getValue(key: string): T | undefined { return undefined; } collectAllValues(): { [key: string]: any; } { return Object.create(null); } } class ConfigAwareContextValuesContainer extends Context { private static _keyPrefix = 'config.'; private readonly _values = new Map(); private readonly _listener: IDisposable; constructor( id: number, private readonly _configurationService: IConfigurationService, emitter: Emitter ) { super(id, null); this._listener = this._configurationService.onDidChangeConfiguration(event => { if (event.source === ConfigurationTarget.DEFAULT) { // new setting, reset everything const allKeys = keys(this._values); this._values.clear(); emitter.fire(new ArrayContextKeyChangeEvent(allKeys)); } else { const changedKeys: string[] = []; for (const configKey of event.affectedKeys) { const contextKey = `config.${configKey}`; if (this._values.has(contextKey)) { this._values.delete(contextKey); changedKeys.push(contextKey); } } emitter.fire(new ArrayContextKeyChangeEvent(changedKeys)); } }); } dispose(): void { this._listener.dispose(); } getValue(key: string): any { if (key.indexOf(ConfigAwareContextValuesContainer._keyPrefix) !== 0) { return super.getValue(key); } if (this._values.has(key)) { return this._values.get(key); } const configKey = key.substr(ConfigAwareContextValuesContainer._keyPrefix.length); const configValue = this._configurationService.getValue(configKey); let value: any = undefined; switch (typeof configValue) { case 'number': case 'boolean': case 'string': value = configValue; break; } this._values.set(key, value); return value; } setValue(key: string, value: any): boolean { return super.setValue(key, value); } removeValue(key: string): boolean { return super.removeValue(key); } collectAllValues(): { [key: string]: any; } { const result: { [key: string]: any } = Object.create(null); this._values.forEach((value, index) => result[index] = value); return { ...result, ...super.collectAllValues() }; } } class ContextKey implements IContextKey { private _service: AbstractContextKeyService; private _key: string; private _defaultValue: T | undefined; constructor(service: AbstractContextKeyService, key: string, defaultValue: T | undefined) { this._service = service; this._key = key; this._defaultValue = defaultValue; this.reset(); } public set(value: T): void { this._service.setContext(this._key, value); } public reset(): void { if (typeof this._defaultValue === 'undefined') { this._service.removeContext(this._key); } else { this._service.setContext(this._key, this._defaultValue); } } public get(): T | undefined { return this._service.getContextKeyValue(this._key); } } class SimpleContextKeyChangeEvent implements IContextKeyChangeEvent { constructor(readonly key: string) { } affectsSome(keys: IReadableSet): boolean { return keys.has(this.key); } } class ArrayContextKeyChangeEvent implements IContextKeyChangeEvent { constructor(readonly keys: string[]) { } affectsSome(keys: IReadableSet): boolean { for (const key of this.keys) { if (keys.has(key)) { return true; } } return false; } } class CompositeContextKeyChangeEvent implements IContextKeyChangeEvent { constructor(readonly events: IContextKeyChangeEvent[]) { } affectsSome(keys: IReadableSet): boolean { for (const e of this.events) { if (e.affectsSome(keys)) { return true; } } return false; } } export abstract class AbstractContextKeyService implements IContextKeyService { public _serviceBrand: any; protected _isDisposed: boolean; protected _onDidChangeContext = new PauseableEmitter({ merge: input => new CompositeContextKeyChangeEvent(input) }); protected _myContextId: number; constructor(myContextId: number) { this._isDisposed = false; this._myContextId = myContextId; } abstract dispose(): void; public createKey(key: string, defaultValue: T | undefined): IContextKey { if (this._isDisposed) { throw new Error(`AbstractContextKeyService has been disposed`); } return new ContextKey(this, key, defaultValue); } public get onDidChangeContext(): Event { return this._onDidChangeContext.event; } bufferChangeEvents(callback: Function): void { this._onDidChangeContext.pause(); try { callback(); } finally { this._onDidChangeContext.resume(); } } public createScoped(domNode: IContextKeyServiceTarget): IContextKeyService { if (this._isDisposed) { throw new Error(`AbstractContextKeyService has been disposed`); } return new ScopedContextKeyService(this, this._onDidChangeContext, domNode); } public contextMatchesRules(rules: ContextKeyExpr | undefined): boolean { if (this._isDisposed) { throw new Error(`AbstractContextKeyService has been disposed`); } const context = this.getContextValuesContainer(this._myContextId); const result = KeybindingResolver.contextMatchesRules(context, rules); // console.group(rules.serialize() + ' -> ' + result); // rules.keys().forEach(key => { console.log(key, ctx[key]); }); // console.groupEnd(); return result; } public getContextKeyValue(key: string): T | undefined { if (this._isDisposed) { return undefined; } return this.getContextValuesContainer(this._myContextId).getValue(key); } public setContext(key: string, value: any): void { if (this._isDisposed) { return; } const myContext = this.getContextValuesContainer(this._myContextId); if (!myContext) { return; } if (myContext.setValue(key, value)) { this._onDidChangeContext.fire(new SimpleContextKeyChangeEvent(key)); } } public removeContext(key: string): void { if (this._isDisposed) { return; } if (this.getContextValuesContainer(this._myContextId).removeValue(key)) { this._onDidChangeContext.fire(new SimpleContextKeyChangeEvent(key)); } } public getContext(target: IContextKeyServiceTarget | null): IContext { if (this._isDisposed) { return NullContext.INSTANCE; } return this.getContextValuesContainer(findContextAttr(target)); } public abstract getContextValuesContainer(contextId: number): Context; public abstract createChildContext(parentContextId?: number): number; public abstract disposeContext(contextId: number): void; } export class ContextKeyService extends AbstractContextKeyService implements IContextKeyService { private _lastContextId: number; private readonly _contexts = new Map(); private _toDispose: IDisposable[] = []; constructor(@IConfigurationService configurationService: IConfigurationService) { super(0); this._lastContextId = 0; const myContext = new ConfigAwareContextValuesContainer(this._myContextId, configurationService, this._onDidChangeContext); this._contexts.set(this._myContextId, myContext); this._toDispose.push(myContext); // Uncomment this to see the contexts continuously logged // let lastLoggedValue: string | null = null; // setInterval(() => { // let values = Object.keys(this._contexts).map((key) => this._contexts[key]); // let logValue = values.map(v => JSON.stringify(v._value, null, '\t')).join('\n'); // if (lastLoggedValue !== logValue) { // lastLoggedValue = logValue; // console.log(lastLoggedValue); // } // }, 2000); } public dispose(): void { this._isDisposed = true; this._toDispose = dispose(this._toDispose); } public getContextValuesContainer(contextId: number): Context { if (this._isDisposed) { return NullContext.INSTANCE; } return this._contexts.get(contextId) || NullContext.INSTANCE; } public createChildContext(parentContextId: number = this._myContextId): number { if (this._isDisposed) { throw new Error(`ContextKeyService has been disposed`); } let id = (++this._lastContextId); this._contexts.set(id, new Context(id, this.getContextValuesContainer(parentContextId))); return id; } public disposeContext(contextId: number): void { if (!this._isDisposed) { this._contexts.delete(contextId); } } } class ScopedContextKeyService extends AbstractContextKeyService { private _parent: AbstractContextKeyService; private _domNode: IContextKeyServiceTarget | undefined; constructor(parent: AbstractContextKeyService, emitter: PauseableEmitter, domNode?: IContextKeyServiceTarget) { super(parent.createChildContext()); this._parent = parent; this._onDidChangeContext = emitter; if (domNode) { this._domNode = domNode; this._domNode.setAttribute(KEYBINDING_CONTEXT_ATTR, String(this._myContextId)); } } public dispose(): void { this._isDisposed = true; this._parent.disposeContext(this._myContextId); if (this._domNode) { this._domNode.removeAttribute(KEYBINDING_CONTEXT_ATTR); this._domNode = undefined; } } public get onDidChangeContext(): Event { return this._parent.onDidChangeContext; } public getContextValuesContainer(contextId: number): Context { if (this._isDisposed) { return NullContext.INSTANCE; } return this._parent.getContextValuesContainer(contextId); } public createChildContext(parentContextId: number = this._myContextId): number { if (this._isDisposed) { throw new Error(`ScopedContextKeyService has been disposed`); } return this._parent.createChildContext(parentContextId); } public disposeContext(contextId: number): void { if (this._isDisposed) { return; } this._parent.disposeContext(contextId); } } function findContextAttr(domNode: IContextKeyServiceTarget | null): number { while (domNode) { if (domNode.hasAttribute(KEYBINDING_CONTEXT_ATTR)) { const attr = domNode.getAttribute(KEYBINDING_CONTEXT_ATTR); if (attr) { return parseInt(attr, 10); } return NaN; } domNode = domNode.parentElement; } return 0; } CommandsRegistry.registerCommand(SET_CONTEXT_COMMAND_ID, function (accessor, contextKey: any, contextValue: any) { accessor.get(IContextKeyService).createKey(String(contextKey), contextValue); });