Sprint 9 solution http api

java-kanban.iml

@@ -1,28 +1,9 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <module type="JAVA_MODULE" version="4">
-  <component name="NewModuleRootManager" inherit-compiler-output="true">
-    <exclude-output />
-    <content url="file://$MODULE_DIR$">
+  <component name="AdditionalModuleElements">
+    <content url="file://$MODULE_DIR$" dumb="true">
       <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
       <sourceFolder url="file://$MODULE_DIR$/test" isTestSource="true" />
     </content>
-    <orderEntry type="inheritedJdk" />
-    <orderEntry type="sourceFolder" forTests="false" />
-    <orderEntry type="module-library" scope="TEST">
-      <library name="JUnit5.8.1">
-        <CLASSES>
-          <root url="jar://$MODULE_DIR$/lib/junit-jupiter-5.8.1.jar!/" />
-          <root url="jar://$MODULE_DIR$/lib/junit-jupiter-api-5.8.1.jar!/" />
-          <root url="jar://$MODULE_DIR$/lib/opentest4j-1.2.0.jar!/" />
-          <root url="jar://$MODULE_DIR$/lib/junit-platform-commons-1.8.1.jar!/" />
-          <root url="jar://$MODULE_DIR$/lib/apiguardian-api-1.1.2.jar!/" />
-          <root url="jar://$MODULE_DIR$/lib/junit-jupiter-params-5.8.1.jar!/" />
-          <root url="jar://$MODULE_DIR$/lib/junit-jupiter-engine-5.8.1.jar!/" />
-          <root url="jar://$MODULE_DIR$/lib/junit-platform-engine-1.8.1.jar!/" />
-        </CLASSES>
-        <JAVADOC />
-        <SOURCES />
-      </library>
-    </orderEntry>
   </component>
 </module>

pom.xml

@@ -0,0 +1,50 @@
+<?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>ru.yandex.practicum</groupId>
+    <artifactId>java-kanban</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>11</maven.compiler.source>
+        <maven.compiler.target>11</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.10.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <version>5.9.2</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.11.0</version>
+                <configuration>
+                    <source>11</source>
+                    <target>11</target>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <version>3.0.0</version>
+            </plugin>
+        </plugins>
+    </build>
+</project>

src/http/BaseHttpHandler.java

@@ -0,0 +1,62 @@
+package http;
+
+import com.sun.net.httpserver.HttpExchange;
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+
+public class BaseHttpHandler {
+
+    protected void sendText(HttpExchange exchange, String text) throws IOException {
+        byte[] response = text.getBytes(StandardCharsets.UTF_8);
+        exchange.getResponseHeaders().add("Content-Type", "application/json;charset=utf-8");
+        exchange.sendResponseHeaders(200, response.length);
+        exchange.getResponseBody().write(response);
+        exchange.close();
+    }
+
+    protected void sendSuccess(HttpExchange exchange) throws IOException {
+        exchange.getResponseHeaders().add("Content-Type", "application/json;charset=utf-8");
+        exchange.sendResponseHeaders(201, -1);
+        exchange.close();
+    }
+
+    protected void sendNotFound(HttpExchange exchange) throws IOException {
+        String response = String.format("{\"error\": \"%s\"}", "Объект не найден");
+        byte[] bytes = response.getBytes(StandardCharsets.UTF_8);
+        exchange.getResponseHeaders().add("Content-Type", "application/json;charset=utf-8");
+        exchange.sendResponseHeaders(404, bytes.length);
+        exchange.getResponseBody().write(bytes);
+        exchange.close();
+    }
+
+    protected void sendHasInteractions(HttpExchange exchange) throws IOException {
+        String response = String.format("{\"error\": \"%s\"}", "Задача пересекается с существующими");
+        byte[] bytes = response.getBytes(StandardCharsets.UTF_8);
+        exchange.getResponseHeaders().add("Content-Type", "application/json;charset=utf-8");
+        exchange.sendResponseHeaders(406, bytes.length);
+        exchange.getResponseBody().write(bytes);
+        exchange.close();
+    }
+
+    protected void sendInternalError(HttpExchange exchange) throws IOException {
+        String response = String.format("{\"error\": \"%s\"}", "Внутренняя ошибка сервера");
+        byte[] bytes = response.getBytes(StandardCharsets.UTF_8);
+        exchange.getResponseHeaders().add("Content-Type", "application/json;charset=utf-8");
+        exchange.sendResponseHeaders(500, bytes.length);
+        exchange.getResponseBody().write(bytes);
+        exchange.close();
+    }
+
+    protected void sendBadRequest(HttpExchange exchange, String message) throws IOException {
+        String response = String.format("{\"error\": \"%s\"}", message);
+        byte[] bytes = response.getBytes(StandardCharsets.UTF_8);
+        exchange.getResponseHeaders().add("Content-Type", "application/json;charset=utf-8");
+        exchange.sendResponseHeaders(400, bytes.length);
+        exchange.getResponseBody().write(bytes);
+        exchange.close();
+    }
+
+    protected String readRequestBody(HttpExchange exchange) throws IOException {
+        return new String(exchange.getRequestBody().readAllBytes(), StandardCharsets.UTF_8);
+    }
+}

