Engines enforcement

.github/workflows/check-build.yml

@@ -6,7 +6,7 @@ jobs:
 
     strategy:
       matrix:
-        node-version: [16.x]
+        node-version: [20.x, 21.x]
 
     steps:
       - uses: actions/checkout@v3
@@ -17,7 +17,7 @@ jobs:
           cache: 'npm'
       - run: npm install
       - run: npm run lint
-      - run: npm run test
+      - run: npm run unit-test
         env:
           BASE_URL: ${{ secrets.BASE_URL }}
           API_USERNAME: ${{ secrets.API_USERNAME }}

.npmrc

@@ -0,0 +1 @@
+engine-strict=true

lib/account-streamer.ts

@@ -3,6 +3,7 @@
 import type { JsonMap, JsonValue } from './utils/json-util'
 import { JsonBuilder } from './utils/json-util'
 import TastytradeSession from './models/tastytrade-session'
+import { MinTlsVersion } from './utils/constants'
 
 export enum STREAMER_STATE {
   Open = 0,
@@ -43,14 +44,14 @@
 export class AccountStreamer {
   private websocket: WebSocket | null = null
   private startResolve: ((result: boolean) => void) | null = null
   private startReject: ((reason?: any) => void) | null = null
   private requestCounter: number = 0
   private queued: string[] = []
 
   private heartbeatTimerId: number | NodeJS.Timeout | null = null
 
   lastCloseEvent: any = null
   lastErrorEvent: any = null
   private _streamerState: STREAMER_STATE = STREAMER_STATE.Closed
 
   private readonly streamerStateObservers: StreamerStateObserver[] = []
@@ -123,7 +124,10 @@
       return this.startPromise
     }
 
-    const websocket = (this.websocket = new WebSocket(this.url))
+    this.websocket = new WebSocket(this.url, [], {
+      minVersion: MinTlsVersion // TLS Config
+    })
+    const websocket = this.websocket
     this.lastCloseEvent = null
     this.lastErrorEvent = null
     websocket.addEventListener('open', this.handleOpen)
@@ -300,7 +304,7 @@
     this.queued = []
   }
 
