package christie.test.topology.paxos.proposer;


import christie.annotation.Peek;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.test.topology.paxos.Proposal;
import christie.topology.TopologyDataGear;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.util.List;

public class ProposerCodeGear extends CodeGear {

    @Peek
    TopologyDataGear topoDG;

    @Override
    protected void run(CodeGearManager cgm) {
        String nodeName = topoDG.getNodeName();
        int totalNodeNum = topoDG.getTotalNodeNum();

        int id = Character.getNumericValue(nodeName.charAt(nodeName.length() - 1)) + 1;
        cgm.setup(new SendPrepareRequestCodeGear(new Proposal(nodeName, totalNodeNum, id, id, topoDG.getConnectionList().size())));
    }
}