fixed requests
This commit is contained in:
@@ -22,6 +22,13 @@ app.prepare().then(() => {
|
|||||||
|
|
||||||
const wss = new WebSocketServer({ noServer: true });
|
const wss = new WebSocketServer({ noServer: true });
|
||||||
|
|
||||||
|
// Request
|
||||||
|
server.on("request", (req) => {
|
||||||
|
if (!req.url || !req.method) return;
|
||||||
|
|
||||||
|
config?.app.emit(req.method as any, req.url, toRequest(req));
|
||||||
|
});
|
||||||
|
|
||||||
// Upgrade HTTP → WebSocket
|
// Upgrade HTTP → WebSocket
|
||||||
server.on("upgrade", (req, socket, head) => {
|
server.on("upgrade", (req, socket, head) => {
|
||||||
if (!req.url) return;
|
if (!req.url) return;
|
||||||
|
|||||||
@@ -9,6 +9,9 @@ export interface WsRouteHandler {
|
|||||||
upgrade?: (req: Request, socket: Duplex, head: NonSharedBuffer) => void;
|
upgrade?: (req: Request, socket: Duplex, head: NonSharedBuffer) => void;
|
||||||
post?: (req: Request) => void;
|
post?: (req: Request) => void;
|
||||||
get?: (req: Request) => void;
|
get?: (req: Request) => void;
|
||||||
|
put?: (req: Request) => void;
|
||||||
|
delete?: (req: Request) => void;
|
||||||
|
patch?: (req: Request) => void;
|
||||||
}
|
}
|
||||||
|
|
||||||
export class NextWebsocketApp {
|
export class NextWebsocketApp {
|
||||||
|
|||||||
Reference in New Issue
Block a user