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 java.util.List;

public class ProposerCodeGear extends CodeGear {

    @Peek
    TopologyDataGear topoDG;

    @Override
    protected void run(CodeGearManager cgm) {
        String nodeName = topoDG.getNodeName();
        int proposerNum = topoDG.getTotalNodeNum();
        List<String> _CLIST = topoDG.getConnectionList();
        cgm.setup(new SendPrepareRequestCodeGear());
        put("promiseCount", 0);
        int id = Character.getNumericValue(nodeName.charAt(nodeName.length() - 1));
        put("sendProposal", new Proposal(nodeName, proposerNum, id, id, _CLIST.size()));
    }
}