admin/rdv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

and so the db wars continue....

Browse Source
This commit is contained in:
bootunloader
2025-01-30 12:32:29 +02:00
parent 52ff4c637a
commit c70fafeaa8
1 changed files with 47 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
src/lib/server/connectors/surreal.db.ts
View File

@@ -2,29 +2,62 @@ import Surreal, { StringRecordId } from "surrealdb";
export type { QueryResult } from "surrealdb"; export type { QueryResult } from "surrealdb";
try { try {
if (document || window) { if (document || window) {
throw new Error("SurrealDB needs a NodeJS environment to run."); throw new Error("SurrealDB needs a NodeJS environment to run.");
} }
} catch (err) {} } catch (err) {}
const CONFIG = { const CONFIG = {
url: process.env.SURREAL_URL ?? "", url: process.env.SURREAL_URL ?? "",
user: process.env.SURREAL_USER ?? "", user: process.env.SURREAL_USER ?? "",
pass: process.env.SURREAL_PASS ?? "", pass: process.env.SURREAL_PASS ?? "",
ns: process.env.SURREAL_NS ?? "", ns: process.env.SURREAL_NS ?? "",
db: process.env.SURREAL_DB ?? "", db: process.env.SURREAL_DB ?? "",
} as const; } as const;
const db = new Surreal(); const db = new Surreal();
export function parseToRID(idStr: string) { async function connectDB() {
return new StringRecordId(idStr); try {
}
if (CONFIG.url.length > 0) {
await db.connect(`http://${CONFIG.url}/rpc`); await db.connect(`http://${CONFIG.url}/rpc`);
await db.use({ namespace: CONFIG.ns, database: CONFIG.db }); await db.use({ namespace: CONFIG.ns, database: CONFIG.db });
await db.signin({ username: CONFIG.user, password: CONFIG.pass }); await authenticateDB();
} catch (error) {
console.error("Error connecting to SurrealDB:", error);
}
} }
async function authenticateDB() {
try {
await db.signin({ username: CONFIG.user, password: CONFIG.pass });
console.log("🔑 Successfully authenticated with SurrealDB");
} catch (error) {
console.error("❌ Authentication failed:", error);
}
}
async function ensureAuthenticated() {
try {
console.log("⏳ Ensuring authentication with SurrealDB...");
await db.query("RETURN 1");
} catch (error) {
const e = error as any;
if (e.status === 401) {
console.warn("⚠️ Token expired. Re-authenticating...");
await authenticateDB();
} else {
console.error("Unexpected database error:", e);
}
}
}
const MINS_5 = 5 * 60 * 1000;
setInterval(ensureAuthenticated, MINS_5);
await connectDB();
export const surreal = db as Surreal; export const surreal = db as Surreal;
export function parseToRID(idStr: string) {
return new StringRecordId(idStr);
}