refactor: type, classes overall refactoring

Author: silva-fabio

package.json

@@ -6,7 +6,10 @@
   "types": "build/src/index.d.js",
   "repository": "census-instrumentation/opencensus-node",
   "scripts": {
-    "postinstall": "scripts/update_lerna_modules_links.sh"
+    "postinstall": "npm run bootstrap;npm run build;",
+    "build" : "node_modules/.bin/lerna run build",
+    "bootstrap": "node_modules/.bin/lerna bootstrap",
+    "bump": "node_modules/.bin/lerna publish"
   },
   "keywords": [
     "opencensus",

packages/opencensus-core/package-lock.json

@@ -7,7 +7,7 @@
   "repository": "census-instrumentation/opencensus-node",
   "scripts": {
     "build": "node_modules/.bin/tsc --declaration",
-    "test": "npm run script run-unit-tests",
+    "test": "node_modules/.bin/mocha 'build/test/**/*.js' --reporter spec",
     "clean": "rimraf build/*"
   },
   "keywords": [
@@ -38,6 +38,7 @@
     "@types/mocha": "^2.2.48",
     "@types/node": "^9.4.7",
     "@types/semver": "^5.5.0",
+    "@types/shimmer": "^1.0.1",
     "@types/uuid": "^3.4.3",
     "gts": "^0.5.1",
     "mocha": "^5.0.4",
@@ -50,6 +51,7 @@
     "continuation-local-storage": "^3.2.1",
     "debug": "^3.1.0",
     "semver": "^5.5.0",
+    "shimmer": "^1.2.0",
     "uuid": "^3.2.1"
   }
 }

packages/opencensus-core/package.json

@@ -17,11 +17,11 @@
 import * as uuidv4 from 'uuid/v4';
 
 import {debug} from '../internal/util';
-import {RootSpan} from '../trace/types';
-import {OnEndSpanEventListener} from '../trace/types';
+import {RootSpan} from '../trace/model/types';
+import {OnEndSpanEventListener} from '../trace/model/types';
 
-import {Exporter} from './exporter';
-import {ExporterOptions} from './exporterOptions';
+import {Exporter} from './types';
+import {ExporterOptions} from './types';
 
 // TODO: Implement default size based on application size
 const DEFAULT_BUFFER_SIZE = 3;

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

@@ -14,16 +14,13 @@
  * limitations under the License.
  */
 
+import { RootSpan } from '../trace/model/types';
+import { Exporter, ExporterOptions } from '../exporters/types';
 
-import {RootSpan} from '../trace/types';
-import {OnEndSpanEventListener} from '../trace/types';
-import {ExporterOptions} from './exporterOptions';
-
-export interface Exporter { publish(rootSpans: RootSpan[]); }
 
 /** Do not send span data */
 export class NoopExporter implements Exporter {
-  publish(rootSpans: RootSpan[]) {}
+  publish(rootSpans: RootSpan[]) { }
 }
 
 /** Format and sends span data to the console. */

…pencensus-core/src/exporters/exporter.ts …s-core/src/exporters/console-exporter.tspackages/opencensus-core/src/exporters/exporter.ts renamed to packages/opencensus-core/src/exporters/console-exporter.ts packages/opencensus-core/src/exporters/exporter.ts renamed to packages/opencensus-core/src/exporters/console-exporter.ts

@@ -14,6 +14,11 @@
  * limitations under the License.
  */
 
+
+import {RootSpan} from '../trace/model/types';
+
+export interface Exporter { publish(rootSpans: RootSpan[]); }
+
 /**
  * TODO: Interface to exporters options
  */

…us-core/src/exporters/exporterOptions.ts …s/opencensus-core/src/exporters/types.tspackages/opencensus-core/src/exporters/exporterOptions.ts renamed to packages/opencensus-core/src/exporters/types.ts packages/opencensus-core/src/exporters/exporterOptions.ts renamed to packages/opencensus-core/src/exporters/types.ts

@@ -1,4 +1,3 @@
-
 /**
  * Copyright 2018 Google Inc. All Rights Reserved.
  *
@@ -15,15 +14,28 @@
  * limitations under the License.
  */
 
