This repository has been archived by the owner on May 31, 2022. It is now read-only.
forked from skeema/tengo
-
Notifications
You must be signed in to change notification settings - Fork 0
/
docker_test.go
121 lines (109 loc) · 4.42 KB
/
docker_test.go
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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
package tengo
import (
"os"
"testing"
docker "github.com/fsouza/go-dockerclient"
)
// TestDocker provides coverage for the Docker sandbox logic. It is only run
// under CI normally, since the logic will rarely change and the test can be
// time-consuming to run.
func TestDocker(t *testing.T) {
images := SplitEnv("SKEEMA_TEST_IMAGES")
if os.Getenv("CI") == "" || os.Getenv("CI") == "0" || os.Getenv("CI") == "false" || len(images) < 2 {
t.Skip("Skipping Docker sandbox meta-testing. To run, set env CI and at least 2 SKEEMA_TEST_IMAGES.")
}
dc, err := NewDockerClient(DockerClientOptions{})
if err != nil {
t.Errorf("Unable to create sandbox manager: %s", err)
}
opts := DockerizedInstanceOptions{
Name: "tengo-docker-meta-test",
Image: images[0],
RootPassword: "",
}
if _, err := dc.GetInstance(opts); err != nil {
if nosuchErr, ok := err.(*docker.NoSuchContainer); !ok {
t.Errorf("Expected to get error %T, instead got %T %s", nosuchErr, err, err)
}
} else {
t.Fatal("Expected tengo-docker-meta-test container to not exist, but it does; leftover from a previous crashed run? Please clean up manually!")
}
if _, err := dc.CreateInstance(DockerizedInstanceOptions{}); err == nil {
t.Errorf("Expected to get error creating instance with blank image, but did not")
}
if _, err := dc.CreateInstance(DockerizedInstanceOptions{Image: "jgiejgioerjgeoi"}); err == nil {
t.Errorf("Expected to get error with nonsense image name, but did not")
}
di, err := dc.GetOrCreateInstance(opts)
if err != nil {
t.Fatalf("Unexpected error from GetOrCreateInstance: %s", err)
}
if _, err := dc.CreateInstance(opts); err == nil {
t.Error("Expected to get an error attempting to create another container with duplicate name, but did not")
}
opts.Image = images[1]
if _, err := dc.GetInstance(opts); err == nil {
t.Error("Expected to get an error attempting to fetch container with different image, but did not")
}
opts.Image = images[0]
// Confirm no errors from redundant start/stop
if err := di.Start(); err != nil {
t.Errorf("Unexpected error from redundant start: %s", err)
}
if err := di.Stop(); err != nil {
t.Errorf("Unexpected error from stop: %s", err)
}
if err := di.Stop(); err != nil {
t.Errorf("Unexpected error from redundant stop: %s", err)
}
if _, err := di.SourceSQL("testdata/integration.sql"); err == nil {
t.Error("Expected error attempting to exec in stopped container, instead got nil")
}
if err := di.NukeData(); err == nil {
t.Error("Expected error attempting to nuke data in stopped container, instead got nil")
}
// GetOrCreate should yield a Get (since already exists) and should re-start
// the container. Omitting image should be ok (proving this is a Get) but
// instance image should still be populated correctly
opts.Image = ""
if di, err = dc.GetOrCreateInstance(opts); err != nil {
t.Fatalf("Unexpected error from GetOrCreateInstance: %s", err)
}
if di.Image != images[0] {
t.Errorf("Expected instance image to be %s, instead found %s", images[0], di.Image)
}
if _, err := di.SourceSQL("testdata/integration.sql"); err != nil {
t.Errorf("Unexpected error from SourceSQL: %s", err)
}
if _, err := di.SourceSQL("testdata/does-not-exist.sql"); err == nil {
t.Error("Expected error attempting to SourceSQL nonexistent file, instead got nil")
}
if _, err := di.SourceSQL("NOTICE"); err == nil {
t.Error("Expected error attempting to SourceSQL non-SQL file, instead got nil")
}
if _, err := di.SourceString("CREATE DATABASE testing2"); err != nil {
t.Errorf("Unexpected error SourceString: %s", err)
}
if _, err := di.SourceString("BAD SQL stmt"); err == nil {
t.Error("Expected error attempting to SourceString invalid string, instead got nil")
}
if err := di.Destroy(); err != nil {
t.Fatalf("Unexpected error from Destroy: %s", err)
}
if err := di.Destroy(); err != nil {
t.Errorf("Unexpected error from redundant Destroy: %s", err)
}
if _, err = dc.GetInstance(opts); err != nil {
if nosuchErr, ok := err.(*docker.NoSuchContainer); !ok {
t.Errorf("Expected to get error %T, instead got %T %s", nosuchErr, err, err)
}
} else {
t.Error("Expected error trying to get a just-destroyed container, instead got nil")
}
if err := di.Start(); err == nil {
t.Error("Expected error trying to start a destroyed container, instead got nil")
}
if err := di.Stop(); err == nil {
t.Error("Expected error trying to stop a destroyed container, instead got nil")
}
}