Initial commit

Author: Mike Solomon

.gitignore

@@ -0,0 +1,20 @@
+/bower_components/
+/node_modules/
+/.pulp-cache/
+/output/
+/generated-docs/
+/.psc-package/
+/.psc*
+/.purs*
+/.psa*
+/.spago
+/.venv
+/.vscode
+
+purescript_aff
+
+# purescript-python
+.pure-py/
+
+# purescript-python
+.pure-py/

README.md

@@ -0,0 +1,11 @@
+# purescript-aff.py
+
+This is an initial implementation of Effect.Aff that copies the JavaScript implementation more or less verbatim.
+
+There is still much to do:
+
+- general bug fixing, as there are some subtle bugs due to copy and paste errors
+- making the code more pythonic
+- correctly guarding code with threading.Lock
+
+The repo is in _alpha_ development. The code is not fit for anything other than experimental usage. It needs additional development and testing before being able to be incorporated into the official package-set for purescript.python.

packages.dhall

@@ -0,0 +1,128 @@
+{-
+Welcome to your new Dhall package-set!
+
+Below are instructions for how to edit this file for most use
+cases, so that you don't need to know Dhall to use it.
+
+## Warning: Don't Move This Top-Level Comment!
+
+Due to how `dhall format` currently works, this comment's
+instructions cannot appear near corresponding sections below
+because `dhall format` will delete the comment. However,
+it will not delete a top-level comment like this one.
+
+## Use Cases
+
+Most will want to do one or both of these options:
+1. Override/Patch a package's dependency
+2. Add a package not already in the default package set
+
+This file will continue to work whether you use one or both options.
+Instructions for each option are explained below.
+
+### Overriding/Patching a package
+
+Purpose:
+- Change a package's dependency to a newer/older release than the
+    default package set's release
+- Use your own modified version of some dependency that may
+    include new API, changed API, removed API by
+    using your custom git repo of the library rather than
+    the package set's repo
+
+Syntax:
+Replace the overrides' "{=}" (an empty record) with the following idea
+The "//" or "⫽" means "merge these two records and
+  when they have the same value, use the one on the right:"
+-------------------------------
+let overrides =
+  { packageName =
+      upstream.packageName // { updateEntity1 = "new value", updateEntity2 = "new value" }
+  , packageName =
+      upstream.packageName // { version = "v4.0.0" }
+  , packageName =
+      upstream.packageName // { repo = "https://www.example.com/path/to/new/repo.git" }
+  }
+-------------------------------
+
+Example:
+-------------------------------
+let overrides =
+  { halogen =
+      upstream.halogen // { version = "master" }
+  , halogen-vdom =
+      upstream.halogen-vdom // { version = "v4.0.0" }
+  }
+-------------------------------
+
+### Additions
+
+Purpose:
+- Add packages that aren't already included in the default package set
+
+Syntax:
+Replace the additions' "{=}" (an empty record) with the following idea:
+-------------------------------
+let additions =
+  { package-name =
+       { dependencies =
+           [ "dependency1"
+           , "dependency2"
+           ]
+       , repo =
+           "https://example.com/path/to/git/repo.git"
+       , version =
+           "tag ('v4.0.0') or branch ('master')"
+       }
+  , package-name =
+       { dependencies =
+           [ "dependency1"
+           , "dependency2"
+           ]
+       , repo =
+           "https://example.com/path/to/git/repo.git"
+       , version =
+           "tag ('v4.0.0') or branch ('master')"
+       }
+  , etc.
+  }
+-------------------------------
+
+Example:
+-------------------------------
+let additions =
+  { benchotron =
+      { dependencies =
+          [ "arrays"
+          , "exists"
+          , "profunctor"
+          , "strings"
+          , "quickcheck"
+          , "lcg"
+          , "transformers"
+          , "foldable-traversable"
+          , "exceptions"
+          , "node-fs"
+          , "node-buffer"
+          , "node-readline"
+          , "datetime"
+          , "now"
+          ]
+      , repo =
+          "https://github.com/hdgarrood/purescript-benchotron.git"
+      , version =
+          "v7.0.0"
+      }
+  }
+-------------------------------
+-}
+
+
+let upstream =
+      https://github.com/purescript/package-sets/releases/download/psc-0.13.8/packages.dhall sha256:0e95ec11604dc8afc1b129c4d405dcc17290ce56d7d0665a0ff15617e32bbf03
+
+let overrides = {=}
+
+let additions = {=}
+
+in  upstream // overrides // additions

pure-py.json

@@ -0,0 +1,7 @@
+{
+  "corefn-dir": "output",
+  "data-format": "Compressed",
+  "entry-module": "Main",
+  "index-mirror": "affexpr",
+  "pspy-blueprint": "pspy-blueprint"
+}

python-ffi/Affjax.py

