How to use extractBundleId method in Appium Xcuitest Driver

...46  }47  // ルームもしくはグループのみ48  if (source.type === 'room' || source.type === 'group') {49    if (/^スキップ$/.test(text)) {50      const bundleId = firestore.extractBundleId(source);51      const { userId } = source;52      if (!await firestore.isGameMaster(bundleId, userId)) {53        return lineLib.replyText(replyToken, 'スキップできるのはゲームマスターのみです。');54      }55      const skippedUser = await firestore.skipCurrentUser(bundleId);56      if (!skippedUser) {57        return lineLib.replyText(replyToken, 'エラーが発生しました');58      }59      console.log('skippedUser', skippedUser);60      const latestGame = await firestore.latestGame(bundleId);61      const result = await sendNext.sendNext(bundleId, latestGame.CurrentIndex, true);62      const messages = result.publicMessage;63      messages.unshift(`${skippedUser.displayName}さんの順番はスキップされました。`);64      return lineLib.replyText(replyToken, messages);65    }66    if (/^参加$/.test(text)) {67      const bundleId = firestore.extractBundleId(source);68      const latestGame = await firestore.latestGame(bundleId);69      if (latestGame && latestGame.CurrentIndex > -1) {70        return lineLib.replyText(replyToken,71          {72            type: 'text',73            text: 'ゲーム続行中です。終了する場合は"終了"と送信してください。',74            quickReply: {75              items: [quickReply.stop, quickReply.help],76            },77          });78      }79      // update userlist80      const sourceUserProfile = await lineLib.getMemberProfile(source.userId, bundleId, source.type);81      const res = await firestore.addUserToGame(82        bundleId,83        source.userId,84        sourceUserProfile.displayName,85      );86      let displayNames = [];87      if (latestGame && latestGame.UserId2DisplayNames) {88        displayNames = latestGame.UserId2DisplayNames.map(el => Object.values(el)[0]);89      }90      if (res) {91        displayNames.push(sourceUserProfile.displayName);92      }93      // set users collection94      await firestore.putLatestBundleId(source.userId, firestore.extractBundleId(source));95      return lineLib.replyText(replyToken,96        {97          type: 'text',98          text: `参加を受け付けました🙆‍参加者が揃ったら「開始」と送信してください⏭99(参加者は私と友達になっている必要があります)100現在の参加者一覧👫101${displayNames.join('\n')}`,102          quickReply: {103            items: [quickReply.participate, quickReply.start, quickReply.help],104          },105        });106    }107    if (/^結果発表$/.test(text) || /^次へ$/.test(text)) {108      if (source.type === 'user') {109        return lineLib.replyText(replyToken, 'グループもしくはルームでのみ有効です。');110      }111      const bundleId = firestore.extractBundleId(source);112      const latestGame = await firestore.latestGame(bundleId);113      const currentAnnounceIndex = latestGame.CurrentAnnounceIndex || 0;114      const theme = latestGame.Theme;115      if (latestGame === null || latestGame.Status !== 'done') {116        return lineLib.replyText(replyToken, '結果発表できるゲームが見つかりませんでした。');117      }118      let messages = [];119      let additionalMessage;120      // 結果発表開始121      if (latestGame.CurrentAnnounceIndex === undefined) {122        const currentIndex = 0;123        const firstPlayerUserId = latestGame.UsersIds[latestGame.Orders[currentIndex]];124        const firstPlayerDisplayName = latestGame.UserId2DisplayNames[latestGame.Orders[currentIndex]][firstPlayerUserId];125        // 「次へ」を待たずにいきなりindex = 0の絵を送る126        const imageUrl = s3Lib.buildObjectUrl(127          firestore.extractBundleId(source),128          latestGame.GameId,129          currentIndex,130          firstPlayerUserId,131        );132        messages = [].concat([133          `それでは結果発表です\n\nお題は「${theme}」でした！`,134          `${firstPlayerDisplayName}さんが描いた絵はこちら`,135          {136            type: 'image',137            originalContentUrl: imageUrl,138            previewImageUrl: imageUrl,139          },140        ]);141        await firestore.updateGame(bundleId, { CurrentAnnounceIndex: 1 });142      } else if (currentAnnounceIndex > 0) {143        // 結果発表中144        const targetPlayerUserId = latestGame.UsersIds[latestGame.Orders[currentAnnounceIndex]];145        const targetPlayerDisplayName = latestGame.UserId2DisplayNames[latestGame.Orders[currentAnnounceIndex]][targetPlayerUserId];146        if (util.questionType(currentAnnounceIndex) === 'drawing') {147          const imageUrl = s3Lib.buildObjectUrl(148            firestore.extractBundleId(source),149            latestGame.GameId,150            currentAnnounceIndex,151            targetPlayerUserId,152          );153          messages.push(`${targetPlayerDisplayName}さんが描いた絵はこちら`);154          messages.push({155            type: 'image',156            originalContentUrl: imageUrl,157            previewImageUrl: imageUrl,158          });159        } else if (util.questionType(currentAnnounceIndex) === 'guessing') {160          const s3Object = await s3Lib.getObject(bundleId, latestGame.GameId, currentAnnounceIndex, targetPlayerUserId);161          const answeredTheme = s3Object.Body.toString();162          messages.push(`${targetPlayerDisplayName}さんはこの絵を「${answeredTheme}」だと答えました。`);163        }164        await firestore.updateGame(bundleId, { CurrentAnnounceIndex: currentAnnounceIndex + 1 });165      }166      if (latestGame.UsersIds.length <= currentAnnounceIndex + 1) {167        if (util.questionType(currentAnnounceIndex) === 'drawing') {168          additionalMessage = '最後の絵はどうでしたか？みんなで点数をつけてみると面白いかもしれませんよ。';169        } else if (util.questionType(currentAnnounceIndex) === 'guessing') {170          additionalMessage = '最初のお題は最後の人まで正しく伝わったでしょうか？';171        }172        await firestore.stashEndedGame(firestore.extractBundleId(source));173        // ありがとうメッセージ174        messages.push(175          {176            type: 'text',177            text: `以上で結果発表は終了です。\n${additionalMessage}\n\n新しいお題で遊ぶには、各参加者が「参加」と送信した後に、「開始」と送信してください。`,178            quickReply: {179              items: [quickReply.participate],180            },181          },182        );183      } else {184        messages.push(185          {186            type: 'text',187            text: '「次へ」と送信すると、次の人の絵もしくは回答を見ることができます。',188            quickReply: {189              items: [quickReply.next, quickReply.help],190            },191          },192        );193      }194      return lineLib.replyText(replyToken, messages);195    }196    if (/^終了$/.test(text)) {197      await firestore.stashEndedGame(firestore.extractBundleId(source));198      const endMessage = {199        type: 'text',200        text: 'ゲームを終了しました。再度ゲームを始める場合は、各参加者が「参加」と送信した後に、「開始」と送信してください。',201        quickReply: {202          items: [quickReply.participate],203        },204      };205      return lineLib.replyText(replyToken, endMessage);206    }207    if (/^開始$/.test(text)) {208      // TODO: validate209      // 2人以上でないとエラー210      // 順番、テーマ決め211      const bundleId = firestore.extractBundleId(source);212      const latestGame = await firestore.latestGame(bundleId);213      let playersNum;214      if (!latestGame) {215        return lineLib.replyText(replyToken, 'エラーが発生しました。');216      }217      // すでにゲーム中の場合218      if (latestGame.CurrentIndex > -1) {219        return lineLib.replyText(replyToken, 'ゲーム続行中です。終了する場合は"終了"と送信してください。');220      }221      // 人数を取得222      const uids2dn = latestGame.UserId2DisplayNames;223      if (uids2dn == null) {224        playersNum = 0;225      } else {...

