package alice.topology.manager.reconnection;

import java.util.List;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.DataSegment;
import alice.datasegment.Receiver;
import alice.topology.HostMessage;

public class CheckABSName extends CodeSegment{
	private Receiver abs = ids.create(CommandType.PEEK);
	private Receiver host = ids.create(CommandType.TAKE); 
	private HostMessage message;
	
	public CheckABSName(HostMessage mes) {
		message = mes;
		abs.setKey("_ABSTABLE");
		host.setKey("host");
	}

	@Override
	public void run() {
		@SuppressWarnings("unchecked")
		List<HostMessage> absList = abs.asClass(List.class);
		for (HostMessage mes : absList){
			if (mes.name.equals(message.name)&&mes.port == message.port){
				HostMessage hostInfo = host.asClass(HostMessage.class);
				DataSegment.connect(mes.getABSName(), "", hostInfo.name, hostInfo.port);
				ods.put(mes.getABSName(), "host", mes.getABSName());
				
			}
			
		}
	}

}