From 02a373b8128c1544711d14ecd6ed19e20c7e3b0b Mon Sep 17 00:00:00 2001 From: Adam Soltys Date: Wed, 27 Dec 2023 23:22:27 -0800 Subject: liquid wip --- lib/db.js | 23 ++++++++++++++++++++--- 1 file changed, 20 insertions(+), 3 deletions(-) (limited to 'lib/db.js') diff --git a/lib/db.js b/lib/db.js index d14e4962..c44c7177 100644 --- a/lib/db.js +++ b/lib/db.js @@ -41,16 +41,33 @@ export let db = createClient({ }, }); -async function connectWithRetry() { +export let archive = createClient({ + url: config.archive, + socket: { + reconnectStrategy: (retries) => Math.min(retries * 50, 5000), + }, +}); + +async function dbReconnect() { try { await db.connect(); } catch (err) { console.error("Failed to connect to Redis, retrying...", err); - setTimeout(connectWithRetry, 5000); // Retry after 5 seconds + setTimeout(dbReconnect, 5000); // Retry after 5 seconds + } +} + +async function archiveReconnect() { + try { + await archive.connect(); + } catch (err) { + console.error("Failed to connect to Redis, retrying...", err); + setTimeout(archiveReconnect, 5000); // Retry after 5 seconds } } -connectWithRetry(); +dbReconnect(); +archiveReconnect(); db.on("error", (e) => { if (e.message.startsWith("getaddr")) return; -- cgit v1.2.3