Merge pull request rlidwka#8 from PresenceInsights/sinopia_HashUpdate_fail

Sinopia hash update fail

Author: aeweidne

lib/local-couchdb.js

@@ -22,7 +22,6 @@ var nano      = require('nano')({
 									"requestDefaults" : { "agent" : myagent }	
 								}
 								);
-var fs         = require('fs')
 
 function NanoError(code) {
   var err = Error(code)
@@ -120,24 +119,45 @@ module.exports.read_stream = function (name, stream, callback) {
 	return stream;
 }
 
+
 module.exports.write_stream = function (name) {
-	
-	var stream = MyStreams.UploadTarballStream()
+  var stream = MyStreams.UploadTarballStream()
+
+  var _ended = 0
+  stream.on('end', function() {
+    _ended = 1
+  })
 
-	fs.exists(name, function(exists) {
-	    if (exists) return stream.emit('error', FSError('EEXISTS'))
+  var self = this;
+  self.document_exists(name, function(err, headers){
+		var opened = false
 		var sinopia = nano.db.use('sinopia');
-		
-		stream.emit('open')
 		stream.pipe(
-				sinopia.attachment.insert(name, name, null, 'application/x-compressed', {"docType" : "tarball"} ) 
+				sinopia.attachment.insert(name, name, null, 'application/x-compressed', {"docType" : "tarball"}) 
 		)
-		
-		stream.emit('success')
-	});
-	return stream
+		stream.done = function() {
+		  function onend() {
+		      stream.emit('success')
+		  }
+		  if (_ended) {
+		    onend()
+		  } else {
+		    stream.on('end', onend)
+		  }
+		}
+		stream.abort = function() {
+		  if (opened) {
+		    opened = false
+		  }
+		}
+			opened = true
+		// re-emitting open because it's handled in storage.js
+		stream.emit('open')
+  });
+  return stream
 }
 
+
 module.exports.delete_stream = function (name, callback) {
 	var sinopia = nano.db.use('sinopia');
 	sinopia.get(name, name, function(err, body){