Initial commit

Author: garyb

.eslintrc.json

@@ -0,0 +1,29 @@
+{
+  "parserOptions": {
+    "ecmaVersion": 5
+  },
+  "extends": "eslint:recommended",
+  "env": {
+    "commonjs": true,
+    "browser": true
+  },
+  "rules": {
+    "strict": [2, "global"],
+    "block-scoped-var": 2,
+    "consistent-return": 2,
+    "eqeqeq": [2, "smart"],
+    "guard-for-in": 2,
+    "no-caller": 2,
+    "no-extend-native": 2,
+    "no-loop-func": 2,
+    "no-new": 2,
+    "no-param-reassign": 2,
+    "no-return-assign": 2,
+    "no-unused-expressions": 2,
+    "no-use-before-define": 2,
+    "radix": [2, "always"],
+    "indent": [2, 2],
+    "quotes": [2, "double"],
+    "semi": [2, "always"]
+  }
+}

.travis.yml

@@ -0,0 +1,15 @@
+language: node_js
+dist: trusty
+sudo: required
+node_js: stable
+install:
+  - npm install -g bower
+  - npm install
+  - bower install
+script:
+  - npm run -s build
+after_success:
+- >-
+  test $TRAVIS_TAG &&
+  echo $GITHUB_TOKEN | pulp login &&
+  echo y | pulp publish --no-push

README.md

@@ -1 +1 @@
-# purescript-web-socket
+# purescript-web-socket

bower.json

@@ -0,0 +1,21 @@
+{
+  "name": "purescript-web-socket",
+  "homepage": "https://github.com/purescript-web/purescript-web-socket",
+  "license": "MIT",
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/purescript-web/purescript-web-socket.git"
+  },
+  "ignore": [
+    "**/.*",
+    "bower_components",
+    "node_modules",
+    "output",
+    "bower.json",
+    "package.json"
+  ],
+  "dependencies": {
+    "purescript-arraybuffer-types": "^2.0.0",
+    "purescript-web-file": "#compiler/0.12"
+  }
+}

package.json

@@ -0,0 +1,16 @@
+{
+  "private": true,
+  "scripts": {
+    "clean": "rimraf output && rimraf .pulp-cache",
+    "build": "eslint src && pulp build -- --censor-lib --strict",
+    "test": "pulp test --runtime phantomjs"
+  },
+  "devDependencies": {
+    "eslint": "^3.19.0",
+    "phantomjs-prebuilt": "^2.1.14",
+    "pulp": "^11.0.0",
+    "purescript-psa": "^0.5.0",
+    "purescript": "^0.11.1",
+    "rimraf": "^2.6.1"
+  }
+}

src/Web/WebSocket/BinaryType.purs

@@ -0,0 +1,48 @@
+module Web.WebSocket.BinaryType where
+
+import Prelude
+import Data.Enum (Cardinality(..), class BoundedEnum, defaultPred, defaultSucc, class Enum)
+import Data.Maybe (Maybe(..))
+
+data BinaryType
+  = Blob
+  | ArrayBuffer
+
+derive instance eqBinaryType :: Eq BinaryType
+derive instance ordBinaryType :: Ord BinaryType
+
+instance boundedBinaryType :: Bounded BinaryType where
+  bottom = Blob
+  top = ArrayBuffer
+
+instance enumBinaryType :: Enum BinaryType where
+  succ = defaultSucc toEnumBinaryType fromEnumBinaryType
+  pred = defaultPred toEnumBinaryType fromEnumBinaryType
+
+instance boundedEnumBinaryType :: BoundedEnum BinaryType where
+  cardinality = Cardinality 2
+  toEnum = toEnumBinaryType
+  fromEnum = fromEnumBinaryType
+
+instance showBinaryType :: Show BinaryType where
+  show Blob = "Blob"
+  show ArrayBuffer = "ArrayBuffer"
+
+toEnumBinaryType :: Int -> Maybe BinaryType
+toEnumBinaryType =
+  case _ of
+    0 -> Just Blob
+    1 -> Just ArrayBuffer
+    _ -> Nothing
+
+fromEnumBinaryType :: BinaryType -> Int
+fromEnumBinaryType =
+  case _ of
+    Blob -> 0
+    ArrayBuffer -> 1
+
+printBinaryType :: BinaryType -> String
+printBinaryType =
+  case _ of
+    Blob -> "blob"
+    ArrayBuffer -> "arraybuffer"

src/Web/WebSocket/Event/CloseEvent.js

@@ -0,0 +1,13 @@
+"use strict";
+
+exports.code = function (e) {
+  return e.code;
+};
+
+exports.reason = function (e) {
+  return e.reason;
+};
+
+exports.wasClean = function (e) {
+  return e.wasClean;
+};

src/Web/WebSocket/Event/CloseEvent.purs

