package alice.topology.node;

import java.util.List;

import alice.codesegment.CloseEventCodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.DataSegment;
import alice.datasegment.Receiver;
import alice.topology.manager.keeparive.ListManager;

public class DeleteConnection extends CloseEventCodeSegment {

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

    public DeleteConnection() {
        info.setKey("_CLIST");
        info1.setKey("_SCHEDULER");
    }

    @Override
    public void run() {
        String name = getConnectionInfo().nodeName;
        @SuppressWarnings("unchecked")
        List<String> list = info.asClass(List.class);

        if (list.contains(name))
            list.remove(name);
        if (DataSegment.contains(name)) {
            DataSegment.get(name).shutdown();
            DataSegment.remove(name);
        }
        ListManager manager = info1.asClass(ListManager.class);
        manager.deleteAll(name);
        ods.update(info.key, list);
        ods.update(info1.key, manager);
    }

}