diff --git a/memory/memories.db b/memory/memories.db index 9d5edf20e..fdeb675ec 100644 Binary files a/memory/memories.db and b/memory/memories.db differ diff --git a/memory/memories.db-shm b/memory/memories.db-shm index 5f05045c2..c9a701697 100644 Binary files a/memory/memories.db-shm and b/memory/memories.db-shm differ diff --git a/memory/memories.db-wal b/memory/memories.db-wal index 92a538dae..a8edca1c5 100644 Binary files a/memory/memories.db-wal and b/memory/memories.db-wal differ diff --git a/tools/meeting-notes/dist/index.js b/tools/meeting-notes/dist/index.js index 955a41057..60d6658f6 100644 --- a/tools/meeting-notes/dist/index.js +++ b/tools/meeting-notes/dist/index.js @@ -1,6 +1,7 @@ import 'dotenv/config'; import { Client, GatewayIntentBits, ChannelType, Events } from 'discord.js'; import { joinVoiceChannel, EndBehaviorType } from '@discordjs/voice'; +import prism from 'prism-media'; import { writeFile } from 'fs/promises'; import { existsSync, mkdirSync, unlinkSync } from 'fs'; import { resolve, dirname } from 'path'; @@ -196,12 +197,14 @@ class MeetingNotesBot { subscribeToUser(receiver, userId, userName) { if (!this.activeSession) return; - const audioStream = receiver.subscribe(userId, { + const opusStream = receiver.subscribe(userId, { end: { behavior: EndBehaviorType.AfterSilence, duration: 2000, }, }); + const decoder = new prism.opus.Decoder({ rate: 48000, channels: 2, frameSize: 960 }); + const audioStream = opusStream.pipe(decoder); audioStream.on('data', (chunk) => { const buffers = this.audioBuffers.get(userId) || []; buffers.push(chunk);