merge from hell

Author: cmilfont

Podcast.js

@@ -0,0 +1,30 @@
+var fs  = require('fs');
+
+function Podcast(user, file) {
+	this.user = user;
+	this.file = file;
+	this.filename = "podcasts/" + file + ".raw";
+	this.stream = {};
+	this.isOpen = false;
+	this.fileDescription = {};
+}
+
+Podcast.prototype.record = function() {
+	var self = this;
+	this.stream = fs.createWriteStream(this.filename);
+    this.stream.once('open', function(fd) {
+        self.isOpen = true;
+        self.fileDescription = fd;
+    });
+}
+
+Podcast.prototype.append = function(samples) {
+	this.stream.write(samples);
+}
+
+Podcast.prototype.stop = function() {
+	this.isOpen = false;
+	this.stream.end();
+}
+
+module.exports.Podcast = Podcast;

app.js

@@ -3,6 +3,9 @@ var nko = require('nko')('hfu9xf2WkLaqCx+T');
 var sio = require('socket.io');
 var fs  = require('fs');
 
+require("./normalize");
+var Podcast = require("./Podcast").Podcast;
+
 var app     = express.createServer();
 
 app.set('views', __dirname + '/views');
@@ -15,10 +18,19 @@ app.use(express.bodyParser());
 app.use(app.router);
 
 app.get('/', function(req, res, next){
-    res.render("index");
-    res.end();
+	res.render("index");
+});
+
+
+app.get('/talk', function(req, res, next){
+    res.render("talk");
+});
+
+app.get('/listen', function(req, res, next){
+    res.render("listen");
 });
 
+
 app.use(express.errorHandler({ showStack: true }));
 app.use(express.static(__dirname));
 
@@ -27,39 +39,40 @@ app.listen(80, function () {
   console.log('   app listening on http://' + addr.address + ':' + addr.port);
 });
 
