Update server.js

server.js

@@ -4,7 +4,8 @@ const {
     createAudioPlayer, 
     createAudioResource, 
     AudioPlayerStatus, 
-    StreamType 
+    StreamType,
+    NoSubscriberBehavior
 } = require('@discordjs/voice');
 const express = require('express');
 const app = express();
@@ -25,27 +26,35 @@ const client = new Client({
 });
 
 let voiceConnection;
-const player = createAudioPlayer();
+const player = createAudioPlayer({
+    behaviors: {
+        noSubscriber: NoSubscriberBehavior.Play, // Tiếp tục chạy ngay cả khi không có ai nghe
+    },
+});
+
 let aiStream = null;
 
-// HÀM FIX: Quản lý luồng âm thanh thông minh hơn
 function setupAudioPipeline() {
-    // Nếu đã có stream và đang chạy thì không tạo lại để tránh mất dữ liệu
-    if (aiStream && player.state.status !== AudioPlayerStatus.Idle) return;
+    // Nếu đang có luồng cũ thì kết thúc nó để làm sạch bộ nhớ
+    if (aiStream) {
+        aiStream.destroy();
+    }
 
     aiStream = new PassThrough();
-    
-    // WebmDemuxer giúp tách Opus từ WebM gửi từ Browser
     const demuxer = new prism.opus.WebmDemuxer();
     
+    // Pipe dữ liệu qua demuxer để lấy Opus chuẩn
     const resource = createAudioResource(aiStream.pipe(demuxer), {
         inputType: StreamType.Opus,
-        inlineVolume: true // Cho phép chỉnh âm lượng nếu cần
+        inlineVolume: true
     });
 
-    resource.volume.setVolume(1.5); // Tăng âm lượng lên một chút
+    if (resource.volume) {
+        resource.volume.setVolume(2.0); // Ép âm lượng to lên 200%
+    }
+
     player.play(resource);
-    console.log("🎙️ Discord Player: Luồng giải mã đã kích hoạt.");
+    console.log("🎙️ Discord Player: Luồng giải mã đã kích hoạt và đang chờ dữ liệu...");
 }
 
 app.get('/join', (req, res) => {
@@ -59,11 +68,13 @@ app.get('/join', (req, res) => {
         channelId: channel.id,
         guildId: guildId,
         adapterCreator: channel.guild.voiceAdapterCreator,
+        selfDeaf: false, // TẮT gạch chéo tai nghe
+        selfMute: false  // TẮT gạch chéo mic
     });
     
     voiceConnection.subscribe(player);
-    setupAudioPipeline(); // Chuẩn bị sẵn luồng
-    res.send("Bot đã vào phòng voice!");
+    setupAudioPipeline();
+    res.send("Bot đã vào phòng voice và đã tháo tai nghe!");
 });
 
 io.on('connection', (socket) => {
@@ -71,12 +82,12 @@ io.on('connection', (socket) => {
 
     socket.on('ai_audio_stream', (audioData) => {
         if (audioData && audioData.byteLength > 0) {
-            // Đảm bảo pipeline luôn sẵn sàng
-            if (!aiStream || player.state.status === AudioPlayerStatus.Idle) {
+            // Nếu player bị Idle (hết dữ liệu cũ), khởi động lại pipeline
+            if (player.state.status === AudioPlayerStatus.Idle) {
                 setupAudioPipeline();
             }
             
-            if (aiStream.writable) {
+            if (aiStream && aiStream.writable) {
                 aiStream.write(Buffer.from(audioData));
             }
         }
@@ -87,7 +98,6 @@ io.on('connection', (socket) => {
     });
 });
 
+client.on('ready', () => console.log(`🤖 Bot ${client.user.tag} đã sẵn sàng!`));
 client.login(process.env.DISCORD_TOKEN);
-server.listen(process.env.PORT || 7860, () => {
-    console.log(`🚀 Cầu nối Yue AI đang chạy`);
-});
+server.listen(process.env.PORT || 7860, () => console.log("🚀 Server đang chạy..."));