270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
|
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
|
-
+
+
-
+
+
|
(define (rmt:send-receive-real remote apath dbname rid cmd params)
(let* ((conn (rmt:get-connection remote apath dbname)))
(assert conn "FATAL: Unable to connect to db "apath"/"dbname)
(let* (;; (host (rmt:conn-ipaddr conn))
;; (port (rmt:conn-port conn))
(payload (sexpr->string params))
(res (with-input-from-request
(rmt:conn->uri conn "api") ;; (conc "http://"host":"port"/api")
(rmt:conn->uri conn "api")
`((params . ,payload)
(cmd . ,cmd)
(key . "nokey"))
read-string)))
(if (string? res)
(string->sexpr res))))
(string->sexpr res)
res))))
;; db is at apath/.db/dbname, rid is an intermediary solution and will be removed
;; sometime in the future
;;
(define (rmt:send-receive-server-start remote apath dbname)
(let* ((conn (rmt:get-connection remote apath dbname)))
(assert conn "FATAL: Unable to connect to db "apath"/"dbname)
|