You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
353 lines
10 KiB
353 lines
10 KiB
import { Emitter } from "@socket.io/component-emitter"; |
|
import { CloseDetails } from "./transport.js"; |
|
export interface SocketOptions { |
|
/** |
|
* The host that we're connecting to. Set from the URI passed when connecting |
|
*/ |
|
host: string; |
|
/** |
|
* The hostname for our connection. Set from the URI passed when connecting |
|
*/ |
|
hostname: string; |
|
/** |
|
* If this is a secure connection. Set from the URI passed when connecting |
|
*/ |
|
secure: boolean; |
|
/** |
|
* The port for our connection. Set from the URI passed when connecting |
|
*/ |
|
port: string | number; |
|
/** |
|
* Any query parameters in our uri. Set from the URI passed when connecting |
|
*/ |
|
query: { |
|
[key: string]: any; |
|
}; |
|
/** |
|
* `http.Agent` to use, defaults to `false` (NodeJS only) |
|
*/ |
|
agent: string | boolean; |
|
/** |
|
* Whether the client should try to upgrade the transport from |
|
* long-polling to something better. |
|
* @default true |
|
*/ |
|
upgrade: boolean; |
|
/** |
|
* Forces base 64 encoding for polling transport even when XHR2 |
|
* responseType is available and WebSocket even if the used standard |
|
* supports binary. |
|
*/ |
|
forceBase64: boolean; |
|
/** |
|
* The param name to use as our timestamp key |
|
* @default 't' |
|
*/ |
|
timestampParam: string; |
|
/** |
|
* Whether to add the timestamp with each transport request. Note: this |
|
* is ignored if the browser is IE or Android, in which case requests |
|
* are always stamped |
|
* @default false |
|
*/ |
|
timestampRequests: boolean; |
|
/** |
|
* A list of transports to try (in order). Engine.io always attempts to |
|
* connect directly with the first one, provided the feature detection test |
|
* for it passes. |
|
* @default ['polling','websocket'] |
|
*/ |
|
transports: string[]; |
|
/** |
|
* The port the policy server listens on |
|
* @default 843 |
|
*/ |
|
policyPost: number; |
|
/** |
|
* If true and if the previous websocket connection to the server succeeded, |
|
* the connection attempt will bypass the normal upgrade process and will |
|
* initially try websocket. A connection attempt following a transport error |
|
* will use the normal upgrade process. It is recommended you turn this on |
|
* only when using SSL/TLS connections, or if you know that your network does |
|
* not block websockets. |
|
* @default false |
|
*/ |
|
rememberUpgrade: boolean; |
|
/** |
|
* Are we only interested in transports that support binary? |
|
*/ |
|
onlyBinaryUpgrades: boolean; |
|
/** |
|
* Timeout for xhr-polling requests in milliseconds (0) (only for polling transport) |
|
*/ |
|
requestTimeout: number; |
|
/** |
|
* Transport options for Node.js client (headers etc) |
|
*/ |
|
transportOptions: Object; |
|
/** |
|
* (SSL) Certificate, Private key and CA certificates to use for SSL. |
|
* Can be used in Node.js client environment to manually specify |
|
* certificate information. |
|
*/ |
|
pfx: string; |
|
/** |
|
* (SSL) Private key to use for SSL. Can be used in Node.js client |
|
* environment to manually specify certificate information. |
|
*/ |
|
key: string; |
|
/** |
|
* (SSL) A string or passphrase for the private key or pfx. Can be |
|
* used in Node.js client environment to manually specify certificate |
|
* information. |
|
*/ |
|
passphrase: string; |
|
/** |
|
* (SSL) Public x509 certificate to use. Can be used in Node.js client |
|
* environment to manually specify certificate information. |
|
*/ |
|
cert: string; |
|
/** |
|
* (SSL) An authority certificate or array of authority certificates to |
|
* check the remote host against.. Can be used in Node.js client |
|
* environment to manually specify certificate information. |
|
*/ |
|
ca: string | string[]; |
|
/** |
|
* (SSL) A string describing the ciphers to use or exclude. Consult the |
|
* [cipher format list] |
|
* (http://www.openssl.org/docs/apps/ciphers.html#CIPHER_LIST_FORMAT) for |
|
* details on the format.. Can be used in Node.js client environment to |
|
* manually specify certificate information. |
|
*/ |
|
ciphers: string; |
|
/** |
|
* (SSL) If true, the server certificate is verified against the list of |
|
* supplied CAs. An 'error' event is emitted if verification fails. |
|
* Verification happens at the connection level, before the HTTP request |
|
* is sent. Can be used in Node.js client environment to manually specify |
|
* certificate information. |
|
*/ |
|
rejectUnauthorized: boolean; |
|
/** |
|
* Headers that will be passed for each request to the server (via xhr-polling and via websockets). |
|
* These values then can be used during handshake or for special proxies. |
|
*/ |
|
extraHeaders?: { |
|
[header: string]: string; |
|
}; |
|
/** |
|
* Whether to include credentials (cookies, authorization headers, TLS |
|
* client certificates, etc.) with cross-origin XHR polling requests |
|
* @default false |
|
*/ |
|
withCredentials: boolean; |
|
/** |
|
* Whether to automatically close the connection whenever the beforeunload event is received. |
|
* @default true |
|
*/ |
|
closeOnBeforeunload: boolean; |
|
/** |
|
* Whether to always use the native timeouts. This allows the client to |
|
* reconnect when the native timeout functions are overridden, such as when |
|
* mock clocks are installed. |
|
* @default false |
|
*/ |
|
useNativeTimers: boolean; |
|
/** |
|
* weather we should unref the reconnect timer when it is |
|
* create automatically |
|
* @default false |
|
*/ |
|
autoUnref: boolean; |
|
/** |
|
* parameters of the WebSocket permessage-deflate extension (see ws module api docs). Set to false to disable. |
|
* @default false |
|
*/ |
|
perMessageDeflate: { |
|
threshold: number; |
|
}; |
|
/** |
|
* The path to get our client file from, in the case of the server |
|
* serving it |
|
* @default '/engine.io' |
|
*/ |
|
path: string; |
|
/** |
|
* Either a single protocol string or an array of protocol strings. These strings are used to indicate sub-protocols, |
|
* so that a single server can implement multiple WebSocket sub-protocols (for example, you might want one server to |
|
* be able to handle different types of interactions depending on the specified protocol) |
|
* @default [] |
|
*/ |
|
protocols: string | string[]; |
|
} |
|
interface SocketReservedEvents { |
|
open: () => void; |
|
handshake: (data: any) => void; |
|
packet: (packet: any) => void; |
|
packetCreate: (packet: any) => void; |
|
data: (data: any) => void; |
|
message: (data: any) => void; |
|
drain: () => void; |
|
flush: () => void; |
|
heartbeat: () => void; |
|
ping: () => void; |
|
pong: () => void; |
|
error: (err: string | Error) => void; |
|
upgrading: (transport: any) => void; |
|
upgrade: (transport: any) => void; |
|
upgradeError: (err: Error) => void; |
|
close: (reason: string, description?: CloseDetails | Error) => void; |
|
} |
|
export declare class Socket extends Emitter<{}, {}, SocketReservedEvents> { |
|
id: string; |
|
transport: any; |
|
binaryType: string; |
|
private readyState; |
|
private writeBuffer; |
|
private prevBufferLen; |
|
private upgrades; |
|
private pingInterval; |
|
private pingTimeout; |
|
private pingTimeoutTimer; |
|
private setTimeoutFn; |
|
private clearTimeoutFn; |
|
private readonly beforeunloadEventListener; |
|
private readonly offlineEventListener; |
|
private upgrading; |
|
private maxPayload?; |
|
private readonly opts; |
|
private readonly secure; |
|
private readonly hostname; |
|
private readonly port; |
|
private readonly transports; |
|
static priorWebsocketSuccess: boolean; |
|
static protocol: number; |
|
/** |
|
* Socket constructor. |
|
* |
|
* @param {String|Object} uri or options |
|
* @param {Object} opts - options |
|
* @api public |
|
*/ |
|
constructor(uri: any, opts?: Partial<SocketOptions>); |
|
/** |
|
* Creates transport of the given type. |
|
* |
|
* @param {String} transport name |
|
* @return {Transport} |
|
* @api private |
|
*/ |
|
private createTransport; |
|
/** |
|
* Initializes transport to use and starts probe. |
|
* |
|
* @api private |
|
*/ |
|
private open; |
|
/** |
|
* Sets the current transport. Disables the existing one (if any). |
|
* |
|
* @api private |
|
*/ |
|
private setTransport; |
|
/** |
|
* Probes a transport. |
|
* |
|
* @param {String} transport name |
|
* @api private |
|
*/ |
|
private probe; |
|
/** |
|
* Called when connection is deemed open. |
|
* |
|
* @api private |
|
*/ |
|
private onOpen; |
|
/** |
|
* Handles a packet. |
|
* |
|
* @api private |
|
*/ |
|
private onPacket; |
|
/** |
|
* Called upon handshake completion. |
|
* |
|
* @param {Object} data - handshake obj |
|
* @api private |
|
*/ |
|
private onHandshake; |
|
/** |
|
* Sets and resets ping timeout timer based on server pings. |
|
* |
|
* @api private |
|
*/ |
|
private resetPingTimeout; |
|
/** |
|
* Called on `drain` event |
|
* |
|
* @api private |
|
*/ |
|
private onDrain; |
|
/** |
|
* Flush write buffers. |
|
* |
|
* @api private |
|
*/ |
|
private flush; |
|
/** |
|
* Ensure the encoded size of the writeBuffer is below the maxPayload value sent by the server (only for HTTP |
|
* long-polling) |
|
* |
|
* @private |
|
*/ |
|
private getWritablePackets; |
|
/** |
|
* Sends a message. |
|
* |
|
* @param {String} message. |
|
* @param {Function} callback function. |
|
* @param {Object} options. |
|
* @return {Socket} for chaining. |
|
* @api public |
|
*/ |
|
write(msg: any, options: any, fn?: any): this; |
|
send(msg: any, options: any, fn?: any): this; |
|
/** |
|
* Sends a packet. |
|
* |
|
* @param {String} packet type. |
|
* @param {String} data. |
|
* @param {Object} options. |
|
* @param {Function} callback function. |
|
* @api private |
|
*/ |
|
private sendPacket; |
|
/** |
|
* Closes the connection. |
|
* |
|
* @api public |
|
*/ |
|
close(): this; |
|
/** |
|
* Called upon transport error |
|
* |
|
* @api private |
|
*/ |
|
private onError; |
|
/** |
|
* Called upon transport close. |
|
* |
|
* @api private |
|
*/ |
|
private onClose; |
|
/** |
|
* Filters upgrades, returning only those matching client transports. |
|
* |
|
* @param {Array} server upgrades |
|
* @api private |
|
* |
|
*/ |
|
private filterUpgrades; |
|
} |
|
export {};
|
|
|