-var stream;
+var users = {
+	milfont: {
+		podcasts: []
+	}
+};
 
 var io = sio.listen(app);
 io.set('log level', 1);
 
 io.sockets.on('connection', function (client) {
-    
-  client.on('user message', function (msg) {
-    client.broadcast.emit('podcast', "MIlfont", msg);
-    if(stream) {
-        try {
-            stream.write(msg);
-        } catch(e) {
-            console.log(stream, e);
-        }
-    }
+
+  client.on('user message', function (user, file, msg) {
+    client.broadcast.emit('podcast', "milfont", msg);
+    var podcast = users[user].podcasts.filter(function(podcast){
+        return podcast.file === file;
+    }).first();
+    if(podcast) podcast.append(msg);
   });
 
-  client.on('start', function(name) {
-    stream = fs.createWriteStream("podcasts/" + name + ".wav");
-    stream.once('open', function(fd) {
-        
-    });
+  client.on('start', function(user, name) {
+  	var podcast = new Podcast(user, name);
+  	podcast.record();
+  	users[user].podcasts.add(podcast);
   });
 
-  client.on('stop', function() {
+  client.on('stop', function(user, file) {
     console.log("stop");
-    stream.end();
+    users[user].podcasts.each(function(podcast){
+        if(podcast.isOpen) podcast.stop();
+    });
   });
 
   client.on('listen', function(){
     console.log("listen");
-    
   })
 
 });

layout.html

@@ -0,0 +1,131 @@
+if(typeof Array.prototype.add == "undefined") {
+  Array.prototype.add = function(item) {
+      this[this.length] = item;
+      return this;
+  }
+}
+
+if(typeof Array.prototype.last == "undefined") {
+  Array.prototype.last = function() {
+    return (this.length > 0) ? this[this.length - 1] : -1;
+  };
+}
+
+if(typeof Array.prototype.first == "undefined") {
+  Array.prototype.first = function() {
+    return this[0];
+  };
+}
+
+if(typeof Array.prototype.each == "undefined") {
+  Array.prototype.each = function(fn) {
+    for(var index = 0; index < this.length; index++) {
+      fn(this[index], index);
+    }
+    return this;
+  }
+}
+
+/*
+ Implementação da Mozilla
+ https://developer.mozilla.org/en/JavaScript/Reference/Global_Objects/Array/map
+ Navegadores defasados e antigos como o IE8/9 não possuem
+ Production steps of ECMA-262, Edition 5, 15.4.4.19
+ Reference: http://es5.github.com/#x15.4.4.19
+ */
+if (!Array.prototype.map) {
+  Array.prototype.map = function(callback, thisArg) {
+    var T, A, k;
+    if (this == null) {
+      throw new TypeError(" this is null or not defined");
+    }
+    var O = Object(this);
+    var len = O.length >>> 0;
+    if ({}.toString.call(callback) != "[object Function]") {
+      throw new TypeError(callback + " is not a function");
+    }
+    if (thisArg) {
+      T = thisArg;
+    }
+    A = new Array(len);
+    k = 0;
+    while(k < len) {
+      var kValue, mappedValue;
+      if (k in O) {
+        kValue = O[ k ];
+        mappedValue = callback.call(T, kValue, k, O);
+        A[ k ] = mappedValue;
+      }
+      k++;
+    }
+    return A;
+  };      
+}
+
+
+/*
+  Implementação da Mozilla
+ https://developer.mozilla.org/en/JavaScript/Reference/Global_Objects/Array/Reduce
+ 
+ */
+if ( !Array.prototype.reduce ) {
+  Array.prototype.reduce = function reduce(accumlator){
+        var i, l = this.length, curr;
+        
+        if(typeof accumlator !== "function")
+          throw new TypeError("First argument is not callable");
+
+        if((l == 0 || l === null) && (arguments.length <= 1))
+          throw new TypeError("Array length is 0 and no second argument");
+        
+        if(arguments.length <= 1){
+          curr = this[0];
+          i = 1;
+        }
+        else{
+          curr = arguments[1];
+        }
+        
+        for(i = i || 0 ; i < l ; ++i){
+          if(i in this)
+            curr = accumlator.call(undefined, curr, this[i], i, this);
+        }
+        
+        return curr;
+      };
+  }
+
+/* 
+  Implementação da Mozilla
+  https://developer.mozilla.org/en/JavaScript/Reference/Global_Objects/Array/filter
+  Navegadores defasados e antigos como o IE8/9 não possuem
+*/
+if(typeof Array.prototype.filter == "undefined") {
+  Array.prototype.filter = function(fun)
+    {
+      "use strict";
+
+      if (this === void 0 || this === null)
+        throw new TypeError();
+
+      var t = Object(this);
+      var len = t.length >>> 0;
+      if (typeof fun !== "function")
+        throw new TypeError();
+
+      var res = [];
+      var thisp = arguments[1];
+      for (var i = 0; i < len; i++)
+      {
+        if (i in t)
+        {
+          var val = t[i]; // in case fun mutates this
+          if (fun.call(thisp, val, i, t))
+            res.push(val);
+        }
+      }
+
+      return res;
+    };
+
+}

normalize.js

@@ -5,7 +5,7 @@
 
   <title>Carcará SoundStream</title>
 
-  <link rel="stylesheet" href="/style.css" type="text/css">
+  <link rel="stylesheet" href="/public/style.css" type="text/css">
   <script src="http://platform.twitter.com/anywhere.js?id=261Oz4VtFc8Qb8ho330uA&v=1" type="text/javascript"></script>
 </head>
 <body>
@@ -29,11 +29,11 @@ <h2>It's very simple. Just login and start to talk in your particular internet r
         </div>
         <div class="column">
           Start to speak on your microphone<br><br>
-          <img src="/images/mic.png" height="50">
+          <img src="/public/images/mic.png" height="50">
         </div>
         <div class="column">
           Share with your friend your new live channel<br><br>
-          <img src="/images/listen.png" height="50">
+          <img src="/public/images/listen.png" height="50">
         </div>
       </div>
     </div>

crossdomain.xml public/crossdomain.xml

@@ -1,12 +1,5 @@
-<!doctype html>
-<html>
-<head>
+
     <script src="http://code.jquery.com/jquery-1.6.1.min.js"></script>
     <script src="/socket.io/socket.io.js"></script>
-
-</head>
-<body>
     <audio id="radio"></audio>
-    <script src="listen.js"></script>
-</body>
-</html>
+    <script src="/public/listen.js"></script>

images/listen.png public/images/listen.png

@@ -1,11 +1,8 @@
-<!doctype html>
-<html>
-<head>
+
     <script src="http://code.jquery.com/jquery-1.6.1.min.js"></script>
     <script src="/socket.io/socket.io.js"></script>
-    <script src="microphone.js"></script>
-</head>
-<body>
+    <script src="/public/microphone.js"></script>
+
     <button value="Record">Record</button>
     <button value="Stop">Stop</button>
 
@@ -20,7 +17,7 @@
     var mic;
     $("button[value='Record']").click(function() {
         var name = "id_" + new Date().getTime();
-        socket.emit("start", name);
+        socket.emit("start", "milfont", name);
         var $file = $("#file");
         $file.append("<br/>");
         var link = $("<a>");
@@ -33,7 +30,7 @@
         mic = new Microphone(function(){
             mic.swf.rate = 8;
             mic.onSamplesAvailable = function(data,channelCount){
-                socket.emit('user message', data);
+                socket.emit('user message', "milfont", name, data);
             };
             mic.start();
         });
@@ -42,9 +39,7 @@
     $("button[value='Stop']").click(function() {
         if(mic) {
             mic.stop();
-            socket.emit('stop', "stop");
+            socket.emit('stop', "milfont");
         }
     });
 </script>
-</body>
-</html>