sync: add download as bytevector

1 files changed, 51 insertions, 2 deletions

diff --git a/gnunet/sync.scm b/gnunet/sync.scm
index 038e937..1985f60 100644
--- a/gnunet/sync.scm
+++ b/gnunet/sync.scm
@@ -16,8 +16,9 @@
 ;;;; along with this program.  If not, see <http://www.gnu.org/licenses/>.
 (define-module (gnunet sync))
 
-(use-modules ((srfi srfi-1)))
+(use-modules ((ice-9 binary-ports)))
 (use-modules ((ice-9 threads)))
+(use-modules ((srfi srfi-1)))
 
 (use-modules ((gnunet)))
 
@@ -105,7 +106,7 @@ code is non-zero; otherwise return #t."
 
 (define (search/task configuration uri callback)
   (lambda ()
-    (let ((fs (fs-start configuration "gnunet-guile" (search/progress callback))))
+    (let ((fs (fs-start configuration "c3b2" (search/progress callback))))
       (let ((search-context (fs-search-start fs uri 1 %fs-search-option-none)))
         (scheduler-add-delayed %ten-seconds search/timeout)
         (scheduler-add-shutdown (search/task/shutdown search-context))))))
@@ -126,3 +127,51 @@ code is non-zero; otherwise return #t."
                                   (lambda (uri) (set! out (cons uri out))))))))
       (join-thread thread))
     out))
+
+;;; download
+
+(define (download/task/clean-up fs)
+  (lambda ()
+    (fs-stop fs)))
+
+(define (download/progress callback)
+  (lambda (info)
+    (let ((status (fs-progress-info-status info)))
+      (cond
+       ((eq? status %fs-status-download-completed)
+        (callback)
+        (scheduler-shutdown))
+       ((eq? status %fs-status-download-stopped)
+        (scheduler-add-now (download/task/clean-up (fs-progress-info-fs info))))))))
+
+
+(define (download/task/shutdown download-context)
+  (lambda ()
+    (fs-download-stop download-context #true)))
+
+(define (download/task configuration uri callback)
+  (lambda ()
+    (let ((fs (fs-start configuration "c3b2" (download/progress callback))))
+      (let ((download-context (fs-download-start fs uri 0 #:filename "c3b2.out")))
+        (scheduler-add-shutdown (download/task/shutdown download-context))))))
+
+(define (download-exec configuration uri callback)
+  (let ((configuration* (configuration-create)))
+    (configuration-load! configuration* configuration)
+    (let ((uri (string->uri uri)))
+      (scheduler-run (download/task configuration* uri callback)))))
+
+(define-public (download configuration uri)
+  "Download URI and return its bytevector"
+  (let ((out #f))
+    (let ((thread (call-with-new-thread
+                   (lambda ()
+                     (download-exec configuration
+                                    uri
+                                    (lambda ()
+                                      (call-with-input-file "c3b2.out"
+                                        (lambda (port)
+                                          (set! out (get-bytevector-all port)))
+                                        #:binary #t)))))))
+      (join-thread thread))
+    out))