A fork of the Cocoon PDS but being made more distributed.
nits
+3
-3
+3
-3
server/repo.go
+3
-3
server/repo.go
···
104
104
105
105
dbs := rm.s.getBlockstore(urepo.Did)
106
106
bs := recording_blockstore.New(dbs)
107
-
r, err := repo.OpenRepo(context.TODO(), bs, rootcid)
107
+
r, err := repo.OpenRepo(ctx, bs, rootcid)
108
108
109
109
var results []ApplyWriteResult
110
110
···
196
196
})
197
197
198
198
// delete the record from the repo
199
-
err := r.DeleteRecord(context.TODO(), op.Collection+"/"+*op.Rkey)
199
+
err := r.DeleteRecord(ctx, fmt.Sprintf("%s/%s", op.Collection, *op.Rkey))
200
200
if err != nil {
201
201
return nil, err
202
202
}
···
264
264
}
265
265
266
266
// get a diff of the changes to the repo
267
-
diffops, err := r.DiffSince(context.TODO(), rootcid)
267
+
diffops, err := r.DiffSince(ctx, rootcid)
268
268
if err != nil {
269
269
return nil, err
270
270
}