init

.gitignore

@@ -0,0 +1,155 @@
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+# User-specific stuff:
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/dictionaries
+
+# Sensitive or high-churn files:
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.xml
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+
+# Gradle:
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# CMake
+cmake-build-debug/
+
+# Mongo Explorer plugin:
+.idea/**/mongoSettings.xml
+
+## File-based project format:
+*.iws
+
+## Plugin-specific files:
+
+# IntelliJ
+/out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+# User-specific stuff:
+*.iml
+.idea/**
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/dictionaries
+
+# Sensitive or high-churn files:
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.xml
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+
+# Gradle:
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# CMake
+cmake-build-debug/
+
+# Mongo Explorer plugin:
+.idea/**/mongoSettings.xml
+
+## File-based project format:
+*.iws
+
+## Plugin-specific files:
+
+# IntelliJ
+/out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
+                 # Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+                 # User-specific stuff:
+                 .idea/**/workspace.xml
+                 .idea/**/tasks.xml
+                 .idea/dictionaries
+
+                 # Sensitive or high-churn files:
+                 .idea/**/dataSources/
+                 .idea/**/dataSources.ids
+                 .idea/**/dataSources.xml
+                 .idea/**/dataSources.local.xml
+                 .idea/**/sqlDataSources.xml
+                 .idea/**/dynamic.xml
+                 .idea/**/uiDesigner.xml
+
+                 # Gradle:
+                 .idea/**/gradle.xml
+                 .idea/**/libraries
+
+                 # CMake
+                 cmake-build-debug/
+
+                 # Mongo Explorer plugin:
+                 .idea/**/mongoSettings.xml
+
+                 ## File-based project format:
+                 *.iws
+
+                 ## Plugin-specific files:
+
+                 # IntelliJ
+                 /out/
+
+                 # mpeltonen/sbt-idea plugin
+                 .idea_modules/
+
+                 # JIRA plugin
+                 atlassian-ide-plugin.xml
+
+                 # Cursive Clojure plugin
+                 .idea/replstate.xml
+
+                 # Crashlytics plugin (for Android Studio and IntelliJ)
+                 com_crashlytics_export_strings.xml
+                 crashlytics.properties
+                 crashlytics-build.properties
+                 fabric.properties
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+
+.project
+.classpath
+.settings
+
+
+#maven build target
+target/

pom.xml

@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.zipcoder</groupId>
+    <artifactId>server</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.12</version>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/org.easymock/easymock -->
+        <dependency>
+            <groupId>org.easymock</groupId>
+            <artifactId>easymock</artifactId>
+            <version>3.6</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+</project>

src/main/java/Main.java

@@ -0,0 +1,18 @@
+import com.zipcoder.server.Server;
+
+public class Main {
+
+    public static void main(String[] args) {
+        try {
+            int port = 5000;
+            Server server = new Server(port);
+            System.out.println("\n***** Started server on port http://localhost:5000");
+
+            server.start();
+        } catch (Exception e) {
+            System.err.println("Failed to start the server.");
+            e.printStackTrace();
+            System.exit(1);
+        }
+    }
+}

src/main/java/com/zipcoder/server/Config.java

@@ -0,0 +1,20 @@
+package com.zipcoder.server;
+
+public class Config {
+    public static final String PUBLIC_DIRECTORY = getRootDirectory();
+
+    private static String getRootDirectory() {
+        String directory = System.getProperty("resource_directory");
+        if (directory == null) {
+            directory = Config.class.getResource("/resources").getPath();
+        }
+        return directory;
+    }
+
+    public static final String LOG_PATH = "/logs";
+    public static final String LOG_USERNAME = "admin";
+    public static final String LOG_PASSWORD = "hunter2";
+
+    public static final String ENCODE = "UTF-8";
+
+}

src/main/java/com/zipcoder/server/Logger.java

