49 lines
1.2 KiB
JavaScript
49 lines
1.2 KiB
JavaScript
const dgram = require("dgram");
|
|
const fs = require("fs");
|
|
const path = require("path");
|
|
const cellularChunking = require("./../cellularChunking");
|
|
const messageParser = require("./../messages");
|
|
|
|
const socket = dgram.createSocket("udp4");
|
|
|
|
const theFiles = fs.readdirSync("./alldata")
|
|
theFiles.sort()
|
|
console.log(theFiles)
|
|
let thisFileInd = theFiles.length - 3
|
|
|
|
function send_next_line(i, theLines) {
|
|
console.log(`sending line ${i} of ${theLines.length}`);
|
|
if (theLines.length > i) {
|
|
const theBits = theLines[i].split(" ")
|
|
if(theBits.length < 3 || theBits[2].length < 10) {
|
|
send_next_line(i+1, theLines)
|
|
} else {
|
|
socket.send(
|
|
Buffer.from(theBits[2], "hex"),
|
|
57321,
|
|
"127.0.0.1",
|
|
function (err) {
|
|
setTimeout(send_next_line, 250, i + 1, theLines);
|
|
//send_next_line(i + 1, theLines)
|
|
},
|
|
);
|
|
}
|
|
} else {
|
|
thisFileInd += 1
|
|
do_next_file()
|
|
}
|
|
}
|
|
|
|
function do_next_file() {
|
|
if (thisFileInd > theFiles.length - 2) {
|
|
return
|
|
}
|
|
const fileData = fs.readFileSync(`./alldata/${theFiles[thisFileInd]}`, "utf8");
|
|
const theLines = fileData.split("\n");
|
|
let i = 0;
|
|
send_next_line(i, theLines);
|
|
}
|
|
|
|
// open the file with the messages and then send them
|
|
do_next_file()
|