appview, knotserver: add didAssign event and PDS rewrite on login #1143

+2 -3

appview/db/repos.go

··· 674 674 675 675 type PdsRewrite struct { 676 676 Id int 677 677 - UserDid string 678 677 RepoDid string 679 678 RecordNsid string 680 679 RecordRkey string ··· 683 682 684 683 func GetPendingPdsRewrites(e Execer, userDid string) ([]PdsRewrite, error) { 685 684 rows, err := e.Query( 686 686 - `SELECT id, user_did, repo_did, record_nsid, record_rkey, old_repo_at 685 685 + `SELECT id, repo_did, record_nsid, record_rkey, old_repo_at 687 686 FROM pds_rewrite_status 688 687 WHERE user_did = ? AND status = 'pending'`, 689 688 userDid, ··· 696 695 var rewrites []PdsRewrite 697 696 for rows.Next() { 698 697 var r PdsRewrite 699 699 - if err := rows.Scan(&r.Id, &r.UserDid, &r.RepoDid, &r.RecordNsid, &r.RecordRkey, &r.OldRepoAt); err != nil { 698 698 + if err := rows.Scan(&r.Id, &r.RepoDid, &r.RecordNsid, &r.RecordRkey, &r.OldRepoAt); err != nil { 700 699 return nil, err 701 700 } 702 701 rewrites = append(rewrites, r)

appview/oauth/handler.go

This file has not been changed.

appview/state/knotstream.go

This file has not been changed.

knotserver/db/didassign.go

This file has not been changed.

knotserver/db/events.go

This file has not been changed.

knotserver/events.go

This file has not been changed.

knotserver/git.go

This file has not been changed.

knotserver/internal.go

This file has not been changed.

knotserver/xrpc/xrpc.go

This file has not been changed.

rbac/rbac.go

This file has not been changed.

rbac/rbac_test.go

This file has not been changed.