You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
130 lines
3.1 KiB
JavaScript
130 lines
3.1 KiB
JavaScript
import Logger from './logger';
|
|
|
|
export default class EventEmitter{
|
|
|
|
constructor(vuex = {}){
|
|
Logger.info(vuex ? `Vuex adapter enabled` : `Vuex adapter disabled`);
|
|
Logger.info(vuex.mutationPrefix ? `Vuex socket mutations enabled` : `Vuex socket mutations disabled`);
|
|
Logger.info(vuex ? `Vuex socket actions enabled` : `Vuex socket actions disabled`);
|
|
this.store = vuex.store;
|
|
this.actionPrefix = vuex.actionPrefix ? vuex.actionPrefix : 'SOCKET_';
|
|
this.mutationPrefix = vuex.mutationPrefix;
|
|
this.listeners = new Map();
|
|
}
|
|
|
|
/**
|
|
* register new event listener with vuejs component instance
|
|
* @param event
|
|
* @param callback
|
|
* @param component
|
|
*/
|
|
addListener(event, callback, component){
|
|
|
|
if(typeof callback === 'function'){
|
|
|
|
if (!this.listeners.has(event)) this.listeners.set(event, []);
|
|
this.listeners.get(event).push({ callback, component });
|
|
|
|
Logger.info(`#${event} subscribe, component: ${component.$options.name}`);
|
|
|
|
} else {
|
|
|
|
throw new Error(`callback must be a function`);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* remove a listenler
|
|
* @param event
|
|
* @param component
|
|
*/
|
|
removeListener(event, component){
|
|
|
|
if(this.listeners.has(event)){
|
|
|
|
const listeners = this.listeners.get(event).filter(listener => (
|
|
listener.component !== component
|
|
));
|
|
|
|
if (listeners.length > 0) {
|
|
this.listeners.set(event, listeners);
|
|
} else {
|
|
this.listeners.delete(event);
|
|
}
|
|
|
|
Logger.info(`#${event} unsubscribe, component: ${component.$options.name}`);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
/**
|
|
* broadcast incoming event to components
|
|
* @param event
|
|
* @param args
|
|
*/
|
|
emit(event, args){
|
|
|
|
if(this.listeners.has(event)){
|
|
|
|
Logger.info(`Broadcasting: #${event}, Data:`, args);
|
|
|
|
this.listeners.get(event).forEach((listener) => {
|
|
listener.callback.call(listener.component, args);
|
|
});
|
|
|
|
}
|
|
|
|
this.dispatchStore(event, args);
|
|
|
|
}
|
|
|
|
|
|
/**
|
|
* dispatching vuex actions
|
|
* @param event
|
|
* @param args
|
|
*/
|
|
dispatchStore(event, args){
|
|
|
|
if(this.store && this.store._actions){
|
|
|
|
for (let key in this.store._actions) {
|
|
|
|
let action = key.split('/').pop();
|
|
|
|
if(action === this.actionPrefix+event) {
|
|
|
|
Logger.info(`Dispatching Action: ${action}, Data:`, args);
|
|
|
|
this.store.dispatch(action, args);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if(this.mutationPrefix) {
|
|
|
|
for (let key in this.store._mutations) {
|
|
|
|
let mutation = key.split('/').pop();
|
|
|
|
if(mutation === this.mutationPrefix+event) {
|
|
|
|
Logger.info(`Commiting Mutation: ${mutation}, Data:`, args);
|
|
|
|
this.store.commit(mutation, args);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} |