add Three layer arch to task traker

3layerarch/go.mod

@@ -0,0 +1,7 @@
+module 3layerarch
+
+go 1.24
+
+require github.com/go-sql-driver/mysql v1.9.3
+
+require filippo.io/edwards25519 v1.1.0 // indirect

3layerarch/go.sum

@@ -0,0 +1,4 @@
+filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
+filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
+github.com/go-sql-driver/mysql v1.9.3 h1:U/N249h2WzJ3Ukj8SowVFjdtZKfu9vlLZxjPXV1aweo=
+github.com/go-sql-driver/mysql v1.9.3/go.mod h1:qn46aNg1333BRMNU69Lq93t8du/dwxI64Gl8i5p1WMU=

3layerarch/handler/task/handler.go

@@ -0,0 +1,115 @@
+package taskhandler
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"strconv"
+
+	"3layerarch/models"
+)
+
+type TaskService interface {
+	CreateTask(t models.Task) error
+	GetTask(id int) (models.Task, error)
+	ViewTasks() ([]models.Task, error)
+	UpdateTask(id int) error
+	DeleteTask(id int) error
+}
+
+type Handler struct {
+	Service TaskService
+}
+
+func New(service TaskService) *Handler {
+	return &Handler{Service: service}
+}
+
+func (h *Handler) CreateTask(w http.ResponseWriter, r *http.Request) {
+	body, err := io.ReadAll(r.Body)
+	if err != nil || len(body) == 0 {
+		http.Error(w, "Empty or unreadable body", http.StatusBadRequest)
+		return
+	}
+	var t models.Task
+	if err := json.Unmarshal(body, &t); err != nil {
+		http.Error(w, "Invalid JSON input", http.StatusBadRequest)
+		return
+	}
+	if err := h.Service.CreateTask(t); err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	w.WriteHeader(http.StatusCreated)
+}
+
+func (h *Handler) GetTask(w http.ResponseWriter, r *http.Request) {
+	idStr := r.PathValue("id")
+	if idStr == "" {
+		http.Error(w, "Missing ID", http.StatusBadRequest)
+		return
+	}
+	id, err := strconv.Atoi(idStr)
+	if err != nil {
+		http.Error(w, "Invalid ID format", http.StatusBadRequest)
+		return
+	}
+	t, err := h.Service.GetTask(id)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	b, _ := json.Marshal(t)
+	if _, err := w.Write(b); err != nil {
+		fmt.Printf("failed to write response: %v\n", err)
+	}
+}
+
+func (h *Handler) ViewTasks(w http.ResponseWriter, _ *http.Request) {
+	tasks, err := h.Service.ViewTasks()
+	if err != nil {
+		http.Error(w, "Failed to fetch tasks", http.StatusInternalServerError)
+		return
+	}
+	b, _ := json.Marshal(tasks)
+	if _, err := w.Write(b); err != nil {
+		fmt.Printf("failed to write response: %v\n", err)
+	}
+}
+
+func (h *Handler) UpdateTask(w http.ResponseWriter, r *http.Request) {
+	idStr := r.PathValue("id")
+	if idStr == "" {
+		http.Error(w, "Missing ID", http.StatusBadRequest)
+		return
+	}
+	id, err := strconv.Atoi(idStr)
+	if err != nil {
+		http.Error(w, "Invalid ID format", http.StatusBadRequest)
+		return
+	}
+	if err := h.Service.UpdateTask(id); err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	w.WriteHeader(http.StatusOK)
+}
+
+func (h *Handler) DeleteTask(w http.ResponseWriter, r *http.Request) {
+	idStr := r.PathValue("id")
+	if idStr == "" {
+		http.Error(w, "Missing ID", http.StatusBadRequest)
+		return
+	}
+	id, err := strconv.Atoi(idStr)
+	if err != nil {
+		http.Error(w, "Invalid ID format", http.StatusBadRequest)
+		return
+	}
+	if err := h.Service.DeleteTask(id); err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	w.WriteHeader(http.StatusOK)
+}

3layerarch/handler/user/handler.go

