From 832a9361b632331e82a64c07baa560487ca8abde Mon Sep 17 00:00:00 2001
From: Eduardo Julian
Date: Tue, 29 Dec 2020 00:38:21 -0400
Subject: Moved "lux/data/number" to "lux/math/number".

---
 .../source/program/aedifex/repository/remote.lux   | 138 +++++++++++++++++++++
 1 file changed, 138 insertions(+)
 create mode 100644 stdlib/source/program/aedifex/repository/remote.lux

(limited to 'stdlib/source/program/aedifex/repository/remote.lux')

diff --git a/stdlib/source/program/aedifex/repository/remote.lux b/stdlib/source/program/aedifex/repository/remote.lux
new file mode 100644
index 000000000..4979e5429
--- /dev/null
+++ b/stdlib/source/program/aedifex/repository/remote.lux
@@ -0,0 +1,138 @@
+(.module:
+  [lux #*
+   [host (#+ import:)]
+   [abstract
+    [monad (#+ do)]]
+   [control
+    ["." io (#+ IO)]
+    ["." try]
+    ["." exception (#+ exception:)]]
+   [data
+    ["." binary]
+    ["." text
+     ["%" format (#+ format)]]]
+   [math
+    [number
+     ["n" nat]]]
+   [tool
+    [compiler
+     ["." version]
+     ["." language #_
+      ["#/." lux #_
+       ["#" version]]]]]
+   [world
+    [net (#+ URL)
+     [uri (#+ URI)]]]]
+  ["." //
+   ["#." identity (#+ Identity)]
+   ["/#" // #_
+    ["#." artifact (#+ Artifact)
+     [extension (#+ Extension)]]]])
+
+(type: #export Address
+  URL)
+
+(import: java/lang/String)
+
+(import: java/lang/AutoCloseable
+  ["#::."
+   (close [] #io #try void)])
+
+(import: java/io/InputStream)
+
+(import: java/io/OutputStream
+  ["#::."
+   (flush [] #io #try void)
+   (write [[byte]] #io #try void)])
+
+(import: java/net/URLConnection
+  ["#::."
+   (setDoOutput [boolean] #io #try void)
+   (setRequestProperty [java/lang/String java/lang/String] #io #try void)
+   (getInputStream [] #io #try java/io/InputStream)
+   (getOutputStream [] #io #try java/io/OutputStream)])
+
+(import: java/net/HttpURLConnection
+  ["#::."
+   (setRequestMethod [java/lang/String] #io #try void)
+   (getResponseCode [] #io #try int)])
+
+(import: java/net/URL
+  ["#::."
+   (new [java/lang/String])
+   (openConnection [] #io #try java/net/URLConnection)])
+
+(import: java/io/BufferedInputStream
+  ["#::."
+   (new [java/io/InputStream])
+   (read [[byte] int int] #io #try int)])
+
+(exception: #export (no_credentials {address Address})
+  (exception.report
+   ["Address" (%.text address)]))
+
+(exception: #export (deployment_failure {code Int})
+  (exception.report
+   ["Code" (%.int code)]))
+
+(def: #export (uri artifact extension)
+  (-> Artifact Extension URI)
+  (format (///artifact.uri artifact) extension))
+
+(def: buffer_size
+  (n.* 512 1,024))
+
+(def: user_agent
+  (format "LuxAedifex/" (version.format language/lux.version)))
+
+(structure: #export (repository identity address)
+  (All [s] (-> (Maybe Identity) Address (//.Repository IO)))
+
+  (def: (download uri)
+    (do {! (try.with io.monad)}
+      [connection (|> (format address uri)
+                      java/net/URL::new
+                      java/net/URL::openConnection)
+       #let [connection (:coerce java/net/HttpURLConnection connection)]
+       _ (java/net/HttpURLConnection::setRequestMethod "GET" connection)
+       _ (java/net/URLConnection::setRequestProperty "User-Agent" ..user_agent connection)
+       input (|> connection
+                 java/net/URLConnection::getInputStream
+                 (\ ! map (|>> java/io/BufferedInputStream::new)))
+       #let [buffer (binary.create ..buffer_size)]]
+      (loop [output (\ binary.monoid identity)]
+        (do !
+          [bytes_read (java/io/BufferedInputStream::read buffer +0 (.int ..buffer_size) input)]
+          (case bytes_read
+            -1 (do !
+                 [_ (java/lang/AutoCloseable::close input)]
+                 (wrap output))
+            _ (if (n.= ..buffer_size bytes_read)
+                (recur (\ binary.monoid compose output buffer))
+                (do !
+                  [chunk (\ io.monad wrap (binary.slice 0 (.nat bytes_read) buffer))]
+                  (recur (\ binary.monoid compose output chunk)))))))))
+
+  (def: (upload uri content)
+    (case identity
+      #.None
+      (\ io.monad wrap (exception.throw ..no_credentials [address]))
+      
+      (#.Some [user password])
+      (do (try.with io.monad)
+        [connection (|> (format address uri)
+                        java/net/URL::new
+                        java/net/URL::openConnection)
+         #let [connection (:coerce java/net/HttpURLConnection connection)]
+         _ (java/net/HttpURLConnection::setRequestMethod "PUT" connection)
+         _ (java/net/URLConnection::setDoOutput true connection)
+         _ (java/net/URLConnection::setRequestProperty "Authorization" (//identity.basic_auth user password) connection)
+         stream (java/net/URLConnection::getOutputStream connection)
+         _ (java/io/OutputStream::write content stream)
+         _ (java/io/OutputStream::flush stream)
+         _ (java/lang/AutoCloseable::close stream)
+         code (java/net/HttpURLConnection::getResponseCode connection)]
+        (case code
+          +201 (wrap [])
+          _ (\ io.monad wrap (exception.throw ..deployment_failure [code]))))))
+  )
-- 
cgit v1.2.3