package alice.topology.manager;

import java.util.HashMap;
import java.util.LinkedList;

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

public class RecodeTopology extends CodeSegment {

    private Receiver info = ids.create(CommandType.TAKE);  // NodeInfo
    private Receiver info1 = ids.create(CommandType.TAKE); // HashMap 

    public RecodeTopology(){
        info.setKey("nodeInfo");
        info1.setKey("topology");
    }

    @Override
    public void run() {
        HostMessage hostInfo = info.asClass(HostMessage.class);
        @SuppressWarnings("unchecked")
        HashMap<String, LinkedList<HostMessage>> topology = info1.asClass(HashMap.class);
        LinkedList<HostMessage> connections;        
        if (!topology.containsKey(hostInfo.parentAbsName)) {
            connections = new LinkedList<HostMessage>();
        } else {
            connections = topology.get(hostInfo.parentAbsName);
        }
        connections.add(hostInfo);
        topology.put(hostInfo.parentAbsName, connections);
        ods.update(info1.key, topology);
        
        for (LinkedList<HostMessage> list :topology.values()){
            for (HostMessage host : list){
                System.out.println(host.parentAbsName+" : "+host.name+" "+host.port+" "+host.connectionName+" "+host.reverseName);
            }
        }
    }

}