(t *testing.T, ctx context.Context, rep repo.Repository, entries []entry, comp compression.HeaderID)
| 221 | } |
| 222 | |
| 223 | func verifyMetadataCompressor(t *testing.T, ctx context.Context, rep repo.Repository, entries []entry, comp compression.HeaderID) { |
| 224 | t.Helper() |
| 225 | |
| 226 | for _, e := range entries { |
| 227 | cid, _, ok := e.objectID.ContentID() |
| 228 | if !assert.True(t, ok) { |
| 229 | continue |
| 230 | } |
| 231 | |
| 232 | if !cid.HasPrefix() { |
| 233 | continue |
| 234 | } |
| 235 | |
| 236 | info, err := rep.ContentInfo(ctx, cid) |
| 237 | require.NoError(t, err, "failed to get content info for %v", cid) |
| 238 | assert.Equal(t, comp, info.CompressionHeaderID) |
| 239 | } |
| 240 | } |
| 241 | |
| 242 | func TestUploadMetadataCompression(t *testing.T) { |
| 243 | t.Parallel() |
no test coverage detected