Function TestRunContainer

agent/pkg/docker/docker_api_test.go:122–193

(t *testing.T)

}

func TestRunContainer(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	t.Log("building client")
	rawCl, err := dclient.NewClientWithOpts(dclient.WithAPIVersionNegotiation(), dclient.FromEnv)
	require.NoError(t, err)
	defer func() {
		if cErr := rawCl.Close(); cErr != nil {
			t.Logf("closing docker client: %s", cErr)
		}
	}()
	cl := docker.NewClient(rawCl)

	t.Log("pull test image")
	evs := make(chan docker.Event, 1024)
	pub := events.ChannelPublisher(evs)
	if err = cl.PullImage(ctx, docker.PullImage{Name: testImage}, pub); err != nil {
		t.Errorf("pulling image: %s", err.Error())
		return
	}
	close(evs)
	_, _, err = rawCl.ImageInspectWithRaw(ctx, testImage)
	require.NoError(t, err)

	t.Log("creating simple container")
	evs = make(chan docker.Event, 64)
	pub = events.ChannelPublisher(evs)
	dockerID, err := cl.CreateContainer(ctx, cproto.NewID(), cproto.RunSpec{
		ContainerConfig: container.Config{
			Image:      testImage,
			Entrypoint: []string{"cat", "/tmp/whatever"},
		},
		Archives: []cproto.RunArchive{
			{
				Path: "/tmp",
				Archive: []archive.Item{
					{
						Path:     "/whatever",
						Type:     tar.TypeReg,
						Content:  []byte("hello"),
						FileMode: 0o0777,
					},
				},
			},
		},
	}, pub)
	require.NoError(t, err)

	t.Log("running simple container")
	c, err := cl.RunContainer(ctx, ctx, dockerID, pub)
	require.NoError(t, err)

	close(evs)
	defer func() {
		if err := rawCl.ContainerRemove(
			ctx,
			dockerID,