The node client now submits events to exceptionless!

Author: niemyjski

dist/exceptionless.es5.d.ts

@@ -28,17 +28,57 @@ export interface IEventQueue {
     process(): any;
     suspendProcessing(durationInMinutes?: number, discardFutureQueuedItems?: boolean, clearQueue?: boolean): any;
 }
+export interface IEnvironmentInfo {
+    processor_count?: number;
+    total_physical_memory?: number;
+    available_physical_memory?: number;
+    command_line?: string;
+    process_name?: string;
+    process_id?: string;
+    process_memory_size?: number;
+    thread_id?: string;
+    architecture?: string;
+    o_s_name?: string;
+    o_s_version?: string;
+    ip_address?: string;
+    machine_name?: string;
+    install_id?: string;
+    runtime_version?: string;
+    data?: any;
+}
+export declare class ContextData {
+    setException(exception: Error): void;
+    hasException: boolean;
+    getException(): Error;
+    markAsUnhandledError(): void;
+    isUnhandledError: boolean;
+    setSubmissionMethod(method: string): void;
+    getSubmissionMethod(): string;
+}
+export interface IEnvironmentInfoCollector {
+    getEnvironmentInfo(context: EventPluginContext): IEnvironmentInfo;
+}
+export interface IRequestInfoCollector {
+    getRequestInfo(context: EventPluginContext): IRequestInfo;
+}
 export interface IStorage<T> {
     save<T>(path: string, value: T): boolean;
     get(searchPattern?: string, limit?: number): T[];
     clear(searchPattern?: string): any;
     count(searchPattern?: string): number;
 }
