import { EthAddress } from "@joincivil/typescript-types";
import { Dispatch } from "react-redux";
import { Subscription } from "rxjs";
import { updateUserTokenBalance, updateUserVotingBalance } from "../redux/actionCreators/userAccount";
import { CivilHelper } from "../apis/CivilHelper";

let tokenBalanceSubscriptions: Subscription;
let votingBalanceSubscriptions: Subscription;
export async function initializeTokenSubscriptions(
  helper: CivilHelper,
  dispatch: Dispatch<any>,
  user: EthAddress,
): Promise<void> {
  if (tokenBalanceSubscriptions) {
    tokenBalanceSubscriptions.unsubscribe();
  }
  if (votingBalanceSubscriptions) {
    votingBalanceSubscriptions.unsubscribe();
  }

  const tcr = await helper.getTCR();
  const token = await tcr.getToken();
  tokenBalanceSubscriptions = token.balanceUpdate("latest", user).subscribe(balance => {
    dispatch(updateUserTokenBalance(user, balance));
  });

  votingBalanceSubscriptions = tcr
    .getVoting()
    .balanceUpdate("latest", user)
    .subscribe(balance => {
      dispatch(updateUserVotingBalance(user, balance));
    });
}