fix: clean queue to avoid retain

.gitignore

@@ -128,3 +128,4 @@ dist
 # End of https://www.toptal.com/developers/gitignore/api/node,yarn
 
 src/**/*.png
+*.jpeg

package.json

@@ -10,7 +10,7 @@
     "release": "standard-version",
     "test:local": "jest --setupFiles dotenv/config --ci -i",
     "test:ci": "jest --ci -i",
-    "pub": "nodemon --exec \"DEBUG=WQ:* ts-node -r dotenv/config src/pub.ts\""
+    "pub": "nodemon --exec \"DEBUG=WQ:* ts-node -r dotenv/config scripts/pub.ts\""
   },
   "author": "AnthonyLzq <sluzquinosa@uni.pe>",
   "license": "MIT",

src/pub.ts → scripts/pub.ts

@@ -1,7 +1,7 @@
 import debug from 'debug'
 
-import { MAIN_TOPIC } from 'utils'
-import { getClient } from './network/mqtt'
+import { MAIN_TOPIC } from '../src/utils'
+import { getClient } from '../src/network/mqtt'
 
 const pubDebug = debug(`${MAIN_TOPIC}:Mqtt:demo:pub`)
 const client = getClient()

src/network/mqtt/routes/photo.ts

@@ -4,7 +4,8 @@ import { z } from 'zod'
 
 import { socketConnection } from 'network/socket'
 import { MAIN_TOPIC } from 'utils'
-// import { writeFile } from 'fs/promises'
+
+import { writeFile } from 'fs/promises'
 
 const TOPIC = 'receivePhoto'
 const SUB_TOPIC = `${MAIN_TOPIC}/${TOPIC}`
@@ -42,15 +43,19 @@ const sub = (client: MqttClient) => {
       }
 
       const { data } = messageValidation
-      // const base64 = data.base64.split(';base64,').pop()
 
-      // if (!base64) return
+      if (process.env.NODE_ENV === 'local') {
+        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 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

tsconfig.base.json

@@ -75,7 +75,8 @@
     "src",
     "test",
     "tests",
-    "__test__"
+    "__test__",
+    "scripts"
   ],
   "exclude": [
     "node_modules"

tsconfig.json

@@ -8,7 +8,8 @@
     "test",
     "tests",
     "__test__",
-    "dist"
+    "dist",
+    "scripts"
   ],
   "include": [
     "src"