diff --git a/app.js b/app.js index 2b273e8..d287681 100644 --- a/app.js +++ b/app.js @@ -3,30 +3,40 @@ var lame = require('lame'); var mumble = require('mumble'); -mumble.connect('mumble://wallpiece:9648', function( error, client ) { - if( error ) { throw new Error( error ); } +mumble.connect('mumble://wallpiece:9648', function(error, client) { + if(error) { throw new Error(error); } client.authenticate('MusicBot', 'yolo'); - client.on( 'initialized', function() { - start( client ); + client.on('initialized', function () { + start(client); }); }); var start = function( client ) { - // client.outputStream().pipe(client.inputStream()); var input = client.inputStream(); var decoder = new lame.Decoder(); - var stream; - decoder.on( 'format', function( format ) { - console.log( format ); + client.channelByName('Gaming').join() - stream.pipe( client.inputStream({ - channels: format.channels, - sampleRate: format.sampleRate, - gain: 1 - })); + client.on('textMessage', function (data) { + // console.log(client.userBySession(data.session[0])); + if (data.message == 'play') { + var stream; + decoder.on( 'format', function( format ) { + // console.log( format ); + + stream.pipe( client.inputStream({ + channels: format.channels, + sampleRate: format.sampleRate, + gain: 0.1 + })); + }); + + stream = require('fs').createReadStream(__dirname + '/test.mp3').pipe( decoder ); + } + client.channelByName('Gaming').join() + // if (data.) + // client.sendMessage('Received message'); }); - stream = require('fs').createReadStream(__dirname + '/test.mp3').pipe( decoder ); };