Parallel Testing

// Google Search - Selenium Example Script
//See https://github.com/SeleniumHQ/selenium/wiki/WebDriverJs for detailed instructions

var username = '[email protected]'; //replace with your email address
var authkey = '12345'; //replace with your authkey

var webdriver = require('selenium-webdriver'),
    SeleniumServer = require('selenium-webdriver/remote').SeleniumServer,
    request = require('request');

var remoteHub = "http://" + username + ":" + authkey + "@hub.crossbrowsertesting.com:80/wd/hub";

//add multiple browsers to run in parallel here
var browsers = [
   { browserName: 'firefox', os_api_name: 'Win7', browser_api_name: 'FF27', screen_resolution: '1024x768' },
   { browserName: 'chrome', os_api_name: 'Mac10.9', browser_api_name: 'Chrome40x64', screen_resolution: '1024x768' },
   { browserName: 'internet explorer', os_api_name: 'Win8.1', browser_api_name: 'IE11', screen_resolution: '1024x768' }
];

var flows = browsers.map(function(browser) {
    return webdriver.promise.createFlow(function() {

        var caps = {
            name : 'Google Search - Selenium Test Example',
            build : '1.0',
            
            browserName : browser.browserName, // <---- this needs to be the browser type in lower case: firefox, internet explorer, chrome, opera, or safari
            browser_api_name : browser.browser_api_name,
            os_api_name : browser.os_api_name,
            screen_resolution : browser.screen_resolution,

            record_video : "true",
            record_network : "false", // set to "true" to record network traffic
            record_snapshot : "false",
         
            username : username,
            password : authkey
        };

        var driver = new webdriver.Builder()
             .usingServer(remoteHub)
             .withCapabilities(caps)
             .build();

        //need sessionId before any api calls
        driver.getSession().then(function(session){
            
            var sessionId = session.id_;

            driver.get('http://www.google.com');
            var element = driver.findElement(webdriver.By.name('q'));
            element.sendKeys('cross browser testing');
            element.submit();
            driver.call(takeSnapshot, null, sessionId);
            driver.getTitle().then(function(title) {
                if (title !== ('cross browser testing - Google Search')) {
                    throw Error('Unexpected title: ' + title);
                }
            });
            driver.quit();
            driver.call(setScore, null, 'pass', sessionId);
        });
    });
});

webdriver.promise.fullyResolved(flows).then(function() {
    console.log('All tests passed!');
});

webdriver.promise.controlFlow().on('uncaughtException', function(err){
    console.error('There was an unhandled exception! ' + err);
});




//Call API to set the score
function setScore(score, sessionId) {

    //webdriver has built-in promise to use
    var deferred = webdriver.promise.defer();
    var result = { error: false, message: null }

    if (sessionId){
        
        request({
            method: 'PUT',
            uri: 'https://crossbrowsertesting.com/api/v3/selenium/' + sessionId,
            body: {'action': 'set_score', 'score': score },
            json: true
        },
        function(error, response, body) {
            if (error) {
                result.error = true;
                result.message = error;
            }
            else if (response.statusCode !== 200){
                result.error = true;
                result.message = body;
            }
            else{
                result.error = false;
                result.message = 'success';
            }

            deferred.fulfill(result);
        })
        .auth(username, authkey);
    }
    else{
        result.error = true;
        result.message = 'Session Id was not defined';
        deferred.fulfill(result);
    }

    return deferred.promise;
}

//Call API to get a snapshot
function takeSnapshot(sessionId) {

    //webdriver has built-in promise to use
    var deferred = webdriver.promise.defer();
    var result = { error: false, message: null }
    
    if (sessionId){

       
        request.post(
            'https://crossbrowsertesting.com/api/v3/selenium/' + sessionId + '/snapshots',
            function(error, response, body) {
                if (error) {
                    result.error = true;
                    result.message = error;
                }
                else if (response.statusCode !== 200){
                    result.error = true;
                    result.message = body;
                }
                else{
                    result.error = false;
                    result.message = 'success';
                }
                //console.log('fulfilling promise in takeSnapshot')
                deferred.fulfill(result);
            }
        )
        .auth(username,authkey);
        
    }
    else{
        result.error = true;
        result.message = 'Session Id was not defined';
        deferred.fulfill(result); //never call reject as we don't need this to actually stop the test
    }

    return deferred.promise;
}

from threading import Thread
from selenium import webdriver
import time

