start of test script

test/test.js

@@ -0,0 +1,163 @@
+var async = require("async");
+var spawn = require("child_process").spawn;
+var SerialPort = require("serialport");
+var path = require("path");
+var test = require("tape");
+
+const exec = path.require(process.env.IDF_PATH, "components", "esptool_py", "esptool", "esptool.py");
+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);
+
+  console.log(args);
+
+  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`);
+  });
+});