WIP redux-saga/MQTT event channel

mqtt-event-channel.ts

import { eventChannel } from 'redux-saga';
import { put, take } from 'redux-saga/effects';

const createMqttChannel = mqtt => {
  return eventChannel(emitter => {
    const mqttMsgHandler = (payload: MqttMessage) => {
      recorder.mqtt(payload);
      const { event } = payload;

      switch (event) {
        case 'buttonPressed': {
          emitter(buttonRecallSlice.actions.buttonPressed(payload));
          break;
        }
        // Add more cases as needed
      }
    };

    mqtt.on('message', mqttMsgHandler);

    return () => {
      mqtt.removeListener('message', mqttMsgHandler);
    };
  });
};

function* mqttWatcher(mqtt) {
  const channel = yield call(createMqttChannel, mqtt);

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