/**
 * Copyright 2012 Kjetil Ørbekk <kjetil.orbekk@gmail.com>
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.orbekk.same;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;

public class MasterTest {
    private ExecutorService executor = Executors.newCachedThreadPool();
    private State state = new State();
    private TestConnectionManager connections = new TestConnectionManager();
    private Master master;
    private RpcFactory rpcf = new RpcFactory(5000);
    
    @Before
    public void setUp() {
        String masterLocation = "master:1000";
        state.update(".masterUrl", "http://master/MasterService.json", 1);
        state.update(".masterLocation", masterLocation, 1);
        master = new Master(state, connections,
                "http://master/MasterService.json", masterLocation, rpcf);
        connections.masterMap0.put("master:1000", master.getNewService());
    }

    @Test
    public void clientJoin() throws Exception {
        Client client = new Client(
                new State(), connections,
                "http://client/ClientService.json", "clientLocation", rpcf,
                executor);
        connections.clientMap0.put("clientLocation", client.getNewService());
        client.joinNetwork(master.getMasterInfo());
        master.performWork();
        System.out.println(state);
        System.out.println(master.state);
        assertTrue(state.getList(State.PARTICIPANTS)
                .contains("clientLocation"));
        assertEquals(state, client.testGetState());
    }

    @Test
    @Ignore
    public void updateStateRequest() throws Exception {
        // TODO: Implement this test.
        throw new IllegalStateException();
    }

    @Test
    @Ignore
    public void masterRemovesParticipant() throws Exception {
        // TODO: Implement this test.
        throw new IllegalStateException();
    }

}