@@ -0,0 +1,75 @@
+package com.zipcoder.server;
+
+import java.io.*;
+import java.net.URISyntaxException;
+
+public class Logger {
+
+    private enum Type{
+        INFO, ERROR;
+    }
+
+    public static void info(String message) {
+        log(Type.INFO, message);
+    }
+
+    public static void error(String message, Exception e) {
+        log(Type.ERROR, message);
+
+        PrintWriter writer = getWriter();
+        e.printStackTrace(writer);
+        closeWriter(writer);
+    }
+
+    private static void log(Type type, String message) {
+        Writer writer = null;
+        try {
+            writer = writeMessage(type, message);
+        } catch (IOException e) {
+            System.err.println("Unable to write message");
+            e.printStackTrace();
+        } finally {
+            closeWriter(writer);
+        }
+    }
+
+    private static Writer writeMessage(Type type, String message) throws IOException {
+        Writer writer = getWriter();
+        writer.append(type.name() + ": " + message + "\n");
+        return writer;
+    }
+
+    private static void closeWriter(Writer writer) {
+        try {
+            if (writer != null){
+                writer.close();
+            }
+        } catch (IOException e) {
+            System.err.println("Unable to close log file.");
+        }
+    }
+
+    private static PrintWriter getWriter() {
+        PrintWriter writer = null;
+        try {
+            writer = new PrintWriter(new FileWriter(getLogFile(), true));
+        } catch (Exception e) {
+            handleException(e);
+            writer = new PrintWriter(System.out);
+        }
+        return writer;
+    }
+
+    private static File getLogFile() throws URISyntaxException, IOException {
+        File file = new File(Config.PUBLIC_DIRECTORY + Config.LOG_PATH);
+        if (!file.exists()){
+            file.createNewFile();
+        }
+        return file;
+    }
+
+    private static void handleException(Exception e) {
+        System.err.println("Unable to open log file.");
+        e.printStackTrace();
+    }
+}

src/main/java/com/zipcoder/server/RequestHandler.java

@@ -0,0 +1,40 @@
+package com.zipcoder.server;
+
+import sun.jvm.hotspot.HelloWorld;
+
+import java.io.IOException;
+import java.net.Socket;
+
+public class RequestHandler {
+    private final Socket clientSocket;
+
+
+    public RequestHandler(Socket clientSocket){
+        this.clientSocket = clientSocket;
+    }
+
+    public void run() {
+        try {
+            handleRequest();
+        } catch (IOException e) {
+            Logger.error("Cannot handle request because " + e.getMessage(), e);
+        } finally {
+            closeSocket();
+        }
+    }
+
+    private void closeSocket() {
+        if (clientSocket != null){
+            try {
+                clientSocket.close();
+            } catch (IOException e) {
+                Logger.error("Cannot close socket because " + e.getMessage(), e);
+            }
+        }
+    }
+
+    private void handleRequest() throws IOException {
+        ResponseHello response = new ResponseHello(this.clientSocket.getOutputStream());
+        response.writeResponse();
+    }
+}

src/main/java/com/zipcoder/server/ResponseHello.java

@@ -0,0 +1,34 @@
+package com.zipcoder.server;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+public class ResponseHello {
+
+
+    private final OutputStream outputStream;
+
+    public ResponseHello(OutputStream outputStream){
+        this.outputStream = outputStream;
+    }
+
+    public void writeResponse() throws IOException {
+        String responseMessage = "Hello, world!";
+        StringBuilder httpResponse = new StringBuilder();
+
+        buildHeader(httpResponse, responseMessage);
+        httpResponse.append("\r\n");
+        httpResponse.append(responseMessage);
+
+        System.out.println(httpResponse.toString());
+
+        this.outputStream.write(httpResponse.toString().getBytes());
+    }
+
+
+    private void buildHeader(StringBuilder httpResponse, String responseMessage) {
+        httpResponse.append("HTTP/1.1 200 OK\n");
+        httpResponse.append("text/html\n");
+        httpResponse.append("Content-Length: " + responseMessage.length() + "\n");
+    }
+}

src/main/java/com/zipcoder/server/Server.java

@@ -0,0 +1,26 @@
+package com.zipcoder.server;
+
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class Server {
+    private ServerSocket serverSocket;
+
+    public Server(int port) throws IOException {
+        this.serverSocket = new ServerSocket(5000);
+    }
+
+    public Server(ServerSocket socket) {
+        this.serverSocket = socket;
+    }
+
+    public void start() throws IOException {
+        while(!serverSocket.isClosed()){
+            Socket clientSocket = serverSocket.accept();
+            RequestHandler handler = new RequestHandler(clientSocket);
+            handler.run();
+        }
+    }
+}

src/main/resources/file1

@@ -0,0 +1 @@
+file1 contents

src/main/resources/file2

@@ -0,0 +1 @@
+file2 contents

src/main/resources/partial_content.txt

