1package repo
2
3import (
4 "context"
5 "fmt"
6 "os"
7 "testing"
8
9 cid "github.com/ipfs/go-cid"
10)
11
12func TestRepo(t *testing.T) {
13 t.Skip()
14 fi, err := os.Open("repo.car")
15 if err != nil {
16 t.Fatal(err)
17 }
18 defer fi.Close()
19
20 ctx := context.TODO()
21 r, err := ReadRepoFromCar(ctx, fi)
22 if err != nil {
23 t.Fatal(err)
24 }
25
26 if err := r.ForEach(ctx, "app.bsky.feed.post", func(k string, v cid.Cid) error {
27 fmt.Println(k, v)
28 return nil
29 }); err != nil {
30 t.Fatal(err)
31 }
32}