Skip to content

Commit

Permalink
errors
Browse files Browse the repository at this point in the history
  • Loading branch information
Aeneas Rekkas (arekkas) committed Sep 21, 2016
1 parent adc5972 commit 82f2760
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
9 changes: 5 additions & 4 deletions internal/fosite_store_memory.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ import (
"github.com/ory-am/fosite"
"github.com/ory-am/hydra/client"
"golang.org/x/net/context"
"github.com/pkg/errors"
)

type FositeMemoryStore struct {
Expand All @@ -32,7 +33,7 @@ func (s *FositeMemoryStore) GetOpenIDConnectSession(_ context.Context, authorize
defer s.RUnlock()
cl, ok := s.IDSessions[authorizeCode]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}
return cl, nil
}
Expand All @@ -56,7 +57,7 @@ func (s *FositeMemoryStore) GetAuthorizeCodeSession(_ context.Context, code stri
defer s.RUnlock()
rel, ok := s.AuthorizeCodes[code]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}
return rel, nil
}
Expand All @@ -80,7 +81,7 @@ func (s *FositeMemoryStore) GetAccessTokenSession(_ context.Context, signature s
defer s.RUnlock()
rel, ok := s.AccessTokens[signature]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}
return rel, nil
}
Expand All @@ -104,7 +105,7 @@ func (s *FositeMemoryStore) GetRefreshTokenSession(_ context.Context, signature
defer s.RUnlock()
rel, ok := s.RefreshTokens[signature]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}
return rel, nil
}
Expand Down
8 changes: 4 additions & 4 deletions internal/fosite_store_rethinkdb.go
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@ func (s *FositeRehinkDBStore) GetOpenIDConnectSession(_ context.Context, authori
defer s.RUnlock()
cl, ok := s.IDSessions[authorizeCode]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}
return requestFromRDB(cl, requester.GetSession())
}
Expand All @@ -167,7 +167,7 @@ func (s *FositeRehinkDBStore) GetAuthorizeCodeSession(_ context.Context, code st
defer s.RUnlock()
rel, ok := s.AuthorizeCodes[code]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}

return requestFromRDB(rel, sess)
Expand All @@ -189,7 +189,7 @@ func (s *FositeRehinkDBStore) GetAccessTokenSession(_ context.Context, signature
defer s.RUnlock()
rel, ok := s.AccessTokens[signature]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}

return requestFromRDB(rel, sess)
Expand All @@ -211,7 +211,7 @@ func (s *FositeRehinkDBStore) GetRefreshTokenSession(_ context.Context, signatur
defer s.RUnlock()
rel, ok := s.RefreshTokens[signature]
if !ok {
return nil, fosite.ErrNotFound
return nil, errors.Wrap(fosite.ErrNotFound, "")
}

return requestFromRDB(rel, sess)
Expand Down

0 comments on commit 82f2760

Please sign in to comment.