aboutsummaryrefslogtreecommitdiff
path: root/stdlib/source/program/compositor/import.lux
blob: 7f21f20eca4ae38bae695fda606d4a47849b5763 (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
(.using
 [library
  [lux {"-" Module}
   [abstract
    ["[0]" monad {"+" Monad do}]]
   [control
    ["[0]" try {"+" Try}]
    ["[0]" exception {"+" exception:}]
    [concurrency
     ["[0]" async {"+" Async} ("[1]#[0]" monad)]]
    ["<>" parser
     ["<[0]>" binary]]]
   [data
    [binary {"+" Binary}]
    ["[0]" text
     ["%" format {"+" format}]]
    [collection
     ["[0]" dictionary {"+" Dictionary}]
     ["[0]" sequence]]
    [format
     ["[0]" tar]]]
   [tool
    [compiler
     [meta
      [cli {"+" Library Module}]]]]
   [world
    ["[0]" file]]]])

(def: Action
  (type (All (_ a) (Async (Try a)))))

(exception: .public useless_tar_entry)

(exception: .public (duplicate [library Library
                                module Module])
  (exception.report
   ["Module" (%.text module)]
   ["Library" (%.text library)]))

(type: .public Import
  (Dictionary file.Path Binary))

(def: (import_library system library import)
  (-> (file.System Async) Library Import (Action Import))
  (let [! async.monad]
    (|> library
        (# system read)
        (# ! each (let [! try.monad]
                    (|>> (# ! each (<binary>.result tar.parser))
                         (# ! conjoint)
                         (# ! each (|>> sequence.list
                                        (monad.mix ! (function (_ entry import)
                                                       (case entry
                                                         {tar.#Normal [path instant mode ownership content]}
                                                         (let [path (tar.from_path path)]
                                                           (case (dictionary.has' path (tar.data content) import)
                                                             {try.#Failure error}
                                                             (exception.except ..duplicate [library path])

                                                             import'
                                                             import'))
                                                         
                                                         _
                                                         (exception.except ..useless_tar_entry [])))
                                                   import)))
                         (# ! conjoint)))))))

(def: .public (import system libraries)
  (-> (file.System Async) (List Library) (Action Import))
  (monad.mix (: (Monad Action)
                (try.with async.monad))
             (..import_library system)
             (dictionary.empty text.hash)
             libraries))