Function TestBackupHookBehavior

integration/docker_test.go:467–515

(t *testing.T)

}

func TestBackupHookBehavior(t *testing.T) {
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)
	defer cancel()

	ns, err := docker.NewNamespace("once-backup-hook-test")
	require.NoError(t, err)
	defer ns.Teardown(ctx, true)

	require.NoError(t, ns.EnsureNetwork(ctx))
	require.NoError(t, ns.Proxy().Boot(ctx, getProxyPorts(t)))

	app := deployApp(t, ctx, ns, docker.ApplicationSettings{
		Name:  "hooktest",
		Image: "ghcr.io/basecamp/once-campfire:main",
		Host:  "hooktest.localhost",
	})

	containerName, err := app.ContainerName(ctx)
	require.NoError(t, err)

	backupDir := t.TempDir()

	t.Run("WithoutHook", func(t *testing.T) {
		stop := collectPauseEvents(t, ctx, containerName)
		require.NoError(t, app.BackupToFile(ctx, backupDir, "no-hook.tar.gz"))
		actions := stop()
		assert.Contains(t, actions, "pause")
		assert.Contains(t, actions, "unpause")
	})

	t.Run("WithSuccessfulHook", func(t *testing.T) {
		copyHookToContainer(t, ctx, containerName, "pre-backup", []byte("#!/bin/sh\nexit 0"))

		stop := collectPauseEvents(t, ctx, containerName)
		require.NoError(t, app.BackupToFile(ctx, backupDir, "successful-hook.tar.gz"))
		actions := stop()
		assert.Empty(t, actions)
	})

	t.Run("WithFailedHook", func(t *testing.T) {
		copyHookToContainer(t, ctx, containerName, "pre-backup", []byte("#!/bin/sh\nexit 1"))

		stop := collectPauseEvents(t, ctx, containerName)
		require.NoError(t, app.BackupToFile(ctx, backupDir, "failed-hook.tar.gz"))
		actions := stop()
		assert.Contains(t, actions, "pause")
		assert.Contains(t, actions, "unpause")
	})
}

func TestBackupStoppedContainer(t *testing.T) {
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Minute)