@hono/node-server
Advanced tools
+1
-1
@@ -979,3 +979,3 @@ Object.defineProperty(exports, Symbol.toStringTag, { value: 'Module' }); | ||
| for (const data of datas) try { | ||
| events?.onMessage?.(new MessageEvent("message", { data: isBinary ? data instanceof ArrayBuffer ? data : data.buffer.slice(data.byteOffset, data.byteOffset + data.byteLength) : data.toString("utf-8") }), ctx); | ||
| events?.onMessage?.(new MessageEvent("message", { data: isBinary ? data instanceof ArrayBuffer ? data : data.buffer.slice(data.byteOffset, data.byteOffset + data.byteLength) : typeof data === "string" ? data : Buffer.from(data).toString("utf-8") }), ctx); | ||
| } catch (e) { | ||
@@ -982,0 +982,0 @@ (options?.onError ?? console.error)(e); |
+32
-4
| import { AddressInfo } from "node:net"; | ||
| import { WebSocket, WebSocketServer } from "ws"; | ||
| import { IncomingMessage, Server, ServerOptions, ServerResponse, createServer } from "node:http"; | ||
| import { Http2SecureServer, Http2Server, Http2ServerRequest, Http2ServerResponse, SecureServerOptions, ServerOptions as ServerOptions$1, createSecureServer, createServer as createServer$1 } from "node:http2"; | ||
| import { ServerOptions as ServerOptions$2, createServer as createServer$2 } from "node:https"; | ||
| import { Duplex } from "node:stream"; | ||
| import { UpgradeWebSocket } from "hono/ws"; | ||
| //#region src/websocket-types.d.ts | ||
| type WSReadyState = 0 | 1 | 2 | 3; | ||
| type WebSocketData = string | ArrayBuffer | Uint8Array | readonly Uint8Array[]; | ||
| type WebSocketSendOptions = { | ||
| compress?: boolean; | ||
| }; | ||
| interface WebSocketLike { | ||
| protocol: string; | ||
| readyState: WSReadyState; | ||
| close(code?: number, reason?: string): void; | ||
| send(data: string | ArrayBuffer | ArrayBufferView, options?: WebSocketSendOptions): void; | ||
| on(event: 'message', listener: (data: WebSocketData, isBinary: boolean) => void): this; | ||
| on(event: 'close', listener: (code: number, reason: Uint8Array) => void): this; | ||
| on(event: 'error', listener: (error: unknown) => void): this; | ||
| off(event: 'message', listener: (data: WebSocketData, isBinary: boolean) => void): this; | ||
| } | ||
| interface WebSocketServerLike { | ||
| options: { | ||
| noServer?: boolean; | ||
| }; | ||
| on(event: 'connection', listener: (ws: WebSocketLike, request: IncomingMessage) => void): this; | ||
| on(event: 'headers', listener: (headers: string[]) => void): this; | ||
| off(event: 'headers', listener: (headers: string[]) => void): this; | ||
| emit(event: 'connection', ws: WebSocketLike, request: IncomingMessage): boolean; | ||
| handleUpgrade(request: IncomingMessage, socket: Duplex, head: Buffer, callback: (ws: WebSocketLike) => void): void; | ||
| close(): void; | ||
| } | ||
| //#endregion | ||
| //#region src/types.d.ts | ||
@@ -43,3 +71,3 @@ type HttpBindings = { | ||
| websocket?: { | ||
| server: WebSocketServer; | ||
| server: WebSocketServerLike; | ||
| }; | ||
@@ -57,3 +85,3 @@ } & ServerOptions$3; | ||
| }; | ||
| declare const upgradeWebSocket: UpgradeWebSocket<WebSocket, UpgradeWebSocketOptions>; | ||
| declare const upgradeWebSocket: UpgradeWebSocket<WebSocketLike, UpgradeWebSocketOptions>; | ||
| //#endregion | ||
@@ -75,2 +103,2 @@ //#region src/listener.d.ts | ||
| //#endregion | ||
| export { type Http2Bindings, type HttpBindings, RequestError, type ServerType, createAdaptorServer, getRequestListener, serve, upgradeWebSocket }; | ||
| export { type Http2Bindings, type HttpBindings, RequestError, type ServerType, type WebSocketData, type WebSocketLike, type WebSocketServerLike, createAdaptorServer, getRequestListener, serve, upgradeWebSocket }; |
+32
-4
| import { IncomingMessage, Server, ServerOptions, ServerResponse, createServer } from "node:http"; | ||
| import { Http2SecureServer, Http2Server, Http2ServerRequest, Http2ServerResponse, SecureServerOptions, ServerOptions as ServerOptions$1, createSecureServer, createServer as createServer$1 } from "node:http2"; | ||
| import { Duplex } from "node:stream"; | ||
| import { UpgradeWebSocket } from "hono/ws"; | ||
| import { AddressInfo } from "node:net"; | ||
| import { WebSocket, WebSocketServer } from "ws"; | ||
| import { ServerOptions as ServerOptions$2, createServer as createServer$2 } from "node:https"; | ||
| //#region src/websocket-types.d.ts | ||
| type WSReadyState = 0 | 1 | 2 | 3; | ||
| type WebSocketData = string | ArrayBuffer | Uint8Array | readonly Uint8Array[]; | ||
| type WebSocketSendOptions = { | ||
| compress?: boolean; | ||
| }; | ||
| interface WebSocketLike { | ||
| protocol: string; | ||
| readyState: WSReadyState; | ||
| close(code?: number, reason?: string): void; | ||
| send(data: string | ArrayBuffer | ArrayBufferView, options?: WebSocketSendOptions): void; | ||
| on(event: 'message', listener: (data: WebSocketData, isBinary: boolean) => void): this; | ||
| on(event: 'close', listener: (code: number, reason: Uint8Array) => void): this; | ||
| on(event: 'error', listener: (error: unknown) => void): this; | ||
| off(event: 'message', listener: (data: WebSocketData, isBinary: boolean) => void): this; | ||
| } | ||
| interface WebSocketServerLike { | ||
| options: { | ||
| noServer?: boolean; | ||
| }; | ||
| on(event: 'connection', listener: (ws: WebSocketLike, request: IncomingMessage) => void): this; | ||
| on(event: 'headers', listener: (headers: string[]) => void): this; | ||
| off(event: 'headers', listener: (headers: string[]) => void): this; | ||
| emit(event: 'connection', ws: WebSocketLike, request: IncomingMessage): boolean; | ||
| handleUpgrade(request: IncomingMessage, socket: Duplex, head: Buffer, callback: (ws: WebSocketLike) => void): void; | ||
| close(): void; | ||
| } | ||
| //#endregion | ||
| //#region src/types.d.ts | ||
@@ -43,3 +71,3 @@ type HttpBindings = { | ||
| websocket?: { | ||
| server: WebSocketServer; | ||
| server: WebSocketServerLike; | ||
| }; | ||
@@ -57,3 +85,3 @@ } & ServerOptions$3; | ||
| }; | ||
| declare const upgradeWebSocket: UpgradeWebSocket<WebSocket, UpgradeWebSocketOptions>; | ||
| declare const upgradeWebSocket: UpgradeWebSocket<WebSocketLike, UpgradeWebSocketOptions>; | ||
| //#endregion | ||
@@ -75,2 +103,2 @@ //#region src/listener.d.ts | ||
| //#endregion | ||
| export { type Http2Bindings, type HttpBindings, RequestError, type ServerType, createAdaptorServer, getRequestListener, serve, upgradeWebSocket }; | ||
| export { type Http2Bindings, type HttpBindings, RequestError, type ServerType, type WebSocketData, type WebSocketLike, type WebSocketServerLike, createAdaptorServer, getRequestListener, serve, upgradeWebSocket }; |
+1
-1
@@ -978,3 +978,3 @@ import { t as X_ALREADY_SENT } from "./constants-BLSFu_RU.mjs"; | ||
| for (const data of datas) try { | ||
| events?.onMessage?.(new MessageEvent("message", { data: isBinary ? data instanceof ArrayBuffer ? data : data.buffer.slice(data.byteOffset, data.byteOffset + data.byteLength) : data.toString("utf-8") }), ctx); | ||
| events?.onMessage?.(new MessageEvent("message", { data: isBinary ? data instanceof ArrayBuffer ? data : data.buffer.slice(data.byteOffset, data.byteOffset + data.byteLength) : typeof data === "string" ? data : Buffer.from(data).toString("utf-8") }), ctx); | ||
| } catch (e) { | ||
@@ -981,0 +981,0 @@ (options?.onError ?? console.error)(e); |
+1
-1
| { | ||
| "name": "@hono/node-server", | ||
| "version": "2.0.3", | ||
| "version": "2.0.4", | ||
| "description": "Node.js Adapter for Hono", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.mjs", |
108208
2.66%