MQTT File Copy

fileReceiver.js

const mqtt = require("mqtt");
const fs = require("fs");
const client = mqtt.connect("mqtt://localhost");

client.on("connect", function () {
    client.subscribe("test");
});

client.on("message", function (topic, message) {
    data = JSON.parse(message);
    console.log(data);
    fs.writeFileSync("result-" + data.name, Buffer.from(data.data));
    client.end();
});

fileSender.js

const mqtt = require('mqtt');
const fs = require('fs');
const client = mqtt.connect('mqtt://localhost');

let fileName = "test.txt";
let data = fs.readFileSync(fileName);
let buffer = {
    "name": fileName,
    "data": data,
}

client.on('connect', function () {
    client.subscribe('test');
    client.publish('test', JSON.stringify(buffer));
})

client.on('message', function (topic, message) {
    console.log(`Sender: ${topic}`);
    client.end();
});