How to use adb.fingerprint method in Appium Android Driver

1var Promise = require('bluebird')2var logger = require('../../util/logger')3var wire = require('../../wire')4var wirerouter = require('../../wire/router')5var wireutil = require('../../wire/util')6var dbapi = require('../../db/api')7var lifecycle = require('../../util/lifecycle')8var srv = require('../../util/srv')9var zmqutil = require('../../util/zmqutil')10module.exports = function(options) {11  var log = logger.createLogger('processor')12  if (options.name) {13    logger.setGlobalIdentifier(options.name)14  }15  // App side16  var appDealer = zmqutil.socket('dealer')17  Promise.map(options.endpoints.appDealer, function(endpoint) {18    return srv.resolve(endpoint).then(function(records) {19      return srv.attempt(records, function(record) {20        log.info('App dealer connected to "%s"', record.url)21        appDealer.connect(record.url)22        return Promise.resolve(true)23      })24    })25  })26  .catch(function(err) {27    log.fatal('Unable to connect to app dealer endpoint', err)28    lifecycle.fatal()29  })30  appDealer.on('message', function(channel, data) {31    devDealer.send([channel, data])32  })33  // Device side34  var devDealer = zmqutil.socket('dealer')35  Promise.map(options.endpoints.devDealer, function(endpoint) {36    return srv.resolve(endpoint).then(function(records) {37      return srv.attempt(records, function(record) {38        log.info('Device dealer connected to "%s"', record.url)39        devDealer.connect(record.url)40        return Promise.resolve(true)41      })42    })43  })44  .catch(function(err) {45    log.fatal('Unable to connect to dev dealer endpoint', err)46    lifecycle.fatal()47  })48  devDealer.on('message', wirerouter()49    // Initial device message50    .on(wire.DeviceIntroductionMessage, function(channel, message, data) {51      dbapi.saveDeviceInitialState(message.serial, message)52        .then(function() {53          devDealer.send([54            message.provider.channel55          , wireutil.envelope(new wire.DeviceRegisteredMessage(56              message.serial57            ))58          ])59          appDealer.send([channel, data])60        })61    })62    // Workerless messages63    .on(wire.DevicePresentMessage, function(channel, message, data) {64      dbapi.setDevicePresent(message.serial)65      appDealer.send([channel, data])66    })67    .on(wire.DeviceAbsentMessage, function(channel, message, data) {68      dbapi.setDeviceAbsent(message.serial)69      appDealer.send([channel, data])70    })71    .on(wire.DeviceStatusMessage, function(channel, message, data) {72      dbapi.saveDeviceStatus(message.serial, message.status)73      appDealer.send([channel, data])74    })75    .on(wire.DeviceHeartbeatMessage, function(channel, message, data) {76      appDealer.send([channel, data])77    })78    // Worker initialized79    .on(wire.DeviceReadyMessage, function(channel, message, data) {80      dbapi.setDeviceReady(message.serial, message.channel)81        .then(function() {82          devDealer.send([83            message.channel84          , wireutil.envelope(new wire.ProbeMessage())85          ])86          appDealer.send([channel, data])87        })88    })89    // Worker messages90    .on(wire.JoinGroupByAdbFingerprintMessage, function(channel, message) {91      dbapi.lookupUserByAdbFingerprint(message.fingerprint)92        .then(function(user) {93          if (user) {94            devDealer.send([95              channel96            , wireutil.envelope(new wire.AutoGroupMessage(97                new wire.OwnerMessage(98                  user.email99                , user.name100                , user.group101                )102              , message.fingerprint103              ))104            ])105          }106          else if (message.currentGroup) {107            appDealer.send([108              message.currentGroup109            , wireutil.envelope(new wire.JoinGroupByAdbFingerprintMessage(110                message.serial111              , message.fingerprint112              , message.comment113              ))114            ])115          }116        })117        .catch(function(err) {118          log.error(119            'Unable to lookup user by ADB fingerprint "%s"'120          , message.fingerprint121          , err.stack122          )123        })124    })125    .on(wire.JoinGroupByVncAuthResponseMessage, function(channel, message) {126      dbapi.lookupUserByVncAuthResponse(message.response, message.serial)127        .then(function(user) {128          if (user) {129            devDealer.send([130              channel131            , wireutil.envelope(new wire.AutoGroupMessage(132                new wire.OwnerMessage(133                  user.email134                , user.name135                , user.group136                )137              , message.response138              ))139            ])140          }141          else if (message.currentGroup) {142            appDealer.send([143              message.currentGroup144            , wireutil.envelope(new wire.JoinGroupByVncAuthResponseMessage(145                message.serial146              , message.response147              ))148            ])149          }150        })151        .catch(function(err) {152          log.error(153            'Unable to lookup user by VNC auth response "%s"'154          , message.response155          , err.stack156          )157        })158    })159    .on(wire.JoinGroupMessage, function(channel, message, data) {160      dbapi.setDeviceOwner(message.serial, message.owner)161      appDealer.send([channel, data])162    })163    .on(wire.LeaveGroupMessage, function(channel, message, data) {164      dbapi.unsetDeviceOwner(message.serial, message.owner)165      appDealer.send([channel, data])166    })167    .on(wire.DeviceLogMessage, function(channel, message, data) {168      appDealer.send([channel, data])169    })170    .on(wire.DeviceIdentityMessage, function(channel, message, data) {171      dbapi.saveDeviceIdentity(message.serial, message)172      appDealer.send([channel, data])173    })174    .on(wire.TransactionProgressMessage, function(channel, message, data) {175      appDealer.send([channel, data])176    })177    .on(wire.TransactionDoneMessage, function(channel, message, data) {178      appDealer.send([channel, data])179    })180    .on(wire.DeviceLogcatEntryMessage, function(channel, message, data) {181      appDealer.send([channel, data])182    })183    .on(wire.AirplaneModeEvent, function(channel, message, data) {184      dbapi.setDeviceAirplaneMode(message.serial, message.enabled)185      appDealer.send([channel, data])186    })187    .on(wire.BatteryEvent, function(channel, message, data) {188      dbapi.setDeviceBattery(message.serial, message)189      appDealer.send([channel, data])190    })191    .on(wire.DeviceBrowserMessage, function(channel, message, data) {192      dbapi.setDeviceBrowser(message.serial, message)193      appDealer.send([channel, data])194    })195    .on(wire.ConnectivityEvent, function(channel, message, data) {196      dbapi.setDeviceConnectivity(message.serial, message)197      appDealer.send([channel, data])198    })199    .on(wire.PhoneStateEvent, function(channel, message, data) {200      dbapi.setDevicePhoneState(message.serial, message)201      appDealer.send([channel, data])202    })203    .on(wire.RotationEvent, function(channel, message, data) {204      dbapi.setDeviceRotation(message.serial, message.rotation)205      appDealer.send([channel, data])206    })207    .on(wire.ReverseForwardsEvent, function(channel, message, data) {208      dbapi.setDeviceReverseForwards(message.serial, message.forwards)209      appDealer.send([channel, data])210    })211    .handler())212  lifecycle.observe(function() {213    [appDealer, devDealer].forEach(function(sock) {214      try {215        sock.close()216      }217      catch (err) {218        // No-op219      }220    })221  })...

1var util = require('util')2var syrup = require('stf-syrup')3var Promise = require('bluebird')4var logger = require('../../../util/logger')5var grouputil = require('../../../util/grouputil')6var wire = require('../../../wire')7var wireutil = require('../../../wire/util')8var lifecycle = require('../../../util/lifecycle')9var dbapi = require('../../../db/api')10module.exports = syrup.serial()11  .dependency(require('../support/adb'))12  .dependency(require('../support/router'))13  .dependency(require('../support/push'))14  .dependency(require('./group'))15  .dependency(require('./solo'))16  .dependency(require('./util/urlformat'))17  .dependency(require('./rentcontrol'))18  .define(function (options, adb, router, push, group, solo, urlformat, rentcontrol) {19    var log = logger.createLogger('device:plugins:connect')20    var plugin = Object.create(null)21    var activeServer = null22    plugin.port = options.connectPort23    plugin.url = urlformat(options.connectUrlPattern, plugin.port)24    plugin.start = function () {25      console.log("start device")26      return new Promise(function (resolve, reject) {27        if (plugin.isRunning()) {28          return resolve(plugin.url)29        }30        console.log("start device:" + plugin.url)31        var server = adb.createTcpUsbBridge(options.serial, {32          auth: function (key) {33            var resolver = Promise.defer()34            function notify() {35              dbapi.dumpsUsersAdbKey(key.fingerprint).then(function () {36                group.get()37                  .then(function (currentGroup) {38                    console.log("notify:" + currentGroup)39                    dbapi.dumpsUsersAdbKey(key.fingerprint).then(function () {40                      push.send([41                        solo.channel42                        , wireutil.envelope(new wire.JoinGroupByAdbFingerprintMessage(43                          options.serial44                          , key.fingerprint45                          , key.comment46                          , currentGroup.group47                        ))48                      ])49                    })50                  })51                  .catch(grouputil.NoGroupError, function () {52                    push.send([53                      solo.channel54                      , wireutil.envelope(new wire.JoinGroupByAdbFingerprintMessage(55                        options.serial56                        , key.fingerprint57                        , key.comment58                      ))59                    ])60                  })61              })62            }63            function notify1() {64              group.get()65                .then(function (currentGroup) {66                  console.log("notify1:" + currentGroup)67                  push.send([68                    solo.channel69                    , wireutil.envelope(new wire.JoinGroupByAdbFingerprintMessage(70                      options.serial71                      , key.fingerprint72                      , key.comment73                      , currentGroup.group74                    ))75                  ])76                })77                .catch(grouputil.NoGroupError, function () {78                  push.send([79                    solo.channel80                    , wireutil.envelope(new wire.JoinGroupByAdbFingerprintMessage(81                      options.serial82                      , key.fingerprint83                      , key.comment84                    ))85                  ])86                })87            }88            function joinListener(group, identifier) {89              if (identifier !== key.fingerprint) {90                resolver.reject(new Error('Somebody else took the device'))91              }92            }93            function autojoinListener(identifier, joined) {94              if (identifier === key.fingerprint) {95                if (joined) {96                  resolver.resolve()97                }98                else {99                  resolver.reject(new Error('Device is already in use'))100                }101              }102            }103            group.on('join', joinListener)104            group.on('autojoin', autojoinListener)105            router.on(wire.AdbKeysUpdatedMessage, notify1)106            notify()107            return resolver.promise108              .timeout(120000)109              .finally(function () {110                group.removeListener('join', joinListener)111                group.removeListener('autojoin', autojoinListener)112                router.removeListener(wire.AdbKeysUpdatedMessage, notify)113              })114          }115        })116        server.on('listening', function () {117          resolve(plugin.url)118        })119        server.on('connection', function (conn) {120          log.info('New remote ADB connection from %s', conn.remoteAddress)121          conn.on('userActivity', function () {122            group.keepalive()123            rentcontrol.keepalive()124          })125        })126        server.on('error', reject)127        log.info(util.format('Listening on port %d', plugin.port))128        server.listen(plugin.port)129        activeServer = server130        lifecycle.share('Remote ADB', activeServer)131      })132    }133    plugin.stop = Promise.method(function () {134      if (plugin.isRunning()) {135        activeServer.close()136        activeServer.end()137      }138    })139    plugin.end = Promise.method(function () {140      if (plugin.isRunning()) {141        activeServer.end()142      }143    })144    plugin.isRunning = function () {145      return !!activeServer146    }147    lifecycle.observe(plugin.stop)148    group.on('leave', plugin.end)149    router150      .on(wire.ConnectStartMessage, function (channel) {151        var reply = wireutil.reply(options.serial)152        plugin.start()153          .then(function (url) {154            push.send([155              channel156              , reply.okay(url)157            ])158            // Update DB159            push.send([160              channel161              , wireutil.envelope(new wire.ConnectStartedMessage(162                options.serial163                , url164              ))165            ])166            log.important('Remote Connect Started for device "%s" at "%s"', options.serial, url)167          })168          .catch(function (err) {169            log.error('Unable to start remote connect service', err.stack)170            push.send([171              channel172              , reply.fail(err.message)173            ])174          })175      })176      .on(wire.ConnectStopMessage, function (channel) {177        var reply = wireutil.reply(options.serial)178        plugin.end()179          .then(function () {180            push.send([181              channel182              , reply.okay()183            ])184            // Update DB185            push.send([186              channel187              , wireutil.envelope(new wire.ConnectStoppedMessage(188                options.serial189              ))190            ])191            log.important('Remote Connect Stopped for device "%s"', options.serial)192          })193          .catch(function (err) {194            log.error('Failed to stop connect service', err.stack)195            push.send([196              channel197              , reply.fail(err.message)198            ])199          })200      })201    return plugin.start()202      .return(plugin)...