1 files changed, 29 insertions, 21 deletions

diff --git a/prototypes/c3b2/web.scm b/prototypes/c3b2/web.scm
index 0f72aa0..1c430c3 100755
--- a/prototypes/c3b2/web.scm
+++ b/prototypes/c3b2/web.scm
@@ -23,6 +23,8 @@ exec guile -L $(pwd) -e '(@ (web) main)' -s "$0" "$@"
 (use-modules ((ice-9 match)))
 (use-modules ((web request)))
 (use-modules ((web uri)))
+(use-modules ((rnrs bytevectors)))
+(use-modules (ice-9 binary-ports))
 
 ;; third party
 (use-modules ((fibers web server)))
@@ -37,34 +39,28 @@ exec guile -L $(pwd) -e '(@ (web) main)' -s "$0" "$@"
 (use-modules ((web html)))
 (use-modules ((web mime-types)))
 (use-modules ((web static)))
+(use-modules ((sha-2)))
 
+;; gnunet
+(use-modules ((gnunet sync)))
 
-(setlocale LC_ALL "")
-
-;;; helpers
-;;
-;; until we have real messages backend by wt and gnunet
-;;
 
-(define %loremipsum (string-split "Suspendisse potenti. Quisque ac orci sed metus molestie ornare. Nam in neque magna. Proin vel consectetur nisl, a suscipit est. Ut eget lectus maximus, scelerisque felis non, gravida leo. Pellentesque nisi risus, posuere vitae elit eget, efficitur euismod risus. Cras pulvinar, nisl vitae tincidunt hendrerit, dui nulla pellentesque libero, vel maximus erat arcu sed dui. Mauris porta dui nec arcu auctor, quis tristique massa dictum. Etiam consequat leo quis tortor vulputate, vitae eleifend lorem tempus. Lorem ipsum dolor sit amet, consectetur adipiscing elit. Quisque a enim scelerisque, tristique turpis sed, accumsan velit. Proin eleifend, augue sit amet efficitur volutpat, magna ipsum consequat elit, vel tempor est nulla et sem. Cras faucibus odio ac est vestibulum varius. Sed lobortis fringilla egestas. Vestibulum pulvinar est vel mauris malesuada, at dapibus nibh rutrum. Etiam pellentesque lacus nec sapien pharetra, quis ultrices lorem condimentum!" #\space))
+(setlocale LC_ALL "")
 
-(define (choice lst)
-  (list-ref lst (random (length lst))))
 
-(define (loremipsum length)
-  (string-join (map (lambda _ (choice %loremipsum)) (iota length)) " "))
+(define %configuration #f)
+(define %home #f)
 
-(define (make-message body parent)
-  `((parent . ,parent)
-    (body . ,body)))
+;;; helpers
 
-(define (make-random-topic)
-  (make-message (loremipsum 99) #f))
+(define (make-hash bv)
+  (let ((hash (make-sha-512)))
+    (sha-512-update! hash bv)
+    (sha-512-finish! hash)
+    (sha-512->string hash)))
 
 ;;;
 
-(define %topics (map (lambda _ (make-random-topic)) (iota 0)))
-
 (define (c3b2/topics)
   "Return vertices of topics ie. messages without parent"
   (map get (fs:find 'parent #f)))
@@ -73,7 +69,16 @@ exec guile -L $(pwd) -e '(@ (web) main)' -s "$0" "$@"
   (let ((new-topic `((kind . message)
                      (body . ,body)
                      (parent . #f))))
-    (save (create-vertex new-topic))))
+    (let ((topic (save (create-vertex new-topic))))
+      (let* ((payload (vertex-ref topic 'body))
+             (payload (string->utf8 payload))
+             (hash (make-hash payload))
+             (filepath (string-append %home "/" hash)))
+        (call-with-output-file filepath
+          (lambda (port)
+            (put-bytevector port payload))
+          #:binary #t)
+        (publish %configuration filepath '("c3b2://v1/topic"))))))
 
 ;;; web
 
@@ -108,7 +113,7 @@ exec guile -L $(pwd) -e '(@ (web) main)' -s "$0" "$@"
   (render-html (template "index" (template/index (c3b2/topics)))))
 
 (define (route/index/post body)
-  (c3b2/topic-add! (assoc-ref (decode body) "body"))
+  (c3b2/topic-add! (car (assoc-ref (decode body) "body")))
   (redirect "/"))
 
 (define (router request body)
@@ -120,7 +125,10 @@ exec guile -L $(pwd) -e '(@ (web) main)' -s "$0" "$@"
      (_ (not-found (uri->string (request-uri request)))))))
 
 
-(define-public (main _)
+(define-public (main args)
+  (set! %configuration (cadr args))
+  (set! %home (caddr args))
+  (pk %configuration %home)
   (format #t "Server running @ http://localhost:8080\n")
   (with-env (env-open* "wt" (list *feature-space*) "create,log=(enabled=true)")
     (run-server router)))