pull/125/head
lastmirage 6 years ago
parent ec192d89b9
commit ffbf48ee28

@ -4,9 +4,9 @@ export default new class {
} }
addListener(label, callback, vm) { addListener(label, callback, vm) {
if(typeof callback == 'function'){ if (typeof callback == 'function') {
this.listeners.has(label) || this.listeners.set(label, []); this.listeners.has(label) || this.listeners.set(label, []);
this.listeners.get(label).push({callback: callback, vm: vm}); this.listeners.get(label).push({ callback: callback, vm: vm });
return true return true
} }
@ -39,7 +39,7 @@ export default new class {
if (listeners && listeners.length) { if (listeners && listeners.length) {
listeners.forEach((listener) => { listeners.forEach((listener) => {
listener.callback.call(listener.vm,...args) listener.callback.call(listener.vm, ...args)
}); });
return true; return true;
} }

@ -3,16 +3,16 @@ import Emitter from './Emitter'
export default { export default {
install(Vue, connection, store){ install(Vue, connection, store) {
if(!connection) throw new Error("[Vue-Socket.io] cannot locate connection") if (!connection) throw new Error("[Vue-Socket.io] cannot locate connection")
let observer = new Observer(connection, store) let observer = new Observer(connection, store)
Vue.prototype.$socket = observer.Socket; Vue.prototype.$socket = observer.Socket;
Vue.mixin({ Vue.mixin({
created(){ created() {
let sockets = this.$options['sockets'] let sockets = this.$options['sockets']
this.$options.sockets = new Proxy({}, { this.$options.sockets = new Proxy({}, {
@ -28,16 +28,16 @@ export default {
} }
}) })
if(sockets){ if (sockets) {
Object.keys(sockets).forEach((key) => { Object.keys(sockets).forEach((key) => {
this.$options.sockets[key] = sockets[key]; this.$options.sockets[key] = sockets[key];
}); });
} }
}, },
beforeDestroy(){ beforeDestroy() {
let sockets = this.$options['sockets'] let sockets = this.$options['sockets']
if(sockets){ if (sockets) {
Object.keys(sockets).forEach((key) => { Object.keys(sockets).forEach((key) => {
delete this.$options.sockets[key] delete this.$options.sockets[key]
}); });

@ -1,30 +1,30 @@
import Emitter from './Emitter' import Emitter from './Emitter'
import Socket from 'socket.io-client' import Socket from 'socket.io-client'
export default class{ export default class {
constructor(connection, store) { constructor(connection, store) {
if(typeof connection == 'string'){ if (typeof connection == 'string') {
this.Socket = Socket(connection); this.Socket = Socket(connection);
}else{ } else {
this.Socket = connection this.Socket = connection
} }
if(store) this.store = store; if (store) this.store = store;
this.onEvent() this.onEvent()
} }
onEvent(){ onEvent() {
var super_onevent = this.Socket.onevent; var super_onevent = this.Socket.onevent;
this.Socket.onevent = (packet) => { this.Socket.onevent = (packet) => {
super_onevent.call(this.Socket, packet); super_onevent.call(this.Socket, packet);
Emitter.emit.apply(Emitter, packet.data); Emitter.emit.apply(Emitter, packet.data);
if(this.store) this.passToStore('SOCKET_'+packet.data[0], [ ...packet.data.slice(1)]) if (this.store) this.passToStore('SOCKET_' + packet.data[0], [...packet.data.slice(1)])
}; };
let _this = this; let _this = this;
@ -33,30 +33,30 @@ export default class{
.forEach((value) => { .forEach((value) => {
_this.Socket.on(value, (data) => { _this.Socket.on(value, (data) => {
Emitter.emit(value, data); Emitter.emit(value, data);
if(_this.store) _this.passToStore('SOCKET_'+value, data) if (_this.store) _this.passToStore('SOCKET_' + value, data)
}) })
}) })
} }
passToStore(event, payload){ passToStore(event, payload) {
if(!event.startsWith('SOCKET_')) return if (!event.startsWith('SOCKET_')) return
for(let namespaced in this.store._mutations) { for (let namespaced in this.store._mutations) {
let mutation = namespaced.split('/').pop() let mutation = namespaced.split('/').pop()
if(mutation === event.toUpperCase()) this.store.commit(namespaced, payload) if (mutation === event.toUpperCase()) this.store.commit(namespaced, payload)
} }
for(let namespaced in this.store._actions) { for (let namespaced in this.store._actions) {
let action = namespaced.split('/').pop() let action = namespaced.split('/').pop()
if(!action.startsWith('socket_')) continue if (!action.startsWith('socket_')) continue
let camelcased = 'socket_'+event.toLowerCase() let camelcased = 'socket_' + event.toLowerCase()
.replace('SOCKET_', '') .replace('SOCKET_', '')
.replace(/[\W\s_]+(\w)/g, (match, p1) => p1.toUpperCase()) .replace(/[\W\s_]+(\w)/g, (match, p1) => p1.toUpperCase())
if(action === camelcased) this.store.dispatch(namespaced, payload) if (action === camelcased) this.store.dispatch(namespaced, payload)
} }
} }
} }

Loading…
Cancel
Save