How to use waitForUnlock method in Appium Android Driver

...249    if (error) {250      callback(error);251    } else if (isLocked) {252      setTimeout(function() {253        exports.waitForUnlock(callback, lockData, ++attempts);254      }, 500);255    } else {256      callback();257    }258  });259};260exports.checkCache = function(file, boards, callback) {261  var lockData = exports.getLockData(file, boards);262  if (!lockData) {263    callback(null, true);264    return;265  }266  cacheHandler.getLock(lockData, false, function gotLock(error, isLocked) {267    if (error) {268      callback(error);269    } else if (!isLocked) {270      if (feDebug) {271        templateHandler.dropAlternativeTemplates();272        templateHandler.loadTemplates();273      }274      // style exception, too simple275      exports.generateCache(lockData, function generatedCache(error, notFound) {276        exports.finishedCacheGeneration(lockData, error, notFound, callback);277      });278      // style exception, too simple279    } else {280      exports.waitForUnlock(callback, lockData);281    }282  });...

1import * as path from 'path';2import * as _ from 'lodash';3import * as nodeUuid from 'uuid';4import * as chalk from 'chalk';5import Collection from './core/collection';6import Tyr from './tyr';7const clr = chalk.hex('#cc5500'),8  clrMig = chalk.hex('#cc0055'),9  clrDesc = chalk.hex('#000000'),10  clrRed = chalk.keyword('red'),11  clrGreen = chalk.keyword('green'),12  clrYellow = chalk.hex('#aaaa00');13const MigrationStatus = new Collection({14  id: '_m1',15  name: 'tyrMigrationStatus',16  internal: true,17  client: false,18  fields: {19    _id: { is: 'string' },20    appliedOn: { is: 'date' },21    uuid: { is: 'string' },22  },23});24const doRemoveLock = async remove => {25  if (remove) {26    await MigrationStatus.db.deleteOne({ _id: '$$MIGRATION-LOCK' });27    log({ note: 'End Migration', end: true });28  }29};30const waitForUnLock = async () => {31  const lock = await MigrationStatus.findOne({32    query: { _id: '$$MIGRATION-LOCK' },33  });34  if (!lock) {35    Tyr.options.migration.waitingOnMigration = false;36  } else {37    Tyr.options.migration.waitingOnMigration = true;38    log({ note: 'Waiting for migration to finish...' });39    setTimeout(waitForUnLock, 5000);40  }41};42let allStartMs, startMs;43function log(opts) {44  let { migration, action, note, desc, error } = opts;45  if (desc) {46    let text = clr('*** ');47    text += clrMig.bold('^');48    text += clrDesc(' ' + desc);49    text += clrDesc(' '.padEnd(94 - desc.length));50    text += clr(' ***');51    console.log(text);52  } else if (migration) {53    let text = clr('*** ');54    text += clrMig.bold(`${migration}`);55    text += clr(' '.padEnd(30 - migration.length, '*'));56    text += ' ';57    let actionLabel,58      ms = '';59    switch (action) {60      case 'start':61        actionLabel = 'STARTING';62        text += clrGreen(actionLabel);63        startMs = Date.now();64        break;65      case 'complete':66        actionLabel = 'COMPLETE';67        text += clrGreen.bold(actionLabel);68        ms = ` (${Date.now() - startMs}ms)`;69        break;70      case 'skip':71        actionLabel = 'SKIPPING';72        text += clrYellow.bold(actionLabel);73        break;74      case 'error':75        actionLabel = 'ERROR';76        text += clrRed.bold(actionLabel);77        break;78      default:79        actionLabel = '';80    }81    note = note ? ' -- ' + note : '';82    text += clr(note);83    if (ms) {84      text += clr.bold(ms);85    }86    text += ''.padEnd(65 - actionLabel.length - note.length - ms.length);87    text += clr(' ***');88    console.log(text);89    if (error) {90      console.error(error);91    }92  } else {93    if (opts.start) {94      //console.log(clr(''.padEnd(104, '*')));95      allStartMs = Date.now();96    } else if (opts.end) {97      note += ` (${Date.now() - allStartMs}ms)`;98    }99    const filler = 102 - note.length;100    const leadFiller = Math.floor(filler / 2);101    let text = clr(''.padEnd(leadFiller, '*'));102    text += ' ';103    text += clr.bold(note);104    text += ' ';105    text += clr(''.padEnd(filler - leadFiller, '*'));106    console.log(text);107    //if (opts.end) console.log(clr(''.padEnd(104, '*')));108  }109}110export async function migrate(migrationArray) {111  const migrations = migrationArray || Tyr.options.migration.list;112  let removeLock = false;113  const uuid = nodeUuid.v4();114  try {115    const setOnInsert = { uuid };116    Tyr.migrating = true;117    //console.log('Adding lock', setOnInsert);118    const lockObj = await MigrationStatus.findAndModify({119      query: { _id: '$$MIGRATION-LOCK' },120      update: {121        $setOnInsert: setOnInsert,122      },123      new: true,124      upsert: true,125    });126    //console.log('lockObj', JSON.stringify(lockObj, null, 2));127    if (_.get(lockObj, 'value.uuid') !== uuid) {128      waitForUnLock();129      return lockObj;130    }131    removeLock = true;132    log({ note: 'Beginning Migration', start: true });133    for (const migrationName of migrations) {134      const migration = require(path.join(135        Tyr.options.migration.dir,136        migrationName137      ));138      if (migration.skip) {139        log({140          migration: migrationName,141          action: 'skip',142          note: 'Marked as skip',143        });144        continue;145      }146      const m = await MigrationStatus.db.findOne({ _id: migrationName });147      if (!m) {148        await MigrationStatus.db.insertOne({149          _id: migrationName,150          appliedOn: new Date(),151        });152        log({ migration: migrationName, action: 'start' });153        if (migration.desc) {154          log({ migration: migrationName, desc: migration.desc });155        }156        try {157          await migration.migrate();158          if (migration.noCommit) {159            await MigrationStatus.db.deleteOne({ _id: migrationName });160            log({161              migration: migrationName,162              action: 'complete',163              note: 'Not committed',164            });165          } else {166            log({ migration: migrationName, action: 'complete' });167          }168        } catch (err) {169          console.log(err.stack);170          await MigrationStatus.db.deleteOne({ _id: migrationName });171          log({ migration: migrationName, action: 'error', error: err });172        }173      } else {174        log({175          migration: migrationName,176          action: 'skip',177          note: 'Already applied',178        });179      }180    }181  } catch (err) {182    console.log(err.stack);183  } finally {184    doRemoveLock(removeLock);185    Tyr.migrating = false;186  }187}...

...65        await eRelease();66    }67}68async function getBoardgameData(){69    await bgMutex.waitForUnlock();70    return boardgameData71}72async function getRegisteredUserData(){73    await ruMutex.waitForUnlock();74    return registeredUserData75}76async function getEventData(){77    await eMutex.waitForUnlock();78    return eventData79}80async function registerEvent(targetEvent, author){81    const release = await eMutex.acquire();82    try{83        // Check 2 - The target is a valid event //84        if (!eventData.some(e => e.name === targetEvent)) {85            return "No event was found with the name '" + targetEvent + "', please use '!schedule' to see a full list of events and try again."86        }87        var i = await eventData.findIndex(e => e.name === targetEvent);88        // Check 3 - The author is already signed up //89        if (await eventData[i].users.includes(author.username)) {90            return "Successfully signed up user '" + author.username + "' to the " + targetEvent + " event."91        }...

...48    return new Promise((resolve) => {49      if (this.isUnlocked()) {50        resolve()51      } else {52        this.waitForUnlock(resolve, shouldShowUnlockRequest)53      }54    })55  }56  /**57   * Adds a Promise's resolve function to the waitingForUnlock queue.58   * Also opens the extension popup if specified.59   *60   * @param {Promise.resolve} resolve - A Promise's resolve function that will61   * be called when the extension is unlocked.62   * @param {boolean} shouldShowUnlockRequest - Whether the extension notification63   * popup should be opened.64   */65  waitForUnlock (resolve, shouldShowUnlockRequest) {66    this.waitingForUnlock.push({ resolve })...

...63            }64            log(message) {65                if (this.debug) console.log(message);66            }67            waitForUnlock(callback) {68                this.log("WAIT FOR UNLOCK CALLED");69                if (this.locked < this.limit) {70                    this.log("PROCEEDING");71                    this.lock();72                    callback();73                } else {74                    this.log("WAITING");75                    this.queue.push(() => {76                        this.log("WAIT OVER, RETRYING");77                        this.waitForUnlock(callback);78                    });79                }80            }81            lock() {82                this.log("LOCKED");83                this.locked++;84            }85            unlock() {86                this.log("UNLOCKED");87                this.locked--;88                if (this.queue.length) {89                    this.log("STARTING QUEUE");90                    setImmediate(() => this.queue.shift()());91                }92            }93            promise() {94                return new Promise(resolve => this.waitForUnlock(resolve));95            }96        }97    };98    return extra;...

...55      let attempts = -1;56      while (attempts < MAX_ATTEMPS) {57        attempts++;58        try {59          const secretAttempt = await KeychainStore.waitForUnlock(keychain, true, attempts);60          await new Promise(r => setTimeout(r, 500)); // Modals have a "cooldown"61          if (!secretAttempt) {62            break;63          }64          secret = await challengeKeychainFromSecret(keychain, secretAttempt);65        } catch (e) { }66        if (secret) {67          break;68        }69      }70      if (!secret) {71        throw new Error('E_INVALID_PASSWORD_CHALLENGE_OUTCOME');72      }73    } else {74      secret = await KeychainStore.waitForUnlock(keychain, false);75      if (!secret) {76        throw new Error('E_INVALID_SECRET');77      }78      await saveKeychainToStorage(keychain, secret);79      await new Promise(r => setTimeout(r, 500)); // Modals have a "cooldown"80    }81    this.storeToCache(keychain, secret);82    return secret;83  }84  async setSecretIfEmpty(keychain, secret) {85    if (!keychain) {86      throw new Error('E_INVALID_KEYCHAIN');87    }88    if (!secret) {...

1'use strict';2/**3 * CloseLockManager manages requests from multiple modules on whether we4 * should close ourselves *now* or wait for the "stayAwake" lock to unlock.5 * The "requestClose" request is a lock too because one might ask to close6 * the app but decide not to do that later.7 *8 * Examples:9 *10 * 1. If there is no stayAwake lock exist and one ask for a requestClose lock,11 *    the app will be closed immediately.12 * 2. If there is a stayAwake lock exist, app will close only until the existing13 *    stayAwake lock unlocks.14 * 2.1. Or, you could cancel the request by unlock your requestClose lock.15 *16 */17(function(exports) {18var CloseLock = function(manager, topic) {19  this._manager = manager;20  this._topic = topic;21};22CloseLock.prototype.unlock = function() {23  this._manager.releaseLock(this, this._topic);24};25var CloseLockManager = function CloseLockManager() {26  this._closeLocks = null;27  this._awakeLocks = null;28  this.waitForUnlock = false;29};30CloseLockManager.prototype.start = function() {31  this._closeLocks = new Set();32  this._awakeLocks = new Set();33  this.waitForUnlock = false;34};35CloseLockManager.prototype.stop = function() {36  this._closeLocks = null;37  this._awakeLocks = null;38  this.waitForUnlock = false;39};40CloseLockManager.prototype.requestLock = function(topic) {41  var lock = new CloseLock(this, topic);42  switch (topic) {43    case 'requestClose':44      this._closeLocks.add(lock);45      break;46    case 'stayAwake':47      this._awakeLocks.add(lock);48      break;49    default:50      throw 'CloseLockManager: Undefined topic ' + topic;51  }52  this._maybeCloseNow();53  return lock;54};55CloseLockManager.prototype.releaseLock = function(lock, topic) {56  if (!(lock instanceof CloseLock)) {57    throw 'CloseLockManager: releaseLock need a lock.';58  }59  var set;60  switch (topic) {61    case 'requestClose':62      set = this._closeLocks;63      break;64    case 'stayAwake':65      set = this._awakeLocks;66      break;67    default:68      throw 'CloseLockManager: Undefined topic ' + topic;69  }70  if (!set.has(lock)) {71    // Already released72    return;73  }74  set.delete(lock);75  this._maybeCloseNow();76};77CloseLockManager.prototype._maybeCloseNow = function() {78  // If there is no stayAwake lock present and there is a requestClose lock,79  // we should close now.80  if (this._awakeLocks.size === 0 && this._closeLocks.size !== 0) {81    window.close();82  }83};84exports.CloseLockManager = CloseLockManager;85exports.CloseLock = CloseLock;...

...14    await run()15  } catch (e) {}16  await removeLock()17}...