https://github.com/bluesky-social/goat but with tangled's CI
10
fork

Configure Feed

Select the types of activity you want to include in your feed.

rename `atproto/repo` CAR loading function names (#1016)

This only touches code I am developing, so will probably self-merge

authored by

bnewbold and committed by
GitHub
d9609274 4d8d860b

+6 -6
+3 -3
firehose.go
··· 256 256 } 257 257 258 258 func (gfc *GoatFirehoseConsumer) handleSyncEvent(ctx context.Context, evt *comatproto.SyncSubscribeRepos_Sync) error { 259 - commit, err := repo.LoadCARCommit(ctx, bytes.NewReader(evt.Blocks)) 259 + commit, _, err := repo.LoadCommitFromCAR(ctx, bytes.NewReader(evt.Blocks)) 260 260 if err != nil { 261 261 return err 262 262 } ··· 296 296 return err 297 297 } 298 298 299 - commit, err := repo.LoadCARCommit(ctx, bytes.NewReader(evt.Blocks)) 299 + commit, _, err := repo.LoadCommitFromCAR(ctx, bytes.NewReader(evt.Blocks)) 300 300 if err != nil { 301 301 return err 302 302 } ··· 409 409 return nil 410 410 } 411 411 412 - _, rr, err := repo.LoadFromCAR(ctx, bytes.NewReader(evt.Blocks)) 412 + _, rr, err := repo.LoadRepoFromCAR(ctx, bytes.NewReader(evt.Blocks)) 413 413 if err != nil { 414 414 logger.Error("failed to read repo from car", "err", err) 415 415 return nil
+3 -3
repo.go
··· 184 184 } 185 185 186 186 // read repository tree in to memory 187 - _, r, err := repo.LoadFromCAR(ctx, fi) 187 + _, r, err := repo.LoadRepoFromCAR(ctx, fi) 188 188 if err != nil { 189 189 return fmt.Errorf("failed to parse repo CAR file: %w", err) 190 190 } ··· 211 211 } 212 212 213 213 // read repository tree in to memory 214 - c, _, err := repo.LoadFromCAR(ctx, fi) 214 + c, _, err := repo.LoadRepoFromCAR(ctx, fi) 215 215 if err != nil { 216 216 return err 217 217 } ··· 255 255 return err 256 256 } 257 257 258 - c, r, err := repo.LoadFromCAR(ctx, fi) 258 + c, r, err := repo.LoadRepoFromCAR(ctx, fi) 259 259 if err != nil { 260 260 return err 261 261 }