mirror of
https://github.com/moby/moby.git
synced 2022-11-09 12:21:53 -05:00
6d801a3caa
If .dockerignore mentions either then the client will send them to the daemon but the daemon will erase them after the Dockerfile has been parsed to simulate them never being sent in the first place. an events test kept failing for me so I tried to fix that too Closes #8330 Signed-off-by: Doug Davis <dug@us.ibm.com>
295 lines
9.5 KiB
Go
295 lines
9.5 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"os/exec"
|
|
"strconv"
|
|
"strings"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestEventsUntag(t *testing.T) {
|
|
image := "busybox"
|
|
dockerCmd(t, "tag", image, "utest:tag1")
|
|
dockerCmd(t, "tag", image, "utest:tag2")
|
|
dockerCmd(t, "rmi", "utest:tag1")
|
|
dockerCmd(t, "rmi", "utest:tag2")
|
|
eventsCmd := exec.Command("timeout", "0.2", dockerBinary, "events", "--since=1")
|
|
out, _, _ := runCommandWithOutput(eventsCmd)
|
|
events := strings.Split(out, "\n")
|
|
nEvents := len(events)
|
|
// The last element after the split above will be an empty string, so we
|
|
// get the two elements before the last, which are the untags we're
|
|
// looking for.
|
|
for _, v := range events[nEvents-3 : nEvents-1] {
|
|
if !strings.Contains(v, "untag") {
|
|
t.Fatalf("event should be untag, not %#v", v)
|
|
}
|
|
}
|
|
logDone("events - untags are logged")
|
|
}
|
|
|
|
func TestEventsPause(t *testing.T) {
|
|
name := "testeventpause"
|
|
out, _, _ := dockerCmd(t, "images", "-q")
|
|
image := strings.Split(out, "\n")[0]
|
|
dockerCmd(t, "run", "-d", "--name", name, image, "sleep", "2")
|
|
dockerCmd(t, "pause", name)
|
|
dockerCmd(t, "unpause", name)
|
|
|
|
defer deleteAllContainers()
|
|
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", time.Now().Unix()))
|
|
out, _, _ = runCommandWithOutput(eventsCmd)
|
|
events := strings.Split(out, "\n")
|
|
if len(events) <= 1 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
|
|
pauseEvent := strings.Fields(events[len(events)-3])
|
|
unpauseEvent := strings.Fields(events[len(events)-2])
|
|
|
|
if pauseEvent[len(pauseEvent)-1] != "pause" {
|
|
t.Fatalf("event should be pause, not %#v", pauseEvent)
|
|
}
|
|
if unpauseEvent[len(unpauseEvent)-1] != "unpause" {
|
|
t.Fatalf("event should be unpause, not %#v", unpauseEvent)
|
|
}
|
|
|
|
waitCmd := exec.Command(dockerBinary, "wait", name)
|
|
if waitOut, _, err := runCommandWithOutput(waitCmd); err != nil {
|
|
t.Fatalf("error thrown while waiting for container: %s, %v", waitOut, err)
|
|
}
|
|
|
|
logDone("events - pause/unpause is logged")
|
|
}
|
|
|
|
func TestEventsContainerFailStartDie(t *testing.T) {
|
|
defer deleteAllContainers()
|
|
|
|
out, _, _ := dockerCmd(t, "images", "-q")
|
|
image := strings.Split(out, "\n")[0]
|
|
eventsCmd := exec.Command(dockerBinary, "run", "-d", "--name", "testeventdie", image, "blerg")
|
|
_, _, err := runCommandWithOutput(eventsCmd)
|
|
if err == nil {
|
|
t.Fatalf("Container run with command blerg should have failed, but it did not")
|
|
}
|
|
|
|
eventsCmd = exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", time.Now().Unix()))
|
|
out, _, _ = runCommandWithOutput(eventsCmd)
|
|
events := strings.Split(out, "\n")
|
|
if len(events) <= 1 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
|
|
startEvent := strings.Fields(events[len(events)-3])
|
|
dieEvent := strings.Fields(events[len(events)-2])
|
|
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("event should be start, not %#v", startEvent)
|
|
}
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
|
|
logDone("events - container failed to start logs die")
|
|
}
|
|
|
|
func TestEventsLimit(t *testing.T) {
|
|
defer deleteAllContainers()
|
|
for i := 0; i < 30; i++ {
|
|
dockerCmd(t, "run", "busybox", "echo", strconv.Itoa(i))
|
|
}
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", time.Now().Unix()))
|
|
out, _, _ := runCommandWithOutput(eventsCmd)
|
|
events := strings.Split(out, "\n")
|
|
nEvents := len(events) - 1
|
|
if nEvents != 64 {
|
|
t.Fatalf("events should be limited to 64, but received %d", nEvents)
|
|
}
|
|
logDone("events - limited to 64 entries")
|
|
}
|
|
|
|
func TestEventsContainerEvents(t *testing.T) {
|
|
dockerCmd(t, "run", "--rm", "busybox", "true")
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", time.Now().Unix()))
|
|
out, exitCode, err := runCommandWithOutput(eventsCmd)
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events with exit code %d: %s", exitCode, err)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
events = events[:len(events)-1]
|
|
if len(events) < 4 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
createEvent := strings.Fields(events[len(events)-4])
|
|
startEvent := strings.Fields(events[len(events)-3])
|
|
dieEvent := strings.Fields(events[len(events)-2])
|
|
destroyEvent := strings.Fields(events[len(events)-1])
|
|
if createEvent[len(createEvent)-1] != "create" {
|
|
t.Fatalf("event should be create, not %#v", createEvent)
|
|
}
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("event should be start, not %#v", startEvent)
|
|
}
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
if destroyEvent[len(destroyEvent)-1] != "destroy" {
|
|
t.Fatalf("event should be destroy, not %#v", destroyEvent)
|
|
}
|
|
|
|
logDone("events - container create, start, die, destroy is logged")
|
|
}
|
|
|
|
func TestEventsImageUntagDelete(t *testing.T) {
|
|
name := "testimageevents"
|
|
defer deleteImages(name)
|
|
_, err := buildImage(name,
|
|
`FROM scratch
|
|
MAINTAINER "docker"`,
|
|
true)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if err := deleteImages(name); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
eventsCmd := exec.Command(dockerBinary, "events", "--since=0", fmt.Sprintf("--until=%d", time.Now().Unix()))
|
|
out, exitCode, err := runCommandWithOutput(eventsCmd)
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events with exit code %d: %s", exitCode, err)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
t.Log(events)
|
|
events = events[:len(events)-1]
|
|
if len(events) < 2 {
|
|
t.Fatalf("Missing expected event")
|
|
}
|
|
untagEvent := strings.Fields(events[len(events)-2])
|
|
deleteEvent := strings.Fields(events[len(events)-1])
|
|
if untagEvent[len(untagEvent)-1] != "untag" {
|
|
t.Fatalf("untag should be untag, not %#v", untagEvent)
|
|
}
|
|
if deleteEvent[len(deleteEvent)-1] != "delete" {
|
|
t.Fatalf("delete should be delete, not %#v", deleteEvent)
|
|
}
|
|
logDone("events - image untag, delete is logged")
|
|
}
|
|
|
|
func TestEventsImagePull(t *testing.T) {
|
|
since := time.Now().Unix()
|
|
pullCmd := exec.Command(dockerBinary, "pull", "hello-world")
|
|
if out, _, err := runCommandWithOutput(pullCmd); err != nil {
|
|
t.Fatalf("pulling the hello-world image from has failed: %s, %v", out, err)
|
|
}
|
|
|
|
eventsCmd := exec.Command(dockerBinary, "events",
|
|
fmt.Sprintf("--since=%d", since),
|
|
fmt.Sprintf("--until=%d", time.Now().Unix()))
|
|
out, _, _ := runCommandWithOutput(eventsCmd)
|
|
|
|
events := strings.Split(strings.TrimSpace(out), "\n")
|
|
event := strings.TrimSpace(events[len(events)-1])
|
|
|
|
if !strings.HasSuffix(event, "hello-world:latest: pull") {
|
|
t.Fatalf("Missing pull event - got:%q", event)
|
|
}
|
|
|
|
logDone("events - image pull is logged")
|
|
}
|
|
|
|
func TestEventsImageImport(t *testing.T) {
|
|
since := time.Now().Unix()
|
|
|
|
defer deleteImages("cirros")
|
|
|
|
server, err := fileServer(map[string]string{
|
|
"/cirros.tar.gz": "/cirros.tar.gz",
|
|
})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer server.Close()
|
|
fileURL := fmt.Sprintf("%s/cirros.tar.gz", server.URL)
|
|
importCmd := exec.Command(dockerBinary, "import", fileURL, "cirros")
|
|
out, _, err := runCommandWithOutput(importCmd)
|
|
if err != nil {
|
|
t.Errorf("import failed with errors: %v, output: %q", err, out)
|
|
}
|
|
|
|
eventsCmd := exec.Command(dockerBinary, "events",
|
|
fmt.Sprintf("--since=%d", since),
|
|
fmt.Sprintf("--until=%d", time.Now().Unix()))
|
|
out, _, _ = runCommandWithOutput(eventsCmd)
|
|
|
|
events := strings.Split(strings.TrimSpace(out), "\n")
|
|
event := strings.TrimSpace(events[len(events)-1])
|
|
|
|
if !strings.HasSuffix(event, ": import") {
|
|
t.Fatalf("Missing pull event - got:%q", event)
|
|
}
|
|
|
|
logDone("events - image import is logged")
|
|
}
|
|
|
|
func TestEventsFilters(t *testing.T) {
|
|
since := time.Now().Unix()
|
|
out, _, err := runCommandWithOutput(exec.Command(dockerBinary, "run", "--rm", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
out, _, err = runCommandWithOutput(exec.Command(dockerBinary, "run", "--rm", "busybox", "true"))
|
|
if err != nil {
|
|
t.Fatal(out, err)
|
|
}
|
|
eventsCmd := exec.Command(dockerBinary, "events", fmt.Sprintf("--since=%d", since), fmt.Sprintf("--until=%d", time.Now().Unix()), "--filter", "event=die")
|
|
out, exitCode, err := runCommandWithOutput(eventsCmd)
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events with exit code %d: %s", exitCode, err)
|
|
}
|
|
events := strings.Split(out, "\n")
|
|
events = events[:len(events)-1]
|
|
if len(events) != 2 {
|
|
t.Fatalf("Expected 2 events, got %d: %v", len(events), events)
|
|
}
|
|
dieEvent := strings.Fields(events[len(events)-1])
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
|
|
dieEvent = strings.Fields(events[len(events)-2])
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
|
|
eventsCmd = exec.Command(dockerBinary, "events", fmt.Sprintf("--since=%d", since), fmt.Sprintf("--until=%d", time.Now().Unix()), "--filter", "event=die", "--filter", "event=start")
|
|
out, exitCode, err = runCommandWithOutput(eventsCmd)
|
|
if exitCode != 0 || err != nil {
|
|
t.Fatalf("Failed to get events with exit code %d: %s", exitCode, err)
|
|
}
|
|
events = strings.Split(out, "\n")
|
|
events = events[:len(events)-1]
|
|
if len(events) != 4 {
|
|
t.Fatalf("Expected 4 events, got %d: %v", len(events), events)
|
|
}
|
|
startEvent := strings.Fields(events[len(events)-4])
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("event should be start, not %#v", startEvent)
|
|
}
|
|
dieEvent = strings.Fields(events[len(events)-3])
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
startEvent = strings.Fields(events[len(events)-2])
|
|
if startEvent[len(startEvent)-1] != "start" {
|
|
t.Fatalf("event should be start, not %#v", startEvent)
|
|
}
|
|
dieEvent = strings.Fields(events[len(events)-1])
|
|
if dieEvent[len(dieEvent)-1] != "die" {
|
|
t.Fatalf("event should be die, not %#v", dieEvent)
|
|
}
|
|
|
|
logDone("events - filters")
|
|
}
|