forks/Vue-Socket.io
1
0
Fork 0
mirror of https://github.com/MetinSeylan/Vue-Socket.io.git synced 2025-04-16 15:21:28 +02:00
Code Issues Projects Releases Packages Wiki Activity

Fix multiple namespaces implementation

Browse source
This commit is contained in:
Mohit Singh 2020-06-16 18:44:22 +05:30
parent 640dfc044c
commit 7dc5367cdc
3 changed files with 26 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
dist/vue-socketio.js vendored
View file

File diff suppressed because one or more lines are too long

7
src/index.js
View file

@ -33,6 +33,13 @@ export default class VueSocketIO {
const namespace = this.namespaceName || this.io.nsp.replace("/", ""); const namespace = this.namespaceName || this.io.nsp.replace("/", "");
if (this.useConnectionNamespace) { if (this.useConnectionNamespace) {
// update list of namespaces
if (Array.isArray(Vue.prototype.VueSocketIONamepaces)) {
Vue.prototype.VueSocketIONamepaces.push(namespace);
} else {
Vue.prototype.VueSocketIONamepaces = [namespace];
}
if (typeof Vue.prototype.$socket === "object") { if (typeof Vue.prototype.$socket === "object") {
Vue.prototype.$socket = { Vue.prototype.$socket = {
...Vue.prototype.$socket, ...Vue.prototype.$socket,

25
src/mixin.js
View file

@ -7,8 +7,8 @@ export default {
if(!this.sockets) this.sockets = {}; if(!this.sockets) this.sockets = {};
if (typeof this.$vueSocketIo === 'object') { if (this.VueSocketIONamespaces && this.VueSocketIONamespaces.length) {
for (const namespace of Object.keys(this.$vueSocketIo)) { for (const namespace of this.VueSocketIONamespaces) {
this.sockets[namespace] = { this.sockets[namespace] = {
subscribe: (event, callback) => { subscribe: (event, callback) => {
this.$vueSocketIo[namespace].emitter.addListener(event, callback, this); this.$vueSocketIo[namespace].emitter.addListener(event, callback, this);
@ -19,8 +19,14 @@ export default {
} }
} }
} else { } else {
this.$vueSocketIo.emitter.addListener(event, callback, this); this.sockets = {
this.$vueSocketIo.emitter.removeListener(event, this); subscribe: (event, callback) => {
this.$vueSocketIo.emitter.addListener(event, callback, this);
},
unsubscribe: (event) => {
this.$vueSocketIo.emitter.removeListener(event, this);
}
};
} }
}, },
@ -31,8 +37,8 @@ export default {
if(this.$options.sockets){ if(this.$options.sockets){
if (typeof this.$vueSocketIo === 'object') { if ( this.VueSocketIONamespaces && this.VueSocketIONamespaces.length ) {
for (const namespace of Object.keys(this.$vueSocketIo)) { for (const namespace of this.VueSocketIONamespaces) {
if (this.$options.sockets[namespace]) { if (this.$options.sockets[namespace]) {
Object.keys(this.$options.sockets[namespace]).forEach(event => { Object.keys(this.$options.sockets[namespace]).forEach(event => {
@ -62,9 +68,8 @@ export default {
beforeDestroy(){ beforeDestroy(){
if(this.$options.sockets){ if(this.$options.sockets){
if (this.VueSocketIONamespaces && this.VueSocketIONamespaces.length) {
if (typeof this.$vueSocketIo === 'object') { for (const namespace of this.VueSocketIONamespaces) {
for (const namespace of Object.keys(this.$vueSocketIo)) {
if (this.$options.sockets[namespace]) { if (this.$options.sockets[namespace]) {
Object.keys(this.$options.sockets[namespace]).forEach(event => { Object.keys(this.$options.sockets[namespace]).forEach(event => {
@ -85,4 +90,4 @@ export default {
} }
} }