Api tests

order/api/api_test.go

@@ -0,0 +1,332 @@
+package api
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"log/slog"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"github.com/PseudoMera/virtual-store/order/service"
+	"github.com/PseudoMera/virtual-store/order/store"
+	"github.com/PseudoMera/virtual-store/shared"
+	userStore "github.com/PseudoMera/virtual-store/user/store"
+	"github.com/go-chi/chi/v5"
+)
+
+const (
+	projectRootPath = "../../"
+
+	testTotalPrice = 120.40
+	testStatus     = "pending"
+	testEmail      = "[email protected]"
+	testPassword   = "testPassword!!!"
+)
+
+func TestCreateOrder(t *testing.T) {
+	ctx := context.Background()
+	db, _, err := shared.SetupPostgresClient(ctx, projectRootPath)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	s := store.NewStore(db.DB())
+	serv := service.NewOrderService(s, slog.Default())
+	api := NewOrderAPI(serv)
+	router := chi.NewRouter()
+	router.Post("/api/v1/order", api.CreateOrder)
+
+	ts := httptest.NewServer(router)
+	defer ts.Close()
+
+	uStore := userStore.NewStore(db.DB())
+	userID, err := uStore.StoreUser(ctx, userStore.User{
+		Email:    testEmail,
+		Password: testPassword,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	createOrder := CreateOrderRequest{
+		UserID:     userID,
+		TotalPrice: testTotalPrice,
+		Status:     testStatus,
+	}
+	createOrderBytes, err := json.Marshal(createOrder)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req, err := http.NewRequest("POST", ts.URL+"/api/v1/order", bytes.NewBuffer(createOrderBytes))
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req.Header.Set("Content-type", "application/json")
+
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	defer resp.Body.Close()
+
+	if status := resp.StatusCode; status != http.StatusCreated {
+		t.Fatalf("wanted %d, got %d", http.StatusCreated, status)
+	}
+}
+
+func TestGetOrder(t *testing.T) {
+	ctx := context.Background()
+	db, _, err := shared.SetupPostgresClient(ctx, projectRootPath)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	s := store.NewStore(db.DB())
+	serv := service.NewOrderService(s, slog.Default())
+	api := NewOrderAPI(serv)
+	router := chi.NewRouter()
+	router.Get("/api/v1/order", api.GetOrder)
+
+	ts := httptest.NewServer(router)
+	defer ts.Close()
+
+	uStore := userStore.NewStore(db.DB())
+	userID, err := uStore.StoreUser(ctx, userStore.User{
+		Email:    testEmail,
+		Password: testPassword,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	orderID, err := s.StoreOrder(ctx, store.Order{
+		UserID:     userID,
+		TotalPrice: testTotalPrice,
+		Status:     testStatus,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	getOrder := GetOrderRequest{
+		ID: orderID,
+	}
+	getOrderBytes, err := json.Marshal(getOrder)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req, err := http.NewRequest("GET", ts.URL+"/api/v1/order", bytes.NewBuffer(getOrderBytes))
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req.Header.Set("Content-type", "application/json")
+
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	defer resp.Body.Close()
+
+	if status := resp.StatusCode; status != http.StatusOK {
+		t.Fatalf("wanted %d, got %d", http.StatusOK, status)
+	}
+}
+
+func TestGetOrdersByUser(t *testing.T) {
+	ctx := context.Background()
+	db, _, err := shared.SetupPostgresClient(ctx, projectRootPath)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	s := store.NewStore(db.DB())
+	serv := service.NewOrderService(s, slog.Default())
+	api := NewOrderAPI(serv)
+	router := chi.NewRouter()
+	router.Get("/api/v1/order", api.GetOrdersByUser)
+
+	ts := httptest.NewServer(router)
+	defer ts.Close()
+
+	uStore := userStore.NewStore(db.DB())
+	userID, err := uStore.StoreUser(ctx, userStore.User{
+		Email:    testEmail,
+		Password: testPassword,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	_, err = s.StoreOrder(ctx, store.Order{
+		UserID:     userID,
+		TotalPrice: testTotalPrice,
+		Status:     testStatus,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	getOrder := GetOrdersByUserRequest{
+		UserID: userID,
+	}
+	getOrderBytes, err := json.Marshal(getOrder)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req, err := http.NewRequest("GET", ts.URL+"/api/v1/order", bytes.NewBuffer(getOrderBytes))
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req.Header.Set("Content-type", "application/json")
+
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	defer resp.Body.Close()
+
+	if status := resp.StatusCode; status != http.StatusOK {
+		t.Fatalf("wanted %d, got %d", http.StatusOK, status)
+	}
+}
+
+func TestUpdateOrder(t *testing.T) {
+	ctx := context.Background()
+	db, _, err := shared.SetupPostgresClient(ctx, projectRootPath)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	s := store.NewStore(db.DB())
+	serv := service.NewOrderService(s, slog.Default())
+	api := NewOrderAPI(serv)
+	router := chi.NewRouter()
+	router.Put("/api/v1/order", api.UpdateOrder)
+
+	ts := httptest.NewServer(router)
+	defer ts.Close()
+
+	uStore := userStore.NewStore(db.DB())
+	userID, err := uStore.StoreUser(ctx, userStore.User{
+		Email:    testEmail,
+		Password: testPassword,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	orderID, err := s.StoreOrder(ctx, store.Order{
+		UserID:     userID,
+		TotalPrice: testTotalPrice,
+		Status:     testStatus,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	updateOrder := UpdateOrderRequest{
+		ID:         orderID,
+		Status:     "completed",
+		TotalPrice: 125555,
+	}
+	updateOrderBytes, err := json.Marshal(updateOrder)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req, err := http.NewRequest("PUT", ts.URL+"/api/v1/order", bytes.NewBuffer(updateOrderBytes))
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req.Header.Set("Content-type", "application/json")
+
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	defer resp.Body.Close()
+
+	if status := resp.StatusCode; status != http.StatusNoContent {
+		t.Fatalf("wanted %d, got %d", http.StatusNoContent, status)
+	}
+}
+
+func TestUpdateOrderStatus(t *testing.T) {
+	ctx := context.Background()
+	db, _, err := shared.SetupPostgresClient(ctx, projectRootPath)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	s := store.NewStore(db.DB())
+	serv := service.NewOrderService(s, slog.Default())
+	api := NewOrderAPI(serv)
+	router := chi.NewRouter()
+	router.Put("/api/v1/order", api.UpdateOrderStatus)
+
+	ts := httptest.NewServer(router)
+	defer ts.Close()
+
+	uStore := userStore.NewStore(db.DB())
+	userID, err := uStore.StoreUser(ctx, userStore.User{
+		Email:    testEmail,
+		Password: testPassword,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	orderID, err := s.StoreOrder(ctx, store.Order{
+		UserID:     userID,
+		TotalPrice: testTotalPrice,
+		Status:     testStatus,
+	})
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	updateOrder := UpdateOrderStatusRequest{
+		ID:     orderID,
+		Status: "completed",
+	}
+	updateOrderBytes, err := json.Marshal(updateOrder)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req, err := http.NewRequest("PUT", ts.URL+"/api/v1/order", bytes.NewBuffer(updateOrderBytes))
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	req.Header.Set("Content-type", "application/json")
+
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	defer resp.Body.Close()
+
+	if status := resp.StatusCode; status != http.StatusNoContent {
+		t.Fatalf("wanted %d, got %d", http.StatusNoContent, status)
+	}
+}

order/main.go

@@ -12,6 +12,10 @@ import (
 	"github.com/PseudoMera/virtual-store/shared"
 )
 
+const (
+	apiPath = "/api/v1"
+)
+
 func main() {
 	config := getConfig()
 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
@@ -27,7 +31,11 @@ func main() {
 	orderService := service.NewOrderService(store, logger)
 	orderAPI := api.NewOrderAPI(orderService)
 
-	router.Post("/api/v1/order", orderAPI.CreateOrder)
+	router.Post(fmt.Sprintf("%s/order", apiPath), orderAPI.CreateOrder)
+	router.Get(fmt.Sprintf("%s/order", apiPath), orderAPI.GetOrder)
+	router.Get(fmt.Sprintf("%s/user-order", apiPath), orderAPI.GetOrdersByUser)
+	router.Put(fmt.Sprintf("%s/order", apiPath), orderAPI.UpdateOrder)
+	router.Put(fmt.Sprintf("%s/order/status", apiPath), orderAPI.UpdateOrderStatus)
 
 	if err := http.ListenAndServe(fmt.Sprintf(":%s", config.httpServerPort), router); err != nil {
 		panic(err)

product/api/api.go

@@ -66,12 +66,12 @@ func (p *ProductAPI) GetProduct(w http.ResponseWriter, r *http.Request) {
 	shared.WriteResponse(http.StatusOK, product, w)
 }
 
-type GetProducsRequest struct {
+type GetProductsRequest struct {
 	Name string `json:"name"`
 }
 
 func (p *ProductAPI) GetProducts(w http.ResponseWriter, r *http.Request) {
-	var req GetProducsRequest
+	var req GetProductsRequest
 	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
 		shared.WriteErrorResponse(w, err, http.StatusBadRequest)
 		return