graphql-ws
Advanced tools
graphql-ws - npm Package Compare versions
Comparing version 5.11.2 to 5.11.3
@@ -15,3 +15,3 @@ /** | ||
| */ | ||
| export declare type EventConnecting = 'connecting'; | ||
| export type EventConnecting = 'connecting'; | ||
| /** | ||
@@ -22,3 +22,3 @@ * WebSocket has opened. | ||
| */ | ||
| export declare type EventOpened = 'opened'; | ||
| export type EventOpened = 'opened'; | ||
| /** | ||
@@ -29,3 +29,3 @@ * Open WebSocket connection has been acknowledged. | ||
| */ | ||
| export declare type EventConnected = 'connected'; | ||
| export type EventConnected = 'connected'; | ||
| /** | ||
@@ -36,3 +36,3 @@ * `PingMessage` has been received or sent. | ||
| */ | ||
| export declare type EventPing = 'ping'; | ||
| export type EventPing = 'ping'; | ||
| /** | ||
@@ -43,3 +43,3 @@ * `PongMessage` has been received or sent. | ||
| */ | ||
| export declare type EventPong = 'pong'; | ||
| export type EventPong = 'pong'; | ||
| /** | ||
@@ -50,3 +50,3 @@ * A message has been received. | ||
| */ | ||
| export declare type EventMessage = 'message'; | ||
| export type EventMessage = 'message'; | ||
| /** | ||
@@ -57,3 +57,3 @@ * WebSocket connection has closed. | ||
| */ | ||
| export declare type EventClosed = 'closed'; | ||
| export type EventClosed = 'closed'; | ||
| /** | ||
@@ -64,3 +64,3 @@ * WebSocket connection had an error or client had an internal error. | ||
| */ | ||
| export declare type EventError = 'error'; | ||
| export type EventError = 'error'; | ||
| /** | ||
@@ -71,5 +71,5 @@ * All events that could occur. | ||
| */ | ||
| export declare type Event = EventConnecting | EventOpened | EventConnected | EventPing | EventPong | EventMessage | EventClosed | EventError; | ||
| export type Event = EventConnecting | EventOpened | EventConnected | EventPing | EventPong | EventMessage | EventClosed | EventError; | ||
| /** @category Client */ | ||
| export declare type EventConnectingListener = () => void; | ||
| export type EventConnectingListener = () => void; | ||
| /** | ||
@@ -82,3 +82,3 @@ * The first argument is actually the `WebSocket`, but to avoid | ||
| */ | ||
| export declare type EventOpenedListener = (socket: unknown) => void; | ||
| export type EventOpenedListener = (socket: unknown) => void; | ||
| /** | ||
@@ -94,3 +94,3 @@ * The first argument is actually the `WebSocket`, but to avoid | ||
| */ | ||
| export declare type EventConnectedListener = (socket: unknown, payload: ConnectionAckMessage['payload']) => void; | ||
| export type EventConnectedListener = (socket: unknown, payload: ConnectionAckMessage['payload']) => void; | ||
| /** | ||
@@ -102,3 +102,3 @@ * The first argument communicates whether the ping was received from the server. | ||
| */ | ||
| export declare type EventPingListener = (received: boolean, payload: PingMessage['payload']) => void; | ||
| export type EventPingListener = (received: boolean, payload: PingMessage['payload']) => void; | ||
| /** | ||
@@ -110,3 +110,3 @@ * The first argument communicates whether the pong was received from the server. | ||
| */ | ||
| export declare type EventPongListener = (received: boolean, payload: PongMessage['payload']) => void; | ||
| export type EventPongListener = (received: boolean, payload: PongMessage['payload']) => void; | ||
| /** | ||
@@ -118,3 +118,3 @@ * Called for all **valid** messages received by the client. Mainly useful for | ||
| */ | ||
| export declare type EventMessageListener = (message: Message) => void; | ||
| export type EventMessageListener = (message: Message) => void; | ||
| /** | ||
@@ -127,3 +127,3 @@ * The argument is actually the websocket `CloseEvent`, but to avoid | ||
| */ | ||
| export declare type EventClosedListener = (event: unknown) => void; | ||
| export type EventClosedListener = (event: unknown) => void; | ||
| /** | ||
@@ -135,5 +135,5 @@ * Events dispatched from the WebSocket `onerror` are handled in this listener, | ||
| */ | ||
| export declare type EventErrorListener = (error: unknown) => void; | ||
| export type EventErrorListener = (error: unknown) => void; | ||
| /** @category Client */ | ||
| export declare type EventListener<E extends Event> = E extends EventConnecting ? EventConnectingListener : E extends EventOpened ? EventOpenedListener : E extends EventConnected ? EventConnectedListener : E extends EventPing ? EventPingListener : E extends EventPong ? EventPongListener : E extends EventMessage ? EventMessageListener : E extends EventClosed ? EventClosedListener : E extends EventError ? EventErrorListener : never; | ||
| export type EventListener<E extends Event> = E extends EventConnecting ? EventConnectingListener : E extends EventOpened ? EventOpenedListener : E extends EventConnected ? EventConnectedListener : E extends EventPing ? EventPingListener : E extends EventPong ? EventPongListener : E extends EventMessage ? EventMessageListener : E extends EventClosed ? EventClosedListener : E extends EventError ? EventErrorListener : never; | ||
| /** | ||
@@ -140,0 +140,0 @@ * Configuration used for the GraphQL over WebSocket client. |
@@ -380,2 +380,3 @@ "use strict"; | ||
| case common_1.MessageType.Next: { | ||
| // eslint-disable-next-line @typescript-eslint/no-explicit-any -- payload will fit type | ||
| sink.next(message.payload); | ||
@@ -382,0 +383,0 @@ return; |
@@ -46,3 +46,3 @@ /** | ||
| */ | ||
| export declare type ID = string; | ||
| export type ID = string; | ||
| /** @category Common */ | ||
@@ -154,3 +154,3 @@ export interface Disposable { | ||
| /** @category Common */ | ||
| export declare type Message<T extends MessageType = MessageType> = T extends MessageType.ConnectionAck ? ConnectionAckMessage : T extends MessageType.ConnectionInit ? ConnectionInitMessage : T extends MessageType.Ping ? PingMessage : T extends MessageType.Pong ? PongMessage : T extends MessageType.Subscribe ? SubscribeMessage : T extends MessageType.Next ? NextMessage : T extends MessageType.Error ? ErrorMessage : T extends MessageType.Complete ? CompleteMessage : never; | ||
| export type Message<T extends MessageType = MessageType> = T extends MessageType.ConnectionAck ? ConnectionAckMessage : T extends MessageType.ConnectionInit ? ConnectionInitMessage : T extends MessageType.Ping ? PingMessage : T extends MessageType.Pong ? PongMessage : T extends MessageType.Subscribe ? SubscribeMessage : T extends MessageType.Next ? NextMessage : T extends MessageType.Error ? ErrorMessage : T extends MessageType.Complete ? CompleteMessage : never; | ||
| /** | ||
@@ -181,3 +181,3 @@ * Validates the message against the GraphQL over WebSocket Protocol. | ||
| */ | ||
| export declare type JSONMessageReviver = (this: any, key: string, value: any) => any; | ||
| export type JSONMessageReviver = (this: any, key: string, value: any) => any; | ||
| /** | ||
@@ -198,3 +198,3 @@ * Parses the raw websocket message data to a valid message. | ||
| */ | ||
| export declare type JSONMessageReplacer = (this: any, key: string, value: any) => any; | ||
| export type JSONMessageReplacer = (this: any, key: string, value: any) => any; | ||
| /** | ||
@@ -201,0 +201,0 @@ * Stringifies a valid message ready to be sent through the socket. |
@@ -9,3 +9,3 @@ /** | ||
| /** @category Server */ | ||
| export declare type OperationResult = Promise<AsyncGenerator<ExecutionResult | ExecutionPatchResult> | AsyncIterable<ExecutionResult | ExecutionPatchResult> | ExecutionResult> | AsyncGenerator<ExecutionResult | ExecutionPatchResult> | AsyncIterable<ExecutionResult | ExecutionPatchResult> | ExecutionResult; | ||
| export type OperationResult = Promise<AsyncGenerator<ExecutionResult | ExecutionPatchResult> | AsyncIterable<ExecutionResult | ExecutionPatchResult> | ExecutionResult> | AsyncGenerator<ExecutionResult | ExecutionPatchResult> | AsyncIterable<ExecutionResult | ExecutionPatchResult> | ExecutionResult; | ||
| /** | ||
@@ -21,3 +21,3 @@ * A concrete GraphQL execution context value type. | ||
| */ | ||
| export declare type GraphQLExecutionContextValue = object | symbol | number | string | boolean | undefined | null; | ||
| export type GraphQLExecutionContextValue = object | symbol | number | string | boolean | undefined | null; | ||
| /** @category Server */ | ||
@@ -24,0 +24,0 @@ export interface ServerOptions<P extends ConnectionInitMessage['payload'] = ConnectionInitMessage['payload'], E = unknown> { |
@@ -55,4 +55,4 @@ "use strict"; | ||
| socket.onMessage(async function onMessage(data) { | ||
| var e_1, _a; | ||
| var _b; | ||
| var _a, e_1, _b, _c; | ||
| var _d; | ||
| let message; | ||
@@ -103,3 +103,3 @@ try { | ||
| case common_1.MessageType.Pong: | ||
| return await ((_b = socket.onPong) === null || _b === void 0 ? void 0 : _b.call(socket, message.payload)); | ||
| return await ((_d = socket.onPong) === null || _d === void 0 ? void 0 : _d.call(socket, message.payload)); | ||
| case common_1.MessageType.Subscribe: { | ||
@@ -210,5 +210,12 @@ if (!ctx.acknowledged) | ||
| try { | ||
| for (var operationResult_1 = __asyncValues(operationResult), operationResult_1_1; operationResult_1_1 = await operationResult_1.next(), !operationResult_1_1.done;) { | ||
| const result = operationResult_1_1.value; | ||
| await emit.next(result, execArgs); | ||
| for (var _e = true, operationResult_1 = __asyncValues(operationResult), operationResult_1_1; operationResult_1_1 = await operationResult_1.next(), _a = operationResult_1_1.done, !_a;) { | ||
| _c = operationResult_1_1.value; | ||
| _e = false; | ||
| try { | ||
| const result = _c; | ||
| await emit.next(result, execArgs); | ||
| } | ||
| finally { | ||
| _e = true; | ||
| } | ||
| } | ||
@@ -219,3 +226,3 @@ } | ||
| try { | ||
| if (operationResult_1_1 && !operationResult_1_1.done && (_a = operationResult_1.return)) await _a.call(operationResult_1); | ||
| if (!_e && !_a && (_b = operationResult_1.return)) await _b.call(operationResult_1); | ||
| } | ||
@@ -222,0 +229,0 @@ finally { if (e_1) throw e_1.error; } |
@@ -44,3 +44,3 @@ "use strict"; | ||
| ? 'Internal server error' | ||
| : (0, utils_1.limitCloseReason)(err.message, 'Internal server error')); | ||
| : (0, utils_1.limitCloseReason)(err instanceof Error ? err.message : String(err), 'Internal server error')); | ||
| } | ||
@@ -65,3 +65,3 @@ catch (err) { | ||
| ? 'Internal server error' | ||
| : (0, utils_1.limitCloseReason)(err.message, 'Internal server error')); | ||
| : (0, utils_1.limitCloseReason)(err instanceof Error ? err.message : String(err), 'Internal server error')); | ||
| } | ||
@@ -110,3 +110,3 @@ // fastify-websocket uses the WebSocket.createWebSocketStream, | ||
| ? 'Internal server error' | ||
| : (0, utils_1.limitCloseReason)(err.message, 'Internal server error')); | ||
| : (0, utils_1.limitCloseReason)(err instanceof Error ? err.message : String(err), 'Internal server error')); | ||
| } | ||
@@ -113,0 +113,0 @@ }), |
@@ -123,3 +123,3 @@ "use strict"; | ||
| ? 'Internal server error' | ||
| : (0, utils_1.limitCloseReason)(err.message, 'Internal server error')); | ||
| : (0, utils_1.limitCloseReason)(err instanceof Error ? err.message : String(err), 'Internal server error')); | ||
| } | ||
@@ -126,0 +126,0 @@ }, |
@@ -6,4 +6,4 @@ /// <reference types="node" /> | ||
| import { ConnectionInitMessage, Disposable } from '../common'; | ||
| declare type WebSocket = typeof ws.prototype; | ||
| declare type WebSocketServer = ws.Server; | ||
| type WebSocket = typeof ws.prototype; | ||
| type WebSocketServer = ws.Server; | ||
| /** | ||
@@ -10,0 +10,0 @@ * The extra that will be put in the `Context`. |
@@ -35,3 +35,3 @@ "use strict"; | ||
| ? 'Internal server error' | ||
| : (0, utils_1.limitCloseReason)(err.message, 'Internal server error')); | ||
| : (0, utils_1.limitCloseReason)(err instanceof Error ? err.message : String(err), 'Internal server error')); | ||
| } | ||
@@ -51,3 +51,3 @@ catch (err) { | ||
| ? 'Internal server error' | ||
| : (0, utils_1.limitCloseReason)(err.message, 'Internal server error')); | ||
| : (0, utils_1.limitCloseReason)(err instanceof Error ? err.message : String(err), 'Internal server error')); | ||
| }); | ||
@@ -92,3 +92,3 @@ // keep alive through ping-pong messages | ||
| ? 'Internal server error' | ||
| : (0, utils_1.limitCloseReason)(err.message, 'Internal server error')); | ||
| : (0, utils_1.limitCloseReason)(err instanceof Error ? err.message : String(err), 'Internal server error')); | ||
| } | ||
@@ -95,0 +95,0 @@ }), |
@@ -9,2 +9,2 @@ MIT License | ||
| THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. | ||
| THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. |
| { | ||
| "name": "graphql-ws", | ||
| "version": "5.11.2", | ||
| "version": "5.11.3", | ||
| "description": "Coherent, zero-dependency, lazy, simple, GraphQL over WebSocket Protocol compliant server and client", | ||
@@ -30,3 +30,3 @@ "keywords": [ | ||
| }, | ||
| "packageManager": "yarn@3.2.3", | ||
| "packageManager": "yarn@3.4.0", | ||
| "types": "lib/index.d.ts", | ||
@@ -80,3 +80,5 @@ "main": "lib/index.js", | ||
| "gendocs": "typedoc --options typedoc.js src/", | ||
| "lint": "eslint 'src'", | ||
| "lint:eslint": "eslint 'src'", | ||
| "lint:prettier": "prettier -c .", | ||
| "lint": "yarn lint:eslint && yarn lint:prettier", | ||
| "type-check": "tsc --noEmit", | ||
@@ -88,3 +90,3 @@ "test": "jest", | ||
| "build:cjs": "tsc -b tsconfig.cjs.json", | ||
| "build:umd": "rollup -c && gzip umd/graphql-ws.min.js -c > umd/graphql-ws.min.js.gz", | ||
| "build:umd": "rollup --bundleConfigAsCjs --config rollup.config.ts --configPlugin typescript && gzip umd/graphql-ws.min.js -c > umd/graphql-ws.min.js.gz", | ||
| "build": "yarn build:esm && yarn build:cjs && yarn build:umd", | ||
@@ -97,45 +99,43 @@ "release": "semantic-release" | ||
| "devDependencies": { | ||
| "@babel/core": "^7.19.1", | ||
| "@babel/core": "^7.20.12", | ||
| "@babel/plugin-proposal-class-properties": "^7.18.6", | ||
| "@babel/plugin-proposal-nullish-coalescing-operator": "^7.18.6", | ||
| "@babel/plugin-proposal-object-rest-spread": "^7.18.9", | ||
| "@babel/plugin-proposal-optional-chaining": "^7.18.9", | ||
| "@babel/preset-env": "^7.19.1", | ||
| "@babel/plugin-proposal-object-rest-spread": "^7.20.7", | ||
| "@babel/plugin-proposal-optional-chaining": "^7.20.7", | ||
| "@babel/preset-env": "^7.20.2", | ||
| "@babel/preset-typescript": "^7.18.6", | ||
| "@fastify/websocket": "^7.0.1", | ||
| "@rollup/plugin-typescript": "^8.5.0", | ||
| "@semantic-release/changelog": "^6.0.1", | ||
| "@fastify/websocket": "^7.1.2", | ||
| "@rollup/plugin-terser": "^0.4.0", | ||
| "@rollup/plugin-typescript": "^11.0.0", | ||
| "@semantic-release/changelog": "^6.0.2", | ||
| "@semantic-release/git": "^10.0.1", | ||
| "@types/jest": "^29.0.3", | ||
| "@types/ws": "^8.5.3", | ||
| "@typescript-eslint/eslint-plugin": "^5.37.0", | ||
| "@typescript-eslint/parser": "^5.37.0", | ||
| "babel-jest": "^29.0.3", | ||
| "eslint": "^8.23.1", | ||
| "eslint-config-prettier": "^8.5.0", | ||
| "eslint-plugin-prettier": "^4.2.1", | ||
| "fastify": "^4.6.0", | ||
| "@types/eslint": "^8.4.10", | ||
| "@types/glob": "^8.0.1", | ||
| "@types/jest": "^29.4.0", | ||
| "@types/ws": "^8.5.4", | ||
| "@typescript-eslint/eslint-plugin": "^5.50.0", | ||
| "@typescript-eslint/parser": "^5.50.0", | ||
| "babel-jest": "^29.4.1", | ||
| "eslint": "^8.33.0", | ||
| "eslint-config-prettier": "^8.6.0", | ||
| "fastify": "^4.12.0", | ||
| "fastify-websocket": "4.2.2", | ||
| "glob": "^8.0.3", | ||
| "glob": "^8.1.0", | ||
| "graphql": "^16.6.0", | ||
| "jest": "^29.0.3", | ||
| "jest-environment-jsdom": "^29.0.3", | ||
| "jest-jasmine2": "^29.0.3", | ||
| "prettier": "^2.7.1", | ||
| "jest": "^29.4.1", | ||
| "jest-environment-jsdom": "^29.4.1", | ||
| "jest-jasmine2": "^29.4.1", | ||
| "prettier": "^2.8.3", | ||
| "replacestream": "^4.0.3", | ||
| "rollup": "^2.79.0", | ||
| "rollup-plugin-terser": "^7.0.2", | ||
| "semantic-release": "^19.0.5", | ||
| "rollup": "^3.12.1", | ||
| "semantic-release": "^20.1.0", | ||
| "subscriptions-transport-ws": "^0.11.0", | ||
| "tslib": "^2.4.0", | ||
| "typedoc": "^0.23.14", | ||
| "typedoc-plugin-markdown": "^3.13.6", | ||
| "typescript": "^4.8.3", | ||
| "uWebSockets.js": "uNetworking/uWebSockets.js#v20.10.0", | ||
| "ws": "^8.8.1", | ||
| "tslib": "^2.5.0", | ||
| "typedoc": "^0.23.24", | ||
| "typedoc-plugin-markdown": "^3.14.0", | ||
| "typescript": "^4.9.5", | ||
| "uWebSockets.js": "uNetworking/uWebSockets.js#v20.15.0", | ||
| "ws": "^8.12.0", | ||
| "ws7": "npm:ws@^7.5.9" | ||
| }, | ||
| "resolutions": { | ||
| "npm/chalk": "^4.1.2" | ||
| } | ||
| } |
124
README.md
@@ -930,2 +930,63 @@ <div align="center"> | ||
| <details id="client-with-on-reconnect"> | ||
| <summary><a href="#client-with-on-reconnect">🔗</a> Client usage with reconnect listener</summary> | ||
| ```ts | ||
| import { createClient, Client, ClientOptions } from 'graphql-ws'; | ||
| import { refetchSomeQueries } from './on-reconnected'; | ||
| interface ClientWithOnReconnected extends Client { | ||
| onReconnected(cb: () => void): () => void; | ||
| } | ||
| function createClientWithOnReconnected( | ||
| options: ClientOptions, | ||
| ): ClientWithOnReconnected { | ||
| let abruptlyClosed = false; | ||
| const reconnectedCbs: (() => void)[] = []; | ||
| const client = createClient({ | ||
| ...options, | ||
| on: { | ||
| ...options.on, | ||
| closed: (event) => { | ||
| options.on?.closed?.(event); | ||
| // non-1000 close codes are abrupt closes | ||
| if ((event as CloseEvent).code !== 1000) { | ||
| abruptlyClosed = true; | ||
| } | ||
| }, | ||
| connected: (...args) => { | ||
| options.on?.connected?.(...args); | ||
| // if the client abruptly closed, this is then a reconnect | ||
| if (abruptlyClosed) { | ||
| abruptlyClosed = false; | ||
| reconnectedCbs.forEach((cb) => cb()); | ||
| } | ||
| }, | ||
| }, | ||
| }); | ||
| return { | ||
| ...client, | ||
| onReconnected: (cb) => { | ||
| reconnectedCbs.push(cb); | ||
| return () => { | ||
| reconnectedCbs.splice(reconnectedCbs.indexOf(cb), 1); | ||
| }; | ||
| }, | ||
| }; | ||
| } | ||
| const client = createClientWithOnReconnected({ | ||
| url: 'ws://ireconnect:4000/and/notify', | ||
| }); | ||
| const unlisten = client.onReconnected(() => { | ||
| refetchSomeQueries(); | ||
| }); | ||
| ``` | ||
| </details> | ||
| <details id="ws"> | ||
@@ -1328,2 +1389,65 @@ <summary><a href="#ws">🔗</a> Server usage with <a href="https://github.com/websockets/ws">ws</a></summary> | ||
| <details id="apollo-server-hapi-js"> | ||
| <summary><a href="#apollo-server-hapi-js">🔗</a> <a href="https://github.com/websockets/ws">ws</a> server usage with <a href="https://www.apollographql.com/docs/apollo-server/v3/integrations/middleware/#apollo-server-hapi">Apollo Server Hapi.js</a></summary> | ||
| ```typescript | ||
| import { | ||
| ApolloServer, | ||
| ApolloServerPluginStopHapiServer, | ||
| } from 'apollo-server-hapi'; | ||
| import { ApolloServerPluginDrainHttpServer } from 'apollo-server-core'; | ||
| import Hapi from '@hapi/hapi'; | ||
| import { WebSocketServer } from 'ws'; | ||
| import { useServer } from 'graphql-ws/lib/use/ws'; | ||
| import { createServer } from 'http'; | ||
| import { schema } from './my-graphql-schema'; | ||
| // create hapi.js and HTTP server | ||
| const httpServer = createServer(); | ||
| const hapiServer = Hapi.server({ | ||
| port: 4001, | ||
| host: 'localhost', | ||
| listener: httpServer, | ||
| routes: { security: true }, // <-- not required yet good practice | ||
| }); | ||
| // create websocket server | ||
| const wsServer = new WebSocketServer({ | ||
| server: httpServer, | ||
| path: '/graphql', | ||
| }); | ||
| // Save the returned server's info so we can shut down this server later | ||
| const serverCleanup = useServer({ schema }, wsServer); | ||
| // create apollo server | ||
| const apolloServer = new ApolloServer({ | ||
| schema, | ||
| plugins: [ | ||
| // Proper shutdown for the HTTP server. | ||
| ApolloServerPluginDrainHttpServer({ httpServer }), | ||
| // Proper shutdown for the Hapi.js server. | ||
| ApolloServerPluginStopHapiServer({ hapiServer }), | ||
| // Proper shutdown for the WebSocket server. | ||
| { | ||
| async serverWillStart() { | ||
| return { | ||
| async drainServer() { | ||
| await serverCleanup.dispose(); | ||
| }, | ||
| }; | ||
| }, | ||
| }, | ||
| ], | ||
| }); | ||
| await apolloServer.start(); | ||
| await apolloServer.applyMiddleware({ app: hapiServer }); | ||
| await hapiServer.start(); | ||
| console.log('Open GraphQL editor on: %s/graphql', hapiServer.info.uri); | ||
| ``` | ||
| </details> | ||
| <details id="deprecated-fastify-websocket"> | ||
@@ -1330,0 +1454,0 @@ <summary><a href="#deprecated-fastify-websocket">🔗</a> <a href="https://github.com/websockets/ws">ws</a> server usage with <a href="https://www.npmjs.com/package/fastify-websocket">deprecated fastify-websocket</a></summary> |
@@ -575,2 +575,3 @@ (function (global, factory) { | ||
| case exports.MessageType.Next: { | ||
| // eslint-disable-next-line @typescript-eslint/no-explicit-any -- payload will fit type | ||
| sink.next(message.payload); | ||
@@ -688,4 +689,2 @@ return; | ||
| Object.defineProperty(exports, '__esModule', { value: true }); | ||
| })); |
@@ -1,1 +0,1 @@ | ||
| !function(e,o){"object"==typeof exports&&"undefined"!=typeof module?o(exports):"function"==typeof define&&define.amd?define(["exports"],o):o((e="undefined"!=typeof globalThis?globalThis:e||self).graphqlWs={})}(this,(function(e){"use strict";function o(e){return null===e?"null":Array.isArray(e)?"array":typeof e}function t(e){return"object"===o(e)}function r(e,o){return e.length<124?e:o}const n="graphql-transport-ws";var s,i;function a(r){if(!t(r))throw new Error(`Message is expected to be an object, but got ${o(r)}`);if(!r.type)throw new Error("Message is missing the 'type' property");if("string"!=typeof r.type)throw new Error(`Message is expects the 'type' property to be a string, but got ${o(r.type)}`);switch(r.type){case e.MessageType.ConnectionInit:case e.MessageType.ConnectionAck:case e.MessageType.Ping:case e.MessageType.Pong:if("payload"in r&&!t(r.payload))throw new Error(`"${r.type}" message expects the 'payload' property to be an object or missing, but got "${r.payload}"`);break;case e.MessageType.Subscribe:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);if(!t(r.payload))throw new Error(`"${r.type}" message expects the 'payload' property to be an object, but got ${o(r.payload)}`);if("string"!=typeof r.payload.query)throw new Error(`"${r.type}" message payload expects the 'query' property to be a string, but got ${o(r.payload.query)}`);if(null!=r.payload.variables&&!t(r.payload.variables))throw new Error(`"${r.type}" message payload expects the 'variables' property to be a an object or nullish or missing, but got ${o(r.payload.variables)}`);if(null!=r.payload.operationName&&"string"!==o(r.payload.operationName))throw new Error(`"${r.type}" message payload expects the 'operationName' property to be a string or nullish or missing, but got ${o(r.payload.operationName)}`);if(null!=r.payload.extensions&&!t(r.payload.extensions))throw new Error(`"${r.type}" message payload expects the 'extensions' property to be a an object or nullish or missing, but got ${o(r.payload.extensions)}`);break;case e.MessageType.Next:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);if(!t(r.payload))throw new Error(`"${r.type}" message expects the 'payload' property to be an object, but got ${o(r.payload)}`);break;case e.MessageType.Error:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);if(n=r.payload,!(Array.isArray(n)&&n.length>0&&n.every((e=>"message"in e))))throw new Error(`"${r.type}" message expects the 'payload' property to be an array of GraphQL errors, but got ${JSON.stringify(r.payload)}`);break;case e.MessageType.Complete:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);break;default:throw new Error(`Invalid message 'type' property "${r.type}"`)}var n;return r}function p(e,o){return a("string"==typeof e?JSON.parse(e,o):e)}function l(e,o){return a(e),JSON.stringify(e,o)}function c(e){return t(e)&&"code"in e&&"reason"in e}e.CloseCode=void 0,(s=e.CloseCode||(e.CloseCode={}))[s.InternalServerError=4500]="InternalServerError",s[s.InternalClientError=4005]="InternalClientError",s[s.BadRequest=4400]="BadRequest",s[s.BadResponse=4004]="BadResponse",s[s.Unauthorized=4401]="Unauthorized",s[s.Forbidden=4403]="Forbidden",s[s.SubprotocolNotAcceptable=4406]="SubprotocolNotAcceptable",s[s.ConnectionInitialisationTimeout=4408]="ConnectionInitialisationTimeout",s[s.ConnectionAcknowledgementTimeout=4504]="ConnectionAcknowledgementTimeout",s[s.SubscriberAlreadyExists=4409]="SubscriberAlreadyExists",s[s.TooManyInitialisationRequests=4429]="TooManyInitialisationRequests",e.MessageType=void 0,(i=e.MessageType||(e.MessageType={})).ConnectionInit="connection_init",i.ConnectionAck="connection_ack",i.Ping="ping",i.Pong="pong",i.Subscribe="subscribe",i.Next="next",i.Error="error",i.Complete="complete",e.DEPRECATED_GRAPHQL_WS_PROTOCOL="graphql-ws",e.GRAPHQL_TRANSPORT_WS_PROTOCOL=n,e.createClient=function(o){const{url:t,connectionParams:s,lazy:i=!0,onNonLazyError:a=console.error,lazyCloseTimeout:d=0,keepAlive:y=0,disablePong:u,connectionAckWaitTimeout:g=0,retryAttempts:m=5,retryWait:f=async function(e){let o=1e3;for(let t=0;t<e;t++)o*=2;await new Promise((e=>setTimeout(e,o+Math.floor(2700*Math.random()+300))))},shouldRetry:b=c,isFatalConnectionProblem:w,on:h,webSocketImpl:C,generateID:x=function(){return"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const o=16*Math.random()|0;return("x"==e?o:3&o|8).toString(16)}))},jsonMessageReplacer:E,jsonMessageReviver:T}=o;let v;if(C){if(!("function"==typeof(M=C)&&"constructor"in M&&"CLOSED"in M&&"CLOSING"in M&&"CONNECTING"in M&&"OPEN"in M))throw new Error("Invalid WebSocket implementation provided");v=C}else"undefined"!=typeof WebSocket?v=WebSocket:"undefined"!=typeof global?v=global.WebSocket||global.MozWebSocket:"undefined"!=typeof window&&(v=window.WebSocket||window.MozWebSocket);var M;if(!v)throw new Error("WebSocket implementation missing; on Node you can `import WebSocket from 'ws';` and pass `webSocketImpl: WebSocket` to `createClient`");const S=v,$=(()=>{const e=(()=>{const e={};return{on:(o,t)=>(e[o]=t,()=>{delete e[o]}),emit(o){var t;"id"in o&&(null===(t=e[o.id])||void 0===t||t.call(e,o))}}})(),o={connecting:(null==h?void 0:h.connecting)?[h.connecting]:[],opened:(null==h?void 0:h.opened)?[h.opened]:[],connected:(null==h?void 0:h.connected)?[h.connected]:[],ping:(null==h?void 0:h.ping)?[h.ping]:[],pong:(null==h?void 0:h.pong)?[h.pong]:[],message:(null==h?void 0:h.message)?[e.emit,h.message]:[e.emit],closed:(null==h?void 0:h.closed)?[h.closed]:[],error:(null==h?void 0:h.error)?[h.error]:[]};return{onMessage:e.on,on(e,t){const r=o[e];return r.push(t),()=>{r.splice(r.indexOf(t),1)}},emit(e,...t){for(const r of[...o[e]])r(...t)}}})();function N(e){const o=[$.on("error",(t=>{o.forEach((e=>e())),e(t)})),$.on("closed",(t=>{o.forEach((e=>e())),e(t)}))]}let k,P,I=0,A=!1,O=0,R=!1;async function q(){clearTimeout(P);const[o,i]=await(null!=k?k:k=new Promise(((o,i)=>(async()=>{if(A){if(await f(O),!I)return k=void 0,i({code:1e3,reason:"All Subscriptions Gone"});O++}$.emit("connecting");const a=new S("function"==typeof t?await t():t,n);let d,m;function b(){isFinite(y)&&y>0&&(clearTimeout(m),m=setTimeout((()=>{a.readyState===S.OPEN&&(a.send(l({type:e.MessageType.Ping})),$.emit("ping",!1,void 0))}),y))}N((e=>{k=void 0,clearTimeout(d),clearTimeout(m),i(e),c(e)&&4499===e.code&&(a.close(4499,"Terminated"),a.onerror=null,a.onclose=null)})),a.onerror=e=>$.emit("error",e),a.onclose=e=>$.emit("closed",e),a.onopen=async()=>{try{$.emit("opened",a);const o="function"==typeof s?await s():s;if(a.readyState!==S.OPEN)return;a.send(l(o?{type:e.MessageType.ConnectionInit,payload:o}:{type:e.MessageType.ConnectionInit},E)),isFinite(g)&&g>0&&(d=setTimeout((()=>{a.close(e.CloseCode.ConnectionAcknowledgementTimeout,"Connection acknowledgement timeout")}),g)),b()}catch(o){$.emit("error",o),a.close(e.CloseCode.InternalClientError,r(o instanceof Error?o.message:new Error(o).message,"Internal client error"))}};let w=!1;a.onmessage=({data:t})=>{try{const r=p(t,T);if($.emit("message",r),"ping"===r.type||"pong"===r.type)return $.emit(r.type,!0,r.payload),void("pong"===r.type?b():u||(a.send(l(r.payload?{type:e.MessageType.Pong,payload:r.payload}:{type:e.MessageType.Pong})),$.emit("pong",!1,r.payload)));if(w)return;if(r.type!==e.MessageType.ConnectionAck)throw new Error(`First message cannot be of type ${r.type}`);clearTimeout(d),w=!0,$.emit("connected",a,r.payload),A=!1,O=0,o([a,new Promise(((e,o)=>N(o)))])}catch(o){a.onmessage=null,$.emit("error",o),a.close(e.CloseCode.BadResponse,r(o instanceof Error?o.message:new Error(o).message,"Bad response"))}}})())));o.readyState===S.CLOSING&&await i;let a=()=>{};const m=new Promise((e=>a=e));return[o,a,Promise.race([m.then((()=>{if(!I){const e=()=>o.close(1e3,"Normal Closure");isFinite(d)&&d>0?P=setTimeout((()=>{o.readyState===S.OPEN&&e()}),d):e()}})),i])]}function W(o){if(c(o)&&(t=o.code,![1e3,1001,1006,1005,1012,1013,1013].includes(t)&&t>=1e3&&t<=1999||[e.CloseCode.InternalServerError,e.CloseCode.InternalClientError,e.CloseCode.BadRequest,e.CloseCode.BadResponse,e.CloseCode.Unauthorized,e.CloseCode.SubprotocolNotAcceptable,e.CloseCode.SubscriberAlreadyExists,e.CloseCode.TooManyInitialisationRequests].includes(o.code)))throw o;var t;if(R)return!1;if(c(o)&&1e3===o.code)return I>0;if(!m||O>=m)throw o;if(!b(o))throw o;if(null==w?void 0:w(o))throw o;return A=!0}return i||(async()=>{for(I++;;)try{const[,,e]=await q();await e}catch(e){try{if(!W(e))return}catch(e){return null==a?void 0:a(e)}}})(),{on:$.on,subscribe(o,t){const r=x(o);let n=!1,s=!1,i=()=>{I--,n=!0};return(async()=>{for(I++;;)try{const[a,p,c]=await q();if(n)return p();const d=$.onMessage(r,(o=>{switch(o.type){case e.MessageType.Next:return void t.next(o.payload);case e.MessageType.Error:return s=!0,n=!0,t.error(o.payload),void i();case e.MessageType.Complete:return n=!0,void i()}}));return a.send(l({id:r,type:e.MessageType.Subscribe,payload:o},E)),i=()=>{n||a.readyState!==S.OPEN||a.send(l({id:r,type:e.MessageType.Complete},E)),I--,n=!0,p()},void await c.finally(d)}catch(e){if(!W(e))return}})().then((()=>{s||t.complete()})).catch((e=>{t.error(e)})),()=>{n||i()}},async dispose(){if(R=!0,k){const[e]=await k;e.close(1e3,"Normal Closure")}},terminate(){k&&$.emit("closed",{code:4499,reason:"Terminated",wasClean:!1})}}},e.isMessage=function(e){try{return a(e),!0}catch(e){return!1}},e.parseMessage=p,e.stringifyMessage=l,e.validateMessage=a,Object.defineProperty(e,"__esModule",{value:!0})})); | ||
| !function(e,o){"object"==typeof exports&&"undefined"!=typeof module?o(exports):"function"==typeof define&&define.amd?define(["exports"],o):o((e="undefined"!=typeof globalThis?globalThis:e||self).graphqlWs={})}(this,(function(e){"use strict";function o(e){return null===e?"null":Array.isArray(e)?"array":typeof e}function t(e){return"object"===o(e)}function r(e,o){return e.length<124?e:o}const n="graphql-transport-ws";var s,i;function a(r){if(!t(r))throw new Error(`Message is expected to be an object, but got ${o(r)}`);if(!r.type)throw new Error("Message is missing the 'type' property");if("string"!=typeof r.type)throw new Error(`Message is expects the 'type' property to be a string, but got ${o(r.type)}`);switch(r.type){case e.MessageType.ConnectionInit:case e.MessageType.ConnectionAck:case e.MessageType.Ping:case e.MessageType.Pong:if("payload"in r&&!t(r.payload))throw new Error(`"${r.type}" message expects the 'payload' property to be an object or missing, but got "${r.payload}"`);break;case e.MessageType.Subscribe:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);if(!t(r.payload))throw new Error(`"${r.type}" message expects the 'payload' property to be an object, but got ${o(r.payload)}`);if("string"!=typeof r.payload.query)throw new Error(`"${r.type}" message payload expects the 'query' property to be a string, but got ${o(r.payload.query)}`);if(null!=r.payload.variables&&!t(r.payload.variables))throw new Error(`"${r.type}" message payload expects the 'variables' property to be a an object or nullish or missing, but got ${o(r.payload.variables)}`);if(null!=r.payload.operationName&&"string"!==o(r.payload.operationName))throw new Error(`"${r.type}" message payload expects the 'operationName' property to be a string or nullish or missing, but got ${o(r.payload.operationName)}`);if(null!=r.payload.extensions&&!t(r.payload.extensions))throw new Error(`"${r.type}" message payload expects the 'extensions' property to be a an object or nullish or missing, but got ${o(r.payload.extensions)}`);break;case e.MessageType.Next:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);if(!t(r.payload))throw new Error(`"${r.type}" message expects the 'payload' property to be an object, but got ${o(r.payload)}`);break;case e.MessageType.Error:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);if(n=r.payload,!(Array.isArray(n)&&n.length>0&&n.every((e=>"message"in e))))throw new Error(`"${r.type}" message expects the 'payload' property to be an array of GraphQL errors, but got ${JSON.stringify(r.payload)}`);break;case e.MessageType.Complete:if("string"!=typeof r.id)throw new Error(`"${r.type}" message expects the 'id' property to be a string, but got ${o(r.id)}`);if(!r.id)throw new Error(`"${r.type}" message requires a non-empty 'id' property`);break;default:throw new Error(`Invalid message 'type' property "${r.type}"`)}var n;return r}function p(e,o){return a("string"==typeof e?JSON.parse(e,o):e)}function c(e,o){return a(e),JSON.stringify(e,o)}function l(e){return t(e)&&"code"in e&&"reason"in e}e.CloseCode=void 0,(s=e.CloseCode||(e.CloseCode={}))[s.InternalServerError=4500]="InternalServerError",s[s.InternalClientError=4005]="InternalClientError",s[s.BadRequest=4400]="BadRequest",s[s.BadResponse=4004]="BadResponse",s[s.Unauthorized=4401]="Unauthorized",s[s.Forbidden=4403]="Forbidden",s[s.SubprotocolNotAcceptable=4406]="SubprotocolNotAcceptable",s[s.ConnectionInitialisationTimeout=4408]="ConnectionInitialisationTimeout",s[s.ConnectionAcknowledgementTimeout=4504]="ConnectionAcknowledgementTimeout",s[s.SubscriberAlreadyExists=4409]="SubscriberAlreadyExists",s[s.TooManyInitialisationRequests=4429]="TooManyInitialisationRequests",e.MessageType=void 0,(i=e.MessageType||(e.MessageType={})).ConnectionInit="connection_init",i.ConnectionAck="connection_ack",i.Ping="ping",i.Pong="pong",i.Subscribe="subscribe",i.Next="next",i.Error="error",i.Complete="complete",e.DEPRECATED_GRAPHQL_WS_PROTOCOL="graphql-ws",e.GRAPHQL_TRANSPORT_WS_PROTOCOL=n,e.createClient=function(o){const{url:t,connectionParams:s,lazy:i=!0,onNonLazyError:a=console.error,lazyCloseTimeout:d=0,keepAlive:y=0,disablePong:u,connectionAckWaitTimeout:g=0,retryAttempts:m=5,retryWait:f=async function(e){let o=1e3;for(let t=0;t<e;t++)o*=2;await new Promise((e=>setTimeout(e,o+Math.floor(2700*Math.random()+300))))},shouldRetry:b=l,isFatalConnectionProblem:w,on:h,webSocketImpl:C,generateID:x=function(){return"xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g,(e=>{const o=16*Math.random()|0;return("x"==e?o:3&o|8).toString(16)}))},jsonMessageReplacer:E,jsonMessageReviver:T}=o;let v;if(C){if(!("function"==typeof(M=C)&&"constructor"in M&&"CLOSED"in M&&"CLOSING"in M&&"CONNECTING"in M&&"OPEN"in M))throw new Error("Invalid WebSocket implementation provided");v=C}else"undefined"!=typeof WebSocket?v=WebSocket:"undefined"!=typeof global?v=global.WebSocket||global.MozWebSocket:"undefined"!=typeof window&&(v=window.WebSocket||window.MozWebSocket);var M;if(!v)throw new Error("WebSocket implementation missing; on Node you can `import WebSocket from 'ws';` and pass `webSocketImpl: WebSocket` to `createClient`");const S=v,$=(()=>{const e=(()=>{const e={};return{on:(o,t)=>(e[o]=t,()=>{delete e[o]}),emit(o){var t;"id"in o&&(null===(t=e[o.id])||void 0===t||t.call(e,o))}}})(),o={connecting:(null==h?void 0:h.connecting)?[h.connecting]:[],opened:(null==h?void 0:h.opened)?[h.opened]:[],connected:(null==h?void 0:h.connected)?[h.connected]:[],ping:(null==h?void 0:h.ping)?[h.ping]:[],pong:(null==h?void 0:h.pong)?[h.pong]:[],message:(null==h?void 0:h.message)?[e.emit,h.message]:[e.emit],closed:(null==h?void 0:h.closed)?[h.closed]:[],error:(null==h?void 0:h.error)?[h.error]:[]};return{onMessage:e.on,on(e,t){const r=o[e];return r.push(t),()=>{r.splice(r.indexOf(t),1)}},emit(e,...t){for(const r of[...o[e]])r(...t)}}})();function N(e){const o=[$.on("error",(t=>{o.forEach((e=>e())),e(t)})),$.on("closed",(t=>{o.forEach((e=>e())),e(t)}))]}let k,P,I=0,A=!1,O=0,R=!1;async function q(){clearTimeout(P);const[o,i]=await(null!=k?k:k=new Promise(((o,i)=>(async()=>{if(A){if(await f(O),!I)return k=void 0,i({code:1e3,reason:"All Subscriptions Gone"});O++}$.emit("connecting");const a=new S("function"==typeof t?await t():t,n);let d,m;function b(){isFinite(y)&&y>0&&(clearTimeout(m),m=setTimeout((()=>{a.readyState===S.OPEN&&(a.send(c({type:e.MessageType.Ping})),$.emit("ping",!1,void 0))}),y))}N((e=>{k=void 0,clearTimeout(d),clearTimeout(m),i(e),l(e)&&4499===e.code&&(a.close(4499,"Terminated"),a.onerror=null,a.onclose=null)})),a.onerror=e=>$.emit("error",e),a.onclose=e=>$.emit("closed",e),a.onopen=async()=>{try{$.emit("opened",a);const o="function"==typeof s?await s():s;if(a.readyState!==S.OPEN)return;a.send(c(o?{type:e.MessageType.ConnectionInit,payload:o}:{type:e.MessageType.ConnectionInit},E)),isFinite(g)&&g>0&&(d=setTimeout((()=>{a.close(e.CloseCode.ConnectionAcknowledgementTimeout,"Connection acknowledgement timeout")}),g)),b()}catch(o){$.emit("error",o),a.close(e.CloseCode.InternalClientError,r(o instanceof Error?o.message:new Error(o).message,"Internal client error"))}};let w=!1;a.onmessage=({data:t})=>{try{const r=p(t,T);if($.emit("message",r),"ping"===r.type||"pong"===r.type)return $.emit(r.type,!0,r.payload),void("pong"===r.type?b():u||(a.send(c(r.payload?{type:e.MessageType.Pong,payload:r.payload}:{type:e.MessageType.Pong})),$.emit("pong",!1,r.payload)));if(w)return;if(r.type!==e.MessageType.ConnectionAck)throw new Error(`First message cannot be of type ${r.type}`);clearTimeout(d),w=!0,$.emit("connected",a,r.payload),A=!1,O=0,o([a,new Promise(((e,o)=>N(o)))])}catch(o){a.onmessage=null,$.emit("error",o),a.close(e.CloseCode.BadResponse,r(o instanceof Error?o.message:new Error(o).message,"Bad response"))}}})())));o.readyState===S.CLOSING&&await i;let a=()=>{};const m=new Promise((e=>a=e));return[o,a,Promise.race([m.then((()=>{if(!I){const e=()=>o.close(1e3,"Normal Closure");isFinite(d)&&d>0?P=setTimeout((()=>{o.readyState===S.OPEN&&e()}),d):e()}})),i])]}function W(o){if(l(o)&&(t=o.code,![1e3,1001,1006,1005,1012,1013,1013].includes(t)&&t>=1e3&&t<=1999||[e.CloseCode.InternalServerError,e.CloseCode.InternalClientError,e.CloseCode.BadRequest,e.CloseCode.BadResponse,e.CloseCode.Unauthorized,e.CloseCode.SubprotocolNotAcceptable,e.CloseCode.SubscriberAlreadyExists,e.CloseCode.TooManyInitialisationRequests].includes(o.code)))throw o;var t;if(R)return!1;if(l(o)&&1e3===o.code)return I>0;if(!m||O>=m)throw o;if(!b(o))throw o;if(null==w?void 0:w(o))throw o;return A=!0}return i||(async()=>{for(I++;;)try{const[,,e]=await q();await e}catch(e){try{if(!W(e))return}catch(e){return null==a?void 0:a(e)}}})(),{on:$.on,subscribe(o,t){const r=x(o);let n=!1,s=!1,i=()=>{I--,n=!0};return(async()=>{for(I++;;)try{const[a,p,l]=await q();if(n)return p();const d=$.onMessage(r,(o=>{switch(o.type){case e.MessageType.Next:return void t.next(o.payload);case e.MessageType.Error:return s=!0,n=!0,t.error(o.payload),void i();case e.MessageType.Complete:return n=!0,void i()}}));return a.send(c({id:r,type:e.MessageType.Subscribe,payload:o},E)),i=()=>{n||a.readyState!==S.OPEN||a.send(c({id:r,type:e.MessageType.Complete},E)),I--,n=!0,p()},void await l.finally(d)}catch(e){if(!W(e))return}})().then((()=>{s||t.complete()})).catch((e=>{t.error(e)})),()=>{n||i()}},async dispose(){if(R=!0,k){const[e]=await k;e.close(1e3,"Normal Closure")}},terminate(){k&&$.emit("closed",{code:4499,reason:"Terminated",wasClean:!1})}}},e.isMessage=function(e){try{return a(e),!0}catch(e){return!1}},e.parseMessage=p,e.stringifyMessage=c,e.validateMessage=a})); |
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
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
New alerts
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
Fixed alerts
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
Improved metrics
- Total package byte prevSize
- increased by1.29%
360008
- Lines of code
- increased by0.34%
4777
- Number of lines in readme file
- increased by6.03%
2181
Worsened metrics
- Dev dependency count
- increased by2.56%
40
No dependency changes