update to new std/http API

Author: v1rtl

README.md

@@ -15,18 +15,20 @@ Deno HTTP compression middleware.
 ## Example
 
 ```ts
-import { serve } from 'https://deno.land/[email protected]/http/server.ts'
 import { compression } from 'https://deno.land/x/compression/mod.ts'
-
-const s = serve({ port: 3000 })
-
-for await (const req of s) {
-  await compression({
-    // Path to a file
-    path: 'README.md',
-    compression: ['gzip', 'deflate']
-  })(req)
-}
+import { Server } from 'https://deno.land/[email protected]/http/server.ts'
+
+const s = new Server({
+  handler: async (req) => {
+    return await compression({
+      path: 'README.md',
+      compression: ['br', 'gzip', 'deflate']
+    })(req)
+  },
+  addr: ':3000'
+})
+
+s.listenAndServe()
 ```
 
 Now try to send a `HEAD` request with `curl`:

example.ts

@@ -1,11 +1,14 @@
-import { serve } from 'https://deno.land/[email protected]/http/server.ts'
 import { compression } from './mod.ts'
+import { Server } from 'https://deno.land/[email protected]/http/server.ts'
 
-const s = serve({ port: 3000 })
+const s = new Server({
+  handler: async (req) => {
+    return await compression({
+      path: 'README.md',
+      compression: ['br', 'gzip', 'deflate']
+    })(req)
+  },
+  addr: ':3000'
+})
 
-for await (const req of s) {
-  await compression({
-    path: 'README.md',
-    compression: ['br', 'gzip', 'deflate']
-  })(req)
-}
+s.listenAndServe()

mod.ts

@@ -1,8 +1,7 @@
 import { compress as brotli } from 'https://deno.land/x/[email protected]/mod.ts'
 import { gzip, deflate } from 'https://deno.land/x/[email protected]/mod.ts'
-import { ServerRequest } from 'https://deno.land/[email protected]/http/server.ts'
 import { Accepts } from 'https://deno.land/x/[email protected]/mod.ts'
-import { readAll } from 'https://deno.land/std@0.106.0/io/util.ts'
+import { readAll } from 'https://deno.land/std@0.107.0/io/util.ts'
 
 const funcs = {
   br: brotli,
@@ -32,7 +31,7 @@ export type CompressionOptions = {
  *
  * @example
  * ```ts
- *import { serve } from 'https://deno.land/std@0.106.0/http/server.ts'
+ *import { serve } from 'https://deno.land/std@0.107.0/http/server.ts'
  *import { compression } from 'https://deno.land/x/compression/brotli.ts'
  *
  *const s = serve({ port: 3000 })
@@ -45,7 +44,7 @@ export type CompressionOptions = {
  *}
  * ```
  */
-export const compression = (opts: CompressionOptions) => async (req: ServerRequest) => {
+export const compression = (opts: CompressionOptions) => async (req: Request) => {
   const acceptHeader = req.headers.get('Accept-Encoding')
 
   const accepts = new Accepts(req.headers)
@@ -55,8 +54,7 @@ export const compression = (opts: CompressionOptions) => async (req: ServerReque
   const buf = await readAll(await Deno.open(opts.path))
 
   if (!acceptHeader || acceptHeader === 'identity' || (Array.isArray(encodings) && encodings[0] === 'identity')) {
-    return await req.respond({
-      body: buf,
+    return new Response(buf, {
       status: 200,
       headers: new Headers({
         'Content-Encoding': 'identity'
@@ -67,8 +65,7 @@ export const compression = (opts: CompressionOptions) => async (req: ServerReque
 
     const compressed = funcs[preferredAlgo](buf)
 
-    return await req.respond({
-      body: compressed,
+    return new Response(compressed, {
       headers: new Headers({
         'Content-Encoding': preferredAlgo
       }),
@@ -88,26 +85,21 @@ export const compression = (opts: CompressionOptions) => async (req: ServerReque
         }
       }
 
-      return await req.respond({
-        body: compressed,
+      return new Response(compressed, {
         headers: new Headers({
           'Content-Encoding': encs.join(', ')
         })
       })
     } else {
-      return await req.respond(
-        Object.keys(funcs).includes(encodings as string)
-          ? {
-              body: funcs[encodings as Compression](buf),
-              headers: new Headers({
-                'Content-Encoding': encodings as string
-              })
-            }
-          : {
-              status: 406,
-              body: 'Not Acceptable'
-            }
-      )
+      return Object.keys(funcs).includes(encodings as string)
+        ? new Response(funcs[encodings as Compression](buf), {
+            headers: new Headers({
+              'Content-Encoding': encodings as string
+            })
+          })
+        : new Response('Not Acceptable', {
+            status: 406
+          })
     }
   }
 }