feat: some adjustements for testing locally

src/network/mqtt/routes/photo.ts

@@ -4,6 +4,7 @@ import { z } from 'zod'
 
 import { socketConnection } from 'network/socket'
 import { MAIN_TOPIC } from 'utils'
+// import { writeFile } from 'fs/promises'
 
 const TOPIC = 'receivePhoto'
 const SUB_TOPIC = `${MAIN_TOPIC}/${TOPIC}`
@@ -29,6 +30,8 @@ const sub = (client: MqttClient) => {
       const messageString = message.toString()
       subDebug(`Topic: ${topic} - Message received: ${message.toString()}`)
 
+      if (!messageString) return
+
       const messageJson = JSON.parse(messageString)
       const messageValidation = messageSchema.safeParse(messageJson)
 
@@ -39,6 +42,15 @@ const sub = (client: MqttClient) => {
       }
 
       const { data } = messageValidation
+      // const base64 = data.base64.split(';base64,').pop()
+
+      // if (!base64) return
+
+      // const buffer = Buffer.from(base64, 'base64')
+      // // save the base64 as a file
+      // writeFile(`./${data.meta.timestamp}.jpeg`, buffer).then(() => {
+      //   subDebug('File saved')
+      // })
       const {
         meta: { sensorId }
       } = data

src/network/server.ts

@@ -15,11 +15,13 @@ const start = async () => {
     await dbConnection(serverDebug).connect()
   })
 
-  const jobs = await import('../jobs')
+  if (process.env.NODE_ENV !== 'local') {
+    const jobs = await import('../jobs')
 
-  ;(Object.keys(jobs) as (keyof typeof jobs)[]).forEach(job => {
-    jobs[job](getClient(serverDebug))
-  })
+    ;(Object.keys(jobs) as (keyof typeof jobs)[]).forEach(job => {
+      jobs[job](getClient(serverDebug))
+    })
+  }
 }
 
 export { start }

src/pub.ts

@@ -10,6 +10,10 @@ client.on('error', error => {
   pubDebug('Error: ', error)
 })
 
-client.publish(`${MAIN_TOPIC}/electricConductivity`, 'wea', () => {
-  pubDebug('Message send')
-})
+client.publish(
+  `${MAIN_TOPIC}/takePhoto`,
+  'Wp82DjwYQVhhLzm3eYomosZTWSq1/1/1',
+  () => {
+    pubDebug('Message send')
+  }
+)