-export * from './exporters/buffer';
-export * from './exporters/exporter';
-export * from './exporters/exporterOptions';
-export * from './internal/clock';
-export * from './internal/util';
-export * from './trace/config/sampler';
+
+// opencensus core api interfaces 
+export * from './trace/types';
+export * from './trace/model/types';
+export * from './trace/config/types';
 export * from './trace/instrumentation/types';
+export * from './exporters/types';
+
+// domain models impls
 export * from './trace/model/rootspan';
 export * from './trace/model/span';
 export * from './trace/model/tracer';
-export * from './trace/types';
 
+// sampler impl
+export * from './trace/config/sampler';
+
+// base instrumetation class
+export * from './trace/instrumentation/baseplugin';
+
+// console exporter and buffer impls 
+export * from './exporters/buffer';
+export * from './exporters/consolelog-exporter';
+
+// util
+export * from './internal/util';

packages/opencensus-core/src/index.ts

@@ -0,0 +1,51 @@
+/**
+ * Copyright 2018 Google Inc. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+/**
+ * This interface represent the probability of a tracer.
+ */
+export interface Sampler {
+
+  /**
+   * Set idUpperBound with MAX_NUMBER that is equivalent the probability be 1
+   * @returns a Sampler object
+   */
+
+  always(): Sampler;
+  /**
+   * Set idUpperBound with MIN_NUMBER that is equivalent the probability be 0
+   * @returns a Sampler object
+   */
+
+  never(): Sampler;
+
+  /**
+   * Set idUpperBound with the probability. If probability
+   * parameter is bigger then 1 set always. If probability parameter less
+   * than 0, set never.
+   * @param probability probability between 0 and 1
+   * @returns a Sampler object
+   */
+  probability(probability: number): Sampler;
+
+  /**
+   * Checks if trace belong the sample.
+   * @param traceId Used to check the probability
+   * @returns a boolean. True if the traceId is in probability
+   * False if the traceId is not in probability.
+   */
+  shouldSample(traceId: string): boolean;
+}

packages/opencensus-core/src/trace/config/types.ts

@@ -0,0 +1,60 @@
+/**
+ * Copyright 2018 Google Inc. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+import * as shimmer from 'shimmer';
+import {Tracer} from '../model/types';
+
+/**
+ * This class represent the base to patch plugin
+ */
+export abstract class BasePlugin {
+  exporter: any;
+  moduleName: string;
+  tracer: Tracer;
+  version: string;
+
+  constructor(moduleName: string) {
+    this.moduleName = moduleName;
+  }
+  /**
+   * Set modified plugin to the context.
+   * @param exporter object module to set on context
+   * @param tracer tracer relating to context
+   * @param version module version description
+   */
+  protected setPluginContext(exporter: any, tracer: Tracer, version: string) {
+    this.exporter = exporter;
+    this.tracer = tracer;
+    this.version = version;
+  }
+
+  protected wrap(nodule, name, wrapper ) {
+      shimmer.wrap(nodule, name, wrapper )
+  }
+
+  protected unwrap(nodule, name) {
+      shimmer.unwrap(nodule, name);
+  }
+
+  protected massWrap(nodule,names, wrapper) {
+     shimmer.massWrap(nodule, names, wrapper);
+  } 
+
+  protected massUnwrap(nodule,names) {
+    shimmer.massUnwrap(nodule, names);
+  } 
+ 
+ 
+}

packages/opencensus-core/src/trace/instrumentation/base-plugin.ts

@@ -14,33 +14,12 @@
  * limitations under the License.
  */
 
+import {Tracer} from "../model/types";
+
 /**
  * Interface Plugin to apply patch.
  */
-export interface Plugin<T> {
-  applyPatch(module: {}, tracer: T, version: string): void;
+export interface Plugin {
+  applyPatch(module: {}, tracer: Tracer, version: string): any;
+  applyUnpatch(): void;
 }
-/**
- * This class represent the base to patch plugin
- */
-export abstract class BasePlugin<T> {
-  module: {};
-  moduleName: string;
-  tracer: T;
-  version: string;
-
-  constructor(moduleName: string) {
-    this.moduleName = moduleName;
-  }
-  /**
-   * Set modified plugin to the context.
-   * @param http object module to set on context
-   * @param tracer tracer relating to context
-   * @param version module version description
-   */
-  setPluginContext(http: {}, tracer: T, version: string) {
-    this.module = http;
-    this.tracer = tracer;
-    this.version = version;
-  }
-}