refactoring

Author: AirStair

.nvmrc

@@ -1 +1 @@
-v18.20.2
+v16.20.2

README.md

@@ -1,30 +1,27 @@
-![proxy-lib](icon.png "proxy-lib")
+![node-proxy-lib](icon.png "node-proxy-lib")
 
 # node-proxy-lib
-nodejs proxy server
+node.js proxy server
 
-```sh
+```
 npm i node-proxy-lib
 ```
 
 ```js
 import { createProxy } from 'node-proxy-lib';
 
-const proxy = createProxy({
-    host: '127.0.0.1',
-    port: 3030
-});
+const proxy = createProxy();
 
 proxy([
     {
-        pattern: /\/ssr\/.*/,
+        pattern: /(?<path>api\/.+)/,
         host: '127.0.0.1',
-        port: 8080
+        port: 8081
     },
     {
-        pattern: /\/gateway\/.+/,
+        pattern: /(?<path>.+)/,
         host: '127.0.0.1',
-        port: 8081
+        port: 8080
     }
 ]);
 ```

index.mjs

@@ -1,13 +1,15 @@
 import { createServer, request } from 'node:http';
 
-const getBody = incomingMessage => {
+const getBody = (incomingMessage, encoding='utf-8') => {
     return new Promise(resolve => {
-        let body = '';
+        let body = [];
         incomingMessage.on('data', chunk => {
-            body += chunk;
+            body.push(chunk);
         });
         incomingMessage.on('end', () => {
-            resolve(body);
+            const buffer = Buffer.concat(body);
+            const content = buffer.toString(encoding);
+            resolve(content);
         });
     });
 };
@@ -17,34 +19,33 @@ export const createProxy = options => proxyOptions => {
     const port = options?.port || 3030;
     const host = options?.host || '127.0.0.1';
     const server = createServer(async (incomingMessage, serverResponse) => {
-        const path = incomingMessage.url;
+        const url = incomingMessage.url;
         const option = proxyOptions.find(option => {
-            return option.pattern.test(path)
+            return option.pattern.test(url)
         });
+        const encoding = 'utf8';
         if (!option) {
             serverResponse.statusCode = 404;
-            serverResponse.end('NO ROUTE');
+            serverResponse.end('NO ROUTE', encoding);
             return;
         }
+        const match = url.match(option.pattern);
+        const groups = match?.groups;
+        const path = groups?.path;
         console.table('__INCOMING_MESSAGE__');
         console.table([
             {
                 protocol,
                 host,
                 port,
-                path,
                 method: incomingMessage.method,
-                pattern: option.pattern
             }
         ]);
+        console.table({
+            path
+        });
         console.group();
         const body = await getBody(incomingMessage);
-        const content = JSON.parse(body || '{}');
-        console.log('__INCOMING_MESSAGE_BODY__');
-        console.table([
-            content
-        ]);
-
         const clientRequest = request({
             host: option.host,
             port: option.port,
@@ -55,26 +56,23 @@ export const createProxy = options => proxyOptions => {
         }, async response => {
             console.group();
             const body = await getBody(response);
-            const content = JSON.parse(body || '{}');
             console.log('__SERVER_RESPONSE__');
             console.table([
                 {
                     protocol,
                     host: option.host,
                     port: option.port,
-                    path,
                     method: incomingMessage.method,
-                    pattern: option.pattern
+                    status: response.statusCode
                 }
             ]);
-            console.log('__SERVER_RESPONSE_BODY__');
-            console.table([
-                content
-            ]);
-            serverResponse.end(body);
+            console.table({
+                path
+            });
+            serverResponse.end(body, encoding);
             console.groupEnd();
         });
-        clientRequest.end(body);
+        clientRequest.end(body, encoding);
         console.groupEnd();
     });
 
@@ -106,7 +104,7 @@ export const createProxy = options => proxyOptions => {
         close();
     });
 
-    server.on('clientError', error => {
+    server.on('clientError', (error, socket) => {
         console.log(error);
         socket.end('HTTP/1.1 400 Bad Request\r\n\r\n');
     });

package.json

@@ -1,11 +1,12 @@
 {
-  "name": "proxy-lib",
+  "name": "node-proxy-lib",
   "version": "1.0.0",
-  "description": "Node.js proxy",
-  "keywords": ["node", "proxy", "native", "one file"],
+  "license": "MIT",
+  "description": "Node.js proxy server",
+  "keywords": ["node", "proxy", "server"],
   "repository": {
     "type": "git",
-    "url": "https://github.com/AirStair/proxy-lib"
+    "url": "https://github.com/AirStair/node-proxy-lib"
   },
   "author": {
     "name": "AirStair",
@@ -15,6 +16,6 @@
   "main": "index.mjs",
   "type": "module",
   "engines": {
-    "node": "18.20.2"
+    "node": "16.20.2"
   }
 }