tardis-machine
Advanced tools
Comparing version 3.28.1 to 3.28.2
@@ -1,3 +0,3 @@ | ||
import { HttpRequest, WebSocket } from 'uWebSockets.js'; | ||
export declare function replayWS(ws: WebSocket, req: HttpRequest): void; | ||
import { HttpRequest } from 'uWebSockets.js'; | ||
export declare function replayWS(ws: any, req: HttpRequest): void; | ||
//# sourceMappingURL=replay.d.ts.map |
@@ -1,3 +0,3 @@ | ||
import { HttpRequest, WebSocket } from 'uWebSockets.js'; | ||
export declare function replayNormalizedWS(ws: WebSocket, req: HttpRequest): Promise<void>; | ||
import { HttpRequest } from 'uWebSockets.js'; | ||
export declare function replayNormalizedWS(ws: any, req: HttpRequest): Promise<void>; | ||
//# sourceMappingURL=replaynormalized.d.ts.map |
@@ -1,3 +0,3 @@ | ||
import { HttpRequest, WebSocket } from 'uWebSockets.js'; | ||
export declare function streamNormalizedWS(ws: WebSocket, req: HttpRequest): Promise<void>; | ||
import { HttpRequest } from 'uWebSockets.js'; | ||
export declare function streamNormalizedWS(ws: any, req: HttpRequest): Promise<void>; | ||
//# sourceMappingURL=streamnormalized.d.ts.map |
{ | ||
"name": "tardis-machine", | ||
"version": "3.28.1", | ||
"version": "3.28.2", | ||
"engines": { | ||
"node": ">=12" | ||
"node": ">=16" | ||
}, | ||
@@ -63,3 +63,3 @@ "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", | ||
"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" | ||
@@ -66,0 +66,0 @@ }, |
@@ -57,3 +57,3 @@ import findMyWay from 'find-my-way' | ||
}, | ||
open: (ws: WebSocket) => { | ||
open: (ws: any) => { | ||
const path = ws.req.getUrl().toLocaleLowerCase() | ||
@@ -70,3 +70,3 @@ ws.closed = false | ||
message: (ws: WebSocket, message: ArrayBuffer) => { | ||
message: (ws: any, message: ArrayBuffer) => { | ||
if (ws.onmessage !== undefined) { | ||
@@ -77,3 +77,3 @@ ws.onmessage(message) | ||
close: (ws: WebSocket) => { | ||
close: (ws: any) => { | ||
ws.closed = true | ||
@@ -80,0 +80,0 @@ if (ws.onclose !== undefined) { |
@@ -11,3 +11,3 @@ import qs from 'querystring' | ||
export function replayWS(ws: WebSocket, req: HttpRequest) { | ||
export function replayWS(ws: any, req: HttpRequest) { | ||
const parsedQuery = qs.decode(req.getQuery()) | ||
@@ -177,3 +177,3 @@ const from = parsedQuery['from'] as string | ||
constructor(public readonly ws: WebSocket, exchange: Exchange, from: string, to: string) { | ||
constructor(public readonly ws: any, exchange: Exchange, from: string, to: string) { | ||
this.replayOptions = { | ||
@@ -180,0 +180,0 @@ exchange, |
@@ -7,3 +7,3 @@ import qs from 'querystring' | ||
export async function replayNormalizedWS(ws: WebSocket, req: HttpRequest) { | ||
export async function replayNormalizedWS(ws: any, req: HttpRequest) { | ||
let messages: AsyncIterableIterator<any> | undefined | ||
@@ -10,0 +10,0 @@ try { |
@@ -7,3 +7,3 @@ import qs from 'querystring' | ||
export async function streamNormalizedWS(ws: WebSocket, req: HttpRequest) { | ||
export async function streamNormalizedWS(ws: any, req: HttpRequest) { | ||
let messages: AsyncIterableIterator<any> | undefined | ||
@@ -10,0 +10,0 @@ |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
GitHub dependency
Supply chain riskContains a dependency which resolves to a GitHub URL. Dependencies fetched from GitHub specifiers are not immutable can be used to inject untrusted code or reduce the likelihood of a reproducible install.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
GitHub dependency
Supply chain riskContains a dependency which resolves to a GitHub URL. Dependencies fetched from GitHub specifiers are not immutable can be used to inject untrusted code or reduce the likelihood of a reproducible install.
Found 1 instance in 1 package
188946