# HG changeset patch
# User tzara <rc-web@kiben.net>
# Date 1341392140 0
# Node ID 69d572729f5d85a1c459756ff78c04d93218d028

initial push of nodescore server file

diff -r 000000000000 -r 69d572729f5d nodescore.js
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/nodescore.js	Wed Jul 04 08:55:40 2012 +0000
@@ -0,0 +1,226 @@
+////////////////////////////////////////////
+// nodescore server -- nodescore.kiben.net
+////////////////////////////////////////////
+// rc@kiben.net
+////////////////////////////////////////////
+
+var sio = require('socket.io')
+, http = require('http')
+, fs = require('fs')
+,  $ = require('jQuery')
+, static = require('node-static');
+
+////////////////////////////////////////////
+// run webserver serving static html
+////////////////////////////////////////////
+
+var clientFiles = new static.Server('./www');
+var httpServer = http.createServer(function(request, response) {
+    request.addListener('end', function () {
+	clientFiles.serve(request, response);	    
+    });    
+});
+httpServer.listen(8889);
+
+////////////////////////////////////////////
+// connect to websockets 
+////////////////////////////////////////////
+
+var io = sio.listen(httpServer)
+, nicknames = {};
+
+io.set('log level', 2); // reduce logging
+io.sockets.on('connection', function (socket) {
+
+    ////////////////////////////////////////////
+    // metronome
+    ////////////////////////////////////////////
+
+    function stopMetro () {
+	metroState=0;
+    };
+    
+    socket.on('metroStop', stopMetro)
+    ////////////////////////////////////////////
+    // Chronometer
+    ////////////////////////////////////////////
+
+    // number padding: 0 to 00
+
+    function pad(number) { return (number < 10 ? '0' : '') + number }
+    
+    // the chronometer initial states
+    var chronstate = 0; var zecsec = 0; var seconds = -20; 
+    var mins = 0; var hours = 0;
+ 
+    function startChr() { if (chronstate !== 1) {
+	chronstate = 1; chronometer();} 
+			}      // if not already started start the chronometer    
+    function stopChr() {  chronstate = 0; }  // stop the chronometer
+    function resetChr() {  clearInterval();  
+			   var zecsec = 0; var seconds = 0; 
+			   var mins = 0; var hours = 0; 
+			   var chronstate = 0; }
+       
+    function chronometer() {
+	clearInterval();	
+	if (chronstate==1){
+	zecsec += 1;       // set tenths of a second
+	if(zecsec > 9) { zecsec = 0; seconds += 1;}
+	if(seconds > 59) { seconds = 0;mins += 1;}
+	if(mins > 59) { mins = 0; hours += 1; }
+	var chron = pad(hours) +":"+pad(mins)+ ':'+ pad(seconds)+ ":"+ zecsec
+	setTimeout(function(){chronometer()}, 100);
+	socket.broadcast.emit('chronFromServer', chron)
+	socket.emit('chronFromServer', chron)
+	}
+    }
+    
+    socket.on('startChr', function () { startChr();});
+    socket.on('stopChr', function () { stopChr();});
+    socket.on('resetChr', function () { resetChr();});
+     
+    ////////////////////////////////////////////
+    // 
+    ///////////////////////////////////////////
+
+
+
+    ////////////////////////////////////////////  
+    // some latency calculations
+    ///////////////////////////////////////////
+
+    function serverTime(freq) {
+	//	clearInterval();
+	st=setInterval(function() {
+	    var d = new Date(); var n = d.getTime(); 
+	    socket.emit("timeFromServer", n); 
+	}, freq);   
+    }
+    socket.on("clientTimeResponse", function(x) {
+	var d = new Date(); var n = d.getTime();
+	var latency = (n-x)/2;
+	//console.log("SERVERTIME:"+x + " LATENCY:" + latency);
+	socket.emit("latencyFromServer", latency);
+    });	      
+    
+    socket.on("getLatencies", function(x){
+	serverTime(x);
+    });
+
+    ////////////////////////////////////////////
+    // magic square sequencer
+    ////////////////////////////////////////////
+
+    var sequencerState = 0;
+    var timemultiplier=1000
+    var srcsqr = []
+
+    srcsqr[0] = [22,21,24,25,06,07];
+    srcsqr[1] = [20,23,27,26,05,04];
+    srcsqr[2] = [03,00,17,16,35,34];
+    srcsqr[3] = [01,02,19,18,33,32];
+
+    var seqA = { metrobeat:0, voice:1, name: "A", counter: 0, mm: 60, beatsinbar: 4, durations: srcsqr[0], units: [1,2,3,1,2,4]};
+    var seqB = { metrobeat:0, voice:2, name: "B", counter: 0, mm: 60, beatsinbar: 4, durations: srcsqr[1], units: [3,2,1,1,2,3]};
+    var seqC = { metrobeat:0, voice:3, name: "C", counter: 0, mm: 60, beatsinbar: 4, durations: srcsqr[2], units: [4,5,6,5,4,2]};
+    var seqD = { metrobeat:0, voice:4, name: "D", counter: 0, mm: 60, beatsinbar: 4, durations: srcsqr[3], units: [2,3,4,2,3,1]};
+
+    var countdowntick;
+
+    countdowntick = function(seq){
+	var outcount = 12; var incount=12;
+	var time = ((seq.durations[seq.counter]+1) *timemultiplier) + 30000 + (outcount*1000);
+	var ztime = time; var totaltime = time/1000
+	var unit = seq.units[seq.counter];
+	var tempoms = 60000/seq.mm
+
+	setInterval(function(){
+	    
+	    if (ztime >= 0 ){
+		// basic unit is still the second/1000ms - change this to tempoms? no i dont think so
+		// count in and count out
+		////////////////////////////////////////////
+		
+		var counter = ztime/1000
+		
+		if (counter > 0 && counter <= outcount ) {              
+		    socket.broadcast.emit('countinFromServer', seq.voice, counter, "","", "white", "transparent");
+		}
+		// remove displayed number with " " at end of both countin/out
+		if (counter == 0 ) {
+		    socket.broadcast.emit('countinFromServer', seq.voice, " ", "","", "white","transparent");
+		}
+		
+		console.log(counter + "========" + totaltime)
+		if (counter > (totaltime)-incount  && counter <= totaltime ) {              
+		    socket.broadcast.emit('countinFromServer', seq.voice, counter-(totaltime-incount), "","", "red","gray");	    
+		}
+		
+		if (counter == (totaltime)-incount ) {
+		    socket.broadcast.emit('countinFromServer', seq.voice, " ", "","", "red","gray");
+		}
+	    	
+		// push out the pulse to metronome	
+		seq.metrobeat = (seq.metrobeat+1)%seq.beatsinbar ;
+     		console.log(seq.metrobeat);
+     		socket.broadcast.emit('metroPulse', tempoms, seq.voice,seq.metrobeat); 
+		socket.emit('metroPulse', tempoms, seq.voice,seq.metrobeat);	
+	    }
+	    
+	    // flip the page
+	    if (ztime == 0){
+		seq.counter = (seq.counter + 1) % seq.durations.length	    		
+		socket.broadcast.emit("pageFlipfromserver", seq.voice, unit, time, seq.mm,seq.counter);
+		socket.emit("pageFlipfromserver", seq.voice, unit, time, seq.mm,seq.counter);		
+		step(seq);     
+	    }
+	    	    	    
+	    // decrement the time 
+	    ztime -= 1000			
+	},tempoms)
+    };
+    
+
+    var step;
+    step = function (seq) {
+	console.log(seq.voice)
+	// add 30 seconds to the base magic square duration	
+	clearInterval(countdowntick);
+	countdowntick(seq)
+    };
+    
+    function startSeq() {
+	startChr();
+	// start the metronome
+	step(seqA); step(seqB); step(seqC); step(seqD); 
+    };
+    
+    socket.on('startSeq', function () { 
+	if (sequencerState == 0) { 
+	    metroState=1;
+	    sequencerState=1;
+	    startSeq();
+	}
+    });
+    
+    socket.on('stopSeq', function () { 
+	clearInterval(countdowntick);	    
+	sequencerState=0;  
+	metroState=0;
+    });
+
+});
+
+var chat = io.of('/chat');
+chat.on('connection', function (socket) {
+    console.log('chat connection');   
+    socket.on('message', function (msg) {
+        console.log(msg);  
+        chat.send(msg);
+    });
+});
+
+  
+
+