chore: bump uWebSockets version

package.json

@@ -2,7 +2,7 @@
   "name": "tardis-machine",
   "version": "3.28.0",
   "engines": {
-    "node": ">=12"
+    "node": ">=16"
   },
   "description": "Locally runnable server with built-in data caching, providing both tick-level historical and consolidated real-time cryptocurrency market data via HTTP and WebSocket APIs",
   "main": "dist/index.js",
@@ -60,7 +60,7 @@
     "find-my-way": "^6.3.0",
     "is-docker": "^2.2.1",
     "tardis-dev": "^13.28.0",
-    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.10.0",
+    "uWebSockets.js": "github:uNetworking/uWebSockets.js#v20.42.0",
     "yargs": "^17.5.1"
   },
   "devDependencies": {

src/tardismachine.ts

@@ -54,7 +54,7 @@ export class TardisMachine {
           context
         )
       },
-      open: (ws: WebSocket) => {
+      open: (ws: any) => {
         const path = ws.req.getUrl().toLocaleLowerCase()
         ws.closed = false
         const matchingRoute = wsRoutes[path]
@@ -66,13 +66,13 @@ export class TardisMachine {
         }
       },
 
-      message: (ws: WebSocket, message: ArrayBuffer) => {
+      message: (ws: any, message: ArrayBuffer) => {
         if (ws.onmessage !== undefined) {
           ws.onmessage(message)
         }
       },
 
-      close: (ws: WebSocket) => {
+      close: (ws: any) => {
         ws.closed = true
         if (ws.onclose !== undefined) {
           ws.onclose()

src/ws/replay.ts

@@ -8,7 +8,7 @@ import { SubscriptionMapper, subscriptionsMappers } from './subscriptionsmappers
 const replaySessions: { [sessionKey: string]: ReplaySession | undefined } = {}
 let sessionsCounter = 0
 
-export function replayWS(ws: WebSocket, req: HttpRequest) {
+export function replayWS(ws: any, req: HttpRequest) {
   const parsedQuery = qs.decode(req.getQuery())
   const from = parsedQuery['from'] as string
   const to = parsedQuery['to'] as string
@@ -173,7 +173,7 @@ class WebsocketConnection {
   private readonly _subscriptionsMapper: SubscriptionMapper
   public subscriptionsCount = 0
 
-  constructor(public readonly ws: WebSocket, exchange: Exchange, from: string, to: string) {
+  constructor(public readonly ws: any, exchange: Exchange, from: string, to: string) {
     this.replayOptions = {
       exchange,
       from,

src/ws/replaynormalized.ts

@@ -4,7 +4,7 @@ import { HttpRequest, WebSocket } from 'uWebSockets.js'
 import { debug } from '../debug'
 import { constructDataTypeFilter, getComputables, getNormalizers, ReplayNormalizedRequestOptions, wait } from '../helpers'
 
-export async function replayNormalizedWS(ws: WebSocket, req: HttpRequest) {
+export async function replayNormalizedWS(ws: any, req: HttpRequest) {
   let messages: AsyncIterableIterator<any> | undefined
   try {
     const startTimestamp = new Date().getTime()

src/ws/streamnormalized.ts

@@ -4,7 +4,7 @@ import { HttpRequest, WebSocket } from 'uWebSockets.js'
 import { debug } from '../debug'
 import { constructDataTypeFilter, getComputables, getNormalizers, StreamNormalizedRequestOptions, wait } from '../helpers'
 
-export async function streamNormalizedWS(ws: WebSocket, req: HttpRequest) {
+export async function streamNormalizedWS(ws: any, req: HttpRequest) {
   let messages: AsyncIterableIterator<any> | undefined
 
   try {