rework on get connect function

kane50613 · Mar 4, 2024 · 519aacd · 519aacd
1 parent 8c5004a
commit 519aacd
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "redis-on-workers",
-  "version": "0.2.2",
+  "version": "0.2.3",
   "description": "Connect to your Redis server using cloudflare:sockets",
   "scripts": {
     "build": "tsup",

diff --git a/src/get-connect-fn.ts b/src/get-connect-fn.ts
@@ -4,8 +4,16 @@ export async function getConnectFn(fn?: CreateRedisOptions["connectFn"]) {
   if (fn) return fn;
 
   try {
-    return await import("cloudflare:sockets").then((r) => r.connect);
+    const { connect } = await import("cloudflare:sockets");
+
+    return connect;
   } catch (e) {
-    return await import("@arrowood.dev/socket").then((r) => r.connect);
+    try {
+      const { connect } = await import("@arrowood.dev/socket");
+
+      return connect;
+    } catch (e) {
+      throw new Error("No socket provider found");
+    }
   }
 }