Function initializeDatabase

main.js:1600–1721

()

    }

    // Close HTTP server
    server.close(() => {
      console.log('HTTP server closed');
      if (httpServerEpoch === epoch) {
        httpServer = null;
        wsClients = null;
        global.broadcastEvent = null;
        global.sendEvent = null;
      }
      resolve();
    });

    // Force close after timeout if graceful shutdown doesn't complete
    setTimeout(() => {
      if (httpServerEpoch !== epoch) return;
      if (httpServer === server) {
        console.log('Force closing HTTP server...');
        try {
          server.close();
        } catch (error) {
          console.error('Error force closing server:', error);
        }
        httpServer = null;
        wsClients = null;
        wss = null;
        global.broadcastEvent = null;
        global.sendEvent = null;
        resolve();
      }
    }, 5000);
  });
}

function getSettingValueOr(key, fallback) {
  try {
    if (!db) return fallback;
    const row = db.prepare('SELECT value FROM settings WHERE key = ?').get(key);
    if (row && row.value != null && row.value !== '') return row.value;
  } catch (_) { /* ignore */ }
  return fallback;
}

let extensionInboxTimer = null;
let extensionInboxImporting = false;

function getExtensionInboxDirectory() {
  return extensionInbox.resolveInboxDirectory(getSettingValueOr('extensionInboxDirectory', ''));
}

function getExtensionInboxDirectories() {
  const custom = (getSettingValueOr('extensionInboxDirectory', '') || '').trim();
  return extensionInbox.uniqueInboxDirectories([
    custom || null,
    extensionInbox.defaultInboxDirectory(),
    extensionInbox.inboxDirectoryBesideDatabase(getDatabasePath())
  ]);
}