Add support for vuex actions

Author: mikelu92

src/Observer.js

@@ -1,7 +1,10 @@
 import Emitter from './Emitter'
 
+const commit = 'commit'
+const dispatch = 'dispatch'
+
 export default class {
-  constructor (connectionUrl, opts = {}) {
+  constructor(connectionUrl, opts = {}) {
     this.format = opts.format && opts.format.toLowerCase()
 
     if (connectionUrl.startsWith('//')) {
@@ -22,80 +25,105 @@ export default class {
 
     this.connect(connectionUrl, opts)
 
-    if (opts.store) { this.store = opts.store }
-    if (opts.mutations) { this.mutations = opts.mutations }
+    if (opts.store) {
+      this.store = opts.store
+      if ((opts.storeMethodType && opts.storeMethodType == dispatch) || opts.storeMethodType === commit) {
+        this.storeMethodType = opts.storeMethodType
+      } else {
+        this.storeMethodType = commit
+      }
+    }
+    if (opts.methods) {
+      this.methods = opts.methods
+    }
+    if (opts.mutations) {
+      console.warn('vue-native-websocket plugin: mutations will be deprecated, please switch to methods')
+      this.methods = opts.mutations
+    }
     this.onEvent()
   }
 
-  connect (connectionUrl, opts = {}) {
+  connect(connectionUrl, opts = {}) {
     let protocol = opts.protocol || ''
-    this.WebSocket = opts.WebSocket || (protocol === '' ? new WebSocket(connectionUrl) : new WebSocket(connectionUrl, protocol))
+    this.WebSocket =
+      opts.WebSocket || (protocol === '' ? new WebSocket(connectionUrl) : new WebSocket(connectionUrl, protocol))
     if (this.format === 'json') {
       if (!('sendObj' in this.WebSocket)) {
-        this.WebSocket.sendObj = (obj) => this.WebSocket.send(JSON.stringify(obj))
+        this.WebSocket.sendObj = obj => this.WebSocket.send(JSON.stringify(obj))
       }
     }
 
     return this.WebSocket
   }
 
-  reconnect () {
+  reconnect() {
     if (this.reconnectionCount <= this.reconnectionAttempts) {
       this.reconnectionCount++
       clearTimeout(this.reconnectTimeoutId)
 
       this.reconnectTimeoutId = setTimeout(() => {
-        if (this.store) { this.passToStore('SOCKET_RECONNECT', this.reconnectionCount) }
+        if (this.store) {
+          this.passToStore('SOCKET_RECONNECT', this.reconnectionCount)
+        }
 
         this.connect(this.connectionUrl, this.opts)
         this.onEvent()
       }, this.reconnectionDelay)
     } else {
-      if (this.store) { this.passToStore('SOCKET_RECONNECT_ERROR', true) }
+      if (this.store) {
+        this.passToStore('SOCKET_RECONNECT_ERROR', true)
+      }
     }
   }
 
-  onEvent () {
-    ['onmessage', 'onclose', 'onerror', 'onopen'].forEach((eventType) => {
-      this.WebSocket[eventType] = (event) => {
+  onEvent() {
+    ;['onmessage', 'onclose', 'onerror', 'onopen'].forEach(eventType => {
+      this.WebSocket[eventType] = event => {
         Emitter.emit(eventType, event)
 
-        if (this.store) { this.passToStore('SOCKET_' + eventType, event) }
+        if (this.store) {
+          this.passToStore('SOCKET_' + eventType, event)
+        }
 
         if (this.reconnection && eventType === 'onopen') {
           this.opts.$setInstance(event.currentTarget)
           this.reconnectionCount = 0
         }
 
-        if (this.reconnection && eventType === 'onclose') { this.reconnect() }
+        if (this.reconnection && eventType === 'onclose') {
+          this.reconnect()
+        }
       }
     })
   }
 
-  passToStore (eventName, event) {
+  passToStore(eventName, event) {
     if (this.passToStoreHandler) {
       this.passToStoreHandler(eventName, event, this.defaultPassToStore.bind(this))
     } else {
       this.defaultPassToStore(eventName, event)
     }
   }
 
-  defaultPassToStore (eventName, event) {
-    if (!eventName.startsWith('SOCKET_')) { return }
-    let method = 'commit'
+  defaultPassToStore(eventName, event) {
+    if (!eventName.startsWith('SOCKET_')) {
+      return
+    }
+    let method = this.storeMethodType
     let target = eventName.toUpperCase()
     let msg = event
     if (this.format === 'json' && event.data) {
       msg = JSON.parse(event.data)
       if (msg.mutation) {
-        target = [msg.namespace || '', msg.mutation].filter((e) => !!e).join('/')
+        method = commit
+        target = [msg.namespace || '', msg.mutation].filter(e => !!e).join('/')
       } else if (msg.action) {
-        method = 'dispatch'
-        target = [msg.namespace || '', msg.action].filter((e) => !!e).join('/')
+        method = dispatch
+        target = [msg.namespace || '', msg.action].filter(e => !!e).join('/')
       }
     }
-    if (this.mutations) {
-      target = this.mutations[target] || target
+    if (this.methods) {
+      target = this.methods[target] || target
     }
     this.store[method](target, msg)
   }