https://github.com/bluesky-social/goat but with tangled's CI
repo: clarify commit loading name, and return CID
+6
-6
+3
-3
firehose.go
+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
+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
}