Iris/src/js/services/pusher/reducer.js

export default function reducer(pusher = {}, action){
    switch (action.type){

        case 'PUSHER_CONNECT':
        case 'PUSHER_CONNECTING':
            return Object.assign({}, pusher, { connected: false, connecting: true });

        case 'PUSHER_CONNECTED':
            return Object.assign({}, pusher, {
                connected: true,
                connecting: false,
                connection_id: action.connection_id,
                client_id: action.client_id,
                username: action.username
            });

        case 'PUSHER_DISCONNECTED':
            return Object.assign({}, pusher, { connected: false, connecting: false });

        case 'PUSHER_SET_PORT':
            return Object.assign({}, pusher, { port: action.port });

        case 'PUSHER_USERNAME_CHANGED':
            return Object.assign({}, pusher, { username: action.username });

        case 'PUSHER_CONNECTIONS':
            var connections = {}
            for (var i = 0; i < action.connections.length; i++){
                connections[action.connections[i].connection_id] = action.connections[i]
            }
            return Object.assign({}, pusher, { connections: connections });

        case 'PUSHER_CONNECTION_ADDED':
        case 'PUSHER_CONNECTION_CHANGED':
            var connections = Object.assign({}, pusher.connections)
            connections[action.connection.connection_id] = action.connection;
            return Object.assign({}, pusher, { connections: connections });

        case 'PUSHER_CONNECTION_REMOVED':
            var connections = Object.assign({}, pusher.connections)
            delete connections[action.connection.connection_id]
            return Object.assign({}, pusher, { connections: connections });

        case 'PUSHER_VERSION':
            return Object.assign({}, pusher, { 
                version: action.version,
                upgrading: false
            });

        case 'PUSHER_START_UPGRADE':
            return Object.assign({}, pusher, { upgrading: true });

        case 'PUSHER_CONFIG':
            return Object.assign({}, pusher, { config: action.config });

        case 'PUSHER_SNAPCAST':
            return Object.assign({}, pusher, { 
                snapcast_streams: action.snapcast_streams,
                snapcast_groups: action.snapcast_groups,
                snapcast_clients: action.snapcast_clients
            });

        case 'PUSHER_SNAPCAST_GROUP_UPDATED':
            var snapcast_groups = Object.assign({}, pusher.snapcast_groups);
            var group = snapcast_groups[action.key];
            snapcast_groups[action.key] = Object.assign({}, group, action.group);
            return Object.assign({}, pusher, { snapcast_groups: snapcast_groups });

        case 'PUSHER_SNAPCAST_CLIENT_UPDATED':
            var snapcast_clients = Object.assign({}, pusher.snapcast_clients);
            var client = snapcast_clients[action.key];
            client.config = Object.assign({}, client.config, action.client.config);
            snapcast_clients[action.key] = client;
            return Object.assign({}, pusher, { snapcast_clients: snapcast_clients });

        case 'PUSHER_SNAPCAST_CLIENT_REMOVED':
            var snapcast_clients = Object.assign({}, pusher.snapcast_clients);
            delete snapcast_clients[action.key];
            return Object.assign({}, pusher, { snapcast_clients: snapcast_clients });

        default:
            return pusher
    }
}