@@ -0,0 +1,103 @@
+"""
+ var platformSpecific = { };
+  if (typeof module !== "undefined" && module.require && !(typeof process !== "undefined" && process.versions["electron"])) {
+    // We are on node.js
+    platformSpecific.newXHR = function () {
+      var XHR = module.require("xhr2");
+      return new XHR();
+    };
+
+    platformSpecific.fixupUrl = function (url, xhr) {
+      if (xhr.nodejsBaseUrl === null) {
+        var urllib = module.require("url");
+        var u = urllib.parse(url);
+        u.protocol = u.protocol || "http:";
+        u.hostname = u.hostname || "localhost";
+        return urllib.format(u);
+      } else {
+        return url || "/";
+      }
+    };
+
+    platformSpecific.getResponse = function (xhr) {
+      return xhr.response;
+    };
+  } else {
+    // We are in the browser
+    platformSpecific.newXHR = function () {
+      return new XMLHttpRequest();
+    };
+
+    platformSpecific.fixupUrl = function (url) {
+      return url || "/";
+    };
+
+    platformSpecific.getResponse = function (xhr) {
+      return xhr.response;
+    };
+  }
+"""
+import http.client
+from urllib.parse import urlparse
+from base64 import b64encode
+import threading
+
+# todo - is there an analog for withCredentials here?
+def _ajax(mkHeader, options):
+    def _1(errback, callback):
+        if options["responseType"] in ["arraybuffer", "blob", "document"]:
+            errback(
+                Exception(
+                    "Affjax python does not support arraybuffer, blob, or document responses yet"
+                )
+            )
+            return
+
+        def _toThreading():
+            parsedUrl = urlparse(options["url"])
+            conn = (
+                http.client.HTTPConnection(parsedUrl.netloc)
+                if parsedUrl.scheme == "http"
+                else http.client.HTTPSConnection(parsedUrl.netloc)
+            )
+            headers = {}
+            if options.username and options.password:
+                userAndPass = b64encode(b"username:password").decode("ascii")
+                headers["Authorization"] = "Basic %s" % userAndPass
+            if options["headers"]:
+                for header in headers:
+                    headers[header["field"]] = header["value"]
+            try:
+                conn.request(
+                    options["method"] if options["method"] else "GET",
+                    parsedUrl.path,
+                    body=options["content"],
+                    headers=headers,
+                )
+                r1 = conn.getresponse()
+                callback(
+                    {
+                        "status": r1.status,
+                        "statusText": r1.reason,
+                        "headers": tuple([mkHeader(k)(v) for k, v in r1.getheaders]),
+                        "body": r1.read().decode("utf-8"),
+                    }
+                )
+
+            except Exception as e:
+                errback(e)
+                return
+
+        t = threading.Thread(target=_toThreading)
+        t.start()
+
+        def _toRet(error, cancelErrback, cancelCallback):
+            try:
+                t.cancel()
+            except Exception as e:
+                return cancelErrback(e)
+            return cancelCallback()
+
+        return _toRet
+
+    return _1

requirements.txt

@@ -0,0 +1,29 @@
+appdirs==1.4.4
+astroid==2.4.2
+attrs==19.3.0
+black==19.10b0
+bytecode==0.11.0
+certifi==2020.6.20
+chardet==3.0.4
+click==7.1.2
+gitdb==4.0.5
+GitPython==3.1.3
+idna==2.10
+isort==4.3.21
+lazy-object-proxy==1.4.3
+mccabe==0.6.1
+painless-import-extension==0.2.2
+pathspec==0.8.0
+pspy-executable==0.8.8
+purescripto==0.8.8
+pylint==2.5.3
+pysexpr==0.6
+regex==2020.6.8
+requests==2.24.0
+six==1.15.0
+smmap==3.0.4
+toml==0.10.1
+typed-ast==1.4.1
+urllib3==1.25.9
+wisepy2==1.1.1
+wrapt==1.12.1

spago.dhall

@@ -0,0 +1,10 @@
+{-
+Welcome to a Spago project!
+You can edit this file as you like.
+-}
+{ name = "purescript-aff"
+, dependencies = [ "aff", "console", "effect", "psci-support", "affjax" ]
+, packages = ./packages.dhall
+, sources = [ "src/**/*.purs"]
+, backend = "pspy"
+}

src/Main.purs

@@ -0,0 +1,18 @@
+module Main where
+
+import Prelude
+import Affjax as AX
+import Affjax.ResponseFormat as ResponseFormat
+import Data.Argonaut.Core as J
+import Data.Either (Either(..))
+import Data.HTTP.Method (Method(..))
+import Effect.Aff (launchAff)
+import Effect.Class.Console (log)
+
+main =
+  void $ launchAff
+    $ do
+        result <- AX.request (AX.defaultRequest { url = "/api", method = Left GET, responseFormat = ResponseFormat.json })
+        case result of
+          Left err -> log $ "GET /api response failed to decode: " <> AX.printError err
+          Right response -> log $ "GET /api response: " <> J.stringify response.body