-
- public void applyServerConfiguration(ServerConfigurationPayload serverConfig) {
- Set<String> currentPeers = new HashSet<>(context.getPeerIds());
- for(String peerId: serverConfig.getNewServerConfig()) {
- if(!getId().equals(peerId)) {
- if(!currentPeers.contains(peerId)) {
- context.addToPeers(peerId, null, VotingState.VOTING);
- } else {
- currentPeers.remove(peerId);
- }
- }
- }
-
- for(String peerIdToRemove: currentPeers) {
- context.removePeer(peerIdToRemove);
- }
- }