-
Notifications
You must be signed in to change notification settings - Fork 1.9k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
65 changed files
with
1,546 additions
and
1,851 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,196 +1,31 @@ | ||
| // @ts-nocheck | ||
| const cp = require('child_process'); | ||
| const realm = require('../realms/root'); | ||
|
|
||
| const _ = require('lodash'); | ||
| const whichSync = require('which').sync; | ||
| const unparse = require('yargs-unparser'); | ||
|
|
||
| const { composeDetoxConfig } = require('../src/configuration'); | ||
| const DeviceRegistry = require('../src/devices/DeviceRegistry'); | ||
| const GenyDeviceRegistryFactory = require('../src/devices/allocation/drivers/android/genycloud/GenyDeviceRegistryFactory'); | ||
| const { loadLastFailedTests, resetLastFailedTests } = require('../src/utils/lastFailedTests'); | ||
| const log = require('../src/utils/logger').child({ __filename }); | ||
| const { parse, quote } = require('../src/utils/shellQuote'); | ||
|
|
||
| const { readJestConfig } = require('./utils/jestInternals'); | ||
| const { getPlatformSpecificString, printEnvironmentVariables } = require('./utils/misc'); | ||
| const { prependNodeModulesBinToPATH } = require('./utils/misc'); | ||
| const splitArgv = require('./utils/splitArgv'); | ||
| const { DETOX_ARGV_OVERRIDE_NOTICE, DEVICE_LAUNCH_ARGS_DEPRECATION } = require('./utils/warnings'); | ||
| const TestRunnerCommand = require('./testCommand/TestRunnerCommand'); | ||
|
|
||
| module.exports.command = 'test'; | ||
| module.exports.desc = 'Run your test suite with the test runner specified in package.json'; | ||
| module.exports.builder = require('./utils/testCommandArgs'); | ||
| module.exports.handler = async function test(argv) { | ||
| const { detoxArgs, runnerArgs } = splitArgv.detox(argv); | ||
| const { cliConfig, deviceConfig, runnerConfig } = await composeDetoxConfig({ argv: detoxArgs }); | ||
| const [platform] = deviceConfig.type.split('.'); | ||
|
|
||
| const forwardedArgs = await prepareArgs({ | ||
| cliConfig, | ||
| deviceConfig, | ||
| runnerConfig, | ||
| runnerArgs, | ||
| platform, | ||
| }); | ||
|
|
||
| if (detoxArgs['inspect-brk']) { | ||
| const runnerBinary = whichSync('jest', { | ||
| path: prependNodeModulesBinToPATH({ ...process.env }), | ||
| }); | ||
|
|
||
| forwardedArgs.argv.$0 = `node --inspect-brk ${require.resolve(runnerBinary)}`; | ||
| } else { | ||
| forwardedArgs.argv.$0 = runnerConfig.testRunner; | ||
| } | ||
|
|
||
| await runTestRunnerWithRetries(forwardedArgs, { | ||
| keepLockFile: cliConfig.keepLockFile, | ||
| retries: detoxArgs.retries, | ||
| platform, | ||
| }); | ||
| }; | ||
|
|
||
| module.exports.middlewares = [ | ||
| function applyEnvironmentVariableAddendum(argv, yargs) { | ||
| if (process.env.DETOX_ARGV_OVERRIDE) { | ||
| log.warn(DETOX_ARGV_OVERRIDE_NOTICE); | ||
|
|
||
| return yargs.parse([ | ||
| ...process.argv.slice(2), | ||
| ...parse(process.env.DETOX_ARGV_OVERRIDE), | ||
| ]); | ||
| module.exports.builder = require('./testCommand/builder'); | ||
| module.exports.middlewares = require('./testCommand/middlewares').default; | ||
|
|
||
| module.exports.handler = async function test({ detoxArgs, runnerArgs, specs }) { | ||
| try { | ||
| await realm.setup({ argv: detoxArgs }); | ||
|
|
||
| const runnerCommand = new TestRunnerCommand() | ||
| .setDeviceConfig(realm.config.deviceConfig) | ||
| .replicateCLIConfig(realm.config.cliConfig) | ||
| .setRunnerConfig(realm.config.runnerConfig) | ||
| .assignArgv(runnerArgs) | ||
| .setRetries(detoxArgs.retries) | ||
| .setSpecs(specs); | ||
|
|
||
| if (detoxArgs['inspect-brk']) { | ||
| runnerCommand.enableDebugMode(); | ||
| } | ||
|
|
||
| return argv; | ||
| }, | ||
|
|
||
| function warnDeviceAppLaunchArgsDeprecation(argv) { | ||
| if (argv['device-boot-args'] && process.argv.some(a => a.startsWith('--device-launch-args'))) { | ||
| log.warn(DEVICE_LAUNCH_ARGS_DEPRECATION); | ||
| } | ||
|
|
||
| return argv; | ||
| await runnerCommand.execute(); | ||
| } finally { | ||
| await realm.teardown(); | ||
| } | ||
| ]; | ||
|
|
||
| async function prepareArgs({ cliConfig, deviceConfig, runnerArgs, runnerConfig, platform }) { | ||
| const { specs, passthrough } = splitArgv.jest(runnerArgs); | ||
| const platformFilter = getPlatformSpecificString(platform); | ||
|
|
||
| const argv = _.omitBy({ | ||
| color: !cliConfig.noColor && undefined, | ||
| config: runnerConfig.runnerConfig /* istanbul ignore next */ || undefined, | ||
| testNamePattern: platformFilter ? `^((?!${platformFilter}).)*$` : undefined, | ||
| maxWorkers: cliConfig.workers || undefined, | ||
|
|
||
| ...passthrough, | ||
| }, _.isUndefined); | ||
|
|
||
| const hasMultipleWorkers = (await readJestConfig(argv)).globalConfig.maxWorkers > 1; | ||
|
|
||
| return { | ||
| argv, | ||
|
|
||
| env: _.omitBy({ | ||
| DETOX_APP_LAUNCH_ARGS: cliConfig.appLaunchArgs, | ||
| DETOX_ARTIFACTS_LOCATION: cliConfig.artifactsLocation, | ||
| DETOX_CAPTURE_VIEW_HIERARCHY: cliConfig.captureViewHierarchy, | ||
| DETOX_CLEANUP: cliConfig.cleanup, | ||
| DETOX_CONFIGURATION: cliConfig.configuration, | ||
| DETOX_CONFIG_PATH: cliConfig.configPath, | ||
| DETOX_DEBUG_SYNCHRONIZATION: cliConfig.debugSynchronization, | ||
| DETOX_DEVICE_BOOT_ARGS: cliConfig.deviceBootArgs, | ||
| DETOX_DEVICE_NAME: cliConfig.deviceName, | ||
| DETOX_FORCE_ADB_INSTALL: platform === 'android' ? cliConfig.forceAdbInstall : undefined, | ||
| DETOX_GPU: cliConfig.gpu, | ||
| DETOX_HEADLESS: cliConfig.headless, | ||
| DETOX_LOGLEVEL: cliConfig.loglevel, | ||
| DETOX_READ_ONLY_EMU: deviceConfig.type === 'android.emulator' && hasMultipleWorkers ? true : undefined, | ||
| DETOX_RECORD_LOGS: cliConfig.recordLogs, | ||
| DETOX_RECORD_PERFORMANCE: cliConfig.recordPerformance, | ||
| DETOX_RECORD_TIMELINE: cliConfig.recordTimeline, | ||
| DETOX_RECORD_VIDEOS: cliConfig.recordVideos, | ||
| DETOX_REPORT_SPECS: _.isUndefined(cliConfig.jestReportSpecs) | ||
| ? !hasMultipleWorkers | ||
| : `${cliConfig.jestReportSpecs}` === 'true', | ||
| DETOX_REUSE: cliConfig.reuse, | ||
| DETOX_START_TIMESTAMP: Date.now(), | ||
| DETOX_TAKE_SCREENSHOTS: cliConfig.takeScreenshots, | ||
| DETOX_USE_CUSTOM_LOGGER: cliConfig.useCustomLogger, | ||
| }, _.isUndefined), | ||
|
|
||
| specs: _.isEmpty(specs) && runnerConfig.specs ? [runnerConfig.specs] : specs, | ||
| }; | ||
| } | ||
|
|
||
| async function resetLockFile({ platform }) { | ||
| if (platform === 'ios') { | ||
| await DeviceRegistry.forIOS().reset(); | ||
| } | ||
|
|
||
| if (platform === 'android') { | ||
| await DeviceRegistry.forAndroid().reset(); | ||
| await GenyDeviceRegistryFactory.forGlobalShutdown().reset(); | ||
| } | ||
| } | ||
|
|
||
| function launchTestRunner({ argv, env, specs }) { | ||
| const { $0: command, ...restArgv } = argv; | ||
| const fullCommand = [ | ||
| command, | ||
| quote(unparse(_.omitBy(restArgv, _.isUndefined))), | ||
| specs.join(' ') | ||
| ].filter(Boolean).join(' '); | ||
|
|
||
| log.info(printEnvironmentVariables(env) + fullCommand); | ||
|
|
||
| cp.execSync(fullCommand, { | ||
| stdio: 'inherit', | ||
| env: _({}) | ||
| .assign(process.env) | ||
| .assign(env) | ||
| .omitBy(_.isUndefined) | ||
| .tap(prependNodeModulesBinToPATH) | ||
| .value() | ||
| }); | ||
| } | ||
|
|
||
| async function runTestRunnerWithRetries(forwardedArgs, { keepLockFile, platform, retries }) { | ||
| let runsLeft = 1 + retries; | ||
| let launchError; | ||
|
|
||
| do { | ||
| try { | ||
| if (launchError) { | ||
| const list = forwardedArgs.specs.map((file, index) => ` ${index + 1}. ${file}`).join('\n'); | ||
| log.error( | ||
| `There were failing tests in the following files:\n${list}\n\n` + | ||
| 'Detox CLI is going to restart the test runner with those files...\n' | ||
| ); | ||
| } | ||
|
|
||
| if (!keepLockFile) { | ||
| await resetLockFile({ platform }); | ||
| } | ||
|
|
||
| await resetLastFailedTests(); | ||
| launchTestRunner(forwardedArgs); | ||
| launchError = null; | ||
| } catch (e) { | ||
| launchError = e; | ||
|
|
||
| const lastFailedTests = await loadLastFailedTests(); | ||
| if (_.isEmpty(lastFailedTests)) { | ||
| throw e; | ||
| } | ||
|
|
||
| forwardedArgs.specs = lastFailedTests; | ||
| forwardedArgs.env.DETOX_RERUN_INDEX = 1 + (forwardedArgs.env.DETOX_RERUN_INDEX || 0); | ||
| } | ||
| } while (launchError && --runsLeft > 0); | ||
|
|
||
| if (launchError) { | ||
| throw launchError; | ||
| } | ||
| } | ||
| }; |
Oops, something went wrong.