me/mime-chat
Watch
1
0
Fork
You've already forked mime-chat
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge remote-tracking branch 'origin/main' into audio_test

Browse source
This commit is contained in:
Enrique Hernandez 2021-03-03 14:31:24 -06:00
commit cb68e84c0e
1 changed files with 16 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

26
src/background/audio.ts
View file

@ -9,7 +9,11 @@ const portAudio = require('naudiodon');
let ai: typeof portAudio.AudioIO | null = null;
let ao: typeof portAudio.AudioIO | null = null;
let audioInput: Buffer[] = [];
const audioInput: Buffer[] = [];
const audioContainer = {
input: '',
}
const audio: Buffer | null = null;
const encoding = "base64";
const audioOptions = {
channelCount: 1,
@ -19,8 +23,8 @@ const audioOptions = {
closeOnError: false,
}
backgroundMitt.once('window-active', (state: boolean) => {
if(!state) {
backgroundMitt.once('window-active', (active: boolean) => {
if(!active) {
stopStream();
}
});
@ -30,7 +34,6 @@ export function initAudioIO(): void {
if (ai != null) {
ai.quit();
audioInput = [];
}
ai = new portAudio.AudioIO({ inOptions: audioOptions });
@ -44,8 +47,9 @@ export function initAudioIO(): void {
ai.on('data', (chunk: string) => {
// turn string base64 data into buffer object.
const buf = Buffer.from(chunk, encoding);
audioInput.push(buf);
audioContainer.input += chunk;
// const buf = Buffer.from(chunk, encoding);
// audioInput.push(buf);
});
if (ao != null) {
@ -59,15 +63,17 @@ export function initAudioIO(): void {
const updateRecorder = (_event, record: boolean): void => {
if (record) {
// resume mic data flow on space bar key down.
while(audioInput.length) { audioInput.pop() }
// while(audioInput.length) { audioInput.pop() }
if(audioContainer.input.length) audioContainer.input = '';
ai.resume();
} else {
// stop mic data flow on space bar key up.
ai.pause();
const audio = Buffer.concat(audioInput);
sendAudio(audio);
const buf = Buffer.from(audioContainer.input, encoding);
sendAudio(buf);
// clear audioInput.
while(audioInput.length) { audioInput.pop() }
audioContainer.input = '';
// while(audioInput.length) { audioInput.pop() }
}
}