all api done

Author: krishkumar84

cmd/api/main.go

@@ -40,8 +40,8 @@ func main() {
 	})
 
 	router.HandleFunc("POST /api/users",users.New(storage))
-    // router.HandleFunc("GET /api/users/{id}",users.GetUser(storage))
-	// router.HandleFunc("GET /api/users",users.GetAll(storage))
+    router.HandleFunc("GET /api/users/{id}",users.GetById(storage))
+	router.HandleFunc("GET /api/users",users.GetAll(storage))
 
 	//start server
 

pkg/http/handler/users/users.go

@@ -7,6 +7,7 @@ import (
 	"io"
 	"log/slog"
 	"net/http"
+	"strconv"
 
 	"github.com/go-playground/validator/v10"
 	"github.com/krishkumar84/golang-project/pkg/storage"
@@ -55,3 +56,32 @@ func New(storage storage.Storage) http.HandlerFunc{
 	}
 }
 
+func GetById(storage storage.Storage) http.HandlerFunc{
+	return func(w http.ResponseWriter, r *http.Request){
+		id := r.PathValue("id")
+		slog.Info("Get User by Id",slog.String("id",id))
+		intId, err := strconv.ParseInt(id,10,64)
+		if err != nil {
+			response.WriteJson(w, http.StatusBadRequest, response.GeneralError(err))
+			return
+		}
+		user, err := storage.GetUserById(intId)
+		if err != nil {
+			response.WriteJson(w, http.StatusNotFound, response.GeneralError(err))
+			return
+		}
+		response.WriteJson(w, http.StatusOK, user)
+	}
+}
+
+func GetAll(storage storage.Storage) http.HandlerFunc{
+	return func(w http.ResponseWriter, r *http.Request){
+		users, err := storage.GetAllUsers()
+		if err != nil {
+			response.WriteJson(w, http.StatusNotFound, response.GeneralError(err))
+			return
+		}
+		response.WriteJson(w, http.StatusOK, users)
+	}
+}
+

pkg/storage/sqlite/sqlite.go

@@ -5,6 +5,8 @@ import (
 
 	"github.com/krishkumar84/golang-project/pkg/config"
 	_"github.com/mattn/go-sqlite3"
+	"github.com/krishkumar84/golang-project/pkg/types"
+	"fmt"
 
 )
 
@@ -48,3 +50,44 @@ func (s *Sqlite) CreateUser(name string, email string, age int) (int64, error) {
 	}
 	return lastId, nil
 }
+
+func (s *Sqlite) GetUserById(id int64)(types.User, error){
+	stmt, err := s.Db.Prepare("SELECT id,name,email,age FROM users WHERE id = ? LIMIT 1")
+	if err != nil {
+		return types.User{}, err
+	}
+	defer stmt.Close()
+	var user types.User
+
+	err = stmt.QueryRow(id).Scan(&user.Id, &user.Name, &user.Email, &user.Age)
+	if err != nil {
+		if err == sql.ErrNoRows {
+			return types.User{}, fmt.Errorf("user not found %s",fmt.Sprint(id))
+		}
+		return types.User{}, err
+	}
+	return user, nil
+}
+
+func (s *Sqlite) GetAllUsers()([]types.User, error){
+	stmt, err := s.Db.Prepare("SELECT id,name,email,age FROM users")
+	if err != nil {
+		return nil, err
+	}
+	defer stmt.Close()
+	rows, err := stmt.Query()
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	var users []types.User
+	for rows.Next(){
+		var user types.User
+		err := rows.Scan(&user.Id, &user.Name, &user.Email, &user.Age)
+		if err != nil {
+			return nil, err
+		}
+		users = append(users, user)
+	}
+	return users, nil
+}

pkg/storage/storage.go

@@ -1,5 +1,8 @@
 package storage
+import "github.com/krishkumar84/golang-project/pkg/types"
 
 type Storage interface {
 	CreateUser(name string, email string, age int)(int64, error)
+	GetUserById(id int64)(types.User, error) 
+	GetAllUsers()([]types.User, error)
 }