From d923fd1b7642f0c1e42a814f563633ff092b695e Mon Sep 17 00:00:00 2001
From: ansuz <ansuz@transitiontech.ca>
Date: Fri, 5 May 2017 09:00:54 +0200
Subject: [PATCH] close writeStreams before expiring a stream

---
 rpc.js | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/rpc.js b/rpc.js
index 3a7609b62..84bda3b35 100644
--- a/rpc.js
+++ b/rpc.js
@@ -91,6 +91,9 @@ var expireSessions = function (Sessions) {
     var now = +new Date();
     Object.keys(Sessions).forEach(function (key) {
         if (isTooOld(Sessions[key].atime, now)) {
+            if (session.blobstage) {
+                session.blobstage.close();
+            }
             delete Sessions[key];
         }
     });
@@ -445,6 +448,7 @@ var upload = function (stagingPath, Sessions, publicKey, content, cb) {
     var dec = new Buffer(Nacl.util.decodeBase64(content)); // jshint ignore:line
 
     var session = Sessions[publicKey];
+    session.atime = +new Date();
     if (!session.blobstage) {
         makeFileStream(stagingPath, publicKey, function (e, stream) {
             if (e) { return void cb(e); }