White space formatting and fixed type test

unjs · Dec 16, 2024 · cb2b924 · cb2b924
1 parent b83f18c
commit cb2b924
Show file tree

Hide file tree

Showing 8 changed files with 15 additions and 18 deletions.
diff --git a/src/adapters/bun.ts b/src/adapters/bun.ts
@@ -32,7 +32,7 @@ export default defineWebSocketAdapter<BunAdapter, BunOptions>(
       ...adapterUtils(peers),
       async handleUpgrade(request, server) {
         let upgradeHeaders: Headers | undefined;
-
+        
         try {
           const result = await hooks.callHook("upgrade", request);
           if (result instanceof Response) {
@@ -53,7 +53,7 @@ export default defineWebSocketAdapter<BunAdapter, BunOptions>(
           } satisfies ContextData,
           headers: upgradeHeaders,
         });
-
+        
         if (!upgradeOK) {
           return new Response("Upgrade failed", { status: 500 });
         }

diff --git a/src/adapters/cloudflare-durable.ts b/src/adapters/cloudflare-durable.ts
@@ -32,7 +32,7 @@ export default defineWebSocketAdapter<
     },
     handleDurableUpgrade: async (obj, request) => {
       let upgradeHeaders: Headers | undefined;
-
+      
       try {
         const result = await hooks.callHook("upgrade", request as Request);
         if (result instanceof Response) {
@@ -57,7 +57,7 @@ export default defineWebSocketAdapter<
       peers.add(peer);
       (obj as DurableObjectPub).ctx.acceptWebSocket(server);
       await hooks.callHook("open", peer);
-
+      
       // eslint-disable-next-line unicorn/no-null
       return new Response(null, {
         status: 101,

diff --git a/src/adapters/cloudflare.ts b/src/adapters/cloudflare.ts
@@ -34,7 +34,7 @@ export default defineWebSocketAdapter<CloudflareAdapter, CloudflareOptions>(
       ...adapterUtils(peers),
       handleUpgrade: async (request, env, context) => {
         let upgradeHeaders: Headers | undefined;
-
+        
         try {
           const result = await hooks.callHook(
             "upgrade",

diff --git a/src/adapters/node.ts b/src/adapters/node.ts
@@ -1,6 +1,6 @@
 import type { AdapterOptions, AdapterInstance } from "../adapter.ts";
 import type { WebSocket } from "../../types/web.ts";
-import { convertResponseToCloseEvent, toBufferLike } from "../utils.ts";
+import { toBufferLike } from "../utils.ts";
 import { defineWebSocketAdapter, adapterUtils } from "../adapter.ts";
 import { AdapterHookable } from "../hooks.ts";
 import { Message } from "../message.ts";
@@ -88,7 +88,7 @@ export default defineWebSocketAdapter<NodeAdapter, NodeOptions>(
         const request = new NodeReqProxy(nodeReq);
 
         let res: Response | undefined;
-
+        
         try {
           res = await hooks.callHook("upgrade", request);
         } catch (error) {

diff --git a/src/adapters/sse.ts b/src/adapters/sse.ts
@@ -28,7 +28,7 @@ export default defineWebSocketAdapter<SSEAdapter, SSEOptions>((opts = {}) => {
     ...adapterUtils(peers),
     fetch: async (request: Request) => {
       let upgradeHeaders: Headers | undefined;
-
+      
       try {
         const result = await hooks.callHook("upgrade", request);
         if (result instanceof Response) {
@@ -83,11 +83,11 @@ export default defineWebSocketAdapter<SSEAdapter, SSEOptions>((opts = {}) => {
         "Cache-Control": "no-cache",
         Connection: "keep-alive",
       };
-
+      
       if (opts.bidir) {
         headers["x-crossws-id"] = peer.id;
       }
-
+      
       if (upgradeHeaders) {
         headers = new Headers(headers);
         for (const [key, value] of upgradeHeaders) {

diff --git a/src/adapters/uws.ts b/src/adapters/uws.ts
@@ -77,12 +77,9 @@ export default defineWebSocketAdapter<UWSAdapter, UWSOptions>(
           });
 
           let upgradeHeaders: Headers | undefined;
-
+          
           try {
-            const result = await hooks.callHook(
-              "upgrade",
-              new UWSReqProxy(req),
-            );
+            const result = await hooks.callHook("upgrade", new UWSReqProxy(req));
             if (result instanceof Response) {
               // Normal response = headers for upgrade
               upgradeHeaders = result.headers;

diff --git a/src/hooks.ts b/src/hooks.ts
@@ -63,7 +63,7 @@ type HookFn<ArgsT extends any[] = any, RT = void> = (
 export interface Hooks {
   /** Upgrading */
   /**
-   *
+   * 
    * @param request
    * @throws {Response}
    */

diff --git a/test/fixture/_shared.ts b/test/fixture/_shared.ts
@@ -63,12 +63,12 @@ export function createDemo<T extends Adapter<any, any>>(
           headers: { "x-error": "unauthorized" },
         });
       }
-      return {
+      return new Response(undefined, {
         headers: {
           "x-powered-by": "cross-ws",
           "set-cookie": "cross-ws=1; SameSite=None; Secure",
         },
-      };
+      });
     },
   });