chess/assets/js/services/channel.js

import socket from "../socket";
import { setPlayer, setOpponent, setGame, setAvailableMoves } from "../store/actions";

class Channel {
  constructor(store, gameId) {
    this.store = store;
    this.channel = socket.channel(`game:${gameId}`, {});

    this.join();
    this.subscribe();
  }

  join() {
    this.channel.join()
      .receive("error", resp => {
        console.log("Unable to join", resp);
      });
  }

  subscribe() {
    this.channel.on("game:update", data => {
      if (data.player != undefined) {
        this.store.dispatch(setPlayer(data.player));
        this.store.dispatch(setOpponent(data.opponent));
      }
      this.store.dispatch(setGame(data));
    });
  }

  getAvailableMoves(square) {
    this.channel.push("game:get_available_moves", { square })
      .receive("ok", (data) => {
        this.store.dispatch(setAvailableMoves(data.moves));
      });
  }

  sendMove(move) {
    this.channel.push("game:move", move)
      .receive("error", resp => {
        alert(resp.message);
      });
  }
}

export default Channel;