chore(typescript): converting task files to typescript

Author: cnishina

lib/configParser.ts

@@ -19,6 +19,7 @@ try {
 export interface Config {
   specs: Array<string>;
   multiCapabilities: Array<any>;
+  capabilities?: any;
   rootElement: string;
   allScriptsTimeout: number;
   getPageTimeout: number;
@@ -35,6 +36,8 @@ export interface Config {
   suite?: string;
   suites?: any;
   troubleshoot?: boolean;
+  exclude?: Array<string>| string;
+  maxSessions?: number;
 }
 
 export default class ConfigParser {

lib/launcher.js

@@ -5,11 +5,11 @@
 'use strict';
 
 var ConfigParser = require('./configParser').default,
-    TaskScheduler = require('./taskScheduler'),
+    TaskScheduler = require('./taskScheduler').default,
     helper = require('./util'),
     log = require('./logger'),
     q = require('q'),
-    TaskRunner = require('./taskRunner');
+    TaskRunner = require('./taskRunner').default;
 
 var logPrefix = '[launcher]';
 var RUNNERS_FAILED_EXIT_CODE = 100;

lib/taskLogger.js

@@ -0,0 +1,84 @@
+import {EOL} from 'os';
+import * as Logger from './logger';
+
+export default class TaskLogger {
+  private buffer: string = '';
+  private insertTag: boolean = true;
+
+  /**
+   * Log output such that metadata are appended.
+   * Calling log(data) will not flush to console until you call flush()
+   *
+   * @constructor
+   * @param {object} task Task that is being reported.
+   * @param {number} pid PID of process running the task.
+   */
+  constructor(private task: any, private pid: number) { this.logHeader_(); }
+
+  /**
+   * Log the header for the current task including information such as
+   * PID, browser name/version, task Id, specs being run.
+   *
+   * @private
+   */
+  private logHeader_(): void {
+    let output = 'PID: ' + this.pid + EOL;
+    if (this.task.specs.length === 1) {
+      output += 'Specs: ' + this.task.specs.toString() + EOL + EOL;
+    }
+    this.log(output);
+  }
+
+  /**
+   * Flushes the buffer to stdout.
+   */
+  public flush(): void {
+    if (this.buffer) {
+      // Flush buffer if nonempty
+      Logger.print(EOL + '------------------------------------' + EOL);
+      Logger.print(this.buffer);
+      Logger.print(EOL);
+      this.buffer = '';
+    }
+  }
+
+  /**
+   * Log the data in the argument such that metadata are appended.
+   * The data will be saved to a buffer until flush() is called.
+   *
+   * @param {string} data
+   */
+  public log(data: string): void {
+    var tag = '[';
+    var capabilities = this.task.capabilities;
+    tag += (capabilities.logName) ?
+        capabilities.logName :
+        (capabilities.browserName) ? capabilities.browserName : '';
+    tag += (capabilities.version) ? (' ' + capabilities.version) : '';
+    tag += (capabilities.platform) ? (' ' + capabilities.platform) : '';
+    tag += (capabilities.logName && capabilities.count < 2) ? '' : ' #' +
+            this.task.taskId;
+    tag += '] ';
+
+    data = data.toString();
+    for (var i = 0; i < data.length; i++) {
+      if (this.insertTag) {
+        this.insertTag = false;
+        // This ensures that the '\x1B[0m' appears before the tag, so that
+        // data remains correct when color is not processed.
+        // See https://github.com/angular/protractor/pull/1216
+        if (data[i] === '\x1B' && data.substring(i, i + 4) === '\x1B[0m') {
+          this.buffer += ('\x1B[0m' + tag);
+          i += 3;
+          continue;
+        }
+
+        this.buffer += tag;
+      }
+      if (data[i] === '\n') {
+        this.insertTag = true;
+      }
+      this.buffer += data[i];
+    }
+  }
+}