1const dynExp = require('@aws/dynamodb-expressions');2const AWS = require('aws-sdk');3const dynamodbUpdateExpression = require('dynamodb-update-expression');4const util = require('./util');5AWS.config.update({6  region: 'ap-northeast-1',7});8// const docClient = dynamodb.doc;9const docClient = new AWS.DynamoDB.DocumentClient();10const dbClient = new AWS.DynamoDB();11const extractBundleId = source => source.groupId || source.roomId;12const latestGame = async (bundleId) => {13  const params = {14    TableName: process.env.GAMES_DYNAMODB_TABLE,15    Key: {16      BundleId: bundleId,17    },18  };19  try {20    const result = await docClient.get(params).promise();21    if (result.Item) {22      // console.log('item', result.Item);23      // console.log('item2 ', attr.unwrap(result.Item.Orders));24      // console.log('item3 ', attr.unwrap(result.Item.Theme));25      // return attr.unwrap(result.Item.Theme);26      return result.Item;27    }28  } catch (err) {29    console.error('error on latestGame', err);30    console.error('params', params);31  }32  return null;33};34const latestBundleIdOfUser = async (userId) => {35  const params = {36    TableName: process.env.USERS_DYNAMODB_TABLE,37    Key: {38      UserId: userId,39    },40    AttributesToGet: [41      'BundleId',42    ],43    ConsistentRead: false,44    ReturnConsumedCapacity: 'NONE',45  };46  try {47    const result = await docClient.get(params).promise();48    if (result.Item) {49      return result.Item.BundleId;50    }51  } catch (err) {52    console.error(err);53  }54  return null;55};56function buildGameId(isoString) {57  return isoString.replace(/-/g, '');58}59const addUserToGame = async (bundleId, userId, displayName) => {60  const lg = await latestGame(bundleId);61  if (lg == null) {62    const now = new Date();63    const createdAt = now.toISOString();64    const createParams = {65      TableName: process.env.GAMES_DYNAMODB_TABLE,66      Key: {67        BundleId: bundleId,68      },69      UpdateExpression: 'set #createdAt = :now, #gameId = :gameId',70      ExpressionAttributeNames: {71        '#createdAt': 'CreatedAt',72        '#gameId': 'GameId',73      },74      ExpressionAttributeValues: {75        ':now': createdAt,76        ':gameId': buildGameId(createdAt),77      },78    };79    try {80      await docClient.update(createParams).promise();81    } catch (err) {82      console.log('ERROR on Dynamodb update in create phase of addUserToGame', err);83      console.log('createParams', createParams);84    }85  }86  const addUserParams = {87    TableName: process.env.GAMES_DYNAMODB_TABLE,88    Key: {89      BundleId: bundleId,90    },91    ReturnValues: 'ALL_NEW',92    UpdateExpression: 'set #usersIds = list_append(if_not_exists(#usersIds, :emptyList), :userIdList), #uid2dpn = list_append(if_not_exists(#uid2dpn, :emptyList), :uid2dpn)',93    ConditionExpression: 'NOT contains(#usersIds, :userId)',94    ExpressionAttributeNames: {95      '#usersIds': 'UsersIds',96      '#uid2dpn': 'UserId2DisplayNames',97    },98    ExpressionAttributeValues: {99      ':emptyList': [],100      ':userIdList': [userId],101      ':userId': userId,102      ':uid2dpn': [{103        [userId]: displayName,104      }],105    },106  };107  let res;108  try {109    res = await docClient.update(addUserParams).promise();110  } catch (err) {111    if (err.code && err.code === 'ConditionalCheckFailedException') {112      console.debug(`addUserToGame is skipped because the user ${userId} is already added to game in ${bundleId}. `);113    } else {114      console.log('ERROR on Dynamodb update in add phase of addUserToGame', err);115    }116    res = false;117  }118  return res;119};120const putLatestBundleId = async (userId, bundleId) => {121  const params = {122    TableName: process.env.USERS_DYNAMODB_TABLE,123    Item: {124      UserId: userId,125      BundleId: bundleId,126    },127  };128  return docClient.put(params).promise();129};130const updateGame = async (bundleId, updateValues) => {131  // https://stackoverflow.com/questions/43791700/whats-the-simplest-way-to-copy-an-item-from-a-dynamodb-stream-to-another-table132  // https://www.npmjs.com/package/dynamodb-data-types133  console.log('updateGame start', updateValues);134  const expr = new dynExp.UpdateExpression();135  const attributes = new dynExp.ExpressionAttributes();136  const updateExpression = dynamodbUpdateExpression.getUpdateExpression({}, updateValues);137  // eslint-disable-next-line138  for (const [key, value] of Object.entries(updateValues)) {139    console.log(`${key} ${value}`);140    expr.set(key, value);141  }142  // const params = {143  //   TableName: process.env.GAMES_DYNAMODB_TABLE,144  //   Key: {145  //     BundleId: bundleId,146  //   },147  //   UpdateExpression: expr.serialize(attributes),148  //   ExpressionAttributeNames: attributes.names,149  //   ExpressionAttributeValues: attributes.values,150  // };151  const params = Object.assign({152    TableName: process.env.GAMES_DYNAMODB_TABLE,153    Key: {154      BundleId: bundleId,155    },156  }, updateExpression);157  let res;158  console.log('updateGame', params);159  try {160    // res = await dbClient.update(params).promise();161    res = await docClient.update(params).promise();162    console.log('updateGame res', res);163  } catch (err) {164    console.log('ERROR', err);165  }166  return res;167};168// move a record from "games" to "old-games" table169const stashEndedGame = async (bundleId) => {170  const lg = await latestGame(bundleId);171  if (lg == null) {172    return;173  }174  const delteParams = {175    TableName: process.env.GAMES_DYNAMODB_TABLE,176    Key: {177      BundleId: bundleId,178    },179  };180  docClient.delete(delteParams, async (err, data) => {181    if (err == null) {182      const putParams = {183        TableName: process.env.OLD_GAMES_DYNAMODB_TABLE,184        Item: lg,185      };186      try {187        await docClient.put(putParams).promise();188      } catch (e) {189        console.log('ERROR on Dynamodb put in stashEndedGame', e);190        console.log('putParams', putParams);191      }192    } else {193      console.log('ERROR on Dynamodb delte in stashEndedGame', err);194      console.log('deleteParams', delteParams);195    }196  });197};198const skipCurrentUser = async (bundleId) => {199  const lg = await latestGame(bundleId);200  // currentIndex means who is in turn currently in 'Orders' array201  const currentIndex = lg.CurrentIndex;202  // Orders array contains indecies of 'UsersIds' indecies according to actual 'order'203  // e.g. UsersIds: ['bob', 'alice', 'john'] / Orders: [1, 2, 0]204  // -> Order of users to answer is 'alice', 'john', 'bob'205  const currentUserIndex = lg.Orders[currentIndex];206  // remove the skipped item from these 3 arrays207  lg.Orders.splice(currentIndex, 1);208  const newOrders = lg.Orders.map(o => ((o > currentUserIndex) ? o - 1 : 0));209  // NOTE: splice returns 'array' consists of deleted items210  const deletedUserId = lg.UsersIds.splice(currentUserIndex, 1);211  const deletedUser = lg.UserId2DisplayNames.splice(currentUserIndex, 1);212  const updateValues = {213    Orders: newOrders,214    UsersIds: lg.UsersIds,215    UserId2DisplayNames: lg.UserId2DisplayNames,216  };217  const updateExpression = dynamodbUpdateExpression.getUpdateExpression({}, updateValues);218  const params = Object.assign({219    TableName: process.env.GAMES_DYNAMODB_TABLE,220    Key: {221      BundleId: bundleId,222    },223  }, updateExpression);224  try {225    await docClient.update(params).promise();226  } catch (err) {227    console.log('ERROR', err);228    return false;229  }230  return {231    userId: Object.keys(deletedUser[0])[0],232    displayName: Object.values(deletedUser[0])[0],233  };234};235const swapTheme = async (game) => {236  const prevTheme = game.Theme;237  const prevTimes = Number(game.ThemeUpdatedTimes) || 0;238  let newTheme;239  while (newTheme === undefined || prevTheme === newTheme) {240    newTheme = util.pickTheme();241  }242  const updateValues = {243    Theme: newTheme,244    ThemeUpdatedTimes: prevTimes + 1,245  };246  // TODO: replace this with 'aws-labs' module as updateGame method247  const updateExpression = dynamodbUpdateExpression.getUpdateExpression({}, updateValues);248  const params = Object.assign({249    TableName: process.env.GAMES_DYNAMODB_TABLE,250    Key: {251      BundleId: game.BundleId,252    },253  }, updateExpression);254  try {255    await docClient.update(params).promise();256  } catch (err) {257    console.log('ERROR', err);258    return false;259  }260  return Object.assign(game, updateValues);261};262// TODO: 実装263const isGameMaster = async (bundleId, userId) => true;264module.exports = {265  extractBundleId,266  putLatestBundleId,267  latestBundleIdOfUser,268  latestGame,269  addUserToGame,270  stashEndedGame,271  updateGame,272  skipCurrentUser,273  swapTheme,274  isGameMaster,...

