package topology.manager;

import java.io.IOException;
import java.util.HashMap;
import java.util.LinkedList;

import org.apache.log4j.Logger;
import org.msgpack.MessagePack;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.DataSegmentReceiver;
import alice.topology.HostMessage;

public class IncomingHosts extends CodeSegment {
	
	HashMap<String, NodeInfo> topology;
	LinkedList<String> nodeNames;
	DataSegmentReceiver host = new DataSegmentReceiver(ids, CommandType.TAKE);
	Logger logger = Logger.getLogger(IncomingHosts.class);
	
	public IncomingHosts(HashMap<String, NodeInfo> topology, LinkedList<String> nodeNames) {
		this.topology = topology;
		this.nodeNames = nodeNames;
	}

	@Override
	public void run() {
		MessagePack msgpack = new MessagePack();
		try {
			HostMessage host = msgpack.convert(this.host.val, HostMessage.class);
			String nodeName = nodeNames.poll();
			
			// TODO: send nodeName to node
			
		} catch (IOException e) {
			logger.error("HostMessage format error");
			e.printStackTrace();
		}
		
		if (!nodeNames.isEmpty()) {
			IncomingHosts cs = new IncomingHosts(topology, nodeNames);
			cs.host.setKey("local", "host");
		}

	}

}