+1

server/internal/db/oauth.go

reviewed

··· 127 127 if err != nil { 128 128 return nil, errors.New("error scanning oauthsession row: " + err.Error()) 129 129 } 130 130 + session.ID = id 130 131 return &session, nil 131 132 } 132 133

+6

server/internal/recordmanager/recordmanager.go

reviewed

··· 38 38 func (rm *RecordManager) getClient(id int, ctx context.Context) (*oauth.OauthXRPCClient, error) { 39 39 cli, refreshed, err := rm.clientmap.Map(id, ctx) 40 40 if cli == nil { 41 41 + rm.log.Deprintln("resetting client") 41 42 cli, err = rm.resetClient(id, ctx) 42 43 if err != nil { 43 44 return nil, err ··· 49 50 return nil, errors.New("error getting client: " + err.Error()) 50 51 } 51 52 if refreshed { 53 53 + rm.log.Deprintln("refreshed") 52 54 rm.db.UpdateSession(id, cli.GetSession(), ctx) 53 55 } 54 56 ··· 66 68 func (rm *RecordManager) setupClient(session *types.Session) *oauth.OauthXRPCClient { 67 69 client := oauth.NewOauthXRPCClient(rm.db, rm.log, session) 68 70 rm.clientmap.Append(session.ID, client, session.Expiration) 71 71 + rm.log.Deprintf("appended cli %d", session.ID) 72 72 + if client == nil { 73 73 + rm.log.Println("client nil!") 74 74 + } 69 75 return client 70 76 } 71 77