acc-tidal/index.js

92 lines
2.1 KiB
JavaScript

const { SerialPort } = require('serialport')
const { DelimiterParser } = require('@serialport/parser-delimiter')
const osc = require("osc")
// Create an osc.js UDP Port listening on port 57121.
const udpPort = new osc.UDPPort({
localAddress: "0.0.0.0",
localPort: 57129,
metadata: true
});
// Listen for incoming OSC messages.
udpPort.on("message", function (oscMsg, timeTag, info) {
console.log("An OSC message just arrived!", oscMsg);
console.log("Remote info is: ", info);
});
// Open the socket.
udpPort.open();
const { fft, util } = require("fft-js");
const port = new SerialPort({
path: '/dev/ttyUSB1',
baudRate: 115200,
autoOpen: false,
})
port.open(function (err) {
if (err) {
return console.log('Error opening port: ', err.message)
}
// Because there's no callback to write, write errors will be emitted on the port:
port.write('main screen turn on')
})
// The open event is always emitted
port.on('open', function () {
// open logic
})
let signals = [];
let numDevices = 2;
for (let i = 0; i < numDevices; i++) {
signals[i] = [];
}
const parser = port.pipe(new DelimiterParser({ delimiter: "\n" }))
parser.on("data", (data) => {
let xyzs = data.toString().replace(/\s/g, "").split(",");
let results = [];
if (xyzs.length == 3 * numDevices) {
for (let i = 0; i < numDevices; i++) {
let signal = signals[i];
let x = parseFloat(xyzs[3 * i + 0]);
let y = parseFloat(xyzs[3 * i + 1]);
let z = parseFloat(xyzs[3 * i + 2]);
signal.push(Math.sqrt(x * x + y * y + z * z));
if (signal.length > 16) {
signal.shift();
let p = fft(signal);
let mag = util.fftMag(p);
let value = Math.min(1, mag[7] * 2);
results.push(value);
udpPort.send({
address: "/ctrl",
args: [
{
type: "s",
value: "s" + i
},
{
type: "f",
value
},
]
}, "127.0.0.1", 6010);
}
}
}
if (results.length > 0) {
console.log(results);
}
});