fix(dependencies): Update dependencies. Use chokidar instead of @parc…

…el/watcher for hotloading
vinsonchuong · Sep 22, 2021 · 33d4d5e · 33d4d5e
1 parent 7dc6466
commit 33d4d5e
Show file tree

Hide file tree

Showing 19 changed files with 1,847 additions and 3,576 deletions.
diff --git a/bin.js b/bin.js
@@ -1,4 +1,5 @@
 #!/usr/bin/env node
+import process from 'node:process'
 import {createRequire} from 'node:module'
 import run from 'puff-pastry'
 
@@ -9,6 +10,6 @@ if (process.env.NODE_ENV === 'production') {
   run('./cli/index.js')
 } else {
   run('./cli/index.js', {
-    flags: ['--loader', hotEsmPath, '--no-warnings']
+    flags: ['--loader', hotEsmPath, '--no-warnings'],
   })
 }
diff --git a/bin.test.js b/bin.test.js
@@ -1,3 +1,4 @@
+import process from 'node:process'
 import test from 'ava'
 import {useTemporaryDirectory, runProcess, wait} from 'ava-patterns'
 import install from 'quick-install'
@@ -20,13 +21,13 @@ test('starting a development server with hot-reloading', async (t) => {
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   const server = runProcess(t, {
     command: ['npx', 'pass-notes', 'server.mjs'],
     cwd: directory.path,
-    env: {PORT: '10010'}
+    env: {PORT: '10010'},
   })
   try {
     await server.waitForOutput('Listening', 5000)
@@ -39,15 +40,15 @@ test('starting a development server with hot-reloading', async (t) => {
     await sendRequest({
       method: 'GET',
       url: 'http://localhost:10010',
-      headers: {}
+      headers: {},
     }),
     {
       status: 200,
       headers: {
-        'content-type': 'text/plain'
+        'content-type': 'text/plain',
       },
-      body: 'Hello World!'
-    }
+      body: 'Hello World!',
+    },
   )
 
   await directory.writeFile(
@@ -62,23 +63,23 @@ test('starting a development server with hot-reloading', async (t) => {
         body: 'Hello There!'
       }
     }
-    `
+    `,
   )
   await wait(500)
 
   t.like(
     await sendRequest({
       method: 'GET',
       url: 'http://localhost:10010',
-      headers: {}
+      headers: {},
     }),
     {
       status: 200,
       headers: {
-        'content-type': 'text/plain'
+        'content-type': 'text/plain',
       },
-      body: 'Hello There!'
-    }
+      body: 'Hello There!',
+    },
   )
 })
 
@@ -99,13 +100,13 @@ test('not enabling hot-reloading in production', async (t) => {
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   const server = runProcess(t, {
     command: ['npx', 'pass-notes', 'server.mjs'],
     cwd: directory.path,
-    env: {PORT: '10011', NODE_ENV: 'production'}
+    env: {PORT: '10011', NODE_ENV: 'production'},
   })
   try {
     await server.waitForOutput('Listening', 5000)
@@ -118,11 +119,11 @@ test('not enabling hot-reloading in production', async (t) => {
     await sendRequest({
       method: 'GET',
       url: 'http://localhost:10011',
-      headers: {}
+      headers: {},
     }),
     {
-      body: 'Hello World!'
-    }
+      body: 'Hello World!',
+    },
   )
 
   await directory.writeFile(
@@ -137,18 +138,18 @@ test('not enabling hot-reloading in production', async (t) => {
         body: 'Hello There!'
       }
     }
-    `
+    `,
   )
   await wait(500)
 
   t.like(
     await sendRequest({
       method: 'GET',
       url: 'http://localhost:10011',
-      headers: {}
+      headers: {},
     }),
     {
-      body: 'Hello World!'
-    }
+      body: 'Hello World!',
+    },
   )
 })
diff --git a/cli/find-open-port.js b/cli/find-open-port.js
@@ -2,6 +2,6 @@ import getPort from 'get-port'
 
 export default function (...portsToTry) {
   return getPort({
-    port: portsToTry.filter((n) => typeof n === 'number' && !Number.isNaN(n))
+    port: portsToTry.filter((n) => typeof n === 'number' && !Number.isNaN(n)),
   })
 }
