Server bpm compute

Author: sliterok

mic-sender.js

@@ -1,45 +1,14 @@
-import { Essentia, arrayToVector } from 'essentia.js'
 import mic from 'mic'
 import WebSocket from 'ws'
 
-async function main() {
-  const url = process.argv[2] || 'ws://localhost:8081'
-  const ws = new WebSocket(url)
-  await new Promise(resolve => ws.once('open', resolve))
+const url = process.argv[2] || 'ws://localhost:8081'
+const ws = new WebSocket(url)
 
-  const essentia = await Essentia()
-  const sampleRate = 44100
-  const bufferSizeSec = 5
-  const bufferSize = sampleRate * bufferSizeSec
-  let buffer = new Float32Array(0)
-
-  const rhythmAlgo = (signal) =>
-    essentia.RhythmExtractor2013({ signal, sampleRate })
-
-  const micInst = mic({ rate: sampleRate.toString(), channels: '1' })
+ws.on('open', () => {
+  const micInst = mic({ rate: '44100', channels: '1' })
   const micStream = micInst.getAudioStream()
-
   micInst.start()
-
-  micStream.on('data', (chunk) => {
-    ws.send(chunk)
-    const pcm = new Float32Array(chunk.buffer, chunk.byteOffset, chunk.length / 4)
-    const tmp = new Float32Array(buffer.length + pcm.length)
-    tmp.set(buffer)
-    tmp.set(pcm, buffer.length)
-    buffer = tmp
-    if (buffer.length >= bufferSize) {
-      const sigVec = arrayToVector(buffer)
-      const res = rhythmAlgo(sigVec)
-      const bpm = res.bpm
-      ws.send(JSON.stringify({ bpm }))
-      console.log(`BPM: ${bpm.toFixed(2)}, ticks: ${res.ticks.length}`)
-      buffer = buffer.subarray(bufferSize)
-    }
-  })
-
+  micStream.on('data', chunk => ws.send(chunk))
   micStream.on('error', console.error)
-}
-
-main().catch(console.error)
+})
 

package.json

@@ -52,8 +52,8 @@
 		"d3-interpolate": "^3.0.1",
 		"dotenv": "^16.4.5",
 		"express": "^4.18.2",
-		"fft-js": "^0.0.12",
-		"music-tempo": "^1.0.3",
+                "fft-js": "^0.0.12",
+                "music-tempo": "^1.0.3",
                 "mic": "^2.1.1",
                 "essentia.js": "^0.1.3",
 		"react": "^19.1.0",

src/backend/wsAudio.ts

@@ -20,16 +20,7 @@ export function startAudioServer(port = 8081) {
 	const wss = new WebSocketServer({ port })
 	wss.on('connection', ws => {
 		ws.on('message', data => {
-			if (Buffer.isBuffer(data)) {
-				processAudio(data)
-			} else {
-				try {
-					const msg = JSON.parse(data.toString())
-					if (typeof msg.bpm === 'number') audioState.bpm = msg.bpm
-				} catch {
-					// ignore non-json messages
-				}
-			}
+			if (Buffer.isBuffer(data)) processAudio(data)
 		})
 	})
 }