Added simple bidings, need to import purescript-sse-stream package

Author: Woody88

packages.dhall

@@ -123,6 +123,18 @@ let upstream =
 
 let overrides = {=}
 
-let additions = {=}
-
+let additions = 
+  { http-types =
+    { dependencies =
+      [ "tuples"
+      , "unicode"
+      , "uri"
+      ]
+    , repo =
+        "https://github.com/Woody88/purescript-http-types.git"
+    , version =
+        "master"
+    }
+  }
+  
 in  upstream // overrides // additions

spago.dhall

@@ -3,7 +3,7 @@ Welcome to a Spago project!
 You can edit this file as you like.
 -}
 { name = "my-project"
-, dependencies = [ "console", "effect", "psci-support" ]
+, dependencies = [ "console", "effect", "http-types", "psci-support" ]
 , packages = ./packages.dhall
 , sources = [ "src/**/*.purs", "test/**/*.purs" ]
 }

src/EventSource.js

@@ -0,0 +1,41 @@
+"use strict"; 
+
+exports._createEventSource = url => options => () => {
+  options.https = { rejectUnauthorized:  options.httpsRejectUnauthorized }
+  delete options.httpsRejectUnauthorized
+  return new EventSource(url, options);
+}
+
+exports._readyState = evs => () => {
+  evs.readyState 
+}
+exports._addEventListener = evs => e => cb => () => {
+  evs.addEventListener(e, cb)
+}
+
+exports._removeEventListener = evs => e => cb => () => {
+  evs.removeEventListener(e, cb)
+}
+
+exports.close = evs => () => {
+  evs.close()
+}
+
+exports._onOpen = evs => cb => () => {
+  evs.onopen = cb
+}
+
+exports._onMessage = evs => cb => () => {
+  evs.onmessage = cb 
+}
+
+exports._onError = evs => closeError => evsError => cb => () => {
+  evs.onerror = (err) => {
+    if (err.status){
+      const evsErr = evsError({ code: err.status, message: status.message })
+      return cb(evsErr)()
+    }
+
+    return cb(closeError(err.message))()
+  }
+}

src/EventSource.purs

@@ -0,0 +1,81 @@
+module EventSource where
+
+import Prelude
+
+import Data.Generic.Rep (class Generic)
+import Data.Generic.Rep.Show (genericShow)
+import Data.Maybe (Maybe(..))
+import Effect (Effect)
+import Network.HTTP.Types as H
+import Prim.Row (class Union)
+
+foreign import data EventSource :: Type 
+
+newtype EventName = EventName String 
+
+type Extensions = 
+  ( httpsRejectUnauthorized :: Boolean  
+  , withCredentials         :: Boolean 
+  , headers                 :: Array H.Header
+  , proxy                   :: String 
+  )
+
+data EventSourceError 
+  = EventSourceErr H.Status
+  | ConnectionClosedErr String 
+
+-- | Connections states 
+data ReadyState = CONNECTING
+                | OPEN
+                | CLOSED
+
+derive instance genericReadyState :: Generic ReadyState _
+derive instance eqReadyState :: Eq ReadyState
+
+instance showReadyState :: Show ReadyState where
+  show = genericShow
+
+createEventSource :: forall exts t. 
+  Union exts t Extensions 
+  => String 
+  -> Maybe { | exts }
+  -> EventSource
+createEventSource url Nothing = _createEventSource url {}
+createEventSource url (Just exts) = _createEventSource url exts
+
+readyState :: EventSource -> Effect ReadyState
+readyState evs = do
+  state <- _readyState evs
+  pure case state of
+    0 -> CONNECTING
+    1 -> OPEN
+    _ -> CLOSED
+    
+addEventListener :: forall event. EventSource -> EventName -> (event -> Effect Unit) -> Effect Unit  
+addEventListener evs (EventName en) = _addEventListener evs en
+
+removeEventListener :: forall event. EventSource -> EventName -> (event -> Effect Unit) -> Effect Unit  
+removeEventListener evs (EventName en) = _removeEventListener evs en
+
+onOpen :: forall event. EventSource -> (event -> Effect Unit) -> Effect Unit 
+onOpen = _onOpen 
+
+onMessage :: forall event. EventSource -> (event -> Effect Unit) -> Effect Unit 
+onMessage = _onMessage 
+
+onError :: EventSource -> (EventSourceError -> Effect Unit) -> Effect Unit 
+onError evs = _onError evs ConnectionClosedErr EventSourceErr
+
+foreign import _createEventSource :: forall opts. String -> opts -> EventSource 
+foreign import _readyState :: EventSource -> Effect Int  
+foreign import _addEventListener :: forall event. EventSource -> String -> (event -> Effect Unit) -> Effect Unit 
+foreign import _removeEventListener :: forall event. EventSource -> String -> (event -> Effect Unit) -> Effect Unit 
+foreign import close :: EventSource -> Effect Unit  
+foreign import _onOpen :: forall event. EventSource -> (event -> Effect Unit) -> Effect Unit 
+foreign import _onMessage :: forall event. EventSource -> (event -> Effect Unit) -> Effect Unit 
+foreign import _onError :: 
+  EventSource 
+  -> (String  -> EventSourceError) 
+  -> (H.Status -> EventSourceError) 
+  -> (EventSourceError -> Effect Unit) 
+  -> Effect Unit