2 * Copyright (C) 2011 Google Inc. All rights reserved.
4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions are
8 * * Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * * Redistributions in binary form must reproduce the above
11 * copyright notice, this list of conditions and the following disclaimer
12 * in the documentation and/or other materials provided with the
14 * * Neither the name of Google Inc. nor the names of its
15 * contributors may be used to endorse or promote products derived from
16 * this software without specific prior written permission.
18 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
19 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
20 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
21 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
22 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
23 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
24 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
25 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
26 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
28 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
34 function InspectorBackendClass()
36 this._connection = null;
37 this._agentPrototypes = {};
38 this._dispatcherPrototypes = {};
39 this._initialized = false;
41 this._initProtocolAgentsConstructor();
44 InspectorBackendClass._DevToolsErrorCode = -32000;
46 InspectorBackendClass.prototype = {
48 _initProtocolAgentsConstructor: function()
54 * @param {!Object.<string, !Object>} agentsMap
56 window.Protocol.Agents = function(agentsMap) {
57 this._agentsMap = agentsMap;
62 * @param {string} domain
64 _addAgentGetterMethodToProtocolAgentsPrototype: function(domain)
66 var upperCaseLength = 0;
67 while (upperCaseLength < domain.length && domain[upperCaseLength].toLowerCase() !== domain[upperCaseLength])
70 var methodName = domain.substr(0, upperCaseLength).toLowerCase() + domain.slice(upperCaseLength) + "Agent";
73 * @this {Protocol.Agents}
75 function agentGetter()
77 return this._agentsMap[domain];
80 window.Protocol.Agents.prototype[methodName] = agentGetter;
83 * @this {Protocol.Agents}
85 function registerDispatcher(dispatcher)
87 this.registerDispatcher(domain, dispatcher)
90 window.Protocol.Agents.prototype["register" + domain + "Dispatcher"] = registerDispatcher;
94 * @return {!InspectorBackendClass.Connection}
96 connection: function()
98 if (!this._connection)
99 throw "Main connection was not initialized";
100 return this._connection;
104 * @param {!InspectorBackendClass.MainConnection} connection
106 setConnection: function(connection)
108 this._connection = connection;
110 this._connection.registerAgentsOn(window);
111 for (var type in this._enums) {
112 var domainAndMethod = type.split(".");
113 window[domainAndMethod[0] + "Agent"][domainAndMethod[1]] = this._enums[type];
118 * @param {string} domain
119 * @return {!InspectorBackendClass.AgentPrototype}
121 _agentPrototype: function(domain)
123 if (!this._agentPrototypes[domain]) {
124 this._agentPrototypes[domain] = new InspectorBackendClass.AgentPrototype(domain);
125 this._addAgentGetterMethodToProtocolAgentsPrototype(domain);
128 return this._agentPrototypes[domain];
132 * @param {string} domain
133 * @return {!InspectorBackendClass.DispatcherPrototype}
135 _dispatcherPrototype: function(domain)
137 if (!this._dispatcherPrototypes[domain])
138 this._dispatcherPrototypes[domain] = new InspectorBackendClass.DispatcherPrototype();
139 return this._dispatcherPrototypes[domain];
143 * @param {string} method
144 * @param {!Array.<!Object>} signature
145 * @param {!Array.<string>} replyArgs
146 * @param {boolean} hasErrorData
148 registerCommand: function(method, signature, replyArgs, hasErrorData)
150 var domainAndMethod = method.split(".");
151 this._agentPrototype(domainAndMethod[0]).registerCommand(domainAndMethod[1], signature, replyArgs, hasErrorData);
152 this._initialized = true;
156 * @param {string} type
157 * @param {!Object} values
159 registerEnum: function(type, values)
161 this._enums[type] = values;
162 this._initialized = true;
166 * @param {string} eventName
167 * @param {!Object} params
169 registerEvent: function(eventName, params)
171 var domain = eventName.split(".")[0];
172 this._dispatcherPrototype(domain).registerEvent(eventName, params);
173 this._initialized = true;
177 * @param {string} jsonUrl
179 loadFromJSONIfNeeded: function(jsonUrl)
181 if (this._initialized)
184 var xhr = new XMLHttpRequest();
185 xhr.open("GET", jsonUrl, false);
188 var schema = JSON.parse(xhr.responseText);
189 var code = InspectorBackendClass._generateCommands(schema);
194 * @param {function(T)} clientCallback
195 * @param {string} errorPrefix
196 * @param {function(new:T,S)=} constructor
197 * @param {T=} defaultValue
198 * @return {function(?string, S)}
201 wrapClientCallback: function(clientCallback, errorPrefix, constructor, defaultValue)
204 * @param {?string} error
208 function callbackWrapper(error, value)
211 console.error(errorPrefix + error);
212 clientCallback(defaultValue);
216 clientCallback(new constructor(value));
218 clientCallback(value);
220 return callbackWrapper;
228 InspectorBackendClass._generateCommands = function(schema) {
229 var jsTypes = { integer: "number", array: "object" };
233 var domains = schema["domains"] || [];
234 for (var i = 0; i < domains.length; ++i) {
235 var domain = domains[i];
236 for (var j = 0; domain.types && j < domain.types.length; ++j) {
237 var type = domain.types[j];
238 rawTypes[domain.domain + "." + type.id] = jsTypes[type.type] || type.type;
242 function toUpperCase(groupIndex, group0, group1)
244 return [group0, group1][groupIndex].toUpperCase();
246 function generateEnum(enumName, items)
249 for (var m = 0; m < items.length; ++m) {
250 var value = items[m];
251 var name = value.replace(/-(\w)/g, toUpperCase.bind(null, 1)).toTitleCase();
252 name = name.replace(/HTML|XML|WML|API/ig, toUpperCase.bind(null, 0));
253 members.push(name + ": \"" + value +"\"");
255 return "InspectorBackend.registerEnum(\"" + enumName + "\", {" + members.join(", ") + "});";
258 for (var i = 0; i < domains.length; ++i) {
259 var domain = domains[i];
261 var types = domain["types"] || [];
262 for (var j = 0; j < types.length; ++j) {
264 if ((type["type"] === "string") && type["enum"])
265 result.push(generateEnum(domain.domain + "." + type.id, type["enum"]));
266 else if (type["type"] === "object") {
267 var properties = type["properties"] || [];
268 for (var k = 0; k < properties.length; ++k) {
269 var property = properties[k];
270 if ((property["type"] === "string") && property["enum"])
271 result.push(generateEnum(domain.domain + "." + type.id + property["name"].toTitleCase(), property["enum"]));
276 var commands = domain["commands"] || [];
277 for (var j = 0; j < commands.length; ++j) {
278 var command = commands[j];
279 var parameters = command["parameters"];
281 for (var k = 0; parameters && k < parameters.length; ++k) {
282 var parameter = parameters[k];
286 type = jsTypes[parameter.type] || parameter.type;
288 var ref = parameter["$ref"];
289 if (ref.indexOf(".") !== -1)
290 type = rawTypes[ref];
292 type = rawTypes[domain.domain + "." + ref];
295 var text = "{\"name\": \"" + parameter.name + "\", \"type\": \"" + type + "\", \"optional\": " + (parameter.optional ? "true" : "false") + "}";
296 paramsText.push(text);
299 var returnsText = [];
300 var returns = command["returns"] || [];
301 for (var k = 0; k < returns.length; ++k) {
302 var parameter = returns[k];
303 returnsText.push("\"" + parameter.name + "\"");
305 var hasErrorData = String(Boolean(command.error));
306 result.push("InspectorBackend.registerCommand(\"" + domain.domain + "." + command.name + "\", [" + paramsText.join(", ") + "], [" + returnsText.join(", ") + "], " + hasErrorData + ");");
309 for (var j = 0; domain.events && j < domain.events.length; ++j) {
310 var event = domain.events[j];
312 for (var k = 0; event.parameters && k < event.parameters.length; ++k) {
313 var parameter = event.parameters[k];
314 paramsText.push("\"" + parameter.name + "\"");
316 result.push("InspectorBackend.registerEvent(\"" + domain.domain + "." + event.name + "\", [" + paramsText.join(", ") + "]);");
319 return result.join("\n");
324 * @extends {WebInspector.Object}
326 InspectorBackendClass.Connection = function()
328 this._lastMessageId = 1;
329 this._pendingResponsesCount = 0;
331 this._dispatchers = {};
332 this._callbacks = {};
333 this._initialize(InspectorBackend._agentPrototypes, InspectorBackend._dispatcherPrototypes);
334 this._isConnected = true;
337 InspectorBackendClass.Connection.Events = {
338 Disconnected: "Disconnected",
341 InspectorBackendClass.Connection.prototype = {
344 * @param {!Object.<string, !InspectorBackendClass.AgentPrototype>} agentPrototypes
345 * @param {!Object.<string, !InspectorBackendClass.DispatcherPrototype>} dispatcherPrototypes
347 _initialize: function(agentPrototypes, dispatcherPrototypes)
349 for (var domain in agentPrototypes) {
350 this._agents[domain] = Object.create(agentPrototypes[domain]);
351 this._agents[domain].setConnection(this);
354 for (var domain in dispatcherPrototypes)
355 this._dispatchers[domain] = Object.create(dispatcherPrototypes[domain])
360 * @param {!Object} object
362 registerAgentsOn: function(object)
364 for (var domain in this._agents)
365 object[domain + "Agent"] = this._agents[domain];
371 nextMessageId: function()
373 return this._lastMessageId++;
377 * @param {string} domain
378 * @return {!InspectorBackendClass.AgentPrototype}
380 agent: function(domain)
382 return this._agents[domain];
386 * @return {!Object.<string, !Object>}
388 agentsMap: function()
394 * @param {string} domain
395 * @param {string} method
396 * @param {?Object} params
397 * @param {?function(*)} callback
400 _wrapCallbackAndSendMessageObject: function(domain, method, params, callback)
402 if (!this._isConnected && callback) {
403 this._dispatchConnectionErrorResponse(domain, method, callback);
407 var messageObject = {};
409 var messageId = this.nextMessageId();
410 messageObject.id = messageId;
412 messageObject.method = method;
414 messageObject.params = params;
416 var wrappedCallback = this._wrap(callback, domain, method);
418 if (InspectorBackendClass.Options.dumpInspectorProtocolMessages)
419 this._dumpProtocolMessage("frontend: " + JSON.stringify(messageObject));
421 this.sendMessage(messageObject);
422 ++this._pendingResponsesCount;
423 this._callbacks[messageId] = wrappedCallback;
427 * @param {?function(*)} callback
428 * @param {string} method
429 * @param {string} domain
430 * @return {!function(*)}
432 _wrap: function(callback, domain, method)
435 callback = function() {};
437 callback.methodName = method;
438 callback.domain = domain;
439 if (InspectorBackendClass.Options.dumpInspectorTimeStats)
440 callback.sendRequestTime = Date.now();
446 * @param {!Object} messageObject
448 sendMessage: function(messageObject)
450 throw "Not implemented";
454 * @param {!Object} messageObject
456 reportProtocolError: function(messageObject)
458 console.error("Protocol Error: the message with wrong id. Message = " + JSON.stringify(messageObject));
462 * @param {!Object|string} message
464 dispatch: function(message)
466 if (InspectorBackendClass.Options.dumpInspectorProtocolMessages)
467 this._dumpProtocolMessage("backend: " + ((typeof message === "string") ? message : JSON.stringify(message)));
469 var messageObject = /** @type {!Object} */ ((typeof message === "string") ? JSON.parse(message) : message);
471 if ("id" in messageObject) { // just a response for some request
473 var callback = this._callbacks[messageObject.id];
475 this.reportProtocolError(messageObject);
479 var processingStartTime;
480 if (InspectorBackendClass.Options.dumpInspectorTimeStats)
481 processingStartTime = Date.now();
483 this.agent(callback.domain).dispatchResponse(messageObject, callback.methodName, callback);
484 --this._pendingResponsesCount;
485 delete this._callbacks[messageObject.id];
487 if (InspectorBackendClass.Options.dumpInspectorTimeStats)
488 console.log("time-stats: " + callback.methodName + " = " + (processingStartTime - callback.sendRequestTime) + " + " + (Date.now() - processingStartTime));
490 if (this._scripts && !this._pendingResponsesCount)
491 this.runAfterPendingDispatches();
494 var method = messageObject.method.split(".");
495 var domainName = method[0];
496 if (!(domainName in this._dispatchers)) {
497 console.error("Protocol Error: the message " + messageObject.method + " is for non-existing domain '" + domainName + "'");
501 this._dispatchers[domainName].dispatch(method[1], messageObject);
507 * @param {string} domain
508 * @param {!Object} dispatcher
510 registerDispatcher: function(domain, dispatcher)
512 if (!this._dispatchers[domain])
515 this._dispatchers[domain].setDomainDispatcher(dispatcher);
519 * @param {string=} script
521 runAfterPendingDispatches: function(script)
527 this._scripts.push(script);
529 if (!this._pendingResponsesCount) {
530 var scripts = this._scripts;
532 for (var id = 0; id < scripts.length; ++id)
533 scripts[id].call(this);
537 _dumpProtocolMessage: function(message)
539 console.log(message);
544 * @param {string} reason
546 connectionClosed: function(reason)
548 this._isConnected = false;
549 this._runPendingCallbacks();
550 this.dispatchEventToListeners(InspectorBackendClass.Connection.Events.Disconnected, {reason: reason});
553 _runPendingCallbacks: function()
555 var keys = Object.keys(this._callbacks).map(function(num) {return parseInt(num, 10)});
556 for (var i = 0; i < keys.length; ++i) {
557 var callback = this._callbacks[keys[i]];
558 this._dispatchConnectionErrorResponse(callback.domain, callback.methodName, callback)
560 this._callbacks = {};
564 * @param {string} domain
565 * @param {string} methodName
566 * @param {!function(*)} callback
568 _dispatchConnectionErrorResponse: function(domain, methodName, callback)
570 var error = { message: "Connection is closed", code: InspectorBackendClass._DevToolsErrorCode, data: null};
571 var messageObject = {error: error};
572 setTimeout(InspectorBackendClass.AgentPrototype.prototype.dispatchResponse.bind(this.agent(domain), messageObject, methodName, callback), 0);
580 return !this._isConnected;
584 * @param {!Array.<string>} domains
586 suppressErrorsForDomains: function(domains)
588 domains.forEach(function(domain) { this._agents[domain].suppressErrorLogging(); }, this);
591 __proto__: WebInspector.Object.prototype
597 * @extends {InspectorBackendClass.Connection}
599 InspectorBackendClass.MainConnection = function()
601 InspectorBackendClass.Connection.call(this);
602 InspectorFrontendHost.events.addEventListener(InspectorFrontendHostAPI.Events.DispatchMessage, this._dispatchMessage, this);
605 InspectorBackendClass.MainConnection.prototype = {
608 * @param {!Object} messageObject
610 sendMessage: function(messageObject)
612 var message = JSON.stringify(messageObject);
613 InspectorFrontendHost.sendMessageToBackend(message);
617 * @param {!WebInspector.Event} event
619 _dispatchMessage: function(event)
621 this.dispatch(/** @type {!Object|string} */ (event.data));
624 __proto__: InspectorBackendClass.Connection.prototype
629 * @extends {InspectorBackendClass.Connection}
630 * @param {string} url
631 * @param {!function(!InspectorBackendClass.Connection)} onConnectionReady
633 InspectorBackendClass.WebSocketConnection = function(url, onConnectionReady)
635 InspectorBackendClass.Connection.call(this);
636 this._socket = new WebSocket(url);
637 this._socket.onmessage = this._onMessage.bind(this);
638 this._socket.onerror = this._onError.bind(this);
639 this._socket.onopen = onConnectionReady.bind(null, this);
640 this._socket.onclose = this.connectionClosed.bind(this, "websocket_closed");
644 * @param {string} url
645 * @param {!function(!InspectorBackendClass.Connection)} onConnectionReady
647 InspectorBackendClass.WebSocketConnection.Create = function(url, onConnectionReady)
649 new InspectorBackendClass.WebSocketConnection(url, onConnectionReady);
652 InspectorBackendClass.WebSocketConnection.prototype = {
655 * @param {!MessageEvent} message
657 _onMessage: function(message)
659 var data = /** @type {string} */ (message.data)
664 * @param {!Event} error
666 _onError: function(error)
668 console.error(error);
672 * @param {!Object} messageObject
674 sendMessage: function(messageObject)
676 var message = JSON.stringify(messageObject);
677 this._socket.send(message);
680 __proto__: InspectorBackendClass.Connection.prototype
686 * @extends {InspectorBackendClass.Connection}
688 InspectorBackendClass.StubConnection = function()
690 InspectorBackendClass.Connection.call(this);
693 InspectorBackendClass.StubConnection.prototype = {
696 * @param {!Object} messageObject
698 sendMessage: function(messageObject)
700 var message = JSON.stringify(messageObject);
701 setTimeout(this._echoResponse.bind(this, messageObject), 0);
705 * @param {!Object} messageObject
707 _echoResponse: function(messageObject)
709 this.dispatch(messageObject)
712 __proto__: InspectorBackendClass.Connection.prototype
717 * @param {string} domain
719 InspectorBackendClass.AgentPrototype = function(domain)
721 this._replyArgs = {};
722 this._hasErrorData = {};
723 this._domain = domain;
724 this._suppressErrorLogging = false;
727 InspectorBackendClass.AgentPrototype.prototype = {
730 * @param {!InspectorBackendClass.Connection} connection
732 setConnection: function(connection)
734 this._connection = connection;
738 * @param {string} methodName
739 * @param {!Array.<!Object>} signature
740 * @param {!Array.<string>} replyArgs
741 * @param {boolean} hasErrorData
743 registerCommand: function(methodName, signature, replyArgs, hasErrorData)
745 var domainAndMethod = this._domain + "." + methodName;
748 * @this {InspectorBackendClass.AgentPrototype}
750 function sendMessage(vararg)
752 var params = [domainAndMethod, signature].concat(Array.prototype.slice.call(arguments));
753 InspectorBackendClass.AgentPrototype.prototype._sendMessageToBackend.apply(this, params);
756 this[methodName] = sendMessage;
759 * @this {InspectorBackendClass.AgentPrototype}
761 function invoke(vararg)
763 var params = [domainAndMethod].concat(Array.prototype.slice.call(arguments));
764 InspectorBackendClass.AgentPrototype.prototype._invoke.apply(this, params);
767 this["invoke_" + methodName] = invoke;
769 this._replyArgs[domainAndMethod] = replyArgs;
771 this._hasErrorData[domainAndMethod] = true;
776 * @param {string} method
777 * @param {!Array.<!Object>} signature
781 _sendMessageToBackend: function(method, signature, vararg)
783 var args = Array.prototype.slice.call(arguments, 2);
784 var callback = (args.length && typeof args[args.length - 1] === "function") ? args.pop() : null;
787 var hasParams = false;
788 for (var i = 0; i < signature.length; ++i) {
789 var param = signature[i];
790 var paramName = param["name"];
791 var typeName = param["type"];
792 var optionalFlag = param["optional"];
794 if (!args.length && !optionalFlag) {
795 console.error("Protocol Error: Invalid number of arguments for method '" + method + "' call. It must have the following arguments '" + JSON.stringify(signature) + "'.");
799 var value = args.shift();
800 if (optionalFlag && typeof value === "undefined") {
804 if (typeof value !== typeName) {
805 console.error("Protocol Error: Invalid type of argument '" + paramName + "' for method '" + method + "' call. It must be '" + typeName + "' but it is '" + typeof value + "'.");
809 params[paramName] = value;
813 if (args.length === 1 && !callback && (typeof args[0] !== "undefined")) {
814 console.error("Protocol Error: Optional callback argument for method '" + method + "' call must be a function but its type is '" + typeof args[0] + "'.");
818 this._connection._wrapCallbackAndSendMessageObject(this._domain, method, hasParams ? params : null, callback);
822 * @param {string} method
823 * @param {?Object} args
824 * @param {?function(*)} callback
826 _invoke: function(method, args, callback)
828 this._connection._wrapCallbackAndSendMessageObject(this._domain, method, args, callback);
832 * @param {!Object} messageObject
833 * @param {string} methodName
834 * @param {function(!Array.<*>)} callback
836 dispatchResponse: function(messageObject, methodName, callback)
838 if (messageObject.error && messageObject.error.code !== InspectorBackendClass._DevToolsErrorCode && !InspectorBackendClass.Options.suppressRequestErrors && !this._suppressErrorLogging)
839 console.error("Request with id = " + messageObject.id + " failed. " + JSON.stringify(messageObject.error));
841 var argumentsArray = [];
842 argumentsArray[0] = messageObject.error ? messageObject.error.message: null;
844 if (this._hasErrorData[methodName])
845 argumentsArray[1] = messageObject.error ? messageObject.error.data : null;
847 if (messageObject.result) {
848 var paramNames = this._replyArgs[methodName] || [];
849 for (var i = 0; i < paramNames.length; ++i)
850 argumentsArray.push(messageObject.result[paramNames[i]]);
853 callback.apply(null, argumentsArray);
856 suppressErrorLogging: function()
858 this._suppressErrorLogging = true;
865 InspectorBackendClass.DispatcherPrototype = function()
867 this._eventArgs = {};
868 this._dispatcher = null;
871 InspectorBackendClass.DispatcherPrototype.prototype = {
874 * @param {string} eventName
875 * @param {!Object} params
877 registerEvent: function(eventName, params)
879 this._eventArgs[eventName] = params
883 * @param {!Object} dispatcher
885 setDomainDispatcher: function(dispatcher)
887 this._dispatcher = dispatcher;
891 * @param {string} functionName
892 * @param {!Object} messageObject
894 dispatch: function(functionName, messageObject)
896 if (!this._dispatcher)
899 if (!(functionName in this._dispatcher)) {
900 console.error("Protocol Error: Attempted to dispatch an unimplemented method '" + messageObject.method + "'");
904 if (!this._eventArgs[messageObject.method]) {
905 console.error("Protocol Error: Attempted to dispatch an unspecified method '" + messageObject.method + "'");
910 if (messageObject.params) {
911 var paramNames = this._eventArgs[messageObject.method];
912 for (var i = 0; i < paramNames.length; ++i)
913 params.push(messageObject.params[paramNames[i]]);
916 var processingStartTime;
917 if (InspectorBackendClass.Options.dumpInspectorTimeStats)
918 processingStartTime = Date.now();
920 this._dispatcher[functionName].apply(this._dispatcher, params);
922 if (InspectorBackendClass.Options.dumpInspectorTimeStats)
923 console.log("time-stats: " + messageObject.method + " = " + (Date.now() - processingStartTime));
928 InspectorBackendClass.Options = {
929 dumpInspectorTimeStats: false,
930 dumpInspectorProtocolMessages: false,
931 suppressRequestErrors: false
934 InspectorBackend = new InspectorBackendClass();