@testim/testim-cli/runners/DeviceFarmRemoteRunner.js

"use strict";

const utils = require('../utils');
const config = require('../commons/config');
const testimCustomToken = require('../commons/testimCustomToken');
const BaseRunner = require('./BaseRunner');
const TestRunStatus = require('../testRunStatus');
const reporter = require("../reports/reporter");
const Logger = require('../commons/logger');
const gridService = require('../services/gridService');
const logger = Logger.getLogger('remote-test-runner');

class DeviceFarmRemoteRunner extends BaseRunner {
    runExecution(testList, testStatus, executionId, options, branchToUse) {
        const projectId = options.project;
        const sessionType = utils.getSessionType(options);
        // report exec start analytics
        const authData = testimCustomToken.getTokenV3UserData();
        this.analyticsExecsStart({authData, executionId, projectId, sessionType});
        const workerCount = config.TESTIM_CONCURRENT_WORKER_COUNT || options.parallel;

        return this.strategy.runTests(testList, testStatus, executionId, options, branchToUse, authData, workerCount);
    }

    runTest(executionId, testList, gridInfo, branchToUse, options) {
        Logger.setExecutionId(executionId);

        logger.info("start to remote runner", {
            executionId: executionId,
            options: Object.assign({}, options, {token: undefined}),
            branchToUse: branchToUse,
        });

        const testPlanName = "remote run";
        const testStatus = new TestRunStatus(testList, options, branchToUse);
        reporter.onTestPlanStarted([], testList, [], testPlanName, executionId);

        const workerId = 1;
        const browserType = options.projectData.type; //android or ios
        const {gridId, slotId} = gridInfo;
        gridService.addItemToGridCache(workerId, gridId, slotId, browserType);
        options.disableWindowAnimation = options.remoteRunObject.echoedOptions.disableWindowAnimation
        options.baseUrl = options.remoteRunObject.echoedOptions.baseUrl
        return this.runExecution(testList, testStatus, executionId, options, branchToUse)
            .tap(results => reporter.onTestPlanFinished(results, testPlanName, this.startTime, executionId))
            .then(combinedTestResults => combinedTestResults);
    }
}

module.exports = DeviceFarmRemoteRunner;