rc-web@49: /*
rc-web@49: ////////////////////////////////////////////
rc-web@49: 
rc-web@49: nodescore server
rc-web@49: nodescore.kiben.net
rc-web@49: nodescore@kiben.net
rc-web@49: 
rc-web@49: ////////////////////////////////////////////
rc-web@49: */
rc-web@49: var sio = require('socket.io')
rc-web@49: , http = require('http')
rc-web@49: , ch = require('./chronometer')
rc-web@49: , fs = require('fs')
rc-web@49: , static = require('node-static');
rc-web@49: // run webserver serving static html
rc-web@49: ////////////////////////////////////////////
rc-web@49: var clientFiles = new static.Server('./www');
rc-web@49: var httpServer = http.createServer(
rc-web@49:     function(request, response) {
rc-web@49: 	request.addListener('end', function () {
rc-web@49: 	    clientFiles.serve(request, response);	    
rc-web@49: 	    process.setMaxListeners(0);
rc-web@49: 	});    
rc-web@49:     });
rc-web@49: 
rc-web@49: httpServer.listen(8889);
rc-web@49: 
rc-web@49: 
rc-web@49: var pinging=0
rc-web@49: console.log("ping set to 0")
rc-web@49: 
rc-web@49: ////////////////////////////////////////////
rc-web@49: // connect to websockets 
rc-web@49: ////////////////////////////////////////////
rc-web@49: 
rc-web@49: var io = sio.listen(httpServer)
rc-web@49: , nicknames = {};
rc-web@49: 
rc-web@49: io.set('log level', 3); // reduce logging
rc-web@49: 
rc-web@49: io.sockets.on('connection', function (socket) {
rc-web@49: 
rc-web@49:     socket.on('nickname', function (nick, fn) {
rc-web@49: 	if (nicknames[nick]) {
rc-web@49: 	    fn(true);
rc-web@49: 	} else {
rc-web@49: 	    fn(false);
rc-web@49: 	    nicknames[nick] = socket.nickname = nick;
rc-web@49: 	    socket.broadcast.emit('announcement', nick + ' connected');
rc-web@49: 	    io.sockets.emit('nicknames', nicknames);
rc-web@49: 	}
rc-web@49:     });  
rc-web@49: 
rc-web@49:     /// chat user messages to screens and to log file
rc-web@49:     // date format for filename
rc-web@49: 
rc-web@49:     var da = new Date(); var dtstring = da.getFullYear()+ '-' + da.getMonth()+ '-' + da.getDate();
rc-web@49: 
rc-web@49:     ////////////////////////
rc-web@49:     /// log messages to file
rc-web@49:     socket.on('user message', function (msg) {
rc-web@49: 	fs.open('logs/chatlog-'+dtstring+'.txt', 'a', 666, function( e, id ) {	
rc-web@49: 	    //time format for message stamp
rc-web@49: 	    var dt = new Date();var timestring = dt.getHours() + ':' + dt.getMinutes() + ':' + dt.getSeconds();
rc-web@49: 	    
rc-web@49: 	    socket.broadcast.emit('user message', socket.nickname, msg);
rc-web@49: 	    
rc-web@49: 	    var fs = require('fs'), str = msg;
rc-web@49: 	    fs.write( id, timestring+" " + socket.nickname + ": "+ msg+"\n", null, 'utf8', function(){});
rc-web@49: 	});	
rc-web@49:     });
rc-web@49:     
rc-web@49:     ////////////////////////////////////////////
rc-web@49:     // metronome
rc-web@49:     ////////////////////////////////////////////
rc-web@49:     
rc-web@49:     socket.on('metroStop', stopMetro)
rc-web@49:     function stopMetro () {
rc-web@49: 	metroState=0;
rc-web@49:     };
rc-web@49: 
rc-web@49:     ////////////////////////////////////////////
rc-web@49:     // Chronometer
rc-web@49:     ////////////////////////////////////////////
rc-web@49: /*   
rc-web@49:     // number padding: 0 to 00
rc-web@49: 
rc-web@49:     function pad(number) { return (number < 10 ? '0' : '') + number }
rc-web@49:     
rc-web@49:     // the chronometer initial states
rc-web@49:     var chronstate = 0; var zecsec = 0; var seconds = 0; 
rc-web@49:     var mins = 0; var hours = 0;
rc-web@49:    
rc-web@49: 
rc-web@49:     dt = setInterval( function () {
rc-web@49: 	socket.broadcast.emit("dateTime", ch.dateTime());
rc-web@49: 	socket.emit("dateTime", ch.dateTime());
rc-web@49: 	console.log("boooooooooooo")
rc-web@49:     },1000)
rc-web@49: 
rc-web@49: 
rc-web@49:     function chronometer() {
rc-web@49: 	
rc-web@49: 	if (chronstate==1){
rc-web@49: 	    zecsec += 1;       // set tenths of a second
rc-web@49: 	    if(zecsec > 9) { zecsec = 0; seconds += 1;}
rc-web@49: 	    if(seconds > 59) { seconds = 0;mins += 1;}
rc-web@49: 	    if(mins > 59) { mins = 0; hours += 1; }
rc-web@49: 	    var chron = pad(hours) +":"+pad(mins)+ ':'+ pad(seconds)+ ":"+ zecsec
rc-web@49: 	    setTimeout(function(){chronometer()}, 100);
rc-web@49: 	    socket.broadcast.emit('chronFromServer', chron)
rc-web@49: 	    socket.emit('chronFromServer', chron)
rc-web@49: 	}
rc-web@49:     }
rc-web@49: 
rc-web@49: */
rc-web@49: 
rc-web@49:     var chronstate=0;
rc-web@49: 
rc-web@49:     function startChron (){
rc-web@49:     if (chronstate==1){
rc-web@49: 	stopwatch =  setInterval(function () {
rc-web@49: 	    c =  ch.chronometer(1)
rc-web@49: 	    socket.broadcast.emit('chronFromServer', c)
rc-web@49: 	    socket.emit('chronFromServer', c)
rc-web@49: 	}, 100)};
rc-web@49:     }
rc-web@49: 
rc-web@49: datetime =  setInterval(function () {
rc-web@49: 	d =  ch.dateTime()
rc-web@49: 	socket.broadcast.emit('dateTime', d)
rc-web@49: 	socket.emit('dateTime', d)
rc-web@49:     }, 1000)
rc-web@49: 
rc-web@49: 
rc-web@49: 
rc-web@49: 
rc-web@49:     socket.on('startChr', function () { startChr();}); 
rc-web@49:     // if not already started start the chronometer    
rc-web@49:     function startChr() { if (chronstate !== 1) { 
rc-web@49: 	chronstate = 1; 
rc-web@49: 	startChron();
rc-web@49: 
rc-web@49: } 
rc-web@49: 			}
rc-web@49: 
rc-web@49:     
rc-web@49:     socket.on('stopChr', function () { stopChr();} );    
rc-web@49:     function stopChr() {  chronstate = 0; }  
rc-web@49:     // stop the chronometer
rc-web@49:    
rc-web@49:     socket.on('resetChr', function () { resetChr();});
rc-web@49:     function resetChr() {//clearInterval();
rc-web@49: 			   chronstate = 0;
rc-web@49: 			   zecsec = 0; seconds = 0; 
rc-web@49: 			    mins = 0; hours = 0; 
rc-web@49: 			    chronstate = 0; 
rc-web@49: 			   var chron = pad(hours) +":"+pad(mins)+ ':'+ pad(seconds)+ ":"+ zecsec
rc-web@49: 			   // send 0.0.0 values to display
rc-web@49: 			   socket.broadcast.emit('chronFromServer', chron)
rc-web@49: 			   socket.emit('chronFromServer', chron)
rc-web@49: 			}
rc-web@49: 
rc-web@49:     ////////////////////////////////////////////
rc-web@49:     // magic square sequencer
rc-web@49:     ////////////////////////////////////////////
rc-web@49: //    var score = require('./score');
rc-web@49: //    var c = require('./chronometer');
rc-web@49: 
rc-web@49: //    var mm = score.mm
rc-web@49:     var sequencerState = 0;
rc-web@49:   
rc-web@49:     
rc-web@49:   //  var srcsqr = score.srcsqr
rc-web@49:     var srcsqr = []
rc-web@49:     srcsqr[0] = [22,21,24,25,06,07];
rc-web@49:     srcsqr[1] = [20,23,27,26,05,04];
rc-web@49:     srcsqr[2] = [03,00,17,16,35,34];
rc-web@49:     srcsqr[3] = [01,02,19,18,33,32];
rc-web@49: 
rc-web@49: //    var seqA = score.seqA
rc-web@49: //    var seqB = score.seqB
rc-web@49: //    var seqC = score.seqC
rc-web@49: //    var seqD = score.seqD
rc-web@49: 
rc-web@49:     var seqA = { metrobeat:0, voice:1, name: "A", counter: 0, mm: 60, beatsinbar: 4, durations: srcsqr[0], units: [1,2,3,1,2,4]};
rc-web@49:     var seqB = { metrobeat:0, voice:2, name: "B", counter: 0, mm: 120, beatsinbar: 4, durations: srcsqr[1], units: [3,2,1,1,2,3]};
rc-web@49:     var seqC = { metrobeat:0, voice:3, name: "C", counter: 0, mm: 90, beatsinbar: 4, durations: srcsqr[2], units: [4,5,6,5,4,2]};
rc-web@49:     var seqD = { metrobeat:0, voice:4, name: "D", counter: 0, mm: 105, beatsinbar: 4, durations: srcsqr[3], units: [2,3,4,2,3,1]};
rc-web@49:   
rc-web@49: 
rc-web@49:   
rc-web@49:      var countdowntick = function(seq){
rc-web@49: 	// var tempoms = Math.floor(60000/seq.mm)
rc-web@49: 	 var tempoms = Math.floor(60000/seq.mm)
rc-web@49: 	 //console.log(tempoms)
rc-web@49: 	 var timemultiplier=1
rc-web@49: 	 var outcount = 4; var incount=4;
rc-web@49: 	 var time = ((seq.durations[seq.counter]+1) *timemultiplier) + 30000 + (outcount*tempoms);
rc-web@49: 	 var time = Math.floor(time)
rc-web@49: 	 var ztime = time; 
rc-web@49: 	 var totaltime = Math.floor(time/tempoms)
rc-web@49: 	 var unit = seq.units[seq.counter];
rc-web@49: 	 
rc-web@49: 	 // initiate first page here
rc-web@49: 	 socket.broadcast.emit("pageFlipfromserver", seq.voice, unit, time, seq.mm,seq.counter);
rc-web@49: 	 socket.emit("pageFlipfromserver", seq.voice, unit, time, seq.mm,seq.counter);
rc-web@49: 	 
rc-web@49: 	 function sequenCer() {
rc-web@49: 	 //    console.log(ztime)
rc-web@49: 	     if (ztime >= 0 ){
rc-web@49: 		 
rc-web@49: 		// basic unit is still the second/1000ms - change this to tempoms? no i dont think so
rc-web@49: 		// count in and count out
rc-web@49: 		////////////////////////////////////////////
rc-web@49: 		
rc-web@49: 		 var counter = Math.floor(ztime/tempoms)
rc-web@49: 		 //console.log(counter)
rc-web@49: 		 if (counter >= 0 ){
rc-web@49: 		     socket.broadcast.emit('counterText', seq.voice, seq.counter, counter);
rc-web@49: 		     socket.emit('counterText', seq.voice, seq.counter, counter);
rc-web@49: 		     
rc-web@49: 		     if (counter <= outcount ) {              
rc-web@49: 			 socket.broadcast.emit('countinFromServer', seq.voice, counter, "","stop in: ", "red", "transparent");
rc-web@49: 		     }
rc-web@49: 		     
rc-web@49: 		     if (counter > (totaltime)-incount  && counter <= totaltime ) {
rc-web@49: 			 socket.broadcast.emit('countinFromServer', seq.voice, counter-(totaltime-incount), "","play in: ", "green","transparent");
rc-web@49: 			 socket.emit('countinFromServer', seq.voice, counter-(totaltime-incount), "","play in: ", "green","transparent");
rc-web@49: 			 
rc-web@49: 		     }
rc-web@49: 		     
rc-web@49: 		     if (counter == (totaltime)-incount ) {
rc-web@49: 			 socket.broadcast.emit('countinFromServer', seq.voice, "+", "","playing.. ", "green","transparent");
rc-web@49: 			socket.emit('countinFromServer', seq.voice, "+", "","playing.. ", "green","transparent");
rc-web@49: 		     }
rc-web@49: 		     
rc-web@49: 		     // remove displayed number with " " at end of both countin/out
rc-web@49: 		     
rc-web@49: 		     if (counter == 0 ) {
rc-web@49: 			 socket.broadcast.emit('countinFromServer', seq.voice, "", "","", "green","transparent");
rc-web@49: 			 socket.broadcast.emit('counterText', seq.voice, seq.counter, "");
rc-web@49: 			 socket.emit('counterText', seq.voice, seq.counter, "");
rc-web@49: 		     }
rc-web@49: 		 }		    
rc-web@49: 				
rc-web@49: 		 // on each beat do:
rc-web@49: 		 
rc-web@49: 		 // push out the pulse to metronome	
rc-web@49: 		 seq.metrobeat = (seq.metrobeat+1)%seq.beatsinbar ;
rc-web@49:      		 socket.broadcast.emit('metroPulse', tempoms, seq.voice,seq.metrobeat); 
rc-web@49: 		 socket.emit('metroPulse', tempoms, seq.voice,seq.metrobeat);
rc-web@49: 	     }
rc-web@49: 	     
rc-web@49: 	     // flip the page 
rc-web@49: 	     if (counter == 0){
rc-web@49: 
rc-web@49: 		 seq.counter = (seq.counter + 1) % seq.durations.length	    		
rc-web@49: 		socket.broadcast.emit("pageFlipfromserver", seq.voice, unit, time, seq.mm,seq.counter);
rc-web@49: 		 //delete tockTock;	
rc-web@49: 		 step(seq);     
rc-web@49: 	     }
rc-web@49: 	     
rc-web@49: 	     // decrement the time 
rc-web@49: 	     ztime -= tempoms
rc-web@49: 	 }
rc-web@49: 	 
rc-web@49: 	 var pulse = setInterval(sequenCer, tempoms);
rc-web@49: 	 
rc-web@49: 	 socket.on('stopSeq', function () {
rc-web@49: 	     //donaldduck = mickeymouse + 7
rc-web@49: 	     sequenCer.clearInterval
rc-web@49: 	     console.log("sequencer stopping...")	    
rc-web@49: 	     // grrr why wont this clearInterval work
rc-web@49: 	     sequencerState = 0
rc-web@49: 	     clearInterval(pulse)
rc-web@49: 	     stopChr();
rc-web@49: 	 });
rc-web@49:      };
rc-web@49:     
rc-web@49:     ////////////////
rc-web@49:     
rc-web@49:     socket.on('startSeq', function () { 
rc-web@49: 	if (sequencerState == 0) { 
rc-web@49: 	    console.log("sequencer starting...")	    
rc-web@49: 	    startChr();
rc-web@49: 
rc-web@49: //////////////////////////////////////////////////////////////////
rc-web@49: 
rc-web@49: 	    step(seqA);step(seqB); step(seqC); step(seqD);	    
rc-web@49: 	    ztime =-1;
rc-web@49:     }
rc-web@49: 
rc-web@49: 	else console.log("sequencer already started...")
rc-web@49:     });
rc-web@49:     
rc-web@49:     step = function (seq) {
rc-web@49: 	//clearInterval(seq.boo);
rc-web@49: 	//clearInterval(countdowntick);
rc-web@49: 	countdowntick(seq)
rc-web@49: 	sequencerState=1;
rc-web@49:     };
rc-web@49:     
rc-web@49:     socket.on('resetSeq', function () { 
rc-web@49: 	console.log("reset")
rc-web@49: 	resetChr();		
rc-web@49:     });
rc-web@49: 
rc-web@49:     
rc-web@49:     ////////////////////////////////////////////  
rc-web@49:     // some latency calculations
rc-web@49:     ///////////////////////////////////////////
rc-web@49:     
rc-web@49:     /*
rc-web@49:       a ping is periodically broadcast to all connected clients each
rc-web@49:       connected returns a pong to the server via an "emit" and in turn
rc-web@49:       the server returns each unique client a report of the latency
rc-web@49:       via another emit - the emit only sends to the source of the
rc-web@49:       request, whereas the broadcast.emit..  broadcasts.. ie to all
rc-web@49:       connected clients
rc-web@49:       
rc-web@49:       TODO: smooth range and average out results to remove erratic ping
rc-web@49:       times.
rc-web@49: 
rc-web@49:       TODO:
rc-web@49:       The result then needs to be used to stagger outgoing messages to
rc-web@49:       compensate for latency - how much compensation is more connected
rc-web@49:       to the time that any audio/video feed needs to encode/decode as
rc-web@49:       the latency of the route from node A to node B is inavoidable?!
rc-web@49:       so maybe latency is irrelevant in this context - we just need to
rc-web@49:       stagger signals according to encoding decoding times.. hmmm
rc-web@49:     */
rc-web@49: 
rc-web@49: 
rc-web@49: // periodically broadcast a ping
rc-web@49:     function serverTime(freq) {
rc-web@49: 	if (pinging==0){ st = setInterval(function() {
rc-web@49: 	    var pinging=1;
rc-web@49: 	    var d = new Date(); var n = d.getTime(); 
rc-web@49: 	    socket.emit("timeFromServer", n); 
rc-web@49: 	}, 1000);   } else console.log("already pinging")
rc-web@49:     }
rc-web@49:     // receive the pong calculate the latency and
rc-web@49:     // return the response to the client
rc-web@49: 
rc-web@49:     socket.on("clientTimeResponse", function(x) {
rc-web@49: 	var d = new Date(); var n = d.getTime();
rc-web@49: 	var latency = (n-x)/2;
rc-web@49: 	//console.log("SERVERTIME:"+x + " LATENCY:" + latency);
rc-web@49: 	socket.emit("latencyFromServer", latency);
rc-web@49:     });	      
rc-web@49:     
rc-web@49:     // this is the trigger from the control client to start the process
rc-web@49:     // maybe remove this and have latency connections constantly running
rc-web@49:     
rc-web@49:     /*
rc-web@49:       socket.on("getLatencies", function(x){
rc-web@49:       serverTime(x);
rc-web@49:       });
rc-web@49:     */
rc-web@49:     
rc-web@49:     serverTime(1000);
rc-web@49:     
rc-web@49:     socket.on('disconnect', function(client) {	
rc-web@49: 	console.log(socket.nickname + " is gone..." )
rc-web@49: 	clearInterval(st);
rc-web@49: 	
rc-web@49: 	if (!socket.nickname) return;
rc-web@49: 	
rc-web@49: 	delete nicknames[socket.nickname];
rc-web@49: 	socket.broadcast.emit('announcement', socket.nickname + ' disconnected');
rc-web@49: 	socket.broadcast.emit('nicknames', nicknames);
rc-web@49:     });
rc-web@49: 
rc-web@49: });