Function buildHookImage

integration/docker_test.go:1117–1158

(t *testing.T, ctx context.Context, registryURL, name, hookScript string)

}

func buildHookImage(t *testing.T, ctx context.Context, registryURL, name, hookScript string) string {
	t.Helper()
	c, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
	require.NoError(t, err)
	defer c.Close()

	dockerfile := `FROM ghcr.io/basecamp/once-campfire:main
COPY post-restore /hooks/post-restore
`

	var buf bytes.Buffer
	tw := tar.NewWriter(&buf)
	addTarEntry := func(name string, data []byte) {
		require.NoError(t, tw.WriteHeader(&tar.Header{Name: name, Size: int64(len(data)), Mode: 0644}))
		_, err := tw.Write(data)
		require.NoError(t, err)
	}
	addTarEntry("Dockerfile", []byte(dockerfile))

	require.NoError(t, tw.WriteHeader(&tar.Header{Name: "post-restore", Size: int64(len(hookScript)), Mode: 0755}))
	_, err = tw.Write([]byte(hookScript))
	require.NoError(t, err)
	require.NoError(t, tw.Close())

	fullTag := registryURL + "/" + name + ":latest"

	buildResp, err := c.ImageBuild(ctx, &buf, build.ImageBuildOptions{
		Tags:       []string{fullTag},
		Dockerfile: "Dockerfile",
		Remove:     true,
	})
	require.NoError(t, err)
	io.Copy(io.Discard, buildResp.Body)
	buildResp.Body.Close()

	pushResp, err := c.ImagePush(ctx, fullTag, image.PushOptions{RegistryAuth: "e30="}) // base64 "{}"
	require.NoError(t, err)
	io.Copy(io.Discard, pushResp)
	pushResp.Close()

	return fullTag
}

func buildTestBackup(t *testing.T, imageName string) []byte {
	t.Helper()