import Client from "../modules/client";
import connections from "./connections";
import localDiscovery from "./localDiscovery";
import logger from "../modules/logger";
import dht from "./dht";
import * as Types from "../types";
import storage from "./storage";
import state from "./state";
import args from "../modules/arguments";

const client = new Client({ connections, state, storage });

localDiscovery.on("candidate", (data: Types.Discovery.Candidate) => {
  const { type, user_id, node_id, local_ipv4 } = data;
  logger.log("client", "Local discovery candidate", data.local_ipv4); // edit
  if (type && type == "dogma-router" && user_id && node_id) {
    logger.log("nodes", "trying to connect local service", local_ipv4);
    const peer = connections.peerFromIP(local_ipv4);
    client.tryPeer(peer, { user_id, node_id });
  }
});
dht.on("peers", (data: Types.DHT.LookUp.Answer.Data[]) => {
  data.forEach((item) => {
    const { public_ipv4, user_id, node_id } = item;
    const peer = connections.peerFromIP(public_ipv4);
    client.tryPeer(peer, { user_id, node_id });
  });
});

let connectFriendsInterval: NodeJS.Timer | undefined;
let searchFriendsInterval: NodeJS.Timer | undefined;

/**
 * @todo deprecated CHECK!!!
 */
state.subscribe([Types.Event.Type.updateUser, Types.Event.Type.users], () => {
  const user_id = state.state[Types.Event.Type.updateUser];
  connections.closeConnectionsByUserId(user_id);
});

state.subscribe(
  [Types.Event.Type.nodes, Types.Event.Type.users, Types.Event.Type.nodeKey],
  () => {
    // eventEmitter.emit("friends", true);
    if (args.discovery) return; // don't lookup in discovery mode
    clearInterval(connectFriendsInterval);
    client.connectFriends(); // check
    connectFriendsInterval = setInterval(() => client.connectFriends(), 60000); // edit
  }
);

state.subscribe(
  [
    Types.Event.Type.configDhtLookup,
    Types.Event.Type.users,
    Types.Event.Type.nodeKey,
  ],
  ([configDhtLookup]) => {
    // edit
    if (args.discovery) return; // don't lookup in discovery mode
    clearInterval(searchFriendsInterval);
    if (configDhtLookup) {
      client.searchFriends(); // check
      searchFriendsInterval = setInterval(() => client.searchFriends(), 30000); // edit
    }
  }
);

export default client;