upgrade gts to 1.0 (#572)

Author: mayurkale22

packages/opencensus-core/package-lock.json

@@ -60,7 +60,7 @@
     "@types/shimmer": "^1.0.1",
     "@types/uuid": "^3.4.3",
     "codecov": "^3.4.0",
-    "gts": "^0.9.0",
+    "gts": "^1.0.0",
     "intercept-stdout": "^0.1.2",
     "mocha": "^6.1.0",
     "nyc": "14.1.1",

packages/opencensus-core/package.json

@@ -31,23 +31,25 @@ export class ConsoleLogger implements types.Logger {
    * Constructs a new ConsoleLogger instance
    * @param options A logger configuration object.
    */
-  constructor(options?: types.LoggerOptions|string|number) {
+  constructor(options?: types.LoggerOptions | string | number) {
     let opt: types.LoggerOptions = {};
     if (typeof options === 'number') {
       if (options < 0) {
         options = 0;
       } else if (options > ConsoleLogger.LEVELS.length) {
         options = ConsoleLogger.LEVELS.length - 1;
       }
-      opt = {level: ConsoleLogger.LEVELS[options]};
+      opt = { level: ConsoleLogger.LEVELS[options] };
     } else if (typeof options === 'string') {
-      opt = {level: options};
+      opt = { level: options };
     } else {
       opt = options || {};
     }
     if (opt.level) this.level = opt.level;
-    this.logger =
-        logDriver({levels: ConsoleLogger.LEVELS, level: opt.level || 'silent'});
+    this.logger = logDriver({
+      levels: ConsoleLogger.LEVELS,
+      level: opt.level || 'silent',
+    });
   }
 
   /**
@@ -96,8 +98,10 @@ export class ConsoleLogger implements types.Logger {
  * https://github.com/cainus/logdriver/blob/bba1761737ca72f04d6b445629848538d038484a/index.js#L50
  * @param options A logger options or strig to logger in console
  */
-const logger = (options?: types.LoggerOptions|string|number): types.Logger => {
+const logger = (
+  options?: types.LoggerOptions | string | number
+): types.Logger => {
   return new ConsoleLogger(options);
 };
 
-export {logger};
+export { logger };

packages/opencensus-core/src/common/console-logger.ts

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-import {Logger} from './types';
+import { Logger } from './types';
 
 /** No-op implementation of Logger */
 class NoopLogger implements Logger {

packages/opencensus-core/src/common/noop-logger.ts

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-import {Timestamp} from '../metrics/export/types';
+import { Timestamp } from '../metrics/export/types';
 
 const MILLIS_PER_SECOND = 1e3;
 const NANOS_PER_MILLI = 1e3 * 1e3;
@@ -54,9 +54,9 @@ export function getTimestampWithProcessHRTime(): Timestamp {
   const nanos = hrtimeRefNanos + offsetNanos;
 
   if (nanos >= NANOS_PER_SECOND) {
-    return {seconds: seconds + 1, nanos: nanos % NANOS_PER_SECOND};
+    return { seconds: seconds + 1, nanos: nanos % NANOS_PER_SECOND };
   }
-  return {seconds, nanos};
+  return { seconds, nanos };
 }
 
 /**
@@ -68,13 +68,13 @@ export function getTimestampWithProcessHRTime(): Timestamp {
 export function timestampFromMillis(epochMilli: number): Timestamp {
   return {
     seconds: Math.floor(epochMilli / MILLIS_PER_SECOND),
-    nanos: (epochMilli % MILLIS_PER_SECOND) * NANOS_PER_MILLI
+    nanos: (epochMilli % MILLIS_PER_SECOND) * NANOS_PER_MILLI,
   };
 }
 
 setHrtimeReference();
 
 export const TEST_ONLY = {
   setHrtimeReference,
-  resetHrtimeFunctionCache
+  resetHrtimeFunctionCache,
 };

packages/opencensus-core/src/common/time-util.ts

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-import {LabelKey, LabelValue} from '../metrics/export/types';
+import { LabelKey, LabelValue } from '../metrics/export/types';
 
 /**
  * Validates that an object reference passed as a parameter to the calling
@@ -38,17 +38,22 @@ export function validateNotNull<T>(reference: T, errorMessage: string): T {
  * @param errorMessage The exception message to use if the check fails.
  */
 export function validateArrayElementsNotNull<T>(
-    array: T[], errorMessage: string) {
+  array: T[],
+  errorMessage: string
+) {
   const areAllDefined = array.every(
-      element => element !== null && typeof element !== 'undefined');
+    element => element !== null && typeof element !== 'undefined'
+  );
   if (!areAllDefined) {
     throw new Error(`${errorMessage} elements should not be a NULL`);
   }
 }
 
 /** Throws an error if any of the map elements is null. */
 export function validateMapElementNotNull<K, V>(
-    map: Map<K, V>, errorMessage: string) {
+  map: Map<K, V>,
+  errorMessage: string
+) {
   for (const [key, value] of map.entries()) {
     if (key == null || value == null) {
       throw new Error(`${errorMessage} elements should not be a NULL`);
@@ -58,11 +63,15 @@ export function validateMapElementNotNull<K, V>(
 
 /** Throws an error if any of the array element present in the map. */
 export function validateDuplicateKeys(
-    keys: LabelKey[], constantLabels: Map<LabelKey, LabelValue>) {
-  const keysAndConstantKeys =
-      new Set([...keys, ...constantLabels.keys()].map(k => k.key));
-  if (keysAndConstantKeys.size !== (keys.length + constantLabels.size)) {
+  keys: LabelKey[],
+  constantLabels: Map<LabelKey, LabelValue>
+) {
+  const keysAndConstantKeys = new Set(
+    [...keys, ...constantLabels.keys()].map(k => k.key)
+  );
+  if (keysAndConstantKeys.size !== keys.length + constantLabels.size) {
     throw new Error(
-        `The keys from LabelKeys should not be present in constantLabels or LabelKeys should not contains duplicate keys`);
+      `The keys from LabelKeys should not be present in constantLabels or LabelKeys should not contains duplicate keys`
+    );
   }
 }

packages/opencensus-core/src/common/validations.ts

@@ -1,4 +1,3 @@
-
 /**
  * Copyright 2018, OpenCensus Authors
  *
@@ -15,9 +14,9 @@
  * limitations under the License.
  */
 
-type Package = {
+interface Package {
   version: string;
-};
+}
 
 // Load the package details. Note that the `require` is performed at runtime,
 // which means package.json will be relative to the location of this file.

packages/opencensus-core/src/common/version.ts

@@ -15,11 +15,12 @@
  */
 
 import * as loggerTypes from '../common/types';
-import {Measurement, View} from '../stats/types';
-import {TagKey, TagValue} from '../tags/types';
+import { Measurement, View } from '../stats/types';
+import { TagKey, TagValue } from '../tags/types';
 import * as modelTypes from '../trace/model/types';
-import {ExporterBuffer} from './exporter-buffer';
-import {Exporter, ExporterConfig, StatsEventListener} from './types';
+import { ExporterBuffer } from './exporter-buffer';
+import * as logger from '../common/console-logger';
+import { Exporter, ExporterConfig, StatsEventListener } from './types';
 
 /** Do not send span data */
 export class NoopExporter implements Exporter {
@@ -34,8 +35,7 @@ export class NoopExporter implements Exporter {
 /** Format and sends span data to the console. */
 export class ConsoleExporter implements Exporter {
   /** Buffer object to store the spans. */
-  // @ts-ignore
-  private logger?: loggerTypes.Logger;
+  logger: loggerTypes.Logger;
   private buffer: ExporterBuffer;
 
   /**
@@ -45,7 +45,7 @@ export class ConsoleExporter implements Exporter {
    */
   constructor(config: ExporterConfig) {
     this.buffer = new ExporterBuffer(this, config);
-    this.logger = config.logger;
+    this.logger = config.logger || logger.logger();
   }
 
   onStartSpan(span: modelTypes.Span) {}
@@ -66,17 +66,16 @@ export class ConsoleExporter implements Exporter {
    * @param spans A list of spans to publish.
    */
   publish(spans: modelTypes.Span[]) {
-    spans.map((span) => {
+    spans.map(span => {
       const ROOT_STR = `RootSpan: {traceId: ${span.traceId}, spanId: ${
-          span.id}, name: ${span.name} }`;
-      const SPANS_STR: string[] = span.spans.map(
-          (child) => [`\t\t{spanId: ${child.id}, name: ${child.name}}`].join(
-              '\n'));
+        span.id
+      }, name: ${span.name} }`;
+      const SPANS_STR: string[] = span.spans.map(child =>
+        [`\t\t{spanId: ${child.id}, name: ${child.name}}`].join('\n')
+      );
 
       const result: string[] = [];
-      result.push(
-          ROOT_STR + '\n\tChildSpans:\n' +
-          `${SPANS_STR.join('\n')}`);
+      result.push(ROOT_STR + '\n\tChildSpans:\n' + `${SPANS_STR.join('\n')}`);
       console.log(`${result}`);
     });
     return Promise.resolve();
@@ -90,8 +89,9 @@ export class ConsoleStatsExporter implements StatsEventListener {
    * @param view registered view
    */
   onRegisterView(view: View) {
-    console.log(`View registered: ${view.name}, Measure registered: ${
-        view.measure.name}`);
+    console.log(
+      `View registered: ${view.name}, Measure registered: ${view.measure.name}`
+    );
   }
   /**
    * Event called when a measurement is recorded
@@ -100,7 +100,10 @@ export class ConsoleStatsExporter implements StatsEventListener {
    * @param tags The tags to which the value is applied
    */
   onRecord(
-      views: View[], measurement: Measurement, tags: Map<TagKey, TagValue>) {
+    views: View[],
+    measurement: Measurement,
+    tags: Map<TagKey, TagValue>
+  ) {
     console.log(`Measurement recorded: ${measurement.measure.name}`);
   }
 

packages/opencensus-core/src/exporters/console-exporter.ts

@@ -48,12 +48,12 @@ export class ExporterBuffer {
   constructor(exporter: types.Exporter, config: configTypes.BufferConfig) {
     this.exporter = exporter;
     this.logger = config.logger || logger.logger();
-    this.bufferSize = isNaN(Number(config.bufferSize)) ?
-        DEFAULT_BUFFER_SIZE :
-        Number(config.bufferSize);
-    this.bufferTimeout = isNaN(Number(config.bufferTimeout)) ?
-        DEFAULT_BUFFER_TIMEOUT :
-        Number(config.bufferTimeout);
+    this.bufferSize = isNaN(Number(config.bufferSize))
+      ? DEFAULT_BUFFER_SIZE
+      : Number(config.bufferSize);
+    this.bufferTimeout = isNaN(Number(config.bufferTimeout))
+      ? DEFAULT_BUFFER_TIMEOUT
+      : Number(config.bufferTimeout);
     return this;
   }
 

packages/opencensus-core/src/exporters/exporter-buffer.ts

@@ -14,8 +14,8 @@
  * limitations under the License.
  */
 
-import {Measurement, View} from '../stats/types';
-import {TagKey, TagValue} from '../tags/types';
+import { Measurement, View } from '../stats/types';
+import { TagKey, TagValue } from '../tags/types';
 import * as configTypes from '../trace/config/types';
 import * as modelTypes from '../trace/model/types';
 
@@ -25,7 +25,7 @@ export interface Exporter extends modelTypes.SpanEventListener {
    * Sends a list of spans to the service.
    * @param spans A list of spans to publish.
    */
-  publish(spans: modelTypes.Span[]): Promise<number|string|void>;
+  publish(spans: modelTypes.Span[]): Promise<number | string | void>;
 }
 
 /**
@@ -48,8 +48,10 @@ export interface StatsEventListener {
    * @param tags The tags to which the value is applied
    */
   onRecord(
-      views: View[], measurement: Measurement,
-      tags: Map<TagKey, TagValue>): void;
+    views: View[],
+    measurement: Measurement,
+    tags: Map<TagKey, TagValue>
+  ): void;
 
   /**
    * Starts the exporter that polls Metric from Metrics library and send