port NodeBackend to NodeClient

Author: Lms24

packages/node/src/client.ts

@@ -1,17 +1,21 @@
-import { BaseClient, Scope, SDK_VERSION } from '@sentry/core';
+import { BaseClient, getEnvelopeEndpointWithUrlEncodedAuth, initAPIDetails, Scope, SDK_VERSION } from '@sentry/core';
 import { SessionFlusher } from '@sentry/hub';
-import { Event, EventHint } from '@sentry/types';
-import { logger } from '@sentry/utils';
+import { Event, EventHint, Severity, Transport, TransportOptions } from '@sentry/types';
+import { logger, makeDsn, resolvedSyncPromise } from '@sentry/utils';
 
 import { NodeBackend } from './backend';
+import { eventFromMessage, eventFromUnknownInput } from './eventbuilder';
 import { IS_DEBUG_BUILD } from './flags';
+import { HTTPSTransport, HTTPTransport, makeNodeTransport } from './transports';
 import { NodeOptions } from './types';
 
 /**
  * The Sentry Node SDK Client.
  *
  * @see NodeOptions for documentation on configuration options.
  * @see SentryClient for usage documentation.
+ *
+ * TODO: remove NodeBackend
  */
 export class NodeClient extends BaseClient<NodeBackend, NodeOptions> {
   protected _sessionFlusher: SessionFlusher | undefined;
@@ -33,6 +37,7 @@ export class NodeClient extends BaseClient<NodeBackend, NodeOptions> {
       version: SDK_VERSION,
     };
 
+    // TODO: remove NodeBackend param
     super(NodeBackend, options);
   }
 
@@ -106,6 +111,21 @@ export class NodeClient extends BaseClient<NodeBackend, NodeOptions> {
     }
   }
 
+  /**
+   * @inheritDoc
+   */
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any, @typescript-eslint/explicit-module-boundary-types
+  public eventFromException(exception: any, hint?: EventHint): PromiseLike<Event> {
+    return resolvedSyncPromise(eventFromUnknownInput(exception, hint));
+  }
+
+  /**
+   * @inheritDoc
+   */
+  public eventFromMessage(message: string, level: Severity = Severity.Info, hint?: EventHint): PromiseLike<Event> {
+    return resolvedSyncPromise(eventFromMessage(message, level, hint, this._options.attachStacktrace));
+  }
+
   /**
    * @inheritDoc
    */
@@ -128,4 +148,45 @@ export class NodeClient extends BaseClient<NodeBackend, NodeOptions> {
       this._sessionFlusher.incrementSessionStatusCount();
     }
   }
+
+  /**
+   * @inheritDoc
+   */
+  protected _setupTransport(): Transport {
+    if (!this._options.dsn) {
+      // We return the noop transport here in case there is no Dsn.
+      return super._setupTransport();
+    }
+
+    const dsn = makeDsn(this._options.dsn);
+
+    const transportOptions: TransportOptions = {
+      ...this._options.transportOptions,
+      ...(this._options.httpProxy && { httpProxy: this._options.httpProxy }),
+      ...(this._options.httpsProxy && { httpsProxy: this._options.httpsProxy }),
+      ...(this._options.caCerts && { caCerts: this._options.caCerts }),
+      dsn: this._options.dsn,
+      tunnel: this._options.tunnel,
+      _metadata: this._options._metadata,
+    };
+
+    if (this._options.transport) {
+      return new this._options.transport(transportOptions);
+    }
+
+    const api = initAPIDetails(transportOptions.dsn, transportOptions._metadata, transportOptions.tunnel);
+    const url = getEnvelopeEndpointWithUrlEncodedAuth(api.dsn, api.tunnel);
+
+    this._newTransport = makeNodeTransport({
+      url,
+      headers: transportOptions.headers,
+      proxy: transportOptions.httpProxy,
+      caCerts: transportOptions.caCerts,
+    });
+
+    if (dsn.protocol === 'http') {
+      return new HTTPTransport(transportOptions);
+    }
+    return new HTTPSTransport(transportOptions);
+  }
 }