diff --git a/go.mod b/go.mod index 823e921..0e92922 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,4 @@ module github.com/Yandex-Practicum/go-rest-api-homework go 1.20 -require github.com/go-chi/chi/v5 v5.0.10 // indirect +require github.com/go-chi/chi/v5 v5.0.10 diff --git a/precode.go b/precode.go index d082d83..2c2c4ae 100644 --- a/precode.go +++ b/precode.go @@ -1,13 +1,15 @@ package main import ( + "bytes" + "encoding/json" "fmt" "net/http" "github.com/go-chi/chi/v5" ) -// Task ... +// Task структура для определения задач type Task struct { ID string `json:"id"` Description string `json:"description"` @@ -40,13 +42,96 @@ var tasks = map[string]Task{ } // Ниже напишите обработчики для каждого эндпоинта -// ... +func getTasks(w http.ResponseWriter, r *http.Request) { + resp, err := json.Marshal(tasks) + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + w.Header().Set("Content-Type", "application/json") + w.WriteHeader(http.StatusOK) + + _, err = w.Write(resp) + if err != nil { + fmt.Println("Ошибка при записи ответа:", err) + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + +} + +func postTask(w http.ResponseWriter, r *http.Request) { + var task Task + var buf bytes.Buffer + + _, err := buf.ReadFrom(r.Body) + if err != nil { + http.Error(w, err.Error(), http.StatusBadRequest) + return + } + + if err = json.Unmarshal(buf.Bytes(), &task); err != nil { + http.Error(w, err.Error(), http.StatusBadRequest) + return + } + _, ok := tasks[task.ID] + if ok { + http.Error(w, "Задача с таким ID уже cуществует", http.StatusBadRequest) + return + } + tasks[task.ID] = task + + w.Header().Set("Content-Type", "application/json") + w.WriteHeader(http.StatusCreated) +} + +func getTask(w http.ResponseWriter, r *http.Request) { + id := chi.URLParam(r, "id") + task, ok := tasks[id] + if !ok { + http.Error(w, "Задачи с таким ID не существует", http.StatusBadRequest) + return + } + + resp, err := json.Marshal(task) + if err != nil { + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } + + w.Header().Set("Content-Type", "application/json") + w.WriteHeader(http.StatusOK) + _, err = w.Write(resp) + if err != nil { + fmt.Println("Ошибка при записи ответа:", err) + http.Error(w, err.Error(), http.StatusInternalServerError) + return + } +} + +func delTask(w http.ResponseWriter, r *http.Request) { + id := chi.URLParam(r, "id") + + task, ok := tasks[id] + if !ok { + http.Error(w, "Задачи с таким ID не существует", http.StatusBadRequest) + return + } + + delete(tasks, task.ID) + + w.Header().Set("Content-Type", "application/json") + w.WriteHeader(http.StatusOK) +} func main() { r := chi.NewRouter() // здесь регистрируйте ваши обработчики - // ... + r.Get("/tasks/{id}", getTask) + r.Get("/tasks", getTasks) + r.Post("/tasks", postTask) + r.Delete("/tasks/{id}", delTask) if err := http.ListenAndServe(":8080", r); err != nil { fmt.Printf("Ошибка при запуске сервера: %s", err.Error())