From 2813eb9e0445dc079db75e874b263b7539e50e89 Mon Sep 17 00:00:00 2001
From: Tienson Qin <tiensonqin@gmail.com>
Date: Sat, 9 Dec 2023 12:22:28 +0800
Subject: [PATCH] fix: list db

---
 src/main/frontend/db_worker.cljs | 31 ++++++++++++++++++++-----------
 1 file changed, 20 insertions(+), 11 deletions(-)

diff --git a/src/main/frontend/db_worker.cljs b/src/main/frontend/db_worker.cljs
index a58df8cab0..57dfe29ccd 100644
--- a/src/main/frontend/db_worker.cljs
+++ b/src/main/frontend/db_worker.cljs
@@ -6,10 +6,13 @@
             [clojure.edn :as edn]
             [datascript.core :as d]
             [logseq.db.frontend.schema :as db-schema]
+            [logseq.db.sqlite.util :as sqlite-util]
             [shadow.cljs.modern :refer [defclass]]
             [datascript.transit :as dt]
             ["@logseq/sqlite-wasm" :default sqlite3InitModule]
-            ["comlink" :as Comlink]))
+            ["comlink" :as Comlink]
+            [clojure.string :as string]
+            [cljs-bean.core :as bean]))
 
 (defonce *sqlite (atom nil))
 (defonce *sqlite-db (atom nil))
@@ -20,7 +23,7 @@
   []
   (or @*opfs-pool
       (p/let [^js pool (.installOpfsSAHPoolVfs @*sqlite #js {:name "logseq-db"
-                                                         :initialCapacity 100})]
+                                                             :initialCapacity 100})]
         ;; (.removeVfs pool)
         (reset! *opfs-pool pool)
         pool)))
@@ -39,19 +42,22 @@
 (defn- remove-pfs!
   "!! use it only for development"
   []
-  (when-let [^js pool (get-opfs-pool)]
-    (.removeVfs ^js pool)))
+  (p/let [^js pool (get-opfs-pool)]
+    (when pool
+      (.removeVfs ^js pool))))
 
 (defn- get-file-names
   []
-  (when-let [^js pool (get-opfs-pool)]
-    (.getFileNames pool)))
+  (p/let [^js pool (get-opfs-pool)]
+    (when pool
+      (.getFileNames pool))))
 
 (defn- export-db-file
   [file-path]
   ;; TODO: get file name by repo
-  (when-let [^js pool (get-opfs-pool)]
-    (.exportFile ^js pool file-path)))
+  (p/let [^js pool (get-opfs-pool)]
+    (when pool
+      (.exportFile ^js pool file-path))))
 
 (defn upsert-addr-content!
   "Upsert addr+data-seq"
@@ -135,9 +141,12 @@
 
   (listDB
    [_this]
-   ;; TODO:
-   ;; (prn (get-file-names))
-   nil)
+   (p/let [file-names (get-file-names)]
+     (->> file-names
+          (filter (fn [file] (string/ends-with? file ".sqlite")))
+          (map (fn [file]
+                 (subs file 1 (- (count file) 7))))
+          (bean/->js))))
 
   (createOrOpenDB
    [_this repo]