aboutsummaryrefslogtreecommitdiffstats
path: root/lib/db.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/db.js')
-rw-r--r--lib/db.js11
1 files changed, 5 insertions, 6 deletions
diff --git a/lib/db.js b/lib/db.js
index b790917e..31464b19 100644
--- a/lib/db.js
+++ b/lib/db.js
@@ -30,30 +30,29 @@ return {ok = 'ok'}
let debit = defineScript({
NUMBER_OF_KEYS: 2,
SCRIPT,
- transformArguments: (...args) => args.map(a => a.toString())
+ transformArguments: (...args) => args.map((a) => a.toString())
});
export let db = createClient({
url: config.db,
scripts: { debit },
socket: {
- reconnectStrategy: retries => Math.min(retries * 50, 5000)
+ reconnectStrategy: (retries) => Math.min(retries * 50, 5000)
}
});
-
async function connectWithRetry() {
try {
await db.connect();
} catch (err) {
- console.error('Failed to connect to Redis, retrying...', err);
+ console.error("Failed to connect to Redis, retrying...", err);
setTimeout(connectWithRetry, 5000); // Retry after 5 seconds
}
}
connectWithRetry();
-db.on("error", e => {
+db.on("error", (e) => {
if (e.message.startsWith("getaddr")) return;
err("Redis error", e.message);
});
@@ -64,7 +63,7 @@ db.on("end", () => {
export default db;
-export let g = async k => {
+export let g = async (k) => {
let v = await db.get(k);
try {
return JSON.parse(v);