+export interface ISubmissionClient {
+    submit(events: IEvent[], config: Configuration): Promise<SubmissionResponse>;
+    submitDescription(referenceId: string, description: IUserDescription, config: Configuration): Promise<SubmissionResponse>;
+    getSettings(config: Configuration): Promise<SettingsResponse>;
+}
 export interface IConfigurationSettings {
     apiKey?: string;
     serverUrl?: string;
+    environmentInfoCollector?: IEnvironmentInfoCollector;
     lastReferenceIdManager?: ILastReferenceIdManager;
     log?: ILog;
+    requestInfoCollector?: IRequestInfoCollector;
     submissionBatchSize?: number;
     submissionClient?: ISubmissionClient;
     storage?: IStorage<any>;
@@ -107,11 +147,6 @@ export declare class InMemoryStorage<T> implements IStorage<T> {
     clear(searchPattern?: string): void;
     count(searchPattern?: string): number;
 }
-export interface ISubmissionClient {
-    submit(events: IEvent[], config: Configuration): Promise<SubmissionResponse>;
-    submitDescription(referenceId: string, description: IUserDescription, config: Configuration): Promise<SubmissionResponse>;
-    getSettings(config: Configuration): Promise<SettingsResponse>;
-}
 export declare class Utils {
     static getHashCode(source: string): string;
     static guid(): string;
@@ -126,8 +161,10 @@ export declare class Configuration implements IConfigurationSettings {
     private _enabled;
     private _serverUrl;
     private _plugins;
+    environmentInfoCollector: IEnvironmentInfoCollector;
     lastReferenceIdManager: ILastReferenceIdManager;
     log: ILog;
+    requestInfoCollector: IRequestInfoCollector;
     submissionBatchSize: any;
     submissionClient: ISubmissionClient;
     storage: IStorage<any>;
@@ -149,40 +186,6 @@ export declare class Configuration implements IConfigurationSettings {
     private static _defaultSettings;
     static defaults: IConfigurationSettings;
 }
-export interface IUserDescription {
-    email_address?: string;
-    description?: string;
-    data?: any;
-}
-export declare class SettingsResponse {
-    success: boolean;
-    settings: any;
-    settingsVersion: number;
-    message: string;
-    exception: any;
-    constructor(success: boolean, settings: any, settingsVersion?: number, exception?: any, message?: string);
-}
-export declare class SubmissionResponse {
-    success: boolean;
-    badRequest: boolean;
-    serviceUnavailable: boolean;
-    paymentRequired: boolean;
-    unableToAuthenticate: boolean;
-    notFound: boolean;
-    requestEntityTooLarge: boolean;
-    statusCode: number;
-    message: string;
-    constructor(statusCode: number, message?: string);
-}
-export declare class ContextData {
-    setException(exception: Error): void;
-    hasException: boolean;
-    getException(): Error;
-    markAsUnhandledError(): void;
-    isUnhandledError: boolean;
-    setSubmissionMethod(method: string): void;
-    getSubmissionMethod(): string;
-}
 export declare class EventBuilder {
     target: IEvent;
     client: ExceptionlessClient;
@@ -315,25 +318,65 @@ export declare class RequestInfoPlugin implements IEventPlugin {
     priority: number;
     name: string;
     run(context: EventPluginContext): Promise<any>;
-    private getCookies();
+}
+export declare class EnvironmentInfoPlugin implements IEventPlugin {
+    priority: number;
+    name: string;
+    run(context: EventPluginContext): Promise<any>;
 }
 export declare class SubmissionMethodPlugin implements IEventPlugin {
     priority: number;
     name: string;
     run(context: EventPluginContext): Promise<any>;
 }
+export interface IUserDescription {
+    email_address?: string;
+    description?: string;
+    data?: any;
+}
+export declare class SettingsResponse {
+    success: boolean;
+    settings: any;
+    settingsVersion: number;
+    message: string;
+    exception: any;
+    constructor(success: boolean, settings: any, settingsVersion?: number, exception?: any, message?: string);
+}
+export declare class SubmissionResponse {
+    success: boolean;
+    badRequest: boolean;
+    serviceUnavailable: boolean;
+    paymentRequired: boolean;
+    unableToAuthenticate: boolean;
+    notFound: boolean;
+    requestEntityTooLarge: boolean;
+    statusCode: number;
+    message: string;
+    constructor(statusCode: number, message?: string);
+}
+export declare class NodeEnvironmentInfoCollector implements IEnvironmentInfoCollector {
+    getEnvironmentInfo(context: EventPluginContext): IEnvironmentInfo;
+    private getIpAddresses();
+}
+export declare class NodeRequestInfoCollector implements IRequestInfoCollector {
+    getRequestInfo(context: EventPluginContext): IRequestInfo;
+}
 export declare class NodeSubmissionClient implements ISubmissionClient {
     submit(events: IEvent[], config: Configuration): Promise<SubmissionResponse>;
     submitDescription(referenceId: string, description: IUserDescription, config: Configuration): Promise<SubmissionResponse>;
     getSettings(config: Configuration): Promise<SettingsResponse>;
     private getResponseMessage(msg);
-    private sendRequest(method, host, path, data?);
+    private sendRequest(method, host, path, apiKey, data?);
 }
 export declare class NodeBootstrapper implements IBootstrapper {
     register(): void;
     private getExitCodeReason(code);
     private isNode();
 }
+export declare class WebRequestInfoCollector implements IRequestInfoCollector {
+    getRequestInfo(context: EventPluginContext): IRequestInfo;
+    private getCookies();
+}
 export declare class DefaultSubmissionClient implements ISubmissionClient {
     submit(events: IEvent[], config: Configuration): Promise<SubmissionResponse>;
     submitDescription(referenceId: string, description: IUserDescription, config: Configuration): Promise<SubmissionResponse>;
@@ -347,28 +390,3 @@ export declare class WindowBootstrapper implements IBootstrapper {
     private getDefaultsSettingsFromScriptTag();
     private handleWindowOnError();
 }
-export interface IEnvironmentInfo {
-    processor_count?: number;
-    total_physical_memory?: number;
-    available_physical_memory?: number;
-    command_line?: string;
-    process_name?: string;
-    process_id?: string;
-    process_memory_size?: number;
-    thread_id?: string;
-    architecture?: string;
-    o_s_name?: string;
-    o_s_version?: string;
-    ip_address?: string;
-    machine_name?: string;
-    install_id?: string;
-    runtime_version?: string;
-    data?: any;
-}
-export interface IEnvironmentInfoCollector {
-    GetEnvironmentInfo(): IEnvironmentInfo;
-}
-export declare class NodeEnvironmentInfoCollector implements IEnvironmentInfoCollector {
-    GetEnvironmentInfo(): IEnvironmentInfo;
-    private getIpAddresses();
-}

dist/exceptionless.es5.js

@@ -1,15 +1,40 @@
 var express = require('express');
 var app = express();
 
-var exceptionless = require('../../dist/exceptionless.es5');
+var client = require('../../dist/exceptionless.es5').ExceptionlessClient.default;
+client.config.apiKey = 'LhhP1C9gijpSKCslHHCvwdSIz298twx271n1l6xw';
+client.config.serverUrl = 'http://localhost:50000';
+client.config.useDebugLogger();
 
 app.get('/', function (req, res) {
   res.send('Hello World!');
 });
 
+app.get('/about', function (req, res) {
+  client.submitFeatureUsage('about');
+  res.send('About');
+});
+
+app.get('/boom', function (req, res) {
+  throw new Error('Boom!!');
+});
+
+
+app.use(function(err, req, res, next) {
+  client.submitException(err);
+  res.status(500).send('Something broke!');
+});
+
+app.use(function(req, res, next) {
+  client.submitNotFound(req.originalUrl);
+  res.status(404).send('Sorry cant find that!');
+});
+
 var server = app.listen(3000, function () {
   var host = server.address().address;
   var port = server.address().port;
 
-  console.log('Example app listening at http://%s:%s', host, port);
+  var message = 'Example app listening at http://' + host + port;
+  console.log(message);
+  client.submitLog('app', message , 'Info');
 });

dist/exceptionless.es5.js.map

@@ -45,12 +45,14 @@ gulp.task('exceptionless.es5', ['exceptionless.es5.umd'], function() {
   gulp.src(files)
     .pipe(sourcemaps.init({ loadMaps: true }))
     .pipe(concat('exceptionless.es5.js'))
+    .pipe(replace('require(\'source-map/lib/source-map/source-map-consumer\')', '{}')) // needed for node until source maps dependency is fixed
     .pipe(sourcemaps.write('.'))
     .pipe(gulp.dest('dist'));
 
   return gulp.src(files)
     .pipe(sourcemaps.init({ loadMaps: true }))
     .pipe(concat('exceptionless.es5.min.js'))
+    .pipe(replace('require(\'source-map/lib/source-map/source-map-consumer\')', '{}')) // needed for node until source maps dependency is fixed
     .pipe(uglify())
     .pipe(sourcemaps.write('.'))
     .pipe(gulp.dest('dist'))

dist/exceptionless.es5.min.js

@@ -2,6 +2,8 @@ import { IBootstrapper } from 'IBootstrapper';
 import { Configuration } from '../configuration/Configuration';
 import { IConfigurationSettings } from '../configuration/IConfigurationSettings';
 import { IError } from '../models/IError';
+import { NodeEnvironmentInfoCollector } from '../services/NodeEnvironmentInfoCollector';
+import { NodeRequestInfoCollector } from '../services/NodeRequestInfoCollector';
 import { NodeSubmissionClient } from '../submission/NodeSubmissionClient';
 import { ExceptionlessClient } from '../ExceptionlessClient';
 import { Utils } from '../Utils';
@@ -12,6 +14,8 @@ export class NodeBootstrapper implements IBootstrapper {
       return;
     }
 
+    Configuration.defaults.environmentInfoCollector = new NodeEnvironmentInfoCollector();
+    Configuration.defaults.requestInfoCollector = new NodeRequestInfoCollector();
     Configuration.defaults.submissionClient = new NodeSubmissionClient();
     process.on('uncaughtException', function(error) {
       ExceptionlessClient.default.submitUnhandledException(error);

dist/exceptionless.es5.min.js.map

@@ -2,6 +2,7 @@ import { IBootstrapper } from 'IBootstrapper';
 import { Configuration } from '../configuration/Configuration';
 import { IConfigurationSettings } from '../configuration/IConfigurationSettings';
 import { IError } from '../models/IError';
+import { WebRequestInfoCollector } from '../services/WebRequestInfoCollector';
 import { DefaultSubmissionClient } from '../submission/DefaultSubmissionClient';
 import { ExceptionlessClient } from '../ExceptionlessClient';
 import { Utils } from '../Utils';
@@ -18,6 +19,7 @@ export class WindowBootstrapper implements IBootstrapper {
       Configuration.defaults.serverUrl = settings.serverUrl;
     }
 
+    Configuration.defaults.requestInfoCollector = new WebRequestInfoCollector();
     Configuration.defaults.submissionClient = new DefaultSubmissionClient();
     this.handleWindowOnError();
   }

example/express/app.js

@@ -10,6 +10,8 @@ import { EventPluginManager } from '../plugins/EventPluginManager';
 import { ReferenceIdPlugin } from '../plugins/default/ReferenceIdPlugin';
 import { IEventQueue } from '../queue/IEventQueue';
 import { DefaultEventQueue } from '../queue/DefaultEventQueue';
+import { IEnvironmentInfoCollector } from '../services/IEnvironmentInfoCollector';
+import { IRequestInfoCollector } from '../services/IRequestInfoCollector';
 import { IStorage } from '../storage/IStorage';
 import { InMemoryStorage } from '../storage/InMemoryStorage';
 import { ISubmissionClient } from '../submission/ISubmissionClient';
@@ -21,8 +23,10 @@ export class Configuration implements IConfigurationSettings {
   private _serverUrl:string = 'https://collector.exceptionless.io';
   private _plugins:IEventPlugin[] = [];
 
+  public environmentInfoCollector:IEnvironmentInfoCollector;
   public lastReferenceIdManager:ILastReferenceIdManager = new InMemoryLastReferenceIdManager();
   public log:ILog;
+  public requestInfoCollector:IRequestInfoCollector;
   public submissionBatchSize;
   public submissionClient:ISubmissionClient;
   public storage:IStorage<any>;
@@ -39,8 +43,10 @@ export class Configuration implements IConfigurationSettings {
 
     this.apiKey = settings.apiKey;
     this.serverUrl = settings.serverUrl;
+    this.environmentInfoCollector = inject(settings.environmentInfoCollector);
     this.lastReferenceIdManager = inject(settings.lastReferenceIdManager) || new InMemoryLastReferenceIdManager();
     this.log = inject(settings.log) || new NullLog();
+    this.requestInfoCollector = inject(settings.requestInfoCollector);
     this.submissionBatchSize = inject(settings.submissionBatchSize) || 50;
     this.submissionClient = inject(settings.submissionClient);
     this.storage = inject(settings.storage) || new InMemoryStorage<any>();