mirror of
https://github.com/fnproject/fn.git
synced 2022-10-28 21:29:17 +03:00
9d6f0b2a05
* Adjust API tests internal API * Refactor API tests to take less time - sqlite: tests 15s, overall time: 1m - mysql: tests 15s, overall time: 59s * Use retry func to survive in faulty places * Use retry func while trying to ping SQL datastore - implements retry func specifically for SQL datastore ping - fmt fixes - using sqlx.Db.PingContext instead of sqlx.Db.Ping - propogate context to SQL datastore * Simplify TestCanCauseTimeout retry loop * Call retry with sane timeout * Fix TestOversizedLog, use retry func * Increase number of attempts 2 test cases are really faulty in CI, so they need a lot more time to finish. * Increase TestCanCauseTimeout timeout * Use retry at TestMultiLog to speed it up * Use retry at TestCanWriteLogs to speed it up * Use retry at TestGetCallsSuccess to speed it up * Use retry at TestCanGetAsyncState to speed it up * Use retry at TestListCallsSuccess to speed it up * Remove sleep calls * Remove dup test case * Cleaup Calls API test * Build API tests binary once This patch lets CI to build API tests binary once and reuse that whenever it needs it * Swap API tests checks * Build API test binary by default dirty fix for CircleCI * Use retry func to determine if datastore is alive in tests * go install should also reduce build time * Fix rebase issues
211 lines
7.3 KiB
Go
211 lines
7.3 KiB
Go
package tests
|
|
|
|
import (
|
|
"testing"
|
|
|
|
"github.com/fnproject/fn/api/id"
|
|
"github.com/fnproject/fn_go/models"
|
|
"reflect"
|
|
)
|
|
|
|
func TestCreateRouteEmptyType(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
_, err := createRoute(s.Context, s.Client, s.AppName, s.RoutePath, s.Image, "",
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
if err == nil {
|
|
t.Errorf("Should fail with Invalid route Type.")
|
|
}
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestCanCreateRoute(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestListRoutes(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
if !assertContainsRoute(ListRoutes(t, s.Context, s.Client, s.AppName), s.RoutePath) {
|
|
t.Errorf("Unable to find corresponding route `%v` in list", s.RoutePath)
|
|
}
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestInspectRoute(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
|
|
rObjects := []*models.Route{GetRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)}
|
|
if !assertContainsRoute(rObjects, s.RoutePath) {
|
|
t.Errorf("Unable to find corresponding route `%v` in list", s.RoutePath)
|
|
}
|
|
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestCanUpdateRouteType(t *testing.T) {
|
|
newRouteType := "sync"
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
|
|
routeResp, err := UpdateRoute(
|
|
t, s.Context, s.Client,
|
|
s.AppName, s.RoutePath,
|
|
s.Image, newRouteType, s.Format,
|
|
s.Memory, s.RouteConfig, s.RouteHeaders, "")
|
|
|
|
CheckRouteResponseError(t, err)
|
|
assertRouteFields(t, routeResp.Payload.Route, s.RoutePath, s.Image, newRouteType, s.Format)
|
|
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestCanUpdateRouteConfig(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
|
|
newRouteConf := map[string]string{
|
|
"A": "a",
|
|
}
|
|
|
|
routeResp, err := UpdateRoute(
|
|
t, s.Context, s.Client,
|
|
s.AppName, s.RoutePath,
|
|
s.Image, s.RouteType, s.Format,
|
|
s.Memory, newRouteConf, s.RouteHeaders, "")
|
|
|
|
CheckRouteResponseError(t, err)
|
|
assertRouteFields(t, routeResp.Payload.Route, s.RoutePath, s.Image, s.RouteType, s.Format)
|
|
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestCantUpdateRoutePath(t *testing.T) {
|
|
|
|
t.Parallel()
|
|
newRoutePath := id.New().String()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
|
|
_, err := UpdateRoute(
|
|
t, s.Context, s.Client,
|
|
s.AppName, s.RoutePath,
|
|
s.Image, s.RouteType, s.Format,
|
|
s.Memory, s.RouteConfig, s.RouteHeaders, newRoutePath)
|
|
if err == nil {
|
|
t.Errorf("Route path suppose to be immutable, but it's not.")
|
|
}
|
|
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestRouteDuplicate(t *testing.T) {
|
|
t.Parallel()
|
|
newRouteType := "async"
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
|
|
_, err := createRoute(s.Context, s.Client, s.AppName, s.Image, s.RoutePath,
|
|
newRouteType, s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
if err == nil {
|
|
t.Errorf("Route duplicate error should appear, but it didn't")
|
|
}
|
|
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestCanDeleteRoute(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
|
|
DeleteRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestCantDeleteRoute(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
|
|
_, err := deleteRoute(s.Context, s.Client, s.AppName, "dummy-route")
|
|
if err == nil {
|
|
t.Error("Delete from missing route must fail.")
|
|
}
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestDeployNewApp(t *testing.T) {
|
|
t.Parallel()
|
|
s := SetupDefaultSuite()
|
|
DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, s.RouteHeaders)
|
|
GetApp(t, s.Context, s.Client, s.AppName)
|
|
GetRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestDeployExistingApp(t *testing.T) {
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, s.RouteHeaders)
|
|
GetApp(t, s.Context, s.Client, s.AppName)
|
|
GetRoute(t, s.Context, s.Client, s.AppName, s.RoutePath)
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestDeployUpdate(t *testing.T) {
|
|
newRouteType := "sync"
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
CreateRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType,
|
|
s.Format, s.Timeout, s.IdleTimeout, s.RouteConfig, s.RouteHeaders)
|
|
|
|
updatedRoute := DeployRoute(
|
|
t, s.Context, s.Client,
|
|
s.AppName, s.RoutePath,
|
|
s.Image, newRouteType,
|
|
s.Format, s.RouteConfig, s.RouteHeaders)
|
|
assertRouteFields(t, updatedRoute, s.RoutePath, s.Image, newRouteType, s.Format)
|
|
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|
|
|
|
func TestMulpileDeployExistingApp(t *testing.T) {
|
|
s := SetupDefaultSuite()
|
|
CreateApp(t, s.Context, s.Client, s.AppName, map[string]string{})
|
|
routeHeaders := map[string][]string{}
|
|
routeHeaders["A"] = []string{"a"}
|
|
routeHeaders["B"] = []string{"b"}
|
|
DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, routeHeaders)
|
|
sameRoute := DeployRoute(t, s.Context, s.Client, s.AppName, s.RoutePath, s.Image, s.RouteType, s.Format, s.RouteConfig, routeHeaders)
|
|
if ok := reflect.DeepEqual(sameRoute.Headers, routeHeaders); !ok {
|
|
t.Error("Route headers should remain the same after multiple deploys with exact the same parameters")
|
|
}
|
|
DeleteApp(t, s.Context, s.Client, s.AppName)
|
|
}
|