esp32-lora/test/test.js

162 lines
3.2 KiB
JavaScript
Raw Normal View History

2018-07-28 16:44:49 -04:00
var async = require("async");
var spawn = require("child_process").spawn;
var SerialPort = require("serialport");
var path = require("path");
var test = require("tape");
2018-07-28 17:30:48 -04:00
const exec = path.join(process.env.IDF_PATH, "components", "esptool_py", "esptool", "esptool.py");
2018-07-28 16:44:49 -04:00
const portString = "/dev/serial/by-id/usb-Silicon_Labs_CP2102_USB_to_UART_Bridge_Controller_SERIAL_ID-if00-port0";
const buildPath = path.join(__dirname, "lora32", "build");
var args = [
"--chip",
"esp32",
"--baud",
"460800",
"--before",
"default_reset",
"--after",
"hard_reset",
"write_flash",
"-z",
"--flash_mode",
"dio",
"--flash_freq",
"40m",
"--flash_size",
"detect",
"0x1000",
path.join(buildPath, "bootloader/bootloader.bin"),
"0x10000",
path.join(buildPath, "lora32.bin"),
"0x8000",
path.join(buildPath, "partitions_singleapp.bin")
];
function flash(port, cb) {
console.log("Flashing devices at %s", port);
var cp = spawn(exec, ["--port", port].concat(args));
cp.on("exit", function(code) {
console.log("%s\nexited: %d", port, code);
cb(code === 0 ? null : new Error("exited non-zero: " + code));
});
}
function toggleReset(sp) {
sp.set({
dtr: false
}, function() {
setTimeout(function() {
sp.set({
dtr: true
});
}, 1000);
});
}
function serial(port, cb) {
var to = -1;
var buf = "";
var sp = new SerialPort(port, {
baudRate: 115200
});
sp.once("open", function() {
console.log("port open %s", port);
sp.on("data", onData);
toggleReset(sp);
});
function done(reason) {
console.log("%s ready%s", port, reason || "");
cb(null, sp);
sp.removeListener("data", onData);
}
function onData(chunk) {
buf += chunk.toString();
clearTimeout(to);
to = setTimeout(function() {
done(" (timeout)");
}, 3000);
if(buf.indexOf("set_spread") !== -1) {
clearTimeout(to);
done(" (got set_spreadfactor)");
}
}
}
async.series([
function(next) {
if(process.env.NOFLASH) {
return next(null);
}
async.parallel([
function(done) {
flash(portString.replace("SERIAL_ID", "0001"), done);
}, function(done) {
flash(portString.replace("SERIAL_ID", "0002"), done);
}], next);
},
function(next) {
async.parallel({
dev1: function(done) {
serial(portString.replace("SERIAL_ID", "0001"), done);
},
dev2: function(done) {
serial(portString.replace("SERIAL_ID", "0002"), done);
}
}, next);
}
], function(err, results) {
var ports = results[1];
console.log("init done");
var buf = "";
var message = "test";
test.onFinish(function() {
console.log("Cleaning up");
ports.dev1.close();
ports.dev2.close();
});
test(function(t) {
t.plan(1);
ports.dev1.on("data", function onData(chunk) {
//process.stdout.write(chunk);
buf += chunk.toString();
if(buf.indexOf(`LORA32: msg: ${message}`) !== -1) {
ports.dev1.removeListener("data", onData);
t.ok("got round-trip message!");
}
});
ports.dev2.on("data", function(chunk) {
//process.stdout.write(chunk);
});
ports.dev2.write(`send${message}\n`);
});
});