@@ -0,0 +1,64 @@
+package userhandler
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"strconv"
+
+	"3layerarch/models"
+)
+
+type UserService interface {
+	CreateUser(u models.User) error
+	GetUser(id int) (models.User, error)
+}
+
+type Handler struct {
+	Service UserService
+}
+
+func New(service UserService) *Handler {
+	return &Handler{Service: service}
+}
+
+func (h *Handler) CreateUser(w http.ResponseWriter, r *http.Request) {
+	body, err := io.ReadAll(r.Body)
+	if err != nil || len(body) == 0 {
+		http.Error(w, "Empty or unreadable body", http.StatusBadRequest)
+		return
+	}
+	var u models.User
+	if err := json.Unmarshal(body, &u); err != nil {
+		http.Error(w, "Invalid JSON input", http.StatusBadRequest)
+		return
+	}
+	if err := h.Service.CreateUser(u); err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	w.WriteHeader(http.StatusCreated)
+}
+
+func (h *Handler) GetUser(w http.ResponseWriter, r *http.Request) {
+	idStr := r.PathValue("id")
+	if idStr == "" {
+		http.Error(w, "Missing ID", http.StatusBadRequest)
+		return
+	}
+	id, err := strconv.Atoi(idStr)
+	if err != nil {
+		http.Error(w, "Invalid ID format", http.StatusBadRequest)
+		return
+	}
+	u, err := h.Service.GetUser(id)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	b, _ := json.Marshal(u)
+	if _, err := w.Write(b); err != nil {
+		fmt.Printf("failed to write response: %v\n", err)
+	}
+}

3layerarch/main.go

@@ -0,0 +1,83 @@
+package main
+
+import (
+	"database/sql"
+	"log"
+	"net/http"
+	"time"
+
+	taskhandler "3layerarch/handler/task"
+	userhandler "3layerarch/handler/user"
+
+	taskservice "3layerarch/service/task"
+	userservice "3layerarch/service/user"
+
+	taskstore "3layerarch/store/task"
+	userstore "3layerarch/store/user"
+
+	_ "github.com/go-sql-driver/mysql"
+)
+
+func main() {
+	db, err := sql.Open("mysql", "root:root123@tcp(localhost:3306)/test_db")
+	if err != nil {
+		log.Fatal("DB connection error:", err)
+	}
+	defer func() {
+		if err := db.Close(); err != nil {
+			log.Println("Error closing DB:", err)
+		}
+	}()
+
+	// Ensure TASKS table exists
+	_, err = db.Exec(`CREATE TABLE IF NOT EXISTS TASKS (
+		id INT AUTO_INCREMENT PRIMARY KEY,
+		task TEXT,
+		completed BOOL DEFAULT FALSE,
+		user_id int         
+	);`)
+	if err != nil {
+		log.Fatal("Failed to create TASKS table:", err)
+	}
+
+	// Ensure USERS table exists
+	_, err = db.Exec(`CREATE TABLE IF NOT EXISTS USERS (
+		id INT AUTO_INCREMENT PRIMARY KEY,
+		name VARCHAR(100)
+	);`)
+	if err != nil {
+		log.Fatal("Failed to create USERS table:", err)
+	}
+
+	// User dependency setup
+	userStore := userstore.New(db)
+	userService := userservice.New(userStore)
+	userHandler := userhandler.New(userService)
+
+	// Task dependency setup
+	taskStore := taskstore.New(db)
+	taskService := taskservice.New(taskStore, userService)
+	taskHandler := taskhandler.New(taskService)
+
+	// Task routes
+	http.HandleFunc("POST /task", taskHandler.CreateTask)
+	http.HandleFunc("GET /task", taskHandler.ViewTasks)
+	http.HandleFunc("GET /task/{id}", taskHandler.GetTask)
+	http.HandleFunc("PUT /task/{id}", taskHandler.UpdateTask)
+	http.HandleFunc("DELETE /task/{id}", taskHandler.DeleteTask)
+
+	// User routes
+	http.HandleFunc("POST /user", userHandler.CreateUser)
+	http.HandleFunc("GET /user/{id}", userHandler.GetUser)
+
+	// Server configuration
+	srv := &http.Server{
+		Addr:         ":8080",
+		ReadTimeout:  5 * time.Second,
+		WriteTimeout: 10 * time.Second,
+		IdleTimeout:  120 * time.Second,
+	}
+
+	//log.Println("Server running on http://localhost:8080")
+	log.Fatal(srv.ListenAndServe())
+}

3layerarch/models/task.go

@@ -0,0 +1,8 @@
+package models
+
+type Task struct {
+	ID        int    `json:"id"`
+	Task      string `json:"task"`
+	Completed bool   `json:"completed"`
+	UserID    int    `json:"user_id"`
+}

3layerarch/models/user.go

@@ -0,0 +1,6 @@
+package models
+
+type User struct {
+	ID   int    `json:"id"`
+	Name string `json:"name"`
+}