refactor(log-services): 🎉 update log services and camera libs

app/app.ts

@@ -6,6 +6,7 @@ import appRouters from "./src/routes/app.routes";
 import bodyParser from "body-parser";
 import cors from "cors";
 import logRouters from "./src/routes/log.routes";
+import foto from "./src/functions/foto";
 
 async function app() {
   const app = express();
@@ -25,6 +26,8 @@ async function app() {
 
   app.use("/", appRouters);
 
+  foto();
+
   app.use("/log", logRouters);
 
   const server = app.listen(env.robot.port, async function () {

app/src/functions/foto.ts

@@ -0,0 +1,20 @@
+import * as NodeWebcam from "node-webcam";
+
+export default async function cam() {
+  const opts = {
+    width: 1280,
+    height: 720,
+    quality: 100,
+    device: "/dev/video0",
+  };
+
+  const Webcam = NodeWebcam.create(opts);
+
+  Webcam.capture("/home/gokhangunduz/Desktop/test.jpg", (err, data) => {
+    if (err) {
+      console.error(err);
+    } else {
+      console.log("Kamera başarıyla açıldı.");
+    }
+  });
+}

app/src/functions/video.ts

@@ -0,0 +1,29 @@
+// import cv from "opencv4nodejs";
+
+// // Video kaydı için kullanılacak dosya adı ve FPS (kare hızı)
+// const videoFileName = "output.mp4";
+// const fps = 30;
+
+// // Video çekimine başlayın
+// const camera = new cv.VideoCapture(0); // 0, varsayılan kamera cihazını temsil eder
+
+// const videoWriter = new cv.VideoWriter(
+//   videoFileName,
+//   cv.VideoWriter.fourcc("X", "2", "6", "4"),
+//   fps,
+//   new cv.Size(640, 480),
+//   true
+// );
+
+// const delay = 1000 / fps;
+
+// function captureFrame() {
+//   const frame = camera.read();
+//   if (!frame.empty) {
+//     videoWriter.write(frame);
+//   }
+//   setTimeout(captureFrame, delay);
+// }
+
+// console.log(`Video kaydediliyor: ${videoFileName}`);
+// captureFrame();

app/src/routes/log.routes.ts

@@ -5,4 +5,10 @@ const router = express.Router();
 
 router.get("/", logServices.get);
 
+router.get("/:name", logServices.getWithName);
+
+router.delete("/", logServices.remove);
+
+router.delete("/:name", logServices.removeWithName);
+
 export default router;

app/src/services/log.services.ts

@@ -1,17 +1,67 @@
 import { Request, Response } from "express";
 import setResponse from "../helpers/setResponse.helper";
 import getRosLogs from "../functions/getRosLogs.function";
+import { RobotLog } from "../types/types";
+import fs from "fs";
 
 async function get(req: Request, res: Response) {
-  const files = await getRosLogs();
+  try {
+    const files: RobotLog[] | null = await getRosLogs();
 
-  if (files) {
-    setResponse(res, 200, "ROS logs retrieved successfully.", files);
-  } else {
-    setResponse(res, 500, "Error while getting ROS logs.", null);
+    if (files) {
+      setResponse(res, 200, "ROS logs retrieved successfully.", files);
+    } else {
+      setResponse(res, 500, "Error while getting ROS logs.", null);
+    }
+  } catch (error) {
+    setResponse(res, 500, "An error occurred", null);
+  }
+}
+
+async function getWithName(req: Request, res: Response) {
+  fs.readFile(
+    `/home/${process.env.USER}/.ros/log/${req.params.name}`,
+    "utf8",
+    function (err: any, data: any) {
+      if (err) {
+        setResponse(res, 500, "Error while getting ROS logs.", null);
+        return;
+      }
+      setResponse(res, 200, "ROS logs retrieved successfully.", data);
+    }
+  );
+}
+
+async function remove(req: Request, res: Response) {
+  try {
+    const files: RobotLog[] | null = await getRosLogs();
+
+    files?.map((file) => {
+      try {
+        fs.rmSync(`/home/${process.env.USER}/.ros/log/${file.name}`);
+      } catch (error) {
+        throw error;
+      }
+    });
+
+    setResponse(res, 200, "ROS logs removed successfully.", null);
+  } catch (error) {
+    setResponse(res, 500, "Error while removing ROS logs.", null);
+  }
+}
+
+async function removeWithName(req: Request, res: Response) {
+  try {
+    fs.rmSync(`/home/${process.env.USER}/.ros/log/${req.params.name}`);
+    setResponse(res, 200, "ROS log removed successfully.", null);
+  } catch (error) {
+    setResponse(res, 500, "Error while removing ROS log.", null);
   }
 }
 
 export default {
   get,
+  getWithName,
+  remove,
+  removeWithName,
 };

app/src/types/types.ts

@@ -37,3 +37,12 @@ export type Topic = {
   name: string;
   listener?: any;
 };
+
+export type RobotLog = {
+  name: string;
+  isDirectory: boolean;
+  path: string;
+  size: number;
+  createdAt: number;
+  updatedAt: number;
+};

package.json

@@ -22,6 +22,7 @@
     "@types/cors": "^2.8.14",
     "@types/express": "^4.17.19",
     "@types/node": "^20.8.4",
+    "@types/node-webcam": "^0.8.2",
     "express": "^4.18.2",
     "ts-node": "^10.9.1",
     "typescript": "^5.2.2"
@@ -31,6 +32,7 @@
     "cors": "^2.8.5",
     "dotenv": "^16.3.1",
     "kafkajs": "^2.2.4",
+    "node-webcam": "^0.8.2",
     "rclnodejs": "^0.23.1"
   }
 }