aboutsummaryrefslogtreecommitdiff
path: root/stdlib/source/library/lux/world/net/http/route.lux
blob: 456ed9e36be1db061fa1fd4f37ee91330559eeeb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
(.module:
  [library
   [lux (#- or)
    [control
     [monad (#+ do)]
     [concurrency
      ["." promise]]]
    [data
     ["." maybe]
     ["." text]
     [number
      ["n" nat]]]]]
  ["." // (#+ URI Server)
   ["#." status]
   ["#." response]])

(template [<scheme> <name>]
  [(def: #export (<name> server)
     (-> Server Server)
     (function (_ (^@ request [identification protocol resource message]))
       (case (get@ #//.scheme protocol)
         <scheme>
         (server request)

         _
         (promise.resolved //response.not-found))))]

  [#//.HTTP  http]
  [#//.HTTPS https]
  )

(template [<method> <name>]
  [(def: #export (<name> server)
     (-> Server Server)
     (function (_ (^@ request [identification protocol resource message]))
       (case (get@ #//.method resource)
         <method>
         (server request)

         _
         (promise.resolved //response.not-found))))]

  [#//.Get     get]
  [#//.Post    post]
  [#//.Put     put]
  [#//.Patch   patch]
  [#//.Delete  delete]
  [#//.Head    head]
  [#//.Connect connect]
  [#//.Options options]
  [#//.Trace   trace]
  )

(def: #export (uri path server)
  (-> URI Server Server)
  (function (_ [identification protocol resource message])
    (if (text.starts-with? path (get@ #//.uri resource))
      (server [identification
               protocol
               (update@ #//.uri
                        (|>> (text.clip' (text.size path)) maybe.assume)
                        resource)
               message])
      (promise.resolved //response.not-found))))

(def: #export (or primary alternative)
  (-> Server Server Server)
  (function (_ request)
    (do promise.monad
      [response (primary request)
       #let [[status message] response]]
      (if (n.= //status.not-found status)
        (alternative request)
        (wrap response)))))