same/src/main/java/com/orbekk/same/MasterServiceImpl.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

package com.orbekk.same;

import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class MasterServiceImpl implements MasterService, UrlReceiver {
    private Logger logger = LoggerFactory.getLogger(getClass());
    private State state;
  
    public MasterServiceImpl(State initialState) {
        state = initialState;
    }
    
    @Override
    public synchronized void joinNetworkRequest(String networkName, String clientUrl) {
        if (networkName.equals(state.getDataOf(".networkName"))) {
            List<String> participants = state.getList(".participants");
            if (!participants.contains(clientUrl)) {
                participants.add(clientUrl);
            } else {                
                logger.warn("Client {} already part of network. " +
                        "Ignoring participation request", clientUrl);
            }
            state.updateFromObject(".participants", participants,
                    state.getRevision(".participants"));
        } else {
            logger.warn("Client {} tried to join {}, but network name is {}",
                    new Object[]{ clientUrl, networkName, 
                            state.getDataOf(".networkName") });
        }
    }

    @Override
    public boolean updateStateRequest(String component, String newData, long revision) {
        // TODO Auto-generated method stub
        return false;
    }

    @Override
    public void setUrl(String url) {
        String myUrl = url + "MasterService.json";
        logger.info("Master URL is " + myUrl);
        state.update(".masterUrl", myUrl, 0);
    }
}