Skip to content

Commit 89a9ae2

Browse files
committed
Add NGINX App Protect instance watcher
1 parent f716793 commit 89a9ae2

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

internal/watcher/instance/nginx-app-protect-instance-watcher_test.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@ package instance
77

88
import (
99
"context"
10-
"log/slog"
1110
"os"
1211
"testing"
1312
"time"
@@ -34,6 +33,7 @@ func TestNginxAppProtectInstanceWatcher_Watch(t *testing.T) {
3433

3534
versionFile := helpers.CreateFileWithErrorCheck(t, os.TempDir(), "version")
3635
defer os.Remove(versionFile.Name())
36+
defer versionFile.Close()
3737

3838
_, err := versionFile.WriteString("5.144.0")
3939
require.NoError(t, err)
@@ -43,24 +43,28 @@ func TestNginxAppProtectInstanceWatcher_Watch(t *testing.T) {
4343

4444
releaseFile := helpers.CreateFileWithErrorCheck(t, os.TempDir(), "release")
4545
defer helpers.RemoveFileWithErrorCheck(t, releaseFile.Name())
46+
defer releaseFile.Close()
4647

4748
_, err = releaseFile.WriteString("4.11.0")
4849
require.NoError(t, err)
4950

5051
attackSignatureVersionFile := helpers.CreateFileWithErrorCheck(t, os.TempDir(), "version")
5152
defer helpers.RemoveFileWithErrorCheck(t, attackSignatureVersionFile.Name())
53+
defer attackSignatureVersionFile.Close()
5254

5355
_, err = attackSignatureVersionFile.WriteString("2024.11.28")
5456
require.NoError(t, err)
5557

5658
threatCampaignVersionFile := helpers.CreateFileWithErrorCheck(t, os.TempDir(), "version")
5759
defer helpers.RemoveFileWithErrorCheck(t, threatCampaignVersionFile.Name())
60+
defer threatCampaignVersionFile.Close()
5861

5962
_, err = threatCampaignVersionFile.WriteString("2024.12.02")
6063
require.NoError(t, err)
6164

6265
enforcerEngineVersionFile := helpers.CreateFileWithErrorCheck(t, os.TempDir(), "enforcer_version")
6366
defer helpers.RemoveFileWithErrorCheck(t, enforcerEngineVersionFile.Name())
67+
defer enforcerEngineVersionFile.Close()
6468

6569
_, err = enforcerEngineVersionFile.WriteString("5.113.0")
6670
require.NoError(t, err)
@@ -91,8 +95,6 @@ func TestNginxAppProtectInstanceWatcher_Watch(t *testing.T) {
9195
},
9296
)
9397

94-
slog.SetLogLoggerLevel(slog.LevelDebug)
95-
9698
go nginxAppProtectInstanceWatcher.Watch(ctx, instancesChannel)
9799

98100
t.Run("Test 1: New instance", func(t *testing.T) {
@@ -133,6 +135,8 @@ func TestNginxAppProtectInstanceWatcher_Watch(t *testing.T) {
133135
})
134136
t.Run("Test 3: Delete instance", func(t *testing.T) {
135137
helpers.RemoveFileWithErrorCheck(t, versionFile.Name())
138+
closeErr := versionFile.Close()
139+
require.NoError(t, closeErr)
136140

137141
select {
138142
case instanceUpdates := <-instancesChannel:

0 commit comments

Comments
 (0)