| 331 | } |
| 332 | |
| 333 | func writeBadBlockFiles(t *testing.T, ww backend.RawWriter, rr backend.RawReader, tenant string) { |
| 334 | t.Logf("writing bad block files") |
| 335 | |
| 336 | ctx := context.Background() |
| 337 | |
| 338 | token := make([]byte, 32) |
| 339 | _, err := rand.Read(token) |
| 340 | require.NoError(t, err) |
| 341 | |
| 342 | err = ww.Write( |
| 343 | ctx, |
| 344 | vparquet3.DataFileName, |
| 345 | backend.KeyPath([]string{tenant, uuid.New().String()}), |
| 346 | bytes.NewReader(token), |
| 347 | int64(len(token)), nil) |
| 348 | |
| 349 | require.NoError(t, err) |
| 350 | |
| 351 | items, err := rr.List(context.Background(), backend.KeyPath([]string{tenant})) |
| 352 | require.NoError(t, err) |
| 353 | t.Logf("items: %v", items) |
| 354 | |
| 355 | var found []string |
| 356 | f := func(opts backend.FindMatch) { |
| 357 | found = append(found, opts.Key) |
| 358 | } |
| 359 | |
| 360 | err = rr.Find(ctx, backend.KeyPath{}, f) |
| 361 | require.NoError(t, err) |
| 362 | t.Logf("items: %v", found) |
| 363 | } |
| 364 | |
| 365 | func pushBlocksToTenant(t *testing.T, tenant string, bb [][]byte, w backend.Writer) []uuid.UUID { |
| 366 | // Randomly pick a block boundary |