aboutsummaryrefslogtreecommitdiff
path: root/stdlib/source/program/compositor/import.lux
blob: 278e992fb666f40e8ee6af314b7c0cbf88ab3f8c (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
75
76
77
(.module:
  [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]" row]]
     [format
      ["[0]" tar]]]
    [tool
     [compiler
      [meta
       [archive
        [descriptor {"+" [Module]}]]]]]
    [world
     ["[0]" file]]]]
  [//
   [cli {"+" [Library]}]])

(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 (|>> row.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))