mirror of
https://github.com/appium/appium.git
synced 2026-05-03 08:51:18 -05:00
remove unused remote debugger files
This commit is contained in:
Jonathan Lipps
@@ -1,39 +0,0 @@
|
||||
"use strict";
|
||||
|
||||
var _ = require("underscore");
|
||||
|
||||
exports.sendJSCommand = function(js) {
|
||||
return exports.command("Runtime.evaluate",
|
||||
{expression: js, returnByValue: true});
|
||||
};
|
||||
|
||||
exports.callJSFunction = function(objId, fn, args) {
|
||||
return exports.command("Runtime.callFunctionOn",
|
||||
{objectId: objId, functionDeclaration: fn, arguments: args, returnByValue: true});
|
||||
};
|
||||
|
||||
exports.setUrl = function(url) {
|
||||
return exports.command("Page.navigate", {url: url});
|
||||
};
|
||||
|
||||
exports.enablePage = function() {
|
||||
return exports.command("Page.enable", {});
|
||||
};
|
||||
|
||||
|
||||
//generate a json request using the webkit protocol
|
||||
exports.command = function(method, params) {
|
||||
var jsonRequest = {
|
||||
method: method,
|
||||
params: {
|
||||
objectGroup: "console",
|
||||
includeCommandLineAPI: true,
|
||||
doNotPauseOnExceptionsAndMuteConsole: true
|
||||
}
|
||||
};
|
||||
if (params) {
|
||||
//if there any parameters add them
|
||||
jsonRequest.params = _.extend(jsonRequest.params, params);
|
||||
}
|
||||
return jsonRequest;
|
||||
};
|
||||
@@ -1,214 +0,0 @@
|
||||
"use strict";
|
||||
/* DEPENDENCIES */
|
||||
|
||||
var net = require('net')
|
||||
, appLogger = require('../../logger.js').get('appium')
|
||||
, _ = require('underscore')
|
||||
, messages = require('./rdp-messages.js')
|
||||
, atoms = require('./ios/webdriver-atoms')
|
||||
, status = require("../uiauto/lib/status")
|
||||
, uuid = require('node-uuid')
|
||||
, colors = require('colors')
|
||||
, noop = function () {}
|
||||
, assert = require('assert')
|
||||
, util = require('util')
|
||||
, RemoteDebugger = require('./ios/remote-debugger.js').RemoteDebugger
|
||||
, http = require('http')
|
||||
, WebSocket = require('ws');
|
||||
|
||||
var logger = {
|
||||
info: function(msg) {
|
||||
appLogger.info("[REMOTE] " + msg);
|
||||
}
|
||||
, debug: function(msg) {
|
||||
appLogger.debug(("[REMOTE] " + msg).grey);
|
||||
}
|
||||
, error: function(msg) {
|
||||
appLogger.error("[REMOTE] " + msg);
|
||||
}
|
||||
};
|
||||
|
||||
// ====================================
|
||||
// CONFIG
|
||||
// ====================================
|
||||
|
||||
var WebKitRemoteDebugger = function(onDisconnect) {
|
||||
this.host = 'localhost';
|
||||
this.port = 9222;
|
||||
this.init(onDisconnect);
|
||||
this.dataMethods = {};
|
||||
};
|
||||
|
||||
//extend the remote debugger
|
||||
_.extend(WebKitRemoteDebugger.prototype, RemoteDebugger.prototype);
|
||||
|
||||
// ====================================
|
||||
// API
|
||||
// ====================================
|
||||
|
||||
WebKitRemoteDebugger.prototype.connect = function(pageId, cb, pageChangeCb) {
|
||||
var me = this;
|
||||
this.pageChangeCb = pageChangeCb;
|
||||
var url = 'ws://' + this.host + ':' + this.port + '/devtools/page/' + pageId;
|
||||
this.pageIdKey = pageId;
|
||||
this.socket = new WebSocket(url);
|
||||
this.socket.on('open', function() {
|
||||
logger.info('Debugger web socket connected to url [' + url + ']');
|
||||
cb();
|
||||
});
|
||||
this.socket.on('close', function() {
|
||||
logger.info('Debugger web socket disconnected');
|
||||
me.socket.close();
|
||||
});
|
||||
this.socket.on('error', function(exception) {
|
||||
console.log('Debugger web socket error %s', exception);
|
||||
});
|
||||
this.socket.on('message', function(data) {
|
||||
console.log('Debugger web socket received data : %s', data);
|
||||
me.receive(data);
|
||||
});
|
||||
};
|
||||
|
||||
WebKitRemoteDebugger.prototype.disconnect = function() {
|
||||
logger.info("Disconnecting from remote debugger");
|
||||
this.socket.close();
|
||||
};
|
||||
|
||||
WebKitRemoteDebugger.prototype.pageArrayFromJson = function(cb){
|
||||
this.getJSONFromUrl(this.host, this.port, '/json',function(returnValue){
|
||||
var pageElementJSON = returnValue;
|
||||
var newPageArray = [];
|
||||
//Add elements to the array
|
||||
_.each(pageElementJSON, function(pageObject) {
|
||||
var urlArray = pageObject.webSocketDebuggerUrl.split('/').reverse();
|
||||
var id = urlArray[0];
|
||||
newPageArray.push({
|
||||
id: id
|
||||
, title: pageObject.title
|
||||
, url: pageObject.url
|
||||
, isKey: id
|
||||
});
|
||||
});
|
||||
cb(newPageArray);
|
||||
});
|
||||
};
|
||||
|
||||
//TODO: move to utility class
|
||||
WebKitRemoteDebugger.prototype.getJSONFromUrl = function(host, port, path, callback){
|
||||
http.get({ host: host, port: port, path: path }, function(response) {
|
||||
var jsonResponse = "";
|
||||
response.on('data', function(chunk) {
|
||||
jsonResponse += chunk;
|
||||
});
|
||||
response.on('end', function() {
|
||||
callback(JSON.parse(jsonResponse));
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
WebKitRemoteDebugger.prototype.execute = function(command, cb) {
|
||||
var me = this;
|
||||
if (this.pageLoading) {
|
||||
logger.info("Trying to execute but page is not loaded. Waiting for dom");
|
||||
this.waitForDom(function() {
|
||||
me.execute(command, cb);
|
||||
});
|
||||
} else {
|
||||
//assert.ok(this.connId); assert.ok(this.appIdKey); assert.ok(this.senderId);
|
||||
//assert.ok(this.pageIdKey);
|
||||
var sendJSCommand = messages.sendJSCommand(command, this.appIdKey,
|
||||
this.connId, this.senderId, this.pageIdKey);
|
||||
this.send(sendJSCommand, cb);
|
||||
}
|
||||
};
|
||||
|
||||
WebKitRemoteDebugger.prototype.navToUrl = function(url, cb) {
|
||||
//assert.ok(this.connId); assert.ok(this.appIdKey); assert.ok(this.senderId);
|
||||
//assert.ok(this.pageIdKey);
|
||||
logger.info("Navigating to new URL: " + url);
|
||||
var me = this;
|
||||
var navToUrl = messages.setUrl(url, this.appIdKey, this.connId,
|
||||
this.senderId, this.pageIdKey);
|
||||
this.send(navToUrl, noop);
|
||||
//TODO: There seems to be an issue which is slowing the navigation down.
|
||||
this.waitForFrameNavigated(function() {
|
||||
me.checkPageIsReady(function(err, isReady) {
|
||||
if (isReady) return cb();
|
||||
me.waitForDom(cb);
|
||||
});
|
||||
});
|
||||
};
|
||||
|
||||
// ====================================
|
||||
// HANDLERS
|
||||
// ====================================
|
||||
|
||||
WebKitRemoteDebugger.prototype.handleMessage = function(data, method) {
|
||||
var handlerFor = null;
|
||||
if (method !== null) {
|
||||
handlerFor = method;
|
||||
} else {
|
||||
handlerFor = data.method;
|
||||
}
|
||||
if (!handlerFor) {
|
||||
logger.debug("Got an invalid method");
|
||||
return;
|
||||
}
|
||||
if (_.has(this.handlers, handlerFor)) {
|
||||
this.handlers[handlerFor](data);
|
||||
} else {
|
||||
logger.info("Debugger got a message for '" + handlerFor + "' and have no " +
|
||||
"handler, doing nothing.");
|
||||
}
|
||||
};
|
||||
|
||||
WebKitRemoteDebugger.prototype.setHandlers = function() {
|
||||
var me = this;
|
||||
this.handlers = {
|
||||
'Runtime.evaluate': function (data) {
|
||||
var msgId = data.id
|
||||
, result = data.result
|
||||
, error = data.error || null;
|
||||
me.dataCbs[msgId](error, result);
|
||||
me.dataCbs[msgId] = null;
|
||||
} ,
|
||||
'Profiler.resetProfiles' : function(data) {
|
||||
logger.info("Device is telling us to reset profiles. Should probably " +
|
||||
"do some kind of callback here");
|
||||
//me.onPageChange();
|
||||
}
|
||||
};
|
||||
};
|
||||
|
||||
// ====================================
|
||||
// SOCKET I/O
|
||||
// ====================================
|
||||
|
||||
WebKitRemoteDebugger.prototype.send = function (data, cb) {
|
||||
var me = this;
|
||||
//increase the current id
|
||||
this.curMsgId += 1;
|
||||
//set the id in the message
|
||||
data.id = this.curMsgId;
|
||||
//store the call back and the data sent
|
||||
this.dataCbs[this.curMsgId.toString()] = cb;
|
||||
this.dataMethods[this.curMsgId.toString()] = data.method;
|
||||
//send the data
|
||||
logger.info('Remote debugger data sent [' + JSON.stringify(data).slice(0, 3000) + ']');
|
||||
data = JSON.stringify(data);
|
||||
this.socket.send(data);
|
||||
};
|
||||
|
||||
WebKitRemoteDebugger.prototype.receive = function(data){
|
||||
var method = null;
|
||||
data = JSON.parse(data);
|
||||
//check if there was an id
|
||||
if(data.id) {
|
||||
method = this.dataMethods[data.id];
|
||||
}
|
||||
this.handleMessage(data, method);
|
||||
};
|
||||
|
||||
exports.init = function(onDisconnect) {
|
||||
return new WebKitRemoteDebugger(onDisconnect);
|
||||
};
|
||||
Reference in New Issue
Block a user