(.module: [library [lux {"-" [Name]} ["[0]" ffi {"+" [import:]}] [abstract [order {"+" [Order]}] [monad {"+" [do]}]] [control ["[0]" try {"+" [Try]}] ["[0]" exception {"+" [exception:]}] ["[0]" io {"+" [IO]}] [concurrency ["[0]" async {"+" [Async]} ("[1]#[0]" monad)]]] [data ["[0]" product] ["[0]" text ("[1]#[0]" order) ["%" format {"+" [format]}]] [collection ["[0]" list ("[1]#[0]" functor mix)] ["[0]" dictionary {"+" [Dictionary]}] ["[0]" set]]] [math [number ["n" nat] ["i" int]]] [world ["[0]" program {"+" [Program]}] ["[0]" file {"+" [Path]}] ["[0]" shell {"+" [Exit Process Shell]}] ["[0]" console {"+" [Console]}] [net ["[0]" uri]]]]] ["[0]" /// "_" ["[1]" profile] ["[1][0]" action] ["[1][0]" command {"+" [Command]}] ["[1][0]" local] ["[1][0]" repository] ["[1][0]" runtime] ["[1][0]" dependency {"+" [Dependency]} ["[1]/[0]" resolution {"+" [Resolution]}]] ["[1][0]" artifact {"+" [Group Name Version Artifact]} ["[1]/[0]" type]]]) (type: Finder (-> Resolution (Maybe Dependency))) (def: (dependency_finder group name) (-> Group Name Finder) (|>> dictionary.entries (list.one (function (_ [dependency package]) (if (and (text#= group (value@ [///dependency.#artifact ///artifact.#group] dependency)) (text#= name (value@ [///dependency.#artifact ///artifact.#name] dependency))) {.#Some dependency} {.#None}))))) (def: .public lux_group Group "com.github.luxlang") (template [ ] [(def: .public Name )] ["lux-jvm" jvm_compiler_name] ["lux-js" js_compiler_name] ["lux-python" python_compiler_name] ["lux-lua" lua_compiler_name] ["lux-ruby" ruby_compiler_name] ) (exception: .public no_available_compiler) (exception: .public no_specified_program) (type: .public Compiler (Variant {#JVM Dependency} {#JS Dependency} {#Python Dependency} {#Lua Dependency} {#Ruby Dependency})) (def: (remove_dependency dependency) (-> Dependency (-> Resolution Resolution)) (|>> dictionary.entries (list.only (|>> product.left (same? dependency) not)) (dictionary.of_list ///dependency.hash))) (def: (compiler resolution compiler_dependency) (-> Resolution Dependency (Try [Resolution Compiler])) (let [[[compiler_group compiler_name compiler_version] compiler_type] compiler_dependency] (case (..dependency_finder compiler_group compiler_name resolution) {.#Some dependency} (case compiler_name (^template [ ] [(^ (static )) {try.#Success [(..remove_dependency dependency resolution) { dependency}]}]) ([#JVM ..jvm_compiler_name] [#JS ..js_compiler_name] [#Python ..python_compiler_name] [#Lua ..lua_compiler_name] [#Ruby ..ruby_compiler_name]) _ (exception.except ..no_available_compiler [])) _ (exception.except ..no_available_compiler [])))) (def: (path fs home dependency) (All (_ !) (-> (file.System !) Path Dependency Path)) (let [/ (# fs separator) artifact (value@ ///dependency.#artifact dependency)] (|> artifact (///local.uri (value@ ///artifact.#version artifact)) (text.replaced uri.separator /) (format home /) (text.suffix (format "." (value@ ///dependency.#type dependency)))))) (def: (libraries fs home) (All (_ !) (-> (file.System !) Path Resolution (List Path))) (|>> dictionary.keys (list.only (|>> (value@ ///dependency.#type) (text#= ///artifact/type.lux_library))) (list#each (..path fs home)))) (def: version_separator ".") (implementation: version_order (Order Version) (def: &equivalence text.equivalence) (def: (< left right) (loop [left (text.all_split_by ..version_separator left) right (text.all_split_by ..version_separator right)] (case [left right] [{.#Item leftH leftT} {.#Item rightH rightT}] (if (text#= leftH rightH) (recur leftT rightT) (or (n.< (text.size leftH) (text.size rightH)) (text#< leftH rightH))) [{.#Item leftH leftT} {.#End}] false [{.#End} {.#Item rightH rightT}] true [{.#End} {.#End}] false)))) (def: .public (host_dependencies fs home) (All (_ !) (-> (file.System !) Path Resolution (List Path))) (|>> dictionary.keys (list.only (|>> (value@ ///dependency.#type) (text#= ///artifact/type.lux_library) not)) (list#mix (function (_ dependency uniques) (let [artifact (value@ ///dependency.#artifact dependency) identity [(value@ ///artifact.#group artifact) (value@ ///artifact.#name artifact)] version (value@ ///artifact.#version artifact)] (case (dictionary.value identity uniques) {.#Some [current_version current_path]} (if (# version_order < version current_version) (dictionary.has identity [version dependency] uniques) uniques) {.#None} (dictionary.has identity [version dependency] uniques)))) (: (Dictionary [Group Name] [Version Dependency]) (dictionary.empty (product.hash text.hash text.hash)))) dictionary.values (list#each (|>> product.right (..path fs home))))) (def: (singular name) (-> Text Text (List Text)) (|>> (list name))) (def: (plural name) (-> Text (List Text) (List Text)) (|>> (list#each (|>> (list name))) list.together)) (def: .public start "[BUILD STARTED]") (def: .public success "[BUILD ENDED]") (def: .public failure "[BUILD FAILED]") (template [ ] [(def: .public ( console process) (-> (Console Async) (Process Async) (Async (Try Any))) ... This is a very odd way of implementing this function. ... But it's written this way because the more straightforward way (i.e. by using (try.with async.monad)) ... eventually led to the function hanging/freezing. ... I'm not sure why it happened, but I got this weirder implementation to work. (let [[read! write!] (: [(Async (Try Any)) (async.Resolver (Try Any))] (async.async [])) _ (|> (# process []) (async.upon! (function (recur ?line) (case ?line {try.#Failure error} (if (exception.match? shell.no_more_output error) (write! {try.#Success []}) (async.upon! write! (console.write_line error console))) {try.#Success line} (async.upon! (function (_ outcome) (case outcome {try.#Failure error} (write! {try.#Failure error}) {try.#Success _} (async.upon! recur (# process [])))) (console.write_line line console))))) io.run!)] read!))] [log_output! read] [log_error! error] ) (import: java/lang/System ["[1]::[0]" ("static" getProperty [java/lang/String] "io" "try" java/lang/String)]) (def: windows? Bit (|> (java/lang/System::getProperty "os.name") io.run! (try.else "") text.lower_cased (text.starts_with? "windows"))) (def: jvm_class_path_separator (if windows? ";" ":")) (def: (jvm_class_path host_dependencies) (-> (List Path) Text) (|> host_dependencies {.#Item "."} (text.interposed ..jvm_class_path_separator))) (def: .public (with_jvm_class_path host_dependencies runtime) (-> (List Path) ///runtime.Runtime ///runtime.Runtime) (case host_dependencies {.#End} runtime _ (revised@ ///runtime.#parameters (|>> (list& "-cp" (..jvm_class_path host_dependencies))) runtime))) (def: .public (do! console program fs shell resolution) (-> (Console Async) (Program Async) (file.System Async) (Shell Async) Resolution (Command [Exit Compiler Path])) (function (_ profile) (let [target (value@ ///.#target profile)] (case (value@ ///.#program profile) {.#None} (async#in (exception.except ..no_specified_program [])) {.#Some program_module} (do async.monad [environment (program.environment async.monad program) .let [home (# program home) working_directory (# program directory)]] (do ///action.monad [[resolution compiler] (async#in (..compiler resolution (value@ ///.#compiler profile))) .let [host_dependencies (..host_dependencies fs home resolution) [[command compiler_params] output] (case compiler {#JVM dependency} [(|> (value@ ///.#java profile) (with@ ///runtime.#parameters (list "program._")) (with_jvm_class_path {.#Item (..path fs home dependency) host_dependencies})) "program.jar"] (^template [ ] [{ dependency} [(|> dependency (..path fs home) (///runtime.for (value@ profile))) ]]) ([#JS ///.#js "program.js"] [#Python ///.#java "program.py"] [#Lua ///.#java "program.lua"] [#Ruby ///.#java "program.rb"])) / (# fs separator) cache_directory (format working_directory / target)] _ (console.write_line ..start console) .let [full_parameters (list.together (list compiler_params (list "build") (..plural "--library" (..libraries fs home resolution)) (..plural "--host_dependency" host_dependencies) (..plural "--source" (set.list (value@ ///.#sources profile))) (..singular "--target" cache_directory) (..singular "--module" program_module)))] process (# shell execute [environment working_directory command full_parameters]) _ (..log_output! console process) _ (..log_error! console process) exit (# process await []) _ (console.write_line (if (i.= shell.normal exit) ..success ..failure) console)] (in [exit compiler (format cache_directory / output)])))))))