backup_archive_test.go 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. //go:build unit
  2. package service
  3. import (
  4. "bytes"
  5. "crypto/sha256"
  6. "fmt"
  7. "os"
  8. "testing"
  9. "github.com/stretchr/testify/require"
  10. )
  11. func TestSplitBackupFile_ReassemblesExactBytes(t *testing.T) {
  12. src := writeBackupArchiveFixture(t, []byte("0123456789abcdefg"))
  13. parts, err := splitBackupFile(src, 5)
  14. require.NoError(t, err)
  15. require.Len(t, parts, 4)
  16. var got bytes.Buffer
  17. for i, part := range parts {
  18. require.Equal(t, i+1, part.Index)
  19. require.LessOrEqual(t, part.SizeBytes, int64(5))
  20. data, readErr := os.ReadFile(part.Path)
  21. require.NoError(t, readErr)
  22. require.Equal(t, fmt.Sprintf("%x", sha256.Sum256(data)), part.SHA256)
  23. got.Write(data)
  24. }
  25. require.Equal(t, []byte("0123456789abcdefg"), got.Bytes())
  26. }
  27. func TestSplitBackupFile_RejectsInvalidInput(t *testing.T) {
  28. src := writeBackupArchiveFixture(t, []byte("data"))
  29. _, err := splitBackupFile(src, 0)
  30. require.Error(t, err)
  31. empty := writeBackupArchiveFixture(t, nil)
  32. _, err = splitBackupFile(empty, 5)
  33. require.Error(t, err)
  34. _, err = splitBackupFile(filepathForMissingBackupArchive(t), 5)
  35. require.Error(t, err)
  36. }
  37. func writeBackupArchiveFixture(t *testing.T, content []byte) string {
  38. t.Helper()
  39. path := filepathForBackupArchive(t)
  40. require.NoError(t, os.WriteFile(path, content, 0o600))
  41. return path
  42. }
  43. func filepathForBackupArchive(t *testing.T) string {
  44. t.Helper()
  45. return t.TempDir() + "/archive.gz"
  46. }
  47. func filepathForMissingBackupArchive(t *testing.T) string {
  48. t.Helper()
  49. return t.TempDir() + "/missing.gz"
  50. }