...30      [sessionId] = await super.createSession(caps);31      // fail very early if the app doesn't actually exist32      await this.checkAppPresent();33      if (!this.opts.bundleId) {34        this.opts.bundleId = await extractBundleId(this.opts.app);35      }36      // start sim, or use running sim37      log.info('starting simlator (if not booted)');38      this.sim = await this.startSim();39      this.wda = new WebDriverAgent({40        udid: this.sim.udid,41        platformVersion: this.opts.platformVersion,42        host: this.opts.host,43        agentPath: this.opts.agentPath44      });45      await this.wda.launch(sessionId);46      log.info("Installing the app");47      // TODO don't re-install (need to check if version numbers match)?48      await installApp(this.sim.udid, this.opts.app);...

1import path from 'path';2import _ from 'lodash';3import { plist } from 'appium-support';4import log from './logger.js';5let plistObjects = {};6async function extractPlist (app) {7  let plistFile = path.resolve(app, 'Info.plist');8  try {9    return await plist.parsePlistFile(plistFile);10  } catch (err) {11    log.errorAndThrow(`Could not extract Info.plist from application: ${err.message}`);12  }13}14async function extractPlistEntry (app, entryName) {15  if (_.isUndefined(plistObjects[app])) {16    plistObjects[app] = await extractPlist(app);17  }18  return plistObjects[app][entryName];19}20async function extractAppDisplayName (app) {21  log.debug("Getting application name from app");22  return await extractPlistEntry(app, 'CFBundleDisplayName');23}24async function extractBundleId (app) {25  let bundleId = await extractPlistEntry(app, 'CFBundleIdentifier');26  log.debug(`Getting bundle ID from app '${app}': '${bundleId}'`);27  return bundleId;28}...

...17  });18});19describe('extractBundleId', function () {20  it('should get bundleId of app', async function () {21    let bundleId = await appUtils.extractBundleId(app);22    bundleId.should.equal('com.example.apple-samplecode.UICatalog');23  });...

...7chai.use(chaiAsPromised);8describe('extractBundleId', () => {9  it('should get bundleId of app', async () => {10    let app = absolute.iphonesimulator;11    let bundleId = await extractBundleId(app);12    bundleId.should.equal('io.appium.TestApp');13  });...

1import log from './logger.js';2import extractPlistEntry from './extract';3async function extractBundleId (app) {4  let bundleId = await extractPlistEntry(app, 'CFBundleIdentifier');5  log.debug(`Getting bundle ID from app '${app}': '${bundleId}'`);6  return bundleId;7}...

1import { default as extractBundleId } from './lib/bundleId';2import { default as extractAppDisplayName } from './lib/appname';...