131 lines
3.6 KiB
Go
131 lines
3.6 KiB
Go
// Package that contains all api routes of this microservice
|
|
package http
|
|
|
|
import (
|
|
"fmt"
|
|
"net/http"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/genofire/hs_master-kss-monolith/lib/database"
|
|
"github.com/genofire/hs_master-kss-monolith/models"
|
|
"github.com/genofire/hs_master-kss-monolith/runtime"
|
|
"github.com/genofire/hs_master-kss-monolith/test"
|
|
)
|
|
|
|
// Function to test addGood()
|
|
func TestAddGood(t *testing.T) {
|
|
assertion, router := test.Init(t)
|
|
|
|
BindAPI(router)
|
|
runtime.PermissionURL = "http://localhost:8080/api-test/session/%s/%d/"
|
|
session := test.NewSession(router)
|
|
|
|
good := models.Good{
|
|
ProductID: 3,
|
|
Comment: "blub",
|
|
}
|
|
|
|
_, w := session.JSONRequest("POST", "/api/good/1", good)
|
|
assertion.Equal(http.StatusForbidden, w.StatusCode)
|
|
|
|
session.Login()
|
|
|
|
_, w = session.JSONRequest("POST", "/api/good/a", good)
|
|
assertion.Equal(http.StatusNotAcceptable, w.StatusCode)
|
|
|
|
_, w = session.JSONRequest("POST", "/api/good/7", good)
|
|
assertion.Equal(http.StatusNotFound, w.StatusCode)
|
|
|
|
_, w = session.JSONRequest("POST", "/api/good/2", true)
|
|
assertion.Equal(http.StatusBadRequest, w.StatusCode)
|
|
|
|
_, w = session.JSONRequest("POST", "/api/good/2", good)
|
|
assertion.Equal(http.StatusOK, w.StatusCode)
|
|
var count int
|
|
database.Read.Model(&good).Where("product_id", 2).Count(&count)
|
|
assertion.Equal(1, count)
|
|
|
|
good = models.Good{
|
|
ProductID: 3,
|
|
Comment: "blub",
|
|
}
|
|
|
|
_, w = session.JSONRequest("POST", "/api/good/4?count=3", good)
|
|
assertion.Equal(http.StatusOK, w.StatusCode)
|
|
database.Read.Model(&good).Where("product_id", 4).Count(&count)
|
|
assertion.Equal(4, count)
|
|
|
|
database.Close()
|
|
|
|
_, w = session.JSONRequest("POST", "/api/good/1", good)
|
|
assertion.Equal(http.StatusInternalServerError, w.StatusCode)
|
|
|
|
session.Logout()
|
|
|
|
_, w = session.JSONRequest("POST", "/api/good/1", good)
|
|
assertion.Equal(http.StatusForbidden, w.StatusCode)
|
|
|
|
session.Login()
|
|
runtime.CacheConfig.After = models.Duration{Duration: time.Duration(5) * time.Millisecond}
|
|
test.CloseServer()
|
|
time.Sleep(time.Duration(10) * time.Millisecond)
|
|
runtime.HasPermission("testsessionkey", runtime.PermissionCreateGood)
|
|
runtime.CleanCache()
|
|
|
|
// Test the gatewaytimeout on product exists
|
|
_, w = session.JSONRequest("POST", "/api/good/1", good)
|
|
assertion.Equal(http.StatusGatewayTimeout, w.StatusCode)
|
|
|
|
time.Sleep(time.Duration(10) * time.Millisecond)
|
|
runtime.CleanCache()
|
|
|
|
// Test the gatewaytimeout on permission exists
|
|
_, w = session.JSONRequest("POST", "/api/good/1", good)
|
|
assertion.Equal(http.StatusGatewayTimeout, w.StatusCode)
|
|
|
|
test.Close()
|
|
}
|
|
|
|
// Function to test delGood()
|
|
func TestDelGood(t *testing.T) {
|
|
assertion, router := test.Init(t)
|
|
|
|
BindAPI(router)
|
|
runtime.PermissionURL = "http://localhost:8080/api-test/session/%s/%d/"
|
|
session := test.NewSession(router)
|
|
|
|
good := models.Good{
|
|
Comment: "blub",
|
|
}
|
|
|
|
database.Write.Create(&good)
|
|
|
|
_, w := session.JSONRequest("DELETE", "/api/good/1", nil)
|
|
assertion.Equal(http.StatusForbidden, w.StatusCode)
|
|
|
|
session.Login()
|
|
|
|
_, w = session.JSONRequest("DELETE", "/api/good/a", nil)
|
|
assertion.Equal(http.StatusNotAcceptable, w.StatusCode)
|
|
|
|
_, w = session.JSONRequest("DELETE", fmt.Sprintf("/api/good/%d", good.ID), nil)
|
|
assertion.Equal(http.StatusOK, w.StatusCode)
|
|
|
|
_, w = session.JSONRequest("DELETE", fmt.Sprintf("/api/good/%d", good.ID), nil)
|
|
assertion.Equal(http.StatusNotFound, w.StatusCode)
|
|
|
|
time.Sleep(time.Millisecond)
|
|
database.Close()
|
|
|
|
_, w = session.JSONRequest("DELETE", "/api/good/1", nil)
|
|
assertion.Equal(http.StatusInternalServerError, w.StatusCode)
|
|
|
|
session.Logout()
|
|
|
|
_, w = session.JSONRequest("DELETE", "/api/good/1", nil)
|
|
assertion.Equal(http.StatusForbidden, w.StatusCode)
|
|
|
|
test.Close()
|
|
}
|