package com.orbekk.same; import java.util.List; import java.util.LinkedList; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class SameServiceImpl implements SameService { private Logger logger = LoggerFactory.getLogger(getClass()); private SameState sameState; public SameServiceImpl(SameState sameState) { this.sameState = sameState; } @Override public void notifyNetwork(String networkName) { logger.info("Notification from network " + networkName); } @Override public void participateNetwork(String networkName, String clientId, String url) { if (!networkName.equals(sameState.getNetworkName())) { logger.warn("Client tried to join {}, but network name is {}.", networkName, sameState.getNetworkName()); return; } if (clientId.equals("") || url.equals("")) { logger.warn("Missing client info: ClientId({}), URL({}).", clientId, url); return; } sameState.addParticipant(clientId, url); } @Override public void notifyParticipation(String networkName, List participants) { logger.info("Joining network {}.", networkName); int i = 1; for (String participant : participants) { logger.info(" {} participant {}: {}", new Object[]{networkName, i, participant}); i++; } logger.warn("Joining not implemented."); } }