Feature/ssl support

package.json

@@ -26,6 +26,7 @@
     "homepage": "https://github.com/ubarilan/mockpox#readme",
     "devDependencies": {
         "@types/node": "^18.0.6",
+        "@types/pem": "^1.9.6",
         "@typescript-eslint/eslint-plugin": "^5.30.7",
         "@typescript-eslint/parser": "^5.30.7",
         "eslint": "^8.20.0",

src/mock/mock.ts

@@ -8,6 +8,7 @@ import ReadConfig from '../lib/readconfig';
 import { MockConf } from '../lib/types/mockTypes';
 import { logger } from '../lib/utils/logger';
 import handler from './handler';
+import { createCertificate } from 'pem';
 
 export default class Mock {
     private server: httpServer | httpsServer; // Implement HTTPS
@@ -26,24 +27,45 @@ export default class Mock {
         this.initServer();
     }
 
-    private initServer() {
-        if (!this.conf.ssl) {
-            this.server = createHttpServer();
-        } else {
-            this.server = createHttpsServer();
-            throw new Error('Not implemented');
-        }
-
+    private startWebServer() {
         try {
             this.server.listen(this.conf.port, this.conf.address, () => {
                 this.logger.info(
-                    `Listening on ${this.conf.address}:${this.conf.port}`
+                    `Mock server listening on ${this.conf.address}:${this.conf.port}`
                 );
             });
-        } catch (error) {
-            throw new Error(`An error occured: ${error}`);
+        } catch (err: unknown) {
+            if (err instanceof Error) {
+                this.logger.crit(
+                    `Error when trying to listen on port ${this.conf.port}: ${err.message}`
+                );
+            }
+            process.exit(1);
         }
-
         this.server.on('request', this.handler.bind(this));
     }
+
+    private initServer() {
+        if (!this.conf.ssl) {
+            this.server = createHttpServer();
+            this.startWebServer();
+        } else {
+            createCertificate(
+                {
+                    days: 1,
+                    selfSigned: true,
+                },
+                (err, keys) => {
+                    if (err) {
+                        throw err;
+                    }
+                    this.server = createHttpsServer({
+                        key: keys.serviceKey,
+                        cert: keys.certificate,
+                    });
+                    this.startWebServer();
+                }
+            );
+        }
+    }
 }

src/record/handler.ts

@@ -24,22 +24,31 @@ export default async function handler(
 
     const sortedUrl = sortUrlQueryStrings(req.url);
 
-    const rex = await axios.request({
-        url: sortedUrl,
-        method: req.method,
-        headers: Object.fromEntries(headerMap),
-        maxRedirects: 0,
-        validateStatus: null,
-    });
+    try {
+        const rex = await axios.request({
+            url: sortedUrl,
+            method: req.method,
+            headers: Object.fromEntries(headerMap),
+            maxRedirects: 0,
+            validateStatus: null,
+        });
+        res.writeHead(rex.status, rex.headers);
+        res.end(rex.data);
 
-    res.writeHead(rex.status, rex.headers);
-    res.end(rex.data);
+        this.logger.info(`${req.method} - ${sortedUrl} - ${rex.status}`);
 
-    this.logger.info(`${req.method} - ${sortedUrl} - ${rex.status}`);
-
-    this.writeConfig.addEndpointData(
-        getUrlWithoutOrigin(sortedUrl),
-        req.method as Method,
-        rex
-    );
+        this.writeConfig.addEndpointData(
+            getUrlWithoutOrigin(sortedUrl),
+            req.method as Method,
+            rex
+        );
+    } catch (err: unknown) {
+        if (err instanceof Error) {
+            res.writeHead(500);
+            res.end(err.message);
+        } else {
+            res.writeHead(500);
+            res.end('Unknown error');
+        }
+    }
 }