phares3757/gatus
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test(store): Make sure the write-through cache works

Browse Source
This commit is contained in:
TwiN
2023-07-19 23:07:19 -04:00
parent 0a37a61619
commit 2f6b8f23f7
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
storage/store/store_test.go
View File

@ -131,6 +131,8 @@ func TestStore_GetEndpointStatusByKey(t *testing.T) {
firstResult.Timestamp = now.Add(-time.Minute) firstResult.Timestamp = now.Add(-time.Minute)
secondResult := testUnsuccessfulResult secondResult := testUnsuccessfulResult
secondResult.Timestamp = now secondResult.Timestamp = now
thirdResult := testSuccessfulResult
thirdResult.Timestamp = now
for _, scenario := range scenarios { for _, scenario := range scenarios {
t.Run(scenario.Name, func(t *testing.T) { t.Run(scenario.Name, func(t *testing.T) {
scenario.Store.Insert(&testEndpoint, &firstResult) scenario.Store.Insert(&testEndpoint, &firstResult)
@ -154,6 +156,14 @@ func TestStore_GetEndpointStatusByKey(t *testing.T) {
if endpointStatus.Results[0].Timestamp.After(endpointStatus.Results[1].Timestamp) { if endpointStatus.Results[0].Timestamp.After(endpointStatus.Results[1].Timestamp) {
t.Error("The result at index 0 should've been older than the result at index 1") t.Error("The result at index 0 should've been older than the result at index 1")
} }
scenario.Store.Insert(&testEndpoint, &thirdResult)
endpointStatus, err = scenario.Store.GetEndpointStatusByKey(testEndpoint.Key(), paging.NewEndpointStatusParams().WithEvents(1, common.MaximumNumberOfEvents).WithResults(1, common.MaximumNumberOfResults))
if err != nil {
t.Fatal("shouldn't have returned an error, got", err.Error())
}
if len(endpointStatus.Results) != 3 {
t.Fatalf("endpointStatus.Results should've had 3 entries")
}
scenario.Store.Clear() scenario.Store.Clear()
}) })
} }
@ -457,8 +467,8 @@ func TestStore_Insert(t *testing.T) {
secondResult.Timestamp = now secondResult.Timestamp = now
for _, scenario := range scenarios { for _, scenario := range scenarios {
t.Run(scenario.Name, func(t *testing.T) { t.Run(scenario.Name, func(t *testing.T) {
scenario.Store.Insert(&testEndpoint, &testSuccessfulResult) scenario.Store.Insert(&testEndpoint, &firstResult)
scenario.Store.Insert(&testEndpoint, &testUnsuccessfulResult) scenario.Store.Insert(&testEndpoint, &secondResult)
ss, err := scenario.Store.GetEndpointStatusByKey(testEndpoint.Key(), paging.NewEndpointStatusParams().WithEvents(1, common.MaximumNumberOfEvents).WithResults(1, common.MaximumNumberOfResults)) ss, err := scenario.Store.GetEndpointStatusByKey(testEndpoint.Key(), paging.NewEndpointStatusParams().WithEvents(1, common.MaximumNumberOfEvents).WithResults(1, common.MaximumNumberOfResults))
if err != nil { if err != nil {
t.Error("shouldn't have returned an error, got", err) t.Error("shouldn't have returned an error, got", err)
@ -472,7 +482,7 @@ func TestStore_Insert(t *testing.T) {
if len(ss.Results) != 2 { if len(ss.Results) != 2 {
t.Fatalf("Endpoint '%s' should've had 2 results, got %d", ss.Name, len(ss.Results)) t.Fatalf("Endpoint '%s' should've had 2 results, got %d", ss.Name, len(ss.Results))
} }
for i, expectedResult := range []core.Result{testSuccessfulResult, testUnsuccessfulResult} { for i, expectedResult := range []core.Result{firstResult, secondResult} {
if expectedResult.HTTPStatus != ss.Results[i].HTTPStatus { if expectedResult.HTTPStatus != ss.Results[i].HTTPStatus {
t.Errorf("Result at index %d should've had a HTTPStatus of %d, got %d", i, ss.Results[i].HTTPStatus, expectedResult.HTTPStatus) t.Errorf("Result at index %d should've had a HTTPStatus of %d, got %d", i, ss.Results[i].HTTPStatus, expectedResult.HTTPStatus)
} }