back interdiff of round #1 and #0

appview: oauth: swap out db store for redis cache #212

merged
opened by anirudh.fi targeting master from push-ruoqnsmttnxx
options
unified split
files
appview
cache
session
store.go
oauth
handler
handler.go
oauth.go
state
router.go
state.go
ERROR
appview/oauth/handler/handler.go

Failed to calculate interdiff for this file.

ERROR
appview/oauth/oauth.go

Failed to calculate interdiff for this file.

ERROR
appview/state/router.go

Failed to calculate interdiff for this file.

ERROR
appview/state/state.go

Failed to calculate interdiff for this file.

NEW
appview/cache/session/store.go
 
···

       
102

       
 

       
}


     

       
103

       
 

       



     

       
104

       
 

       
func (s *SessionStore) GetRequestByState(ctx context.Context, state string) (*OAuthRequest, error) {


     

       
105

       
-

       
	didKey, err := s.getRequestKey(ctx, state)


     

       
106

       
 

       
	if err != nil {


     

       
107

       
 

       
		return nil, err


     

       
108

       
 

       
	}


     
···

       
127

       
 

       
}


     

       
128

       
 

       



     

       
129

       
 

       
func (s *SessionStore) DeleteRequestByState(ctx context.Context, state string) error {


     

       
130

       
-

       
	didKey, err := s.getRequestKey(ctx, state)


     

       
131

       
 

       
	if err != nil {


     

       
132

       
 

       
		return err


     

       
133

       
 

       
	}


     

       
134

       
 

       



     

       
135

       
-

       
	err = s.cache.Del(ctx, fmt.Sprintf(stateKey, "state")).Err()


     

       
136

       
 

       
	if err != nil {


     

       
137

       
 

       
		return err


     

       
138

       
 

       
	}


     
···

       
102

       
 

       
}


     

       
103

       
 

       



     

       
104

       
 

       
func (s *SessionStore) GetRequestByState(ctx context.Context, state string) (*OAuthRequest, error) {


     

       
105

       
+

       
	didKey, err := s.getRequestKeyFromState(ctx, state)


     

       
106

       
 

       
	if err != nil {


     

       
107

       
 

       
		return nil, err


     

       
108

       
 

       
	}


     
···

       
127

       
 

       
}


     

       
128

       
 

       



     

       
129

       
 

       
func (s *SessionStore) DeleteRequestByState(ctx context.Context, state string) error {


     

       
130

       
+

       
	didKey, err := s.getRequestKeyFromState(ctx, state)


     

       
131

       
 

       
	if err != nil {


     

       
132

       
 

       
		return err


     

       
133

       
 

       
	}


     

       
134

       
 

       



     

       
135

       
+

       
	err = s.cache.Del(ctx, fmt.Sprintf(stateKey, state)).Err()


     

       
136

       
 

       
	if err != nil {


     

       
137

       
 

       
		return err


     

       
138

       
 

       
	}