package org.mikeneck.multithreads;

import org.junit.*;
import org.junit.experimental.runners.Enclosed;
import org.junit.rules.TestName;
import org.junit.runner.RunWith;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.*;

import static org.hamcrest.Matchers.is;
import static org.junit.Assert.assertThat;

/**
 * @author mike
 */
@RunWith(Enclosed.class)
public class SimpleSocketTest {

    public static class SingleClient {

        private static final ExecutorService SERVICE = Executors.newFixedThreadPool(1);

        private static final int PORT = 12521;

        private static final String LOCALHOST = "localhost";

        private SimpleClient client;

        @Rule
        public TestName testName = new TestName();

        @BeforeClass
        public static void start () throws IOException {
            SERVICE.execute(new SimpleServer(PORT));
        }

        @Before
        public void setup () throws IOException {
            client = new SimpleClient(LOCALHOST, PORT);
        }

        @After
        public void tearDown () throws Exception {
            System.out.println(testName.getMethodName() + " is closing");
            client.close();
        }

        @AfterClass
        public static void end () throws IOException {
            new SimpleClient(LOCALHOST, PORT).open().bye();
        }

        @Test
        public void socketProcessing () throws IOException {
            client.open();
            String message = client.sendMessage("Hello");
            System.out.println("Message from Server [" + message + "]");
            assertThat(message, is("Hello"));
            System.out.println("Assertion ends.");
        }
    }
}

apply plugin : 'groovy'
apply plugin : 'idea'

group = 'org.mikeneck.multithreads'
version = '1.0'

def compatibility = 1.7

sourceCompatibility = compatibility
targetCompatibility = compatibility

repositories {
  mavenCentral ()
}

dependencies {
  compile 'org.codehaus.groovy:groovy-all:2.1.3'
  testCompile ('junit:junit:4.11') {
      exclude module : 'hamcrest-core'
      exclude module : 'hamcrest'
  }
  testCompile 'org.hamcrest:hamcrest-library:1.+'
}

test {
    exclude '**/*$*'
}