1 files changed, 73 insertions, 0 deletions
diff --git a/module/server/macro.scm b/module/server/macro.scm
new file mode 100644
index 00000000..951e009d
--- /dev/null
+++ b/module/server/macro.scm
@@ -0,0 +1,73 @@
+(define-module (server macro)
+  :export (make-routes)
+  :use-module (util)
+  :use-module (ice-9 regex)
+  :use-module (srfi srfi-1)
+  )
+
+(use-modules* (web (response uri)))
+
+(define (not-null? obj)
+  (if (null? obj) #f obj))
+
+(define (match-count pattern str)
+  (fold-matches pattern str 0
+                (lambda (_ count)
+                  (1+ count))))
+
+
+
+(define-public (parse-endpoint-string str)
+  (let ((rx (make-regexp ":([^/]+)")))
+    (let loop ((str str)
+               (string "")
+               (tokens '()))
+      (let ((m (regexp-exec rx str 0)))
+        (if (not m)
+            (values (string-append string str) (reverse tokens))
+            (loop (match:suffix m)
+                  (string-append string (match:prefix m) "([^/]+)")
+                  (cons (string->symbol (match:substring m 1))
+                        tokens)))))))
+
+(define (generate-case defn)
+  (let* (((method uri param-list . body) defn)
+         (regex tokens (parse-endpoint-string uri))
+         (diff intersect (lset-diff+intersection eq? param-list tokens)))
+    `((and (eq? r:method (quote ,method))
+           (regexp-exec (make-regexp ,(string-append "^" regex "/?$") regexp/icase)
+                        r:path))
+      => (lambda (match-object)
+           ;; (assert
+           ;;  (= (1- (match:count match-object))
+           ;;     (length intersect)))
+           ((lambda ,intersect
+               (lambda* (,@(unless (null? diff) `(#:key ,@diff #:allow-other-keys))
+                         #:rest rest)
+                 ,@body))
+            ,@(unless (null? intersect)
+                (map (lambda (i)
+                       `(match:substring match-object ,i))
+                     (cdr (iota (1+ (length intersect)))))))))))
+
+(define-macro (make-routes . routes)
+  `(lambda (request body)
+     (let ((r:method  (request-method  request))
+           (r:uri     (request-uri     request))
+           (r:version (request-version request))
+           (r:headers (request-headers request))
+           (r:meta    (request-meta    request))
+           (r:port    (request-port    request)))
+       (let ((r:scheme   (uri-scheme   r:uri))
+             (r:userinfo (uri-userinfo r:uri))
+             (r:host     (uri-host     r:uri))
+             (r:port     (uri-port     r:uri))
+             (r:path     (uri-path     r:uri))
+             (r:query    (uri-query    r:uri))
+             (r:fragment (uri-fragment r:uri)))
+         (call/ec (lambda (return)
+                    (apply
+                     (cond ,@(map generate-case routes)
+                           (else (lambda* _ (return (build-response #:code 404)
+                                                    "404 Not Fonud"))))
+                     (parse-query r:query))))))))