vuetwo/vuetron

const io = require('socket.io-client');

const pathParser = (str) => {
  return str.split(/[^A-Za-z0-9]/).filter(elem => elem !== null && elem !== '').join('.');
};

const mutations = {
  // UI mutations
  toggleSidebarDisplay (state) {
    state.displaySidebar = !state.displaySidebar;
  },
  // Client State mutations
  updateClientState (state, newClientState) {
    state.clientState = newClientState;
  },
  revertClientState (state, eid) {
    const events = state.events.slice(0);
    const payload = {};
    payload.mutationLog = [];
    events.forEach((event, i) => {
      if (event.id > eid && event.title === 'STATE CHANGE') {
        event.status = 'inactive';
      } else if (event.id <= eid && !payload.initState) {
        if (event.title === 'STATE CHANGE') {
          payload.mutationLog.unshift(event.mutation);
        } else if (event.title === 'STATE INITIALIZED') {
          payload.initState = event.display;
        }
      }
    });
    state.events = events;
    let port = 9090;
    const socket = io('http://localhost:' + port);
    socket.emit('vuetronStateUpdate', payload);
  },
  mutateClientState (state, eid) {
    let events = state.events.slice(0);
    let evIdx;
    events = events.map((e, i) => {
      if (e.id === eid) {
        evIdx = i;
        e.status = 'active';
      }
      return e;
    });
    state.events = events;
    let port = 9090;
    const socket = io('http://localhost:' + port);
    socket.emit('vuetronMutateState', state.events[evIdx].mutation);
  },
  deactivateStateEvent (state, eid) {
    let events = state.events.slice(0);
    const payload = {};
    payload.mutationLog = [];
    events.forEach((event, i) => {
      if (event.id === eid) event.status = 'inactive';
      if (event.id !== eid && event.title === 'STATE CHANGE' && !payload.initState) {
        payload.mutationLog.unshift(event.mutation);
      } else if (event.id < eid && event.title === 'STATE INITIALIZED' && !payload.initState) {
        payload.initState = event.display;
      }
    });
    state.events = events;
    let port = 9090;
    const socket = io('http://localhost:' + port);
    socket.emit('vuetronStateUpdate', payload);
  },
  // Event mutations
  addNewEvent (state, newEvent) {
    if (!newEvent.title || !newEvent.display) throw new Error('invalid event data');
    if (!newEvent.show) newEvent.show = false;
    state.events.unshift(newEvent);
  },
  // Subscription mutations
  addSubscription (state, str) {
    let newSubs = Object.assign({}, state.subscriptions);
    let path = pathParser(str);
    if (!state.subscriptions.hasOwnProperty(path)) {
      newSubs[path] = [];
      state.subscriptions = newSubs;
    }
  },
  removeSubscription (state, path) {
    let subs = Object.assign({}, state.subscriptions);
    if (subs.hasOwnProperty(path)) {
      delete subs[path];
      state.subscriptions = subs;
    }
  },
  addEventToSubscription (state, info) {
    let subs = Object.assign({}, state.subscriptions);
    subs[info.key].push(info.change);
    state.subscriptions = subs;
  },
  // Component Tree mutations
  updateClientDom (state, newDom) {
    state.domTree = newDom;
  }
};

export default mutations;