@types/socketcluster-server
Advanced tools
Comparing version
@@ -1,15 +0,15 @@ | ||
import { IncomingMessage } from 'http'; | ||
import { AuthTokenExpiredError } from 'sc-errors'; | ||
import { IncomingMessage } from "http"; | ||
import { AuthTokenExpiredError } from "sc-errors"; | ||
import AGServerSocket = require('./serversocket'); | ||
import AGServerSocket = require("./serversocket"); | ||
declare const HANDSHAKE_WS = 'handshakeWS'; | ||
declare const HANDSHAKE_SC = 'handshakeSC'; | ||
declare const MESSAGE = 'message'; | ||
declare const TRANSMIT = 'transmit'; | ||
declare const INVOKE = 'invoke'; | ||
declare const SUBSCRIBE = 'subscribe'; | ||
declare const PUBLISH_IN = 'publishIn'; | ||
declare const PUBLISH_OUT = 'publishOut'; | ||
declare const AUTHENTICATE = 'authenticate'; | ||
declare const HANDSHAKE_WS = "handshakeWS"; | ||
declare const HANDSHAKE_SC = "handshakeSC"; | ||
declare const MESSAGE = "message"; | ||
declare const TRANSMIT = "transmit"; | ||
declare const INVOKE = "invoke"; | ||
declare const SUBSCRIBE = "subscribe"; | ||
declare const PUBLISH_IN = "publishIn"; | ||
declare const PUBLISH_OUT = "publishOut"; | ||
declare const AUTHENTICATE = "authenticate"; | ||
@@ -27,3 +27,3 @@ interface AGActionBase { | ||
outcome: null | 'allowed' | 'blocked'; | ||
outcome: null | "allowed" | "blocked"; | ||
promise: Promise<any>; | ||
@@ -66,3 +66,3 @@ | ||
outcome: null | 'allowed' | 'blocked'; | ||
outcome: null | "allowed" | "blocked"; | ||
promise: Promise<any>; | ||
@@ -69,0 +69,0 @@ |
{ | ||
"name": "@types/socketcluster-server", | ||
"version": "16.1.1", | ||
"version": "16.1.2", | ||
"description": "TypeScript definitions for socketcluster-server", | ||
@@ -38,4 +38,4 @@ "homepage": "https://github.com/DefinitelyTyped/DefinitelyTyped/tree/master/types/socketcluster-server", | ||
}, | ||
"typesPublisherContentHash": "008d55d92e34bda9bf313d63e43885dfd3f715802beee088b61ff4d0786d1226", | ||
"typeScriptVersion": "4.2" | ||
"typesPublisherContentHash": "feabdf9ed6d08ae2ef58249a877b1f063efb3a05e4dee8001dd6492fb5b63f6d", | ||
"typeScriptVersion": "4.5" | ||
} |
@@ -11,3 +11,3 @@ # Installation | ||
### Additional Details | ||
* Last updated: Mon, 13 Feb 2023 13:02:35 GMT | ||
* Last updated: Mon, 25 Sep 2023 13:39:06 GMT | ||
* Dependencies: [@types/ag-auth](https://npmjs.com/package/@types/ag-auth), [@types/ag-simple-broker](https://npmjs.com/package/@types/ag-simple-broker), [@types/async-stream-emitter](https://npmjs.com/package/@types/async-stream-emitter), [@types/consumable-stream](https://npmjs.com/package/@types/consumable-stream), [@types/jsonwebtoken](https://npmjs.com/package/@types/jsonwebtoken), [@types/sc-errors](https://npmjs.com/package/@types/sc-errors), [@types/stream-demux](https://npmjs.com/package/@types/stream-demux), [@types/writable-consumable-stream](https://npmjs.com/package/@types/writable-consumable-stream), [@types/ws](https://npmjs.com/package/@types/ws) | ||
@@ -14,0 +14,0 @@ * Global values: none |
@@ -1,17 +0,17 @@ | ||
import AsyncStreamEmitter = require('async-stream-emitter'); | ||
import { Secret } from 'jsonwebtoken'; | ||
import { Server } from 'http'; | ||
import WebSocket = require('ws'); | ||
import WritableConsumableStream = require('writable-consumable-stream'); | ||
import ConsumableStream = require('consumable-stream'); | ||
import AGSimpleBroker = require('ag-simple-broker'); | ||
import AuthEngine = require('ag-auth'); | ||
import AsyncStreamEmitter = require("async-stream-emitter"); | ||
import { Server } from "http"; | ||
import { Secret } from "jsonwebtoken"; | ||
import WebSocket = require("ws"); | ||
import WritableConsumableStream = require("writable-consumable-stream"); | ||
import ConsumableStream = require("consumable-stream"); | ||
import AGSimpleBroker = require("ag-simple-broker"); | ||
import AuthEngine = require("ag-auth"); | ||
import AGServerSocket = require('./serversocket'); | ||
import AGAction = require('./action'); | ||
import AGServerSocket = require("./serversocket"); | ||
import AGAction = require("./action"); | ||
declare const MIDDLEWARE_HANDSHAKE = 'handshake'; | ||
declare const MIDDLEWARE_INBOUND_RAW = 'inboundRaw'; | ||
declare const MIDDLEWARE_INBOUND = 'inbound'; | ||
declare const MIDDLEWARE_OUTBOUND = 'outbound'; | ||
declare const MIDDLEWARE_HANDSHAKE = "handshake"; | ||
declare const MIDDLEWARE_INBOUND_RAW = "inboundRaw"; | ||
declare const MIDDLEWARE_INBOUND = "inbound"; | ||
declare const MIDDLEWARE_OUTBOUND = "outbound"; | ||
@@ -69,29 +69,29 @@ declare class AGServer extends AsyncStreamEmitter<any> { | ||
emit(eventName: 'error', data: { error: Error }): void; | ||
emit(eventName: 'warning', data: { warning: Error }): void; | ||
emit(eventName: 'handshake', data: { socket: AGServerSocket }): void; | ||
emit(eventName: 'authenticationStateChange', data: AGServer.AuthStateChangeData): void; | ||
emit(eventName: 'authentication', data: AGServer.AuthenticationData): void; | ||
emit(eventName: 'deauthentication', data: AGServer.DeauthenticationData): void; | ||
emit(eventName: 'badSocketAuthToken', data: AGServer.BadSocketAuthTokenData): void; | ||
emit(eventName: 'connection', data: AGServer.ConnectionData): void; | ||
emit(eventName: 'subscription', data: AGServer.SubscriptionData): void; | ||
emit(eventName: 'unsubscription', data: AGServer.UnsubscriptionData): void; | ||
emit(eventName: 'connectionAbort', data: AGServer.ConnectionAbortData): void; | ||
emit(eventName: 'disconnection', data: AGServer.DisconnectionData): void; | ||
emit(eventName: 'closure', data: AGServer.ClosureData): void; | ||
emit(eventName: "error", data: { error: Error }): void; | ||
emit(eventName: "warning", data: { warning: Error }): void; | ||
emit(eventName: "handshake", data: { socket: AGServerSocket }): void; | ||
emit(eventName: "authenticationStateChange", data: AGServer.AuthStateChangeData): void; | ||
emit(eventName: "authentication", data: AGServer.AuthenticationData): void; | ||
emit(eventName: "deauthentication", data: AGServer.DeauthenticationData): void; | ||
emit(eventName: "badSocketAuthToken", data: AGServer.BadSocketAuthTokenData): void; | ||
emit(eventName: "connection", data: AGServer.ConnectionData): void; | ||
emit(eventName: "subscription", data: AGServer.SubscriptionData): void; | ||
emit(eventName: "unsubscription", data: AGServer.UnsubscriptionData): void; | ||
emit(eventName: "connectionAbort", data: AGServer.ConnectionAbortData): void; | ||
emit(eventName: "disconnection", data: AGServer.DisconnectionData): void; | ||
emit(eventName: "closure", data: AGServer.ClosureData): void; | ||
listener(eventName: 'error'): ConsumableStream<{ error: Error }>; | ||
listener(eventName: 'warning'): ConsumableStream<{ warning: Error }>; | ||
listener(eventName: 'handshake'): ConsumableStream<{ socket: AGServerSocket }>; | ||
listener(eventName: 'authenticationStateChange'): ConsumableStream<AGServer.AuthStateChangeData>; | ||
listener(eventName: 'authentication'): ConsumableStream<AGServer.AuthenticationData>; | ||
listener(eventName: 'deauthentication'): ConsumableStream<AGServer.DeauthenticationData>; | ||
listener(eventName: 'badSocketAuthToken'): ConsumableStream<AGServer.BadSocketAuthTokenData>; | ||
listener(eventName: 'connection'): ConsumableStream<AGServer.ConnectionData>; | ||
listener(eventName: 'subscription'): ConsumableStream<AGServer.SubscriptionData>; | ||
listener(eventName: 'unsubscription'): ConsumableStream<AGServer.UnsubscriptionData>; | ||
listener(eventName: 'connectionAbort'): ConsumableStream<AGServer.ConnectionAbortData>; | ||
listener(eventName: 'disconnection'): ConsumableStream<AGServer.DisconnectionData>; | ||
listener(eventName: 'closure'): ConsumableStream<AGServer.ClosureData>; | ||
listener(eventName: "error"): ConsumableStream<{ error: Error }>; | ||
listener(eventName: "warning"): ConsumableStream<{ warning: Error }>; | ||
listener(eventName: "handshake"): ConsumableStream<{ socket: AGServerSocket }>; | ||
listener(eventName: "authenticationStateChange"): ConsumableStream<AGServer.AuthStateChangeData>; | ||
listener(eventName: "authentication"): ConsumableStream<AGServer.AuthenticationData>; | ||
listener(eventName: "deauthentication"): ConsumableStream<AGServer.DeauthenticationData>; | ||
listener(eventName: "badSocketAuthToken"): ConsumableStream<AGServer.BadSocketAuthTokenData>; | ||
listener(eventName: "connection"): ConsumableStream<AGServer.ConnectionData>; | ||
listener(eventName: "subscription"): ConsumableStream<AGServer.SubscriptionData>; | ||
listener(eventName: "unsubscription"): ConsumableStream<AGServer.UnsubscriptionData>; | ||
listener(eventName: "connectionAbort"): ConsumableStream<AGServer.ConnectionAbortData>; | ||
listener(eventName: "disconnection"): ConsumableStream<AGServer.DisconnectionData>; | ||
listener(eventName: "closure"): ConsumableStream<AGServer.ClosureData>; | ||
@@ -271,3 +271,3 @@ setMiddleware(type: typeof MIDDLEWARE_HANDSHAKE, middleware: AGServer.handshakeMiddlewareFunction): void; | ||
// bebfore they are ended. | ||
socketStreamCleanupMode?: 'kill' | 'close'; | ||
socketStreamCleanupMode?: "kill" | "close"; | ||
@@ -297,3 +297,7 @@ authVerifyAlgorithms?: string[]; | ||
type Middlewares = typeof MIDDLEWARE_HANDSHAKE | typeof MIDDLEWARE_INBOUND_RAW | typeof MIDDLEWARE_INBOUND | typeof MIDDLEWARE_OUTBOUND; | ||
type Middlewares = | ||
| typeof MIDDLEWARE_HANDSHAKE | ||
| typeof MIDDLEWARE_INBOUND_RAW | ||
| typeof MIDDLEWARE_INBOUND | ||
| typeof MIDDLEWARE_OUTBOUND; | ||
@@ -300,0 +304,0 @@ interface CodecEngine { |
@@ -1,21 +0,21 @@ | ||
import { IncomingMessage } from 'http'; | ||
import { SignOptions } from 'jsonwebtoken'; | ||
import { SocketProtocolIgnoreStatuses, SocketProtocolErrorStatuses } from 'sc-errors'; | ||
import WebSocket = require('ws'); | ||
import AsyncStreamEmitter = require('async-stream-emitter'); | ||
import WritableConsumableStream = require('writable-consumable-stream'); | ||
import DemuxedConsumableStream = require('stream-demux/demuxed-consumable-stream'); | ||
import Consumer = require('writable-consumable-stream/consumer'); | ||
import ConsumableStream = require('consumable-stream'); | ||
import AGSimpleBroker = require('ag-simple-broker'); | ||
import { IncomingMessage } from "http"; | ||
import { SignOptions } from "jsonwebtoken"; | ||
import { SocketProtocolErrorStatuses, SocketProtocolIgnoreStatuses } from "sc-errors"; | ||
import WebSocket = require("ws"); | ||
import AsyncStreamEmitter = require("async-stream-emitter"); | ||
import WritableConsumableStream = require("writable-consumable-stream"); | ||
import DemuxedConsumableStream = require("stream-demux/demuxed-consumable-stream"); | ||
import Consumer = require("writable-consumable-stream/consumer"); | ||
import ConsumableStream = require("consumable-stream"); | ||
import AGSimpleBroker = require("ag-simple-broker"); | ||
import AGServer = require('./server'); | ||
import AGServer = require("./server"); | ||
declare class AGServerSocket extends AsyncStreamEmitter<any> { | ||
readonly CONNECTING: 'connecting'; | ||
readonly OPEN: 'open'; | ||
readonly CLOSED: 'closed'; | ||
readonly CONNECTING: "connecting"; | ||
readonly OPEN: "open"; | ||
readonly CLOSED: "closed"; | ||
readonly AUTHENTICATED: 'authenticated'; | ||
readonly UNAUTHENTICATED: 'unauthenticated'; | ||
readonly AUTHENTICATED: "authenticated"; | ||
readonly UNAUTHENTICATED: "unauthenticated"; | ||
@@ -64,4 +64,4 @@ readonly ignoreStatuses: SocketProtocolIgnoreStatuses; | ||
state: 'connecting' | 'open' | 'closed'; | ||
authState: 'authenticated' | 'unauthenticated'; | ||
state: "connecting" | "open" | "closed"; | ||
authState: "authenticated" | "unauthenticated"; | ||
authToken?: AGServerSocket.AuthToken; | ||
@@ -72,29 +72,29 @@ signedAuthToken?: string; | ||
emit(eventName: 'message' | 'raw', data: { message: { data: any; type: string; target: WebSocket } }): void; | ||
emit(eventName: 'error', data: { error: Error }): void; | ||
emit(eventName: 'authStateChange', data: AGServerSocket.StateChangeData): void; | ||
emit(eventName: 'authenticate', data: AGServerSocket.AuthenticateData): void; | ||
emit(eventName: 'authTokenSigned', data: { signedAuthToken: string }): void; | ||
emit(eventName: 'deauthenticate', data: AGServerSocket.DeauthenticateData): void; | ||
emit(eventName: 'badAuthToken', data: AGServerSocket.BadAuthTokenData): void; | ||
emit(eventName: 'connect', data: AGServerSocket.ConnectData): void; | ||
emit(eventName: 'subscribe', data: AGServerSocket.SubscribeData): void; | ||
emit(eventName: 'unsubscribe', data: AGServerSocket.UnsubscribeData): void; | ||
emit(eventName: 'connectAbort', data: AGServerSocket.ConnectAbortData): void; | ||
emit(eventName: 'disconnect', data: AGServerSocket.DisconnectData): void; | ||
emit(eventName: 'close', data: AGServerSocket.CloseData): void; | ||
emit(eventName: "message" | "raw", data: { message: { data: any; type: string; target: WebSocket } }): void; | ||
emit(eventName: "error", data: { error: Error }): void; | ||
emit(eventName: "authStateChange", data: AGServerSocket.StateChangeData): void; | ||
emit(eventName: "authenticate", data: AGServerSocket.AuthenticateData): void; | ||
emit(eventName: "authTokenSigned", data: { signedAuthToken: string }): void; | ||
emit(eventName: "deauthenticate", data: AGServerSocket.DeauthenticateData): void; | ||
emit(eventName: "badAuthToken", data: AGServerSocket.BadAuthTokenData): void; | ||
emit(eventName: "connect", data: AGServerSocket.ConnectData): void; | ||
emit(eventName: "subscribe", data: AGServerSocket.SubscribeData): void; | ||
emit(eventName: "unsubscribe", data: AGServerSocket.UnsubscribeData): void; | ||
emit(eventName: "connectAbort", data: AGServerSocket.ConnectAbortData): void; | ||
emit(eventName: "disconnect", data: AGServerSocket.DisconnectData): void; | ||
emit(eventName: "close", data: AGServerSocket.CloseData): void; | ||
emit(eventName: 'message' | 'raw'): ConsumableStream<{ message: { data: any; type: string; target: WebSocket } }>; | ||
emit(eventName: 'error'): ConsumableStream<{ error: Error }>; | ||
emit(eventName: 'authStateChange'): ConsumableStream<AGServerSocket.StateChangeData>; | ||
emit(eventName: 'authenticate'): ConsumableStream<AGServerSocket.AuthenticateData>; | ||
emit(eventName: 'authTokenSigned'): ConsumableStream<{ signedAuthToken: string }>; | ||
emit(eventName: 'deauthenticate'): ConsumableStream<AGServerSocket.DeauthenticateData>; | ||
emit(eventName: 'badAuthToken'): ConsumableStream<AGServerSocket.BadAuthTokenData>; | ||
emit(eventName: 'connect'): ConsumableStream<AGServerSocket.ConnectData>; | ||
emit(eventName: 'subscribe'): ConsumableStream<AGServerSocket.SubscribeData>; | ||
emit(eventName: 'unsubscribe'): ConsumableStream<AGServerSocket.UnsubscribeData>; | ||
emit(eventName: 'connectAbort'): ConsumableStream<AGServerSocket.ConnectAbortData>; | ||
emit(eventName: 'disconnect'): ConsumableStream<AGServerSocket.DisconnectData>; | ||
emit(eventName: 'close'): ConsumableStream<AGServerSocket.CloseData>; | ||
emit(eventName: "message" | "raw"): ConsumableStream<{ message: { data: any; type: string; target: WebSocket } }>; | ||
emit(eventName: "error"): ConsumableStream<{ error: Error }>; | ||
emit(eventName: "authStateChange"): ConsumableStream<AGServerSocket.StateChangeData>; | ||
emit(eventName: "authenticate"): ConsumableStream<AGServerSocket.AuthenticateData>; | ||
emit(eventName: "authTokenSigned"): ConsumableStream<{ signedAuthToken: string }>; | ||
emit(eventName: "deauthenticate"): ConsumableStream<AGServerSocket.DeauthenticateData>; | ||
emit(eventName: "badAuthToken"): ConsumableStream<AGServerSocket.BadAuthTokenData>; | ||
emit(eventName: "connect"): ConsumableStream<AGServerSocket.ConnectData>; | ||
emit(eventName: "subscribe"): ConsumableStream<AGServerSocket.SubscribeData>; | ||
emit(eventName: "unsubscribe"): ConsumableStream<AGServerSocket.UnsubscribeData>; | ||
emit(eventName: "connectAbort"): ConsumableStream<AGServerSocket.ConnectAbortData>; | ||
emit(eventName: "disconnect"): ConsumableStream<AGServerSocket.DisconnectData>; | ||
emit(eventName: "close"): ConsumableStream<AGServerSocket.CloseData>; | ||
@@ -147,3 +147,3 @@ emitError(error: Error): void; | ||
getState(): 'connecting' | 'open' | 'closed'; | ||
getState(): "connecting" | "open" | "closed"; | ||
getBytesReceived(): number; | ||
@@ -186,3 +186,3 @@ | ||
triggerAuthenticationEvents(oldAuthState: 'authenticated' | 'unauthenticated'): void; | ||
triggerAuthenticationEvents(oldAuthState: "authenticated" | "unauthenticated"): void; | ||
@@ -214,4 +214,4 @@ getAuthToken(): AGServerSocket.AuthToken; | ||
interface StateChangeData { | ||
oldState: 'authenticated' | 'unauthenticated'; | ||
newState: 'authenticated' | 'unauthenticated'; | ||
oldState: "authenticated" | "unauthenticated"; | ||
newState: "authenticated" | "unauthenticated"; | ||
authToken?: AuthToken; | ||
@@ -218,0 +218,0 @@ } |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
29470
0.12%580
0.69%0
-100%