forked from TrueCloudLab/restic
88f59fc2d6
This keeps backwards compatibility with the previous empty structs. And maybe we'd want to put other fields into the inner struct later, rather than the outer message.
70 lines
3.3 KiB
Go
70 lines
3.3 KiB
Go
package restore
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/restic/restic/internal/errors"
|
|
"github.com/restic/restic/internal/test"
|
|
"github.com/restic/restic/internal/ui"
|
|
)
|
|
|
|
func createJSONProgress() (*ui.MockTerminal, ProgressPrinter) {
|
|
term := &ui.MockTerminal{}
|
|
printer := NewJSONProgress(term, 3)
|
|
return term, printer
|
|
}
|
|
|
|
func TestJSONPrintUpdate(t *testing.T) {
|
|
term, printer := createJSONProgress()
|
|
printer.Update(State{3, 11, 0, 29, 47, 0}, 5*time.Second)
|
|
test.Equals(t, []string{"{\"message_type\":\"status\",\"seconds_elapsed\":5,\"percent_done\":0.6170212765957447,\"total_files\":11,\"files_restored\":3,\"total_bytes\":47,\"bytes_restored\":29}\n"}, term.Output)
|
|
}
|
|
|
|
func TestJSONPrintUpdateWithSkipped(t *testing.T) {
|
|
term, printer := createJSONProgress()
|
|
printer.Update(State{3, 11, 2, 29, 47, 59}, 5*time.Second)
|
|
test.Equals(t, []string{"{\"message_type\":\"status\",\"seconds_elapsed\":5,\"percent_done\":0.6170212765957447,\"total_files\":11,\"files_restored\":3,\"files_skipped\":2,\"total_bytes\":47,\"bytes_restored\":29,\"bytes_skipped\":59}\n"}, term.Output)
|
|
}
|
|
|
|
func TestJSONPrintSummaryOnSuccess(t *testing.T) {
|
|
term, printer := createJSONProgress()
|
|
printer.Finish(State{11, 11, 0, 47, 47, 0}, 5*time.Second)
|
|
test.Equals(t, []string{"{\"message_type\":\"summary\",\"seconds_elapsed\":5,\"total_files\":11,\"files_restored\":11,\"total_bytes\":47,\"bytes_restored\":47}\n"}, term.Output)
|
|
}
|
|
|
|
func TestJSONPrintSummaryOnErrors(t *testing.T) {
|
|
term, printer := createJSONProgress()
|
|
printer.Finish(State{3, 11, 0, 29, 47, 0}, 5*time.Second)
|
|
test.Equals(t, []string{"{\"message_type\":\"summary\",\"seconds_elapsed\":5,\"total_files\":11,\"files_restored\":3,\"total_bytes\":47,\"bytes_restored\":29}\n"}, term.Output)
|
|
}
|
|
|
|
func TestJSONPrintSummaryOnSuccessWithSkipped(t *testing.T) {
|
|
term, printer := createJSONProgress()
|
|
printer.Finish(State{11, 11, 2, 47, 47, 59}, 5*time.Second)
|
|
test.Equals(t, []string{"{\"message_type\":\"summary\",\"seconds_elapsed\":5,\"total_files\":11,\"files_restored\":11,\"files_skipped\":2,\"total_bytes\":47,\"bytes_restored\":47,\"bytes_skipped\":59}\n"}, term.Output)
|
|
}
|
|
|
|
func TestJSONPrintCompleteItem(t *testing.T) {
|
|
for _, data := range []struct {
|
|
action ItemAction
|
|
size uint64
|
|
expected string
|
|
}{
|
|
{ActionDirRestored, 0, "{\"message_type\":\"verbose_status\",\"action\":\"restored\",\"item\":\"test\",\"size\":0}\n"},
|
|
{ActionFileRestored, 123, "{\"message_type\":\"verbose_status\",\"action\":\"restored\",\"item\":\"test\",\"size\":123}\n"},
|
|
{ActionFileUpdated, 123, "{\"message_type\":\"verbose_status\",\"action\":\"updated\",\"item\":\"test\",\"size\":123}\n"},
|
|
{ActionFileUnchanged, 123, "{\"message_type\":\"verbose_status\",\"action\":\"unchanged\",\"item\":\"test\",\"size\":123}\n"},
|
|
{ActionDeleted, 0, "{\"message_type\":\"verbose_status\",\"action\":\"deleted\",\"item\":\"test\",\"size\":0}\n"},
|
|
} {
|
|
term, printer := createJSONProgress()
|
|
printer.CompleteItem(data.action, "test", data.size)
|
|
test.Equals(t, []string{data.expected}, term.Output)
|
|
}
|
|
}
|
|
|
|
func TestJSONError(t *testing.T) {
|
|
term, printer := createJSONProgress()
|
|
test.Equals(t, printer.Error("/path", errors.New("error \"message\"")), nil)
|
|
test.Equals(t, []string{"{\"message_type\":\"error\",\"error\":{\"message\":\"error \\\"message\\\"\"},\"during\":\"restore\",\"item\":\"/path\"}\n"}, term.Errors)
|
|
}
|