package codeine.nodes;

import java.util.List;
import java.util.Map;

import javax.inject.Inject;

import org.apache.log4j.Logger;

import codeine.api.NodeInfo;
import codeine.configuration.PathHelper;
import codeine.jsons.nodes.NodeListJson;
import codeine.jsons.nodes.NodesManager;
import codeine.jsons.project.ProjectJson;
import codeine.utils.FilesUtils;
import codeine.utils.network.InetUtils;

import com.google.common.collect.Maps;

public class NodesManagerPeer implements NodesManager {

	private static final Logger log = Logger.getLogger(NodesManagerPeer.class);

	@Inject
	private NodeScriptDiscovery nodeScriptDiscovery;

	private Map<String, NodeListJson> projectToNode = Maps.newConcurrentMap();
	@Inject
	private PathHelper pathHelper;
	
	@Override
	public NodeListJson nodesOf(ProjectJson projectJson){
		NodeListJson nodeListJson = projectToNode.get(projectJson.name());
		if (null == nodeListJson){
			return new NodeListJson();
		}
		return nodeListJson;
	}
	@Override
	public void init(ProjectJson projectJson){
		log.info("init NodesManagerPeer nodes in peer for project " + projectJson.name());
		String dir = pathHelper.getProjectDir(projectJson.name());
		FilesUtils.mkdirs(dir);
		switch (projectJson.node_discovery_startegy()) {
		case Configuration: {
			List<NodeInfo> nodes = projectJson.nodes_info();
			NodeListJson nodes2 = new NodeListJson();
			for (NodeInfo nodeJson : nodes) {
				if (InetUtils.nameWithoutPort(nodeJson.name()).equals(InetUtils.getLocalHost().getHostName())){
					nodes2.add(nodeJson);
				}
			}
			projectToNode.put(projectJson.name(), nodes2);
			break;
		}
		case Script: {
			projectToNode.put(projectJson.name(), nodeScriptDiscovery.get(projectJson));
			break;
		}
		case Reporter: {
			//this is ok
			break;
		}
		default:
			throw new UnsupportedOperationException("for value " + projectJson.node_discovery_startegy());
		}
	}

}

package codeine.nodes;

import java.util.List;
import java.util.Map;

import javax.inject.Inject;

import org.apache.log4j.Logger;

import codeine.api.NodeInfo;
import codeine.configuration.PathHelper;
import codeine.jsons.nodes.NodeListJson;
import codeine.jsons.nodes.NodesManager;
import codeine.jsons.project.ProjectJson;
import codeine.utils.FilesUtils;
import codeine.utils.network.InetUtils;

import com.google.common.collect.Maps;

public class NodesManagerPeer implements NodesManager {

	private static final Logger log = Logger.getLogger(NodesManagerPeer.class);

	@Inject
	private NodeScriptDiscovery nodeScriptDiscovery;

	private Map<String, NodeListJson> projectToNode = Maps.newConcurrentMap();
	@Inject
	private PathHelper pathHelper;
	
	@Override
	public NodeListJson nodesOf(ProjectJson projectJson){
		NodeListJson nodeListJson = projectToNode.get(projectJson.name());
		if (null == nodeListJson){
			return new NodeListJson();
		}
		return nodeListJson;
	}
	@Override
	public void init(ProjectJson projectJson){
		log.info("init NodesManagerPeer nodes in peer for project " + projectJson.name());
		String dir = pathHelper.getProjectDir(projectJson.name());
		FilesUtils.mkdirs(dir);
		switch (projectJson.node_discovery_startegy()) {
		case Configuration: {
			List<NodeInfo> nodes = projectJson.nodes_info();
			NodeListJson nodes2 = new NodeListJson();
			for (NodeInfo nodeJson : nodes) {
				if (InetUtils.nameWithoutPort(nodeJson.name()).equalsIgnoreCase(InetUtils.getLocalHost().getHostName())){
					nodes2.add(nodeJson);
				}
			}
			projectToNode.put(projectJson.name(), nodes2);
			break;
		}
		case Script: {
			projectToNode.put(projectJson.name(), nodeScriptDiscovery.get(projectJson));
			break;
		}
		case Reporter: {
			//this is ok
			break;
		}
		default:
			throw new UnsupportedOperationException("for value " + projectJson.node_discovery_startegy());
		}
	}

}

fix for windows