@@ -0,0 +1 @@
+This is a file that contains text to read part of in order to fulfill a 206.

src/main/resources/text-file.txt

@@ -0,0 +1 @@
+file1 contents

src/test/java/com/zipcoder/server/RequestHandlerTest.java

@@ -0,0 +1,33 @@
+package com.zipcoder.server;
+
+import com.zipcoder.server.mocks.MockSocket;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+
+public class RequestHandlerTest {
+    private MockSocket socket;
+    private RequestHandler handler;
+
+    @Before
+    public void setUp(){
+        socket = new MockSocket();
+        handler = new RequestHandler(socket);
+    }
+
+    @Test
+    public void testRun() {
+        socket.setRequest("GET / HTTP/1.1");
+
+        handler.run();
+        Assert.assertTrue(socket.getResponse().contains("HTTP/1.1 200 OK"));
+    }
+
+    @Test
+    public void testRun_whenExceptionIsThrownSocketIsClosed() {
+        socket.setRequest("GET /nonexistence HTTP/1.1");
+
+        handler.run();
+        Assert.assertTrue(socket.isClosed());
+    }
+}

src/test/java/com/zipcoder/server/ServerTest.java

@@ -0,0 +1,41 @@
+package com.zipcoder.server;
+
+import org.easymock.EasyMock;
+import org.junit.Test;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+
+public class ServerTest {
+
+    @Test
+    public void testStart_whenSocketIsClosed() throws IOException {
+        ServerSocket serverSocket = getMockServerSocket(true);
+        EasyMock.replay(serverSocket);
+
+        Server server = new Server(serverSocket);
+        server.start();
+
+        EasyMock.verify(serverSocket);
+    }
+
+    @Test
+    public void testStart_whenSocketIsOpen() throws IOException {
+        ServerSocket serverSocket = getMockServerSocket(false, true);
+        EasyMock.expect(serverSocket.accept()).andReturn(null);
+        EasyMock.replay(serverSocket);
+
+        Server server = new Server(serverSocket);
+        server.start();
+
+        EasyMock.verify(serverSocket);
+    }
+
+    private ServerSocket getMockServerSocket(boolean... returnValues) {
+        ServerSocket serverSocket = EasyMock.createMock(ServerSocket.class);
+        for (boolean value : returnValues){
+            EasyMock.expect(serverSocket.isClosed()).andReturn(value);
+        }
+        return serverSocket;
+    }
+}

src/test/java/com/zipcoder/server/mocks/MockInputStream.java

@@ -0,0 +1,18 @@
+package com.zipcoder.server.mocks;
+
+import java.io.IOException;
+import java.io.InputStream;
+
+public class MockInputStream extends InputStream{
+
+    private String request;
+
+    public MockInputStream(String input) {
+
+    }
+
+    @Override
+    public int read() throws IOException {
+        return 0;  //To change body of implemented methods use File | Settings | File Templates.
+    }
+}

src/test/java/com/zipcoder/server/mocks/MockOutputStream.java

@@ -0,0 +1,30 @@
+package com.zipcoder.server.mocks;
+
+import java.io.IOException;
+import java.io.OutputStream;
+
+public class MockOutputStream extends OutputStream {
+    private String value = "";
+    private boolean close;
+
+    @Override
+    public void write(int i) throws IOException {
+    }
+
+    @Override
+    public void write(byte[] bytes, int off, int len) throws IOException {
+        value += (new String(bytes));
+    }
+
+    public String getValue(){
+        return value;
+    }
+
+    public void close(){
+        close = true;
+    }
+
+    public boolean isClosed(){
+        return close;
+    }
+}

src/test/java/com/zipcoder/server/mocks/MockSocket.java

@@ -0,0 +1,29 @@
+package com.zipcoder.server.mocks;
+
+import java.io.*;
+import java.net.Socket;
+
+public class MockSocket extends Socket{
+    private MockOutputStream output;
+    private InputStream input;
+
+    public MockOutputStream getOutputStream(){
+        if (output == null){
+            output = new MockOutputStream();
+        }
+        return output;
+    }
+
+    public InputStream getInputStream(){
+        return input;
+    }
+
+    public void setRequest(String request) {
+        input = new ByteArrayInputStream(request.getBytes());
+    }
+
+    public String getResponse() {
+        return output.getValue();
+    }
+
+}

src/test/resources/file1

@@ -0,0 +1 @@
+I am a test file