socket-saga.js

function* forwardEventsToReducer(channel) {
    while (true) {
        const action = yield take(channel);
        yield put(action);
    }
}

function* watchLogins() {
    while (true) {
        let {token} = yield take(AUTH_LOGIN);
        let socket = io("/", {
            path: "/mo/v2/online/socket",
            query: {
                token
            }
        });
        const channel = eventChannel(emitter => {
            socket.on('connect', () => {
                emitter(presenceConnectedAction(socket));
            });
            socket.on('error', (error) => {
                emitter(presenceErrorAction(error));
                emitter(END);
            });
            socket.on('disconnect', () => {
                emitter(presenceDisconnectedAction());
                emitter(END);
            });
            socket.on('v1/ticket/ack', (data) => {
                emitter(presenceTicketAck());
            });
            socket.on('v1/match/assign', (data) => {
                emitter(presenceMatchAssign(data.gameId))
            });
            socket.on('v1/match/error', (error) => {
                emitter(presenceMatchError(error))
            });

            return () => {
                socket.close();
            }
        });

        yield race({
           eventloop: forwardEventsToReducer(channel),
           error: take(PRESENCE_ERROR),
           logout: take(AUTH_LOGOUT),
           verify: take(AUTH_VERIFY_REQUEST)
        });
        channel.close();
        yield put(presenceDisconnectedAction());
    }
}

function* watchTicketPost() {
    yield takeLatest(PRESENCE_TICKET_REQUEST, function*(action) {
        let state = yield select();
        let {socket} = getPresence(state);
        if (socket !== null) {
            socket.binary(false).emit(`v1/ticket/${action.verb.toLowerCase()}`);
        }
    });
}

export default function* rootPresenceSaga() {
    yield all([
        watchLogins(),
        watchTicketPost(),
    ]);
}