yetangitu/OpenSTF
1
0
Fork 0
mirror of https://github.com/openstf/stf synced 2025-10-05 19:42:01 +02:00
Code Issues Releases Wiki Activity

Promisify provider adb client.

Browse source
This commit is contained in:
Simo Kinnunen 2014-01-15 14:23:03 +09:00
parent 87e7815183
commit 970befa0d0
1 changed files with 26 additions and 30 deletions
Download patch file Download diff file Expand all files Collapse all files

56
lib/roles/provider.js
View file

@ -3,42 +3,38 @@ var Promise = require('bluebird')
module.exports = function(options) {
var log = require('../util/logger').createLogger('provider')
var client = adb.createClient()
var client = Promise.promisifyAll(adb.createClient())
var workers = Object.create(null)
client.trackDevices(function(err, tracker) {
if (err) {
log.fatal('Unable to track devices: %s', err.message)
throw err
}
client.trackDevicesAsync()
.then(function(tracker) {
log.info('Tracking devices')
log.info('Tracking devices')
tracker.on('add', function(device) {
if (isWantedDevice(device)) {
log.info('Found device "%s" (%s)', device.id, device.type)
maybeConnect(device)
}
else {
log.info('Ignoring device "%s" (%s)', device.id, device.type)
}
})
tracker.on('add', function(device) {
if (isWantedDevice(device)) {
log.info('Found device "%s" (%s)', device.id, device.type)
maybeConnect(device)
}
else {
log.info('Ignoring device "%s" (%s)', device.id, device.type)
}
tracker.on('change', function(device) {
if (isWantedDevice(device)) {
log.info('Device "%s" is now "%s"', device.id, device.type)
maybeConnect(device) || maybeDisconnect(device)
}
})
tracker.on('remove', function(device) {
if (isWantedDevice(device)) {
log.info('Lost device "%s" (%s)', device.id, device.type)
maybeDisconnect(device)
}
})
})
tracker.on('change', function(device) {
if (isWantedDevice(device)) {
log.info('Device "%s" is now "%s"', device.id, device.type)
maybeConnect(device) || maybeDisconnect(device)
}
})
tracker.on('remove', function(device) {
if (isWantedDevice(device)) {
log.info('Lost device "%s" (%s)', device.id, device.type)
maybeDisconnect(device)
}
})
})
function isWantedDevice(device) {
return options.filter ? options.filter(device) : true
}