USERNAME = "USERNAME"
API_KEY = "API_KEY"


def get_browser(caps):
    return webdriver.Remote(
            desired_capabilities=caps,
            command_executor="http://%s:%[email protected]:80/wd/hub" % (USERNAME, API_KEY)
        )

browsers = [
  {"platform": "Windows 7 64-bit", "browserName": "Internet Explorer","version": "10", "name": "Python Parallel"},
  {"platform": "Windows 8.1", "browserName": "Chrome", "version": "50", "name": "Python Parallel"},
]
browsers_waiting = []


def get_browser_and_wait(browser_data):
    print ("starting %s\n" % browser_data["browserName"])
    browser = get_browser(browser_data)
    browser.get("http://crossbrowsertesting.com")
    browsers_waiting.append({"data": browser_data, "driver": browser})
    print ("%s ready" % browser_data["browserName"])
    while len(browsers_waiting) < len(browsers):
        print ("working on %s.... please wait" % browser_data["browserName"])
        browser.get("http://crossbrowsertesting.com")
        time.sleep(3)

threads = []
for i, browser in enumerate(browsers):
    thread = Thread(target=get_browser_and_wait, args=[browser])
    threads.append(thread)
    thread.start()


for thread in threads:
    thread.join()

print ("all browsers ready")
for i, b in enumerate(browsers_waiting):
    print ("browser %s's title: %s" % (b["data"]["name"], b["driver"].title))
    b["driver"].quit()

#!/usr/bin/env python

import unittest
from selenium import webdriver

USERNAME = "mikeh"
API_KEY = ""


class SeleniumCBT(unittest.TestCase):
    def setUp(self):
        caps = {}

        caps['name'] = 'Python Nose Parallel'
        caps['build'] = '1.0'
        caps['browser_api_name'] = 'Chrome43x64'
        caps['os_api_name'] = 'Win8.1'
        caps['screen_resolution'] = '1024x768'

        # start the remote browser on our server
        self.driver = webdriver.Remote(
            desired_capabilities=caps,
            command_executor="http://%s:%[email protected]:80/wd/hub" % (USERNAME, API_KEY)
        )

        self.driver.implicitly_wait(20)

    def test_CBT(self):

        # load the page URL
        print('Loading Url')
        self.driver.get('http://crossbrowsertesting.github.io/selenium_example_page.html')

        # check the title
        print('Checking title')
        self.assertTrue("Selenium Test Example Page" in self.driver.title)

    def tearDown(self):
        print("Done with session %s" % self.driver.session_id)
        self.driver.quit()

if __name__ == '__main__':
    unittest.main()

package cbt.selenium.junit;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import org.junit.runners.Parameterized;
import org.junit.runners.model.RunnerScheduler;

public class Parallelized extends Parameterized {
    
  private static class ThreadPoolScheduler implements RunnerScheduler {
    private ExecutorService executor;
    
    public ThreadPoolScheduler() {
      String threads = System.getProperty("junit.parallel.threads", "16");
      int numThreads = Integer.parseInt(threads);
      executor = Executors.newFixedThreadPool(numThreads);
    }
    
    @Override
    public void finished() {
      executor.shutdown();
      try {
        executor.awaitTermination(10, TimeUnit.MINUTES);
      } catch (InterruptedException exc) {
        throw new RuntimeException(exc);
      }
    }

    @Override
    public void schedule(Runnable childStatement) {
      executor.submit(childStatement);
    }
  }

  public Parallelized(Class<?> klass) throws Throwable {
    super(klass);
    setScheduler(new ThreadPoolScheduler());
  }
}

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE suite SYSTEM "http://testng.org/testng-1.0.dtd">
<suite thread-count="2" name="Suite" parallel="tests">
  <test name="FirstTest">
  <parameter name="os" value="Win10"/>
  <parameter name="browser" value="chrome-latest"/>
    <classes>
      <class name="cbt.selenium.testng.TestCase"/>
    </classes>
  </test> <!-- Test -->
  <test name="SecondTest">
  <parameter name="os" value="Win10"/>
  <parameter name="browser" value="ff-latest"/>
    <classes>
      <class name="cbt.selenium.testng.TestCase"/>
    </classes>
  </test> <!-- Test -->
</suite> <!-- Suite -->

source 'https://rubygems.org'

gem 'selenium'
gem 'selenium-webdriver'
gem 'test-unit'
gem 'parallel_tests'