Function TestObjectWritesWithRetention

repo/repository_test.go:557–602

(t *testing.T)

}

func TestObjectWritesWithRetention(t *testing.T) {
	ctx, env := repotesting.NewEnvironment(t, repotesting.FormatNotImportant, repotesting.Options{
		NewRepositoryOptions: func(n *repo.NewRepositoryOptions) {
			n.RetentionMode = blob.Governance
			n.RetentionPeriod = time.Hour * 24
		},
	})

	writer := env.RepositoryWriter.NewObjectWriter(ctx, object.WriterOptions{MetadataCompressor: "zstd-fastest"})
	_, err := writer.Write([]byte("the quick brown fox jumps over the lazy dog"))
	require.NoError(t, err)

	_, err = writer.Result()
	require.NoError(t, err)

	env.RepositoryWriter.ContentManager().Flush(ctx)

	var prefixesWithRetention []string

	versionedMap := testutil.EnsureType[cache.Storage](t, env.RootStorage())

	for _, prefix := range content.PackBlobIDPrefixes {
		prefixesWithRetention = append(prefixesWithRetention, string(prefix))
	}

	prefixesWithRetention = append(prefixesWithRetention, indexblob.V0IndexBlobPrefix, epoch.EpochManagerIndexUberPrefix,
		format.KopiaRepositoryBlobID, format.KopiaBlobCfgBlobID)

	// make sure that we cannot set mtime on the kopia objects created due to the
	// retention time constraint
	require.NoError(t, versionedMap.ListBlobs(ctx, "", func(it blob.Metadata) error {
		for _, prefix := range prefixesWithRetention {
			if strings.HasPrefix(string(it.BlobID), prefix) {
				_, err = versionedMap.TouchBlob(ctx, it.BlobID, 0)
				require.Error(t, err, "expected error while touching blob %s", it.BlobID)

				return nil
			}
		}

		_, err = versionedMap.TouchBlob(ctx, it.BlobID, 0)
		require.NoError(t, err, "unexpected error while touching blob %s", it.BlobID)

		return nil
	}))
}

func TestWriteSessionFlushOnSuccess(t *testing.T) {
	var beforeFlushCount, afterFlushCount atomic.Int32