mirror of
https://github.com/tenrok/vue-native-websocket.git
synced 2026-06-12 13:12:26 +03:00
native websocket with json parsing, vuex integration and namespacing
This commit is contained in:
nathan
+39
-39
@@ -1,49 +1,49 @@
|
||||
export default new class {
|
||||
constructor() {
|
||||
this.listeners = new Map();
|
||||
class Emitter {
|
||||
constructor () {
|
||||
this.listeners = new Map()
|
||||
}
|
||||
|
||||
addListener (label, callback, vm) {
|
||||
if (typeof callback === 'function') {
|
||||
this.listeners.has(label) || this.listeners.set(label, [])
|
||||
this.listeners.get(label).push({callback: callback, vm: vm})
|
||||
return true
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
addListener(label, callback, vm) {
|
||||
if(typeof callback == 'function'){
|
||||
this.listeners.has(label) || this.listeners.set(label, []);
|
||||
this.listeners.get(label).push({callback: callback, vm: vm});
|
||||
removeListener (label, callback, vm) {
|
||||
let listeners = this.listeners.get(label)
|
||||
let index
|
||||
|
||||
return true
|
||||
if (listeners && listeners.length) {
|
||||
index = listeners.reduce((i, listener, index) => {
|
||||
if (typeof listener.callback === 'function' && listener.callback === callback && listener.vm === vm) {
|
||||
i = index
|
||||
}
|
||||
return i
|
||||
}, -1)
|
||||
|
||||
return false
|
||||
if (index > -1) {
|
||||
listeners.splice(index, 1)
|
||||
this.listeners.set(label, listeners)
|
||||
return true
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
removeListener(label, callback, vm) {
|
||||
let listeners = this.listeners.get(label),
|
||||
index;
|
||||
emit (label, ...args) {
|
||||
let listeners = this.listeners.get(label)
|
||||
|
||||
if (listeners && listeners.length) {
|
||||
index = listeners.reduce((i, listener, index) => {
|
||||
return (typeof listener.callback == 'function' && listener.callback === callback && listener.vm == vm) ?
|
||||
i = index :
|
||||
i;
|
||||
}, -1);
|
||||
|
||||
if (index > -1) {
|
||||
listeners.splice(index, 1);
|
||||
this.listeners.set(label, listeners);
|
||||
return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
if (listeners && listeners.length) {
|
||||
listeners.forEach((listener) => {
|
||||
listener.callback.call(listener.vm, ...args)
|
||||
})
|
||||
return true
|
||||
}
|
||||
return false
|
||||
}
|
||||
}
|
||||
|
||||
emit(label, ...args) {
|
||||
let listeners = this.listeners.get(label);
|
||||
|
||||
if (listeners && listeners.length) {
|
||||
listeners.forEach((listener) => {
|
||||
listener.callback.call(listener.vm,...args)
|
||||
});
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
}
|
||||
export default new Emitter()
|
||||
|
||||
+34
-39
@@ -3,50 +3,45 @@ import Emitter from './Emitter'
|
||||
|
||||
export default {
|
||||
|
||||
install(Vue, connection, store){
|
||||
install (Vue, connection, store, opts = {}) {
|
||||
if (!connection) { throw new Error('[vue-native-socket] cannot locate connection') }
|
||||
|
||||
if(!connection) throw new Error("[Vue-Socket.io] cannot locate connection")
|
||||
let observer = new Observer(connection, store, opts)
|
||||
|
||||
let observer = new Observer(connection, store)
|
||||
Vue.prototype.$socket = observer.WebSocket
|
||||
|
||||
Vue.prototype.$socket = observer.Socket;
|
||||
Vue.mixin({
|
||||
created () {
|
||||
let sockets = this.$options['sockets']
|
||||
|
||||
Vue.mixin({
|
||||
created(){
|
||||
let sockets = this.$options['sockets']
|
||||
|
||||
this.$options.sockets = new Proxy({}, {
|
||||
set: (target, key, value) => {
|
||||
Emitter.addListener(key, value, this)
|
||||
target[key] = value
|
||||
return true;
|
||||
},
|
||||
deleteProperty: (target, key) => {
|
||||
Emitter.removeListener(key, this.$options.sockets[key], this)
|
||||
delete target.key;
|
||||
return true
|
||||
}
|
||||
})
|
||||
|
||||
if(sockets){
|
||||
Object.keys(sockets).forEach((key) => {
|
||||
this.$options.sockets[key] = sockets[key];
|
||||
});
|
||||
}
|
||||
},
|
||||
beforeDestroy(){
|
||||
let sockets = this.$options['sockets']
|
||||
|
||||
if(sockets){
|
||||
Object.keys(sockets).forEach((key) => {
|
||||
delete this.$options.sockets[key]
|
||||
});
|
||||
}
|
||||
}
|
||||
this.$options.sockets = new Proxy({}, {
|
||||
set (target, key, value) {
|
||||
Emitter.addListener(key, value, this)
|
||||
target[key] = value
|
||||
return true
|
||||
},
|
||||
deleteProperty (target, key) {
|
||||
Emitter.removeListener(key, this.$options.sockets[key], this)
|
||||
delete target.key
|
||||
return true
|
||||
}
|
||||
})
|
||||
|
||||
}
|
||||
if (sockets) {
|
||||
Object.keys(sockets).forEach((key) => {
|
||||
this.$options.sockets[key] = sockets[key]
|
||||
})
|
||||
}
|
||||
},
|
||||
beforeDestroy () {
|
||||
let sockets = this.$options['sockets']
|
||||
|
||||
if (sockets) {
|
||||
Object.keys(sockets).forEach((key) => {
|
||||
delete this.$options.sockets[key]
|
||||
})
|
||||
}
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
+37
-51
@@ -1,59 +1,45 @@
|
||||
import Emitter from './Emitter'
|
||||
import Socket from 'socket.io-client'
|
||||
|
||||
export default class{
|
||||
|
||||
constructor(connection, store) {
|
||||
|
||||
if(typeof connection == 'string'){
|
||||
this.Socket = Socket(connection);
|
||||
}else{
|
||||
this.Socket = connection
|
||||
}
|
||||
|
||||
if(store) this.store = store;
|
||||
|
||||
this.onEvent()
|
||||
export default class {
|
||||
constructor (connectionUrl, store, opts = {}) {
|
||||
this.format = opts.format && opts.format.toLowerCase()
|
||||
this.connect(connectionUrl)
|
||||
if (store) { this.store = store }
|
||||
this.onEvent()
|
||||
}
|
||||
|
||||
connect (connectionUrl) {
|
||||
this.WebSocket = new WebSocket(connectionUrl)
|
||||
if (this.format === 'json') {
|
||||
if (!('sendObj' in this.WebSocket)) {
|
||||
this.WebSocket.sendObj = (obj) => this.WebSocket.send(JSON.stringify(obj))
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
onEvent(){
|
||||
this.Socket.onevent = (packet) => {
|
||||
Emitter.emit(packet.data[0], packet.data[1]);
|
||||
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_'+packet.data[0], [ ...packet.data.slice(1)])
|
||||
};
|
||||
|
||||
let _this = this;
|
||||
|
||||
["connect", "error", "disconnect", "reconnect", "reconnect_attempt", "reconnecting", "reconnect_error", "reconnect_failed", "connect_error", "connect_timeout", "connecting", "ping", "pong"]
|
||||
.forEach((value) => {
|
||||
_this.Socket.on(value, (data) => {
|
||||
Emitter.emit(value, data);
|
||||
if(_this.store) _this.passToStore('SOCKET_'+value, data)
|
||||
})
|
||||
})
|
||||
}
|
||||
|
||||
|
||||
passToStore(event, payload){
|
||||
if(!event.startsWith('SOCKET_')) return
|
||||
|
||||
for(let namespaced in this.store._mutations) {
|
||||
let mutation = namespaced.split('/').pop()
|
||||
if(mutation === event.toUpperCase()) this.store.commit(namespaced, payload)
|
||||
}
|
||||
|
||||
for(let namespaced in this.store._actions) {
|
||||
let action = namespaced.split('/').pop()
|
||||
|
||||
if(!action.startsWith('socket_')) continue
|
||||
|
||||
let camelcased = 'socket_'+event
|
||||
.replace('SOCKET_', '')
|
||||
.replace(/^([A-Z])|[\W\s_]+(\w)/g, (match, p1, p2) => p2 ? p2.toUpperCase() : p1.toLowerCase())
|
||||
|
||||
if(action === camelcased) this.store.dispatch(namespaced, payload)
|
||||
}
|
||||
passToStore (eventName, event) {
|
||||
if (!eventName.startsWith('SOCKET_')) { return }
|
||||
if (this.format === 'json' && event.data) {
|
||||
let msg = JSON.parse(event.data)
|
||||
let target = msg.namespace || ''
|
||||
if (msg.mutation) {
|
||||
this.store.commit([target, msg.mutation].join('/'), msg)
|
||||
}
|
||||
if (msg.action) {
|
||||
this.store.dispatch([target, msg.action].join('/'), msg)
|
||||
}
|
||||
} else {
|
||||
// default mutation
|
||||
this.store.commit(eventName.toUpperCase(), event)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user