src/http/EpicsHandler.java

@@ -0,0 +1,116 @@
+package http;
+
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import manager.TaskManager;
+import model.Epic;
+import model.Subtask;
+import java.io.IOException;
+import java.util.List;
+
+public class EpicsHandler extends BaseHttpHandler implements HttpHandler {
+    private final TaskManager taskManager;
+
+    public EpicsHandler(TaskManager taskManager) {
+        this.taskManager = taskManager;
+    }
+
+    @Override
+    public void handle(HttpExchange exchange) throws IOException {
+        try {
+            String method = exchange.getRequestMethod();
+            String path = exchange.getRequestURI().getPath();
+
+            switch (method) {
+                case "GET":
+                    handleGet(exchange, path);
+                    break;
+                case "POST":
+                    handlePost(exchange);
+                    break;
+                case "DELETE":
+                    handleDelete(exchange, path);
+                    break;
+                default:
+                    sendBadRequest(exchange, "Метод не поддерживается");
+            }
+        } catch (Exception e) {
+            sendInternalError(exchange);
+        }
+    }
+
+    private void handleGet(HttpExchange exchange, String path) throws IOException {
+        if (path.equals("/epics")) {
+            List<Epic> epics = taskManager.getAllEpics();
+            String response = JsonConverter.epicsToJson(epics);
+            sendText(exchange, response);
+        } else if (path.matches("/epics/\\d+")) {
+            String[] pathParts = path.split("/");
+            int id = Integer.parseInt(pathParts[2]);
+
+            Epic epic = taskManager.getEpicById(id);
+            if (epic != null) {
+                String response = JsonConverter.epicToJson(epic);
+                sendText(exchange, response);
+            } else {
+                sendNotFound(exchange);
+            }
+        } else if (path.matches("/epics/\\d+/subtasks")) {
+            String[] pathParts = path.split("/");
+            int epicId = Integer.parseInt(pathParts[2]);
+
+            Epic epic = taskManager.getEpicById(epicId);
+            if (epic != null) {
+                List<Subtask> subtasks = taskManager.getSubtasksByEpicId(epicId);
+                String response = JsonConverter.subtasksToJson(subtasks);
+                sendText(exchange, response);
+            } else {
+                sendNotFound(exchange);
+            }
+        } else {
+            sendNotFound(exchange);
+        }
+    }
+
+    private void handlePost(HttpExchange exchange) throws IOException {
+        String body = readRequestBody(exchange);
+        Epic epic = JsonConverter.epicFromJson(body);
+
+        if (epic == null) {
+            sendBadRequest(exchange, "Неверный формат эпика");
+            return;
+        }
+
+        if (epic.getId() == 0) {
+            Epic created = taskManager.createEpic(epic);
+            if (created != null) {
+                sendSuccess(exchange);
+            } else {
+                sendInternalError(exchange);
+            }
+        } else {
+            taskManager.updateEpic(epic);
+            sendSuccess(exchange);
+        }
+    }
+
+    private void handleDelete(HttpExchange exchange, String path) throws IOException {
+        if (path.equals("/epics")) {
+            taskManager.deleteAllEpics();
+            sendSuccess(exchange);
+        } else if (path.matches("/epics/\\d+")) {
+            String[] pathParts = path.split("/");
+            int id = Integer.parseInt(pathParts[2]);
+
+            Epic epic = taskManager.getEpicById(id);
+            if (epic != null) {
+                taskManager.deleteEpicById(id);
+                sendSuccess(exchange);
+            } else {
+                sendNotFound(exchange);
+            }
+        } else {
+            sendNotFound(exchange);
+        }
+    }
+}

src/http/HistoryHandler.java

@@ -0,0 +1,31 @@
+package http;
+
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import manager.TaskManager;
+import model.Task;
+import java.io.IOException;
+import java.util.List;
+
+public class HistoryHandler extends BaseHttpHandler implements HttpHandler {
+    private final TaskManager taskManager;
+
+    public HistoryHandler(TaskManager taskManager) {
+        this.taskManager = taskManager;
+    }
+
+    @Override
+    public void handle(HttpExchange exchange) throws IOException {
+        try {
+            if ("GET".equals(exchange.getRequestMethod())) {
+                List<Task> history = taskManager.getHistory();
+                String response = JsonConverter.tasksToJson(history);
+                sendText(exchange, response);
+            } else {
+                sendBadRequest(exchange, "Метод не поддерживается");
+            }
+        } catch (Exception e) {
+            sendInternalError(exchange);
+        }
+    }
+}