add MessagePort

Author: gbagan

README.md

@@ -15,7 +15,7 @@ import Effect (Effect)
 import Control.Monad.Except (runExcept)
 import Foreign (readInt)
 import Web.Worker.GlobalScope (postMessage, onMessage)
-import Web.Worker.Event (data_)
+import Web.Worker.MessageEvent (data_)
 import Effect.Console (log)
 
 main :: Effect Unit
@@ -39,7 +39,7 @@ import Foreign (readInt)
 import Effect (Effect)
 import Effect.Console (log)
 import Web.Worker.Worker (defaultWorkerOptions, new, postMessage, onMessage)
-import Web.Worker.Event (data_)
+import Web.Worker.MessageEvent (data_)
 
 main :: Effect Unit
 main = do

src/Web/Worker/GlobalScope.purs

@@ -14,7 +14,7 @@ import Effect (Effect)
 import Web.Worker.Navigator (Navigator)
 import Web.Worker.Location (Location)
 import Web.Event.Event (Event)
-import Web.Worker.Event (MessageEvent)
+import Web.Worker.MessageEvent (MessageEvent)
 
 foreign import location :: Effect Location
 

src/Web/Worker/Event.js src/Web/Worker/MessageEvent.jssrc/Web/Worker/Event.js renamed to src/Web/Worker/MessageEvent.js

@@ -8,4 +8,8 @@ export function origin(ev) {
 
 export function lastEventId(ev) {
   return ev.lastEventId;
+}
+
+export function ports(ev) {
+  return ev.ports;
 }

src/Web/Worker/Event.purs src/Web/Worker/MessageEvent.purssrc/Web/Worker/Event.purs renamed to src/Web/Worker/MessageEvent.purs

@@ -1,14 +1,22 @@
-module Web.Worker.Event where
+module Web.Worker.MessageEvent
+  ( data_
+  , lastEventId
+  , origin
+  , module Types
+  )
+  where
 
 import Foreign (Foreign)
-
-foreign import data MessageEvent :: Type
+import Web.Worker.Types (MessageEvent, MessagePort)
+import Web.Worker.Types (MessageEvent) as Types
 
 foreign import data_ :: MessageEvent -> Foreign
 
 foreign import origin :: MessageEvent -> String
 
 foreign import lastEventId :: MessageEvent -> String
 
+foreign import ports :: MessageEvent -> Array MessagePort
+
 -- source :: WindwProxy | MessagePort | ServiceWorker
 -- ports :: Array MessagePort

src/Web/Worker/MessagePort.js

@@ -0,0 +1,31 @@
+export function close(port) {
+  return function () {
+    port.close();
+  };
+}
+
+export function start(port) {
+  return function () {
+    port.start();
+  };
+}
+
+export function onMessage(f) {
+  return function (port) {
+    return function () {
+      port.onmessage = function (ev) {
+        f(ev)();
+      };
+    };
+  };
+}
+
+export function onMessageError(f) {
+  return function (port) {
+    return function () {
+      port.onmessageerror = function (ev) {
+        f(ev)();
+      };
+    };
+  };
+}

src/Web/Worker/MessagePort.purs

@@ -0,0 +1,17 @@
+module Web.Worker.MessagePort
+  ( close
+  , module Types
+  , onMessage
+  , onMessageError
+  )
+  where
+
+import Prelude
+import Effect (Effect)
+import Web.Worker.Types (MessageEvent, MessagePort)
+import Web.Worker.Types (MessagePort) as Types
+
+foreign import onMessage :: (MessageEvent -> Effect Unit) -> MessagePort -> Effect Unit
+foreign import onMessageError :: (MessageEvent -> Effect Unit) -> MessagePort -> Effect Unit
+foreign import close :: MessagePort -> Effect Unit
+foreign import start :: MessagePort -> Effect Unit

src/Web/Worker/Types.purs

@@ -0,0 +1,4 @@
+module Web.Worker.Types where
+
+foreign import data MessagePort :: Type
+foreign import data MessageEvent :: Type

src/Web/Worker/Worker.purs

@@ -21,8 +21,7 @@ import Unsafe.Coerce (unsafeCoerce)
 import Web.Event.Event (Event)
 import Web.Event.EventTarget (EventTarget)
 import Web.Internal.FFI (unsafeReadProtoTagged)
-import Web.Worker.Event (MessageEvent)
-
+import Web.Worker.MessageEvent (MessageEvent)
 
 foreign import data Worker :: Type