import SockJS from "sockjs-client";
import Stomp from "webstomp-client";
import { eventChannel } from "redux-saga";

const wsURL = "/seven-wonders-websocket";

export const createWsConnection = (headers = {}) =>
  new Promise((resolve, reject) => {
    let socket = Stomp.over(new SockJS(wsURL), {
      debug: process.env.NODE_ENV !== "production"
    });
    socket.connect(
      headers,
      frame => {
        return resolve({ frame, socket });
      },
      reject
    );
  });

export const createSubscriptionChannel = (socket, path) => {
  return eventChannel(emitter => {
    const receiveUsernameHandler = socket.subscribe(path, event => {
      emitter(JSON.parse(event.body));
    });
    return () => receiveUsernameHandler.unsubscribe();
  });
};