Use SyncPromise static methods everywhere

Author: kamilogorek

packages/browser/src/sdk.ts

@@ -1,5 +1,5 @@
 import { getCurrentHub, initAndBind, Integrations as CoreIntegrations } from '@sentry/core';
-import { getGlobalObject } from '@sentry/utils';
+import { getGlobalObject, SyncPromise } from '@sentry/utils';
 
 import { BrowserOptions } from './backend';
 import { BrowserClient, ReportDialogOptions } from './client';
@@ -138,7 +138,7 @@ export function flush(timeout?: number): Promise<boolean> {
   if (client) {
     return client.flush(timeout);
   }
-  return Promise.reject(false);
+  return SyncPromise.reject(false);
 }
 
 /**
@@ -152,7 +152,7 @@ export function close(timeout?: number): Promise<boolean> {
   if (client) {
     return client.close(timeout);
   }
-  return Promise.reject(false);
+  return SyncPromise.reject(false);
 }
 
 /**

packages/browser/src/transports/xhr.ts

@@ -1,4 +1,5 @@
 import { Event, Response, Status } from '@sentry/types';
+import { SyncPromise } from '@sentry/utils';
 
 import { BaseTransport } from './base';
 
@@ -9,7 +10,7 @@ export class XHRTransport extends BaseTransport {
    */
   public sendEvent(event: Event): Promise<Response> {
     return this._buffer.add(
-      new Promise<Response>((resolve, reject) => {
+      new SyncPromise<Response>((resolve, reject) => {
         const request = new XMLHttpRequest();
 
         request.onreadystatechange = () => {

packages/browser/test/unit/mocks/simpletransport.ts

@@ -1,10 +1,12 @@
+import { SyncPromise } from '@sentry/utils';
+
 import { Event, Response, Status } from '../../../src';
 import { BaseTransport } from '../../../src/transports';
 
 export class SimpleTransport extends BaseTransport {
   public sendEvent(_: Event): Promise<Response> {
     return this._buffer.add(
-      Promise.resolve({
+      SyncPromise.resolve({
         status: Status.fromHttpCode(200),
       }),
     );

packages/core/src/baseclient.ts

@@ -205,7 +205,7 @@ export abstract class BaseClient<B extends Backend, O extends Options> implement
 
   /** Waits for the client to be done with processing. */
   protected _isClientProcessing(timeout?: number): Promise<{ ready: boolean; interval: number }> {
-    return new Promise<{ ready: boolean; interval: number }>(resolve => {
+    return new SyncPromise<{ ready: boolean; interval: number }>(resolve => {
       let ticked: number = 0;
       const tick: number = 1;
 

packages/core/src/transports/noop.ts

@@ -1,12 +1,13 @@
 import { Event, Response, Status, Transport } from '@sentry/types';
+import { SyncPromise } from '@sentry/utils';
 
 /** Noop transport */
 export class NoopTransport implements Transport {
   /**
    * @inheritDoc
    */
   public sendEvent(_: Event): Promise<Response> {
-    return Promise.resolve({
+    return SyncPromise.resolve({
       reason: `NoopTransport: Event has been skipped because no Dsn is configured.`,
       status: Status.Skipped,
     });
@@ -16,6 +17,6 @@ export class NoopTransport implements Transport {
    * @inheritDoc
    */
   public close(_?: number): Promise<boolean> {
-    return Promise.resolve(true);
+    return SyncPromise.resolve(true);
   }
 }

packages/core/test/mocks/transport.ts

@@ -1,8 +1,8 @@
 import { Event, Response, Status, Transport } from '@sentry/types';
-import { PromiseBuffer } from '@sentry/utils';
+import { PromiseBuffer, SyncPromise } from '@sentry/utils';
 
 async function sleep(delay: number): Promise<void> {
-  return new Promise(resolve => setTimeout(resolve, delay));
+  return new SyncPromise(resolve => setTimeout(resolve, delay));
 }
 
 export class FakeTransport implements Transport {
@@ -16,7 +16,7 @@ export class FakeTransport implements Transport {
   public sendEvent(_event: Event): Promise<Response> {
     this.sendCalled += 1;
     return this._buffer.add(
-      new Promise(async res => {
+      new SyncPromise(async res => {
         await sleep(this.delay);
         this.sentCount += 1;
         res({ status: Status.Success });

packages/utils/src/promisebuffer.ts

@@ -1,4 +1,5 @@
 import { SentryError } from './error';
+import { SyncPromise } from './syncpromise';
 
 /** A simple queue that holds promises. */
 export class PromiseBuffer<T> {
@@ -22,7 +23,7 @@ export class PromiseBuffer<T> {
    */
   public add(task: Promise<T>): Promise<T> {
     if (!this.isReady()) {
-      return Promise.reject(new SentryError('Not adding Promise due to buffer limit reached.'));
+      return SyncPromise.reject(new SentryError('Not adding Promise due to buffer limit reached.'));
     }
     if (this._buffer.indexOf(task) === -1) {
       this._buffer.push(task);
@@ -63,7 +64,7 @@ export class PromiseBuffer<T> {
    * @param timeout Number in ms to wait until it resolves with false.
    */
   public drain(timeout?: number): Promise<boolean> {
-    return new Promise<boolean>(resolve => {
+    return new SyncPromise<boolean>(resolve => {
       const capturedSetTimeout = setTimeout(() => {
         if (timeout && timeout > 0) {
           resolve(false);

packages/utils/src/syncpromise.ts

@@ -78,7 +78,6 @@ export class SyncPromise<T> implements Promise<T> {
             if (counter !== 0) {
               return;
             }
-
             resolve(resolvedCollection);
           })
           .catch(reject);