66 [goog.object]
77 [clojure.set]
88 [homebase.js :as hbjs]
9+ [homebase.cache :as hbc]
10+ [nano-id.core :refer [nano-id]]
911 [datascript.core :as d]
1012 [datascript.impl.entity :as de]
1113 [homebase.datalog-console :as datalog-console]))
1214
13-
14-
1515(defn try-hook [hook-name f]
1616 (if hbjs/*debug*
1717 (f )
134134 initial-tx (goog.object/getValueByKeys props #js [" config" " initialData"
135135 debug (goog.object/getValueByKeys props #js [" config" " debug"
136136 _ (when debug (set! hbjs/*debug* debug))
137- conn (d/create-conn (if schema
138- (merge (hbjs/js->schema schema) base-schema)
139- base-schema))]
140- (datalog-console/init! {:conn conn})
141- (when initial-tx (hbjs/transact! conn initial-tx))
142- (react/createElement
143- (goog.object/get homebase-context " Provider"
144- #js {:value conn}
145- (goog.object/get props " children"
137+ [initializing? setInitializing?] (react/useState true )
138+ db-conn (react/useMemo
139+ #(d/create-conn (if schema
140+ (merge (hbjs/js->schema schema) base-schema)
141+ base-schema))
142+ #js [])
143+ cache-conn (react/useMemo
144+ #(hbc/create-conn )
145+ #js [])]
146+ (react/useEffect
147+ (fn []
148+ (hbc/connect! cache-conn db-conn)
149+ (datalog-console/init! {:db-conn db-conn})
150+ (when initial-tx (hbjs/transact! db-conn initial-tx))
151+ (setInitializing? false )
152+ #(hbc/disconnect! db-conn))
153+ #js [])
154+ (if initializing?
155+ " "
156+ (react/createElement
157+ (goog.object/get homebase-context " Provider"
158+ #js {:value #js {:db-conn db-conn :cache-conn cache-conn}}
159+ (goog.object/get props " children"
146160
147161(defn ^:export useClient []
148- (let [conn ( react/useContext homebase-context)
162+ (let [{ :strs [db- conn]} ( js->clj ( react/useContext homebase-context) )
149163 key (react/useMemo rand #js [])
150164 client (react/useMemo
151165 (fn []
152- #js {" dbToString" pr-str @conn)
153- " dbFromString" do (reset! conn (cljs.reader/read-string %))
154- (d/transact! conn [] ::silent ))
155- " dbToDatoms" datoms->js (d/datoms @conn :eavt ))
156- ; ; "dbToJSON" #(clj->js (datoms->json (d/datoms @conn :eavt)))
157- " entity" fn [lookup] (js/Promise.resolve (hbjs/entity conn lookup)))
158- " query" fn [query & args] (js/Promise.resolve (apply hbjs/q query conn args)))
159- " transactSilently" fn [tx] (try-hook " useClient" hbjs/transact! conn tx ::silent )))
160- " addTransactListener" fn [listener-fn] (d/listen! conn key #(when (not= ::silent (:tx-meta %))
166+ #js {" dbToString" pr-str @db- conn)
167+ " dbFromString" do (reset! db- conn (cljs.reader/read-string %))
168+ (d/transact! db- conn [] ::silent ))
169+ " dbToDatoms" datoms->js (d/datoms @db- conn :eavt ))
170+ ; ; "dbToJSON" #(clj->js (datoms->json (d/datoms @db- conn :eavt)))
171+ " entity" fn [lookup] (js/Promise.resolve (hbjs/entity db- conn lookup)))
172+ " query" fn [query & args] (js/Promise.resolve (apply hbjs/q query db- conn args)))
173+ " transactSilently" fn [tx] (try-hook " useClient" hbjs/transact! db- conn tx ::silent )))
174+ " addTransactListener" fn [listener-fn] (d/listen! db- conn key #(when (not= ::silent (:tx-meta %))
161175 (listener-fn (datoms->js (:tx-data %))))))
162- " removeTransactListener" d/unlisten! conn key)})
176+ " removeTransactListener" d/unlisten! db- conn key)})
163177 #js [])]
164178 [client]))
165-
179+
166180(defn ^:export useEntity [lookup]
167- (let [conn (react/useContext homebase-context)
168- cached-entities (react/useMemo #(atom {}) #js [])
169- run-lookup (react/useCallback
170- (fn run-lookup []
171- (touch-entity-cache
172- (try-hook " useEntity" hbjs/entity conn lookup))
173- cached-entities))
174- #js [lookup])
175- [result setResult] (react/useState (run-lookup ))
176- listener (react/useCallback
177- (fn entity-listener []
178- (let [result (run-lookup )]
179- (when (changed? #js [result] @cached-entities false )
180- (setResult result))))
181- #js [run-lookup])]
181+ (let [{:strs [db-conn cache-conn]} (js->clj (react/useContext homebase-context))
182+ hbjs-entity (try-hook " useEntity" hbjs/entity db-conn lookup))
183+ reactive-lookup-uid (react/useMemo #(nano-id ) #js [])
184+ tracked-ea-pairs (react/useMemo #(atom #{}) #js [])
185+ ; ; hbr-entity (make-reactive-entity {:entity entity :setEntity setResult :tracked-ea-pairs tracked-ea-pairs :db-conn db-conn :cache-conn cache-conn :reactive-lookup-uid reactive-lookup-uid})
186+ [result setResult] (react/useState hbjs-entity)
187+ after-lookup (react/useCallback
188+ (fn after-lookup [{:keys [^de/Entity entity attr]}]
189+ (swap! tracked-ea-pairs conj [(:db/id entity) attr])
190+ (swap! cache-conn hbc/assoc-ea [(:db/id entity) attr] reactive-lookup-uid
191+ (fn change-handler []
192+ (let [entity (try-hook " useEntity" hbjs/entity db-conn lookup))
193+ _ (set! ^hbjs/Entity (.-_meta entity)
194+ {:homebase.js/after-lookup (:homebase.js/after-lookup (meta result))})]
195+ (setResult entity))))
196+ #_(js/console.log " after lookup" :db/id entity) attr @cache-conn))
197+ #js [result setResult lookup])
198+ _ (set! ^hbjs/Entity (.-_meta hbjs-entity)
199+ {:homebase.js/after-lookup after-lookup})]
182200 (react/useEffect
183- (fn use-entity-effect []
184- ( let [key ( rand ) ]
185- ( d/listen! conn key listener )
186- #( d/unlisten! conn key )))
187- #js [lookup ])
201+ (fn []
202+ #( doseq [ea @tracked-ea-pairs ]
203+ ( swap! cache- conn hbc/dissoc-ea ea reactive-lookup-uid )
204+ #_( js/console.log " dissoc-ea " ea @cache-conn )))
205+ #js [])
188206 [result]))
189207
190208(defn ^:export useQuery [query & args]
191- (let [conn ( react/useContext homebase-context)
209+ (let [{ :strs [db- conn]} ( js->clj ( react/useContext homebase-context) )
192210 cached-entities (react/useMemo #(atom {}) #js [])
193- run-query (react/useCallback
211+ run-query (react/useCallback
194212 (fn run-query []
195- (let [result (try-hook " useQuery" apply hbjs/q query conn args))]
213+ (let [result (try-hook " useQuery" apply hbjs/q query db- conn args))]
196214 (when (and (not= (count result) (count @cached-entities))
197215 (not= 0 (count result)))
198216 (reset! cached-entities {}))
208226 (react/useEffect
209227 (fn use-query-effect []
210228 (let [key (rand )]
211- (d/listen! conn key listener)
212- #(d/unlisten! conn key)))
229+ (d/listen! db- conn key listener)
230+ #(d/unlisten! db- conn key)))
213231 #js [query args])
214232 [result]))
233+
234+ ; ; (defn ^:export useEntity [lookup]
235+ ; ; (let [{:strs [db-conn]} (js->clj (react/useContext homebase-context))
236+ ; ; cached-entities (react/useMemo #(atom {}) #js [])
237+ ; ; run-lookup (react/useCallback
238+ ; ; (fn run-lookup []
239+ ; ; (touch-entity-cache
240+ ; ; (try-hook "useEntity" #(hbjs/entity db-conn lookup))
241+ ; ; cached-entities))
242+ ; ; #js [lookup])
243+ ; ; [result setResult] (react/useState (run-lookup))
244+ ; ; listener (react/useCallback
245+ ; ; (fn entity-listener []
246+ ; ; (let [result (run-lookup)]
247+ ; ; (when (changed? #js [result] @cached-entities false)
248+ ; ; (setResult result))))
249+ ; ; #js [run-lookup])]
250+ ; ; (react/useEffect
251+ ; ; (fn use-entity-effect []
252+ ; ; (let [key (rand)]
253+ ; ; (d/listen! db-conn key listener)
254+ ; ; #(d/unlisten! db-conn key)))
255+ ; ; #js [lookup])
256+ ; ; [result]))
257+
258+ ; ; (defn ^:export useQuery [query & args]
259+ ; ; (let [{:strs [db-conn]} (js->clj (react/useContext homebase-context))
260+ ; ; cached-entities (react/useMemo #(atom {}) #js [])
261+ ; ; run-query (react/useCallback
262+ ; ; (fn run-query []
263+ ; ; (let [result (try-hook "useQuery" #(apply hbjs/q query db-conn args))]
264+ ; ; (when (and (not= (count result) (count @cached-entities))
265+ ; ; (not= 0 (count result)))
266+ ; ; (reset! cached-entities {}))
267+ ; ; (.map result (fn [e] (touch-entity-cache e cached-entities)))))
268+ ; ; #js [query args])
269+ ; ; [result setResult] (react/useState (run-query))
270+ ; ; listener (react/useCallback
271+ ; ; (fn query-listener []
272+ ; ; (let [result (run-query)]
273+ ; ; (when (changed? result @cached-entities true)
274+ ; ; (setResult result))))
275+ ; ; #js [run-query])]
276+ ; ; (react/useEffect
277+ ; ; (fn use-query-effect []
278+ ; ; (let [key (rand)]
279+ ; ; (d/listen! db-conn key listener)
280+ ; ; #(d/unlisten! db-conn key)))
281+ ; ; #js [query args])
282+ ; ; [result]))
215283
216284(defn ^:export useTransact []
217- (let [conn ( react/useContext homebase-context)
218- transact (react/useCallback
219- (fn transact [tx] (try-hook " useTransact" hbjs/transact! conn tx)))
285+ (let [{ :strs [db- conn]} ( js->clj ( react/useContext homebase-context) )
286+ transact (react/useCallback
287+ (fn transact [tx] (try-hook " useTransact" hbjs/transact! db- conn tx)))
220288 #js [])]
221289 [transact]))
0 commit comments