From 998f2267c4f91239bd1d768c95af67f7b2a33f35 Mon Sep 17 00:00:00 2001
From: ansuz <ansuz@transitiontech.ca>
Date: Tue, 6 Oct 2020 18:53:59 +0530
Subject: [PATCH] ensure the path to the decree file exists before attempting
 to write to it

---
 lib/decrees.js | 40 ++++++++++++++++++++++++----------------
 1 file changed, 24 insertions(+), 16 deletions(-)

diff --git a/lib/decrees.js b/lib/decrees.js
index 6c1242285..46c153170 100644
--- a/lib/decrees.js
+++ b/lib/decrees.js
@@ -140,28 +140,36 @@ var Path = require("path");
 var readFileBin = require("./stream-file").readFileBin;
 var Util = require("./common-util");
 var Schedule = require("./schedule");
+var Fse = require("fs-extra");
+var nThen = require("nthen");
 
 Decrees.load = function (Env, cb) {
     Env.scheduleDecree = Env.scheduleDecree || Schedule();
 
-    var decreeName = Path.join(Env.paths.decree, 'decree.ndjson'); // XXX mkdirp
-
-    var stream = Fs.createReadStream(decreeName, {start: 0});
-
-    var handler = Decrees.createLineHandler(Env);
-
     Env.scheduleDecree.blocking('', function (unblock) {
         var done = Util.once(Util.both(cb, unblock));
-        readFileBin(stream, function (msgObj, next) {
-            var text = msgObj.buff.toString('utf8');
-            try {
-                handler(void 0, JSON.parse(text));
-            } catch (err) {
-                handler(err);
-            }
-            next();
-        }, function (err) {
-            done(err);
+        nThen(function (w) {
+            // ensure that the path to the decree log exists
+            Fse.mkdirp(Env.paths.decree, w(function (err) {
+                if (!err) { return; }
+                w.abort();
+                done(err);
+            }));
+        }).nThen(function () {
+            var decreeName = Path.join(Env.paths.decree, 'decree.ndjson');
+            var stream = Fs.createReadStream(decreeName, {start: 0});
+            var handler = Decrees.createLineHandler(Env);
+            readFileBin(stream, function (msgObj, next) {
+                var text = msgObj.buff.toString('utf8');
+                try {
+                    handler(void 0, JSON.parse(text));
+                } catch (err) {
+                    handler(err);
+                }
+                next();
+            }, function (err) {
+                done(err);
+            });
         });
     });
 };