From 2f023b919ce91d2e6e278b9ff79f8e4e11cf90ba Mon Sep 17 00:00:00 2001
From: Lightling <contact@lightling.xyz>
Date: Wed, 28 Feb 2024 20:50:46 -0500
Subject: [PATCH] fix use of createDb

---
 run-downloadDb.js    |  2 +-
 run-downloadUsers.js | 12 ++++++++----
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/run-downloadDb.js b/run-downloadDb.js
index 2eba1c7..e1afe8f 100644
--- a/run-downloadDb.js
+++ b/run-downloadDb.js
@@ -42,7 +42,7 @@ const downloadDb = async () => {
     if (err.toString().includes('ENOENT')) {
       try {
         log(ctx, 'Database was not yet present. Creating it now.');
-        await createDb();
+        await createDb(directory);
         await tryReadDb();
       } catch (err2) {
         error(ctx, err2);
diff --git a/run-downloadUsers.js b/run-downloadUsers.js
index 1f3152f..a83288e 100644
--- a/run-downloadUsers.js
+++ b/run-downloadUsers.js
@@ -3,7 +3,7 @@ import { readFile, writeFile } from 'fs/promises';
 import { getArg } from './lib/args.js';
 import { getMany } from './lib/dl.js';
 import { error, log } from './lib/log.js';
-import { userSchema } from './lib/schema.js';
+import { createDb, userSchema } from './lib/schema.js';
 
 const ctx = 'downloadUser.js';
 
@@ -29,14 +29,18 @@ const downloadUsers = async () => {
   } catch (err) {
     log(ctx, 'Using 1 thread');
   }
-  try {
+  const tryReadDb = async () => {
     let file = await readFile(`${directory}/db.json`, { encoding: 'utf8' });
     db = JSON.parse(file);
+  }
+  try {
+    await tryReadDb();
   } catch (err) {
     if (err.toString().includes('ENOENT')) {
       try {
-        db = [];
-        await writeFile(`${directory}/db.json`, JSON.stringify(db, null, 2));
+        log(ctx, 'Database was not yet present. Creating it now.');
+        await createDb(directory);
+        await tryReadDb();
       } catch (err2) {
         error(ctx, err2);
         return;