add sync publish procedure in gnunet/sync.scm

1 files changed, 84 insertions, 0 deletions

diff --git a/gnunet/sync.scm b/gnunet/sync.scm
new file mode 100644
index 0000000..c351a95
--- /dev/null
+++ b/gnunet/sync.scm
@@ -0,0 +1,84 @@
+;;;; -*- mode: Scheme; indent-tabs-mode: nil; fill-column: 80; -*-
+;;;;
+;;;; Copyright © 2018 Amirouche Boubekki <amirouche@hypermove.net>
+;;;;
+;;;; This program is free software: you can redistribute it and/or modify
+;;;; it under the terms of the GNU General Public License as published by
+;;;; the Free Software Foundation, either version 3 of the License, or
+;;;; (at your option) any later version.
+;;;;
+;;;; This program is distributed in the hope that it will be useful,
+;;;; but WITHOUT ANY WARRANTY; without even the implied warranty of
+;;;; MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+;;;; GNU General Public License for more details.
+;;;;
+;;;; You should have received a copy of the GNU General Public License
+;;;; 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 threads)))
+
+(use-modules ((gnunet)))
+
+
+(define (publish/task/shutdown publish-context)
+  (lambda ()
+    (fs-publish-stop publish-context)))
+
+(define (publish/progress callback)
+  (lambda (info)
+    (let ((status (fs-progress-info-status info)))
+      (cond
+       ((eq? status %fs-status-publish-completed)
+        (callback (uri->string (fs-progress-info-publish-chk-uri info)))
+        (scheduler-shutdown))))))
+
+(define (publish/task configuration filename callback)
+  (lambda ()
+    (let ((fs (fs-start configuration "c3b2" (publish/progress callback))))
+      (let ((fi (fs-file-information-create-from-file
+                 fs
+                 filename
+                  ;; TODO: doesn't work, see publish-keywords
+                 (fs-uri-ksk-create "c3b2://topic")
+                 (container-meta-data-create)
+                 %gnunet-yes
+                 (fs-block-options))))
+        (let ((publish-context (fs-publish-start fs fi)))
+          (scheduler-add-shutdown (publish/task/shutdown publish-context)))))))
+
+(define (publish-exec configuration filename callback)
+  (let ((configuration* (configuration-create)))
+    (configuration-load! configuration* configuration)
+    (scheduler-run (publish/task configuration* filename callback))))
+
+(define (publish-file configuration filename)
+  (let ((out #f))
+    (let ((thread (call-with-new-thread
+                   (lambda ()
+                     (publish-exec configuration
+                                   filename
+                                   (lambda (uri) (set! out uri)))))))
+      (join-thread thread))
+    out))
+
+(define (invoke program . args)  ;; stolen from guix
+  "Invoke PROGRAM with the given ARGS.  Raise an error if the exit
+code is non-zero; otherwise return #t."
+  (let ((status (apply system* program args)))
+    (unless (zero? status)
+      (error (format #f "program ~s exited with non-zero code" program)
+             status))
+    #t))
+
+(define (publish-keywords configuration uri keywords)
+  (apply invoke (append (list "gnunet-publish" "-c" configuration "-u" uri)
+                        (append-map (lambda (keyword) (list "-k" keyword))
+                                    keywords))))
+
+(define-public (publish configuration filename keywords)
+  "Publish FILENAME tagged with keywords"
+  (let ((uri (publish-file configuration filename)))
+    (publish-keywords configuration uri keywords)
+    uri))