Merge pull request #12 from kcoderhtml/Add-logging-middleware

Add logging middleware

index.ts

@@ -65,9 +65,34 @@ app.get("/s/10daysinpublic/:user", async (req, res) => {
   streamData(req, res, userDetail);
 });
 
+let logger = (req, res, next) => {
+  let current_datetime = new Date();
+  let formatted_date =
+    current_datetime.getFullYear() +
+    "-" +
+    (current_datetime.getMonth() + 1) +
+    "-" +
+    current_datetime.getDate() +
+    " " +
+    current_datetime.getHours() +
+    ":" +
+    current_datetime.getMinutes() +
+    ":" +
+    current_datetime.getSeconds();
+  let method = req.method;
+  let url = req.url;
+  let status = res.statusCode;
+  let user_agent = req.headers["user-agent"];
+  let log = `[${formatted_date}] ${method}:${url} ${status} ${user_agent}`;
+  console.log(log);
+};
+
 // Create server
 const server = http.createServer(app);
 
+// add logging middleware
+server.on("request", logger);
+
 // Start server
 server.listen(port, () => {
   console.log(`Server is listening on port ${port}`);

utils/streaming.ts

@@ -20,8 +20,6 @@ wrote: {bytes} bytes
 `;
 
 export function streamData(req: Request, res: Response, message: string) {
-  console.log("sending transmission to " + req.ip);
-
   // get total bytes of message and replace {bytes} in transmissionEnd with the number of bytes of the message
   const body =
     transmissionStart +
@@ -51,6 +49,5 @@ export function streamData(req: Request, res: Response, message: string) {
   // Close the connection after sending the last chunk
   setTimeout(() => {
     res.end();
-    console.log("finished sending transmission");
   }, delay);
 }