1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
package integrationtests
import (
"context"
"fmt"
"os"
"testing"
"github.com/mimecast/dtail/internal/config"
)
func TestDServer(t *testing.T) {
if !config.Env("DTAIL_INTEGRATION_TEST_RUN_MODE") {
t.Log("Skipping")
return
}
csvFile := "dserver.csv"
expectedCsvFile := "dserver.csv.expected"
queryFile := fmt.Sprintf("%s.query", csvFile)
expectedQueryFile := "dserver.csv.query.expected"
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
stdoutCh, stderrCh, cmdErrCh, err := startCommand(ctx, t,
"../dserver",
"--cfg", "dserver.cfg",
"--logger", "stdout",
"--logLevel", "info",
"--bindAddress", "localhost",
"--shutdownAfter", "5",
"--port", fmt.Sprintf("%d", getUniquePortNumber()),
)
if err != nil {
t.Error(err)
return
}
waitForCommand(ctx, t, stdoutCh, stderrCh, cmdErrCh)
if err := compareFiles(t, csvFile, expectedCsvFile); err != nil {
t.Error(err)
return
}
if err := compareFiles(t, queryFile, expectedQueryFile); err != nil {
t.Error(err)
return
}
os.Remove(csvFile)
os.Remove(queryFile)
}
|
