this repo has no description
remove some commented code
-52
-52
cmd/relayered/relay/account.go
-52
cmd/relayered/relay/account.go
···
30
30
return xu.UID, nil
31
31
}
32
32
33
-
/* XXX: unused?
34
-
func (r *Relay) GetAccountByUID(ctx context.Context, uid uint64) (*models.Account, error) {
35
-
ctx, span := tracer.Start(ctx, "getAccount")
36
-
defer span.End()
37
-
38
-
var acc models.Account
39
-
if err := r.db.First(&acc, uid).Error; err != nil {
40
-
if errors.Is(result.Error, gorm.ErrRecordNotFound) {
41
-
return nil, ErrAccountNotFound
42
-
}
43
-
return nil, err
44
-
}
45
-
46
-
// TODO: is this further check needed?
47
-
if acc.ID == 0 {
48
-
return nil, ErrAccountNotFound
49
-
}
50
-
51
-
return &acc, nil
52
-
}
53
-
*/
54
-
55
33
func (r *Relay) GetAccount(ctx context.Context, did syntax.DID) (*models.Account, error) {
56
34
ctx, span := tracer.Start(ctx, "getAccount")
57
35
defer span.End()
···
64
42
*/
65
43
66
44
var acc models.Account
67
-
// XXX: this needs to be a "find where"
68
45
if err := r.db.Where("did = ?", did).First(&acc).Error; err != nil {
69
46
if errors.Is(err, gorm.ErrRecordNotFound) {
70
47
return nil, ErrAccountNotFound
···
266
243
if res.Error != nil {
267
244
return fmt.Errorf("failed to increment repo count for pds %q: %w", canonicalHost.Hostname, res.Error)
268
245
}
269
-
r.Logger.Warn("XXX creating new account", "did", newAccount.DID)
270
246
if terr := tx.Create(&newAccount).Error; terr != nil {
271
247
r.Logger.Error("failed to create user", "did", newAccount.DID, "err", terr)
272
248
return fmt.Errorf("failed to create other pds user: %w", terr)
···
292
268
if err := r.db.Model(models.Account{}).Where("uid = ?", acc.UID).Update("status", status).Error; err != nil {
293
269
return err
294
270
}
295
-
// XXX: u.SetTakenDown(true)
296
271
297
272
// NOTE: not wiping events for user from persister (backfill window)
298
273
return nil
299
274
}
300
-
301
-
/* XXX
302
-
func (r *Relay) GetRepoRoot(ctx context.Context, uid uint64) (cid.Cid, error) {
303
-
var prevState models.AccountPreviousState
304
-
err := r.db.First(&prevState, uid).Error
305
-
if err == nil {
306
-
return prevState.Cid.CID, nil
307
-
} else if errors.Is(err, gorm.ErrRecordNotFound) {
308
-
return cid.Cid{}, ErrAccountRepoNotFound
309
-
} else {
310
-
r.Logger.Error("user db err", "err", err)
311
-
return cid.Cid{}, fmt.Errorf("user prev db err, %w", err)
312
-
}
313
-
}
314
-
*/
315
-
316
-
/*
317
-
func (r *Relay) GetHostForDID(ctx context.Context, did string) (string, error) {
318
-
var pdsHostname string
319
-
// TODO: use gorm, not "Raw"
320
-
err := r.db.Raw("SELECT pds.host FROM users JOIN pds ON users.pds = pds.id WHERE users.did = ?", did).Scan(&pdsHostname).Error
321
-
if err != nil {
322
-
return "", err
323
-
}
324
-
return pdsHostname, nil
325
-
}
326
-
*/
327
275
328
276
func (r *Relay) ListAccounts(ctx context.Context, cursor int64, limit int) ([]*models.Account, error) {
329
277