New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@types/socketcluster-server

Package Overview
Dependencies
Maintainers
1
Versions
39
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@types/socketcluster-server - npm Package Compare versions

Comparing version

to
16.1.2

28

socketcluster-server v16.1/action.d.ts

@@ -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 @@ }