@@ -0,0 +1,20 @@
+module Web.WebSocket.Event.CloseEvent where
+
+import Data.Maybe (Maybe)
+import Unsafe.Coerce (unsafeCoerce)
+import Web.Event.Event (Event)
+import Web.Internal.FFI (unsafeReadProtoTagged)
+
+foreign import data CloseEvent :: Type
+
+fromEvent :: Event -> Maybe CloseEvent
+fromEvent = unsafeReadProtoTagged "CloseEvent"
+
+toEvent :: CloseEvent -> Event
+toEvent = unsafeCoerce
+
+foreign import code :: CloseEvent -> Int
+
+foreign import reason :: CloseEvent -> String
+
+foreign import wasClean :: CloseEvent -> Boolean

src/Web/WebSocket/Event/EventTypes.purs

@@ -0,0 +1,15 @@
+module Web.WebSocket.Event.EventTypes where
+
+import Web.Event.Event (EventType(..))
+
+onOpen :: EventType
+onOpen = EventType "open"
+
+onMessage :: EventType
+onMessage = EventType "message"
+
+onError :: EventType
+onError = EventType "error"
+
+onClose :: EventType
+onClose = EventType "close"

src/Web/WebSocket/Event/MessageEvent.js

@@ -0,0 +1,13 @@
+"use strict";
+
+exports.data_ = function (e) {
+  return e.data;
+};
+
+exports.origin = function (e) {
+  return e.origin;
+};
+
+exports.lastEventId = function (e) {
+  return e.lastEventId;
+};

src/Web/WebSocket/Event/MessageEvent.purs

@@ -0,0 +1,21 @@
+module Web.WebSocket.Event.MessageEvent where
+
+import Data.Maybe (Maybe)
+import Foreign (Foreign)
+import Unsafe.Coerce (unsafeCoerce)
+import Web.Event.Event (Event)
+import Web.Internal.FFI (unsafeReadProtoTagged)
+
+foreign import data MessageEvent :: Type
+
+fromEvent :: Event -> Maybe MessageEvent
+fromEvent = unsafeReadProtoTagged "MessageEvent"
+
+toEvent :: MessageEvent -> Event
+toEvent = unsafeCoerce
+
+foreign import data_ :: MessageEvent -> Foreign
+
+foreign import origin :: MessageEvent -> String
+
+foreign import lastEventId :: MessageEvent -> String

src/Web/WebSocket/ReadyState.purs

@@ -0,0 +1,50 @@
+module Web.WebSocket.ReadyState where
+
+import Prelude
+import Data.Enum (Cardinality(..), class BoundedEnum, defaultPred, defaultSucc, class Enum)
+import Data.Maybe (Maybe(..))
+
+data ReadyState
+  = Connecting
+  | Open
+  | Closing
+  | Closed
+
+derive instance eqReadyState :: Eq ReadyState
+derive instance ordReadyState :: Ord ReadyState
+
+instance boundedReadyState :: Bounded ReadyState where
+  bottom = Connecting
+  top = Closed
+
+instance enumReadyState :: Enum ReadyState where
+  succ = defaultSucc toEnumReadyState fromEnumReadyState
+  pred = defaultPred toEnumReadyState fromEnumReadyState
+
+instance boundedEnumReadyState :: BoundedEnum ReadyState where
+  cardinality = Cardinality 4
+  toEnum = toEnumReadyState
+  fromEnum = fromEnumReadyState
+
+instance showReadyState :: Show ReadyState where
+  show Connecting = "Connecting"
+  show Open = "Open"
+  show Closing = "Closing"
+  show Closed = "Closed"
+
+toEnumReadyState :: Int -> Maybe ReadyState
+toEnumReadyState =
+  case _ of
+    0 -> Just Connecting
+    1 -> Just Open
+    2 -> Just Closing
+    3 -> Just Closed
+    _ -> Nothing
+
+fromEnumReadyState :: ReadyState -> Int
+fromEnumReadyState =
+  case _ of
+    Connecting -> 0
+    Open -> 1
+    Closing -> 2
+    Closed -> 3

src/Web/WebSocket/WebSocket.js

@@ -0,0 +1,67 @@
+"use strict";
+
+exports.create = function (url) {
+  return function (protocols) {
+    return function () {
+      return new WebSocket(url, protocols);
+    };
+  };
+};
+
+exports.url = function (ws) {
+  return function () {
+    return ws.url;
+  };
+};
+
+exports.readyStateImpl = function (ws) {
+  return function () {
+    return ws.readyState;
+  };
+};
+
+exports.bufferedAmount = function (ws) {
+  return function () {
+    return ws.bufferedAmount;
+  };
+};
+
+exports.extensions = function (ws) {
+  return function () {
+    return ws.extensions;
+  };
+};
+
+exports.protocol = function (ws) {
+  return function () {
+    return ws.protocol;
+  };
+};
+
+exports.close = function (ws) {
+  return function () {
+    return ws.close();
+  };
+};
+
+exports.getBinaryTypeImpl = function (ws) {
+  return function () {
+    return ws.binaryType;
+  };
+};
+
+exports.setBinaryTypeImpl = function (ws) {
+  return function (bt) {
+    return function () {
+      ws.binaryType = bt;
+    };
+  };
+};
+
+exports.sendImpl = function (ws) {
+  return function (value) {
+    return function () {
+      ws.send(value);
+    };
+  };
+};