-  private readonly handleOpen = (event: Event) => {
+  private readonly handleOpen = (event: WebSocket.Event) => {
     if (this.startResolve === null) {
       return
     }
@@ -315,7 +319,7 @@
     this.scheduleHeartbeatTimer()
   }
 
-  private readonly handleClose = (event: CloseEvent) => {
+  private readonly handleClose = (event: WebSocket.CloseEvent) => {
     this.logger.info('AccountStreamer closed', event)
     if (this.websocket === null) {
       return
@@ -326,7 +330,7 @@
     this.teardown()
   }
 
-  private readonly handleError = (event: Event) => {
+  private readonly handleError = (event: WebSocket.ErrorEvent) => {
     if (this.websocket === null) {
       return
     }
@@ -344,7 +348,7 @@
     this.teardown()
   }
 
-  private readonly handleMessage = (event: MessageEvent) => {
+  private readonly handleMessage = (event: WebSocket.MessageEvent) => {
     const json = JSON.parse(event.data as string) as JsonMap
 
     if (json.results !== undefined) {

lib/market-data-streamer.ts

@@ -1,6 +1,7 @@
 import WebSocket from 'isomorphic-ws'
 import _ from 'lodash'
 import { v4 as uuidv4 } from 'uuid'
+import { MinTlsVersion } from './utils/constants'
 
 export enum MarketDataSubscriptionType {
   Candle = 'Candle',
@@ -26,12 +27,12 @@
   Price = 'p'
 }
 
 export type MarketDataListener = (data: any) => void
 export type ErrorListener = (error: any) => void
 export type AuthStateListener = (isAuthorized: boolean) => void
 
 type QueuedSubscription = { symbol: string, subscriptionTypes: MarketDataSubscriptionType[], subscriptionArgs?: any }
 type SubscriptionOptions = { subscriptionTypes: MarketDataSubscriptionType[], channelId: number, subscriptionArgs?: any }
 export type CandleSubscriptionOptions = { period: number, type: CandleType, channelId: number }
 type Remover = () => void
 
@@ -45,7 +46,7 @@
 export default class MarketDataStreamer {
   private webSocket: WebSocket | null = null
   private token = ''
   private keepaliveIntervalId: any | null = null
   private dataListeners = new Map()
   private openChannels = new Set()
   private subscriptionsQueue: Map<number, QueuedSubscription[]> = new Map()
@@ -89,7 +90,9 @@
     }
 
     this.token = token
-    this.webSocket = new WebSocket(url)
+    this.webSocket = new WebSocket(url, [], {
+      minVersion: MinTlsVersion // TLS Config
+    })
     this.webSocket.onopen = this.onOpen.bind(this)
     this.webSocket.onerror = this.onError.bind(this)
     this.webSocket.onmessage = this.handleMessageReceived.bind(this)
@@ -243,7 +246,7 @@
       return
     }
 
     _.remove(queue, (queueItem: any) => queueItem.symbol === symbol)
   }
 
   private sendQueuedSubscriptions(channelId: number) {
@@ -343,9 +346,9 @@
     this.errorListeners.forEach(listener => listener(error))
   }
 
-  private handleMessageReceived(data: string) {
-    const messageData = _.get(data, 'data', data)
-    const jsonData = JSON.parse(messageData)
+  private handleMessageReceived(data: WebSocket.MessageEvent) {
+    const messageData = _.get(data, 'data', '{}')
+    const jsonData = JSON.parse(messageData as string)
     switch (jsonData.type) {
       case 'AUTH_STATE':
         this.handleAuthStateMessage(jsonData)

lib/services/tastytrade-http-client.ts

@@ -3,6 +3,8 @@ import axios from "axios"
 import qs from 'qs'
 import { recursiveDasherizeKeys } from "../utils/json-util"
 import _ from 'lodash'
+import https from 'https'
+import { MinTlsVersion } from "../utils/constants"
 
 const ParamsSerializer = {
   serialize: function (queryParams: object) {
@@ -12,9 +14,11 @@ const ParamsSerializer = {
 
 export default class TastytradeHttpClient{
     public readonly session: TastytradeSession
+    private readonly httpsAgent: https.Agent
 
     constructor(private readonly baseUrl: string) {
       this.session = new TastytradeSession()
+      this.httpsAgent = new https.Agent({ minVersion: MinTlsVersion })
     }
 
     private getDefaultHeaders(): any {
@@ -37,7 +41,8 @@ export default class TastytradeHttpClient{
         data: dasherizedData,
         headers: mergedHeaders, 
         params: dasherizedParams,
-        paramsSerializer: ParamsSerializer
+        paramsSerializer: ParamsSerializer,
+        httpsAgent: this.httpsAgent
        }, _.isEmpty)
 
       return axios.request(config)

lib/utils/constants.ts

@@ -0,0 +1 @@
+export const MinTlsVersion = 'TLSv1.2'

package.json

@@ -1,11 +1,15 @@
 {
   "name": "@tastytrade/api",
-  "version": "2.1.1",
+  "version": "3.0.0",
   "main": "dist/tastytrade-api.js",
   "typings": "dist/tastytrade-api.d.ts",
   "repository": "https://github.com/tastytrade/tastytrade-api-js",
   "license": "MIT",
   "description": "Typescript impelementation of tastytrade api",
+  "engines": {
+    "npm": ">=9.0.0",
+    "node": ">=20.0.0"
+  },
   "scripts": {
     "build": "tsc -p tsconfig.json",
     "test": "jest -i --restoreMocks",
@@ -26,9 +30,11 @@
     "ws": "^8.13.0"
   },
   "devDependencies": {
+    "@types/axios": "^0.14.0",
     "@types/jest": "^29.5.0",
-    "@types/node": "17.0.27",
+    "@types/node": "20.9.0",
     "@types/uuid": "^9.0.2",
+    "@types/ws": "^8.5.9",
     "@typescript-eslint/eslint-plugin": "^5.57.1",
     "@typescript-eslint/parser": "^5.57.1",
     "dotenv": "^16.0.3",