hs_monolith/http/good_test.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 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 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()
}