diff --git a/cli/index.js b/cli/index.js
@@ -40,7 +40,7 @@ export default async function ({cwd, env, argv, stdout}) {
     const finish = logger.measure({
       level: 'INFO',
       topic: 'HTTP',
-      message: `${request.method} ${request.url}`
+      message: `${request.method} ${request.url}`,
     })
 
     try {
@@ -60,17 +60,17 @@ export default async function ({cwd, env, argv, stdout}) {
       response = {
         status: 500,
         headers: {
-          'Content-Type': 'text/plain'
+          'Content-Type': 'text/plain',
         },
-        body: error_.message
+        body: error_.message,
       }
       error = error_
     }
 
     finish({
       level: error ? 'ERROR' : 'INFO',
       message: `${response.status}`,
-      error
+      error,
     })
 
     return response
@@ -79,7 +79,7 @@ export default async function ({cwd, env, argv, stdout}) {
   logger.log({
     level: 'INFO',
     topic: 'HTTP',
-    message: `Listening on port ${port}`
+    message: `Listening on port ${port}`,
   })
 
   return server

diff --git a/cli/index.test.js b/cli/index.test.js
@@ -1,3 +1,4 @@
+import process from 'node:process'
 import * as https from 'node:https'
 import test from 'ava'
 import {useTemporaryDirectory} from 'ava-patterns'
@@ -21,8 +22,8 @@ async function runScript(t, env, script) {
     stdout: {
       write(text) {
         output.push(text)
-      }
-    }
+      },
+    },
   })
   t.teardown(async () => {
     await stopServer(server)
@@ -46,7 +47,7 @@ test('running the CLI', async (t) => {
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   t.true(output[0].includes('Listening on port 11000'))
@@ -55,15 +56,15 @@ test('running the CLI', async (t) => {
     await sendRequest({
       method: 'GET',
       url: 'http://localhost:11000',
-      headers: {}
+      headers: {},
     }),
     {
       status: 200,
       headers: {
-        'content-type': 'text/plain'
+        'content-type': 'text/plain',
       },
-      body: 'Hello World!'
-    }
+      body: 'Hello World!',
+    },
   )
 })
 
@@ -79,7 +80,7 @@ test('defaulting to port 8080', async (t) => {
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   t.true(output[0].includes('Listening on port 8080'))
@@ -88,9 +89,9 @@ test('defaulting to port 8080', async (t) => {
     await sendRequest({
       method: 'GET',
       url: 'http://localhost:8080',
-      headers: {}
+      headers: {},
     }),
-    {status: 200}
+    {status: 200},
   )
 })
 
@@ -102,19 +103,19 @@ test('gracefully handling errors', async (t) => {
     export default function () {
       throw new Error('Something bad happened.')
     }
-    `
+    `,
   )
 
   t.like(
     await sendRequest({
       method: 'GET',
       url: 'http://localhost:11001',
-      headers: {}
+      headers: {},
     }),
     {
       status: 500,
-      body: 'Something bad happened.'
-    }
+      body: 'Something bad happened.',
+    },
   )
 })
 
@@ -140,11 +141,11 @@ test('automatically creating a self-signed certificate for localhost', async (t)
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   t.like(await getCertificate('https://localhost:11002'), {
-    subject: {CN: 'localhost'}
+    subject: {CN: 'localhost'},
   })
 })
 
@@ -162,11 +163,11 @@ test('allowing a certificate to be provided via environment variables', async (t
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   t.like(await getCertificate('https://localhost:11003'), {
-    subject: {CN: 'foo'}
+    subject: {CN: 'foo'},
   })
 })
 
@@ -189,11 +190,11 @@ test('allowing a certificate to be provided in application code', async (t) => {
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   t.like(await getCertificate('https://localhost:11004'), {
-    subject: {CN: 'bar'}
+    subject: {CN: 'bar'},
   })
 })
 
@@ -215,13 +216,13 @@ test('logging requests', async (t) => {
         body: 'Hello World!'
       }
     }
-    `
+    `,
   )
 
   await sendRequest({
     method: 'GET',
     url: 'http://localhost:11005/foo',
-    headers: {}
+    headers: {},
   })
   t.true(output[1].includes('[INFO] [HTTP] GET /foo'))
   t.true(output[2].includes('[INFO] [HTTP] GET /foo › 200'))
@@ -230,15 +231,15 @@ test('logging requests', async (t) => {
     method: 'POST',
     url: 'http://localhost:11005/bar',
     headers: {},
-    body: ''
+    body: '',
   })
   t.true(output[3].includes('[INFO] [HTTP] POST /bar'))
   t.true(output[4].includes('[INFO] [HTTP] POST /bar › 200'))
 
   await sendRequest({
     method: 'GET',
     url: 'http://localhost:11005/error',
-    headers: {}
+    headers: {},
   })
   t.true(output[5].includes('[INFO] [HTTP] GET /error'))
   t.true(output[6].includes('[ERROR] [HTTP] GET /error › 500'))
@@ -258,13 +259,13 @@ test('using a custom logger', async (t) => {
       logger.log({level: 'INFO', topic: 'APP', message: 'Hello World!'})
       return {status: 200}
     }
-    `
+    `,
   )
 
   await sendRequest({
     method: 'GET',
     url: 'http://localhost:11006',
-    headers: {}
+    headers: {},
   })
   t.true(output[1].includes('[INFO] [HTTP] GET /'))
   t.true(output[2].includes('[INFO] [APP] Hello World!'))

diff --git a/http/connect/index.js b/http/connect/index.js
@@ -31,15 +31,15 @@ export default async function (url) {
 
     pushedResponses.push([
       {method, url, headers: requestHeaders},
-      {status, headers: responseHeaders, body}
+      {status, headers: responseHeaders, body},
     ])
   })
 
   return {
     async sendRequest(request) {
       const nodeResponse = client.request({
         [HTTP2_HEADER_PATH]: request.url,
-        ...request.headers
+        ...request.headers,
       })
 
       const nodeHeaders = await pEvent(nodeResponse, 'response')
@@ -55,6 +55,6 @@ export default async function (url) {
       await pEvent(client, 'close')
     },
 
-    pushedResponses
+    pushedResponses,
   }
 }