Refactor the SDK to use the new HTTP event tracker

.github/workflows/pr-preview.yaml

@@ -0,0 +1,50 @@
+name: PR preview
+
+on:
+  pull_request:
+    types:
+      - synchronize
+      - opened
+
+env:
+  BASE_ENDPOINT: https://api.croct.io
+  MAX_QUERY_LENGTH: 500
+
+jobs:
+  preview:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - uses: actions/setup-node@v4
+        with:
+          node-version: 20
+
+      - name: Cache dependencies
+        id: cache-dependencies
+        uses: actions/cache@v4
+        with:
+          path: node_modules
+          key: node_modules-${{ hashFiles('**/package-lock.json') }}
+
+      - name: Install dependencies
+        if: steps.cache-dependencies.outputs.cache-hit != 'true'
+        run: npm ci
+
+      - name: Build package
+        run: npm run build
+
+      - name: Prepare release
+        run: |-
+          cp package.json LICENSE README.md build/
+          cd build
+          find . -type f -path '*/*\.js.map' -exec sed -i -e "s~../src~src~" {} +          
+          sed -i -e "s~<@version@>~0.0.0-dev~" constants.*
+          sed -i -e "s~<@baseEndpointUrl@>~${BASE_ENDPOINT}~" constants.*
+          sed -i -e "s~parseInt('<@maxQueryLength@>', 10)~${MAX_QUERY_LENGTH}~" constants.*
+          cp -r ../src src
+
+      - name: Publish preview
+        run: |-
+          npx pkg-pr-new publish \
+            --compact --comment=update \
+            ./build

package.json

@@ -39,8 +39,6 @@
     "jest": "^29.3.1",
     "jest-environment-jsdom": "^29.3.1",
     "jest-extended": "^4.0.0",
-    "jest-websocket-mock": "^2.4.0",
-    "mock-socket": "^9.1.5",
     "node-fetch": "^2.6.7",
     "ts-jest": "^29.0.3",
     "typescript": "^5.0.0"

src/channel/channel.ts

@@ -1,3 +1,31 @@
+import {formatMessage} from '../error';
+
+export class MessageDeliveryError extends Error {
+    public readonly retryable: boolean;
+
+    public constructor(message: string, retryable: boolean) {
+        super(message);
+
+        this.retryable = retryable;
+
+        Object.setPrototypeOf(this, MessageDeliveryError.prototype);
+    }
+
+    public static fromCause(cause: any, retryable?: boolean): MessageDeliveryError {
+        if (cause instanceof MessageDeliveryError) {
+            return cause;
+        }
+
+        const error = new MessageDeliveryError(formatMessage(cause), retryable ?? true);
+
+        if (cause instanceof Error) {
+            error.stack = cause.stack;
+        }
+
+        return error;
+    }
+}
+
 export interface Closeable {
     close(): Promise<void>;
 }

src/channel/guaranteedChannel.ts

@@ -1,5 +1,5 @@
 import {Logger, NullLogger} from '../logging';
-import {DuplexChannel, OutputChannel} from './channel';
+import {DuplexChannel, MessageDeliveryError, OutputChannel} from './channel';
 
 export type MessageStamper<M, S> = {
     generate(message: M): S,
@@ -49,7 +49,7 @@ export class GuaranteedChannel<M, S> implements OutputChannel<M> {
 
     public publish(message: M): Promise<void> {
         if (this.closed) {
-            return Promise.reject(new Error('Channel is closed.'));
+            return Promise.reject(new MessageDeliveryError('Channel is closed.', false));
         }
 
         return new Promise((resolve, reject): void => {
@@ -99,7 +99,7 @@ export class GuaranteedChannel<M, S> implements OutputChannel<M> {
                     () => {
                         if (this.closed) {
                             // Cancel delay immediately when the channel is closed
-                            abort(new Error('Connection deliberately closed.'));
+                            abort(new MessageDeliveryError('Connection deliberately closed.', false));
                         }
                     },
                     0,
@@ -109,7 +109,7 @@ export class GuaranteedChannel<M, S> implements OutputChannel<M> {
 
                 timeoutTimer = window.setTimeout(
                     () => {
-                        abort(new Error('Maximum confirmation time reached.'));
+                        abort(new MessageDeliveryError('Maximum confirmation time reached.', true));
                     },
                     this.options.ackTimeout,
                 );