sync: add search

1 files changed, 44 insertions, 0 deletions

diff --git a/gnunet/sync.scm b/gnunet/sync.scm
index c351a95..038e937 100644
--- a/gnunet/sync.scm
+++ b/gnunet/sync.scm
@@ -22,6 +22,8 @@
 (use-modules ((gnunet)))
 
 
+;;; publish
+
 (define (publish/task/shutdown publish-context)
   (lambda ()
     (fs-publish-stop publish-context)))
@@ -82,3 +84,45 @@ code is non-zero; otherwise return #t."
   (let ((uri (publish-file configuration filename)))
     (publish-keywords configuration uri keywords)
     uri))
+
+;;; search
+
+(define (search/task/shutdown search-context)
+  (lambda ()
+    (fs-search-stop search-context)))
+
+(define (search/progress callback)
+  (lambda (info)
+    (let ((status (fs-progress-info-status info)))
+      (cond
+       ((eq? status %fs-status-search-result)
+        (callback (uri->string (fs-progress-info-search-result-uri info))))))))
+
+(define (search/timeout)
+  (scheduler-shutdown))
+
+(define %ten-seconds (* 10 (expt 10 6)))
+
+(define (search/task configuration uri callback)
+  (lambda ()
+    (let ((fs (fs-start configuration "gnunet-guile" (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))))))
+
+(define (search-exec configuration keywords callback)
+  (let ((configuration* (configuration-create))
+        (uri (apply fs-uri-ksk-create keywords)))
+    (configuration-load! configuration* configuration)
+    (scheduler-run (search/task configuration* uri callback))))
+
+(define-public (search configuration keywords)
+  "Search for files on matchin KEYWORDS"
+  (let ((out '()))
+    (let ((thread (call-with-new-thread
+                   (lambda ()
+                     (search-exec configuration
+                                  keywords
+                                  (lambda (uri) (set! out (cons uri out))))))))
+      (join-thread thread))
+    out))