remove cache

example_test.go

@@ -51,23 +51,6 @@ func Example_config() {
 	// start making authenticated requests.
 	client := http.Client{Transport: t}
 	client.Get("...")
-
-	// Alternatively, you can initiate a new transport
-	// with tokens from a cache.
-	cache := oauth2.NewFileCache("/path/to/file")
-	// NewTransportWithCache will try to read the cached
-	// token, if any error occurs, it returns the error.
-	// If a token is available at the cache, initiates
-	// a new transport authorized and authenticated with
-	// the read token. If token expires, and a new access
-	// token is retrieved, it writes the newly fetched
-	// token to the cache.
-	t, err = conf.NewTransportWithCache(cache)
-	if err != nil {
-		log.Fatal(err)
-	}
-	client = http.Client{Transport: t}
-	client.Get("...")
 }
 
 func Example_jWTConfig() {
@@ -95,18 +78,4 @@ func Example_jWTConfig() {
 	// request will be made on the behalf of [email protected].
 	client = http.Client{Transport: conf.NewTransportWithUser("[email protected]")}
 	client.Get("...")
-
-	// Alternatively you can iniate a transport with
-	// a token read from the cache.
-	// If the existing access token expires, and a new access token is
-	// retrieved, the newly fetched token will be written to the cache.
-	cache := oauth2.NewFileCache("/path/to/file")
-	t, err := conf.NewTransportWithCache(cache)
-	if err != nil {
-		log.Fatal(err)
-	}
-	client = http.Client{Transport: t}
-	// The following request will be authorized by the token
-	// retrieved from the cache.
-	client.Get("...")
 }

google/appengine.go

@@ -5,8 +5,9 @@ package google
 import (
 	"strings"
 
-	"appengine"
 	"github.com/golang/oauth2"
+
+	"appengine"
 )
 
 // AppEngineConfig represents a configuration for an
@@ -28,12 +29,6 @@ func (c *AppEngineConfig) NewTransport() oauth2.Transport {
 	return oauth2.NewAuthorizedTransport(c, nil)
 }
 
-// NewTransport returns a token-caching transport that authorizes
-// the requests with the application's service account.
-func (c *AppEngineConfig) NewTransportWithCache(cache oauth2.Cache) (oauth2.Transport, error) {
-	return oauth2.NewAuthorizedTransportWithCache(c, cache)
-}
-
 // FetchToken fetches a new access token for the provided scopes.
 func (c *AppEngineConfig) FetchToken(existing *oauth2.Token) (*oauth2.Token, error) {
 	token, expiry, err := appengine.AccessToken(c.context, strings.Join(c.scopes, " "))

google/appenginevm.go

@@ -14,7 +14,6 @@ import (
 type AppEngineConfig struct {
 	context appengine.Context
 	scopes  []string
-	cache   oauth2.Cache
 }
 
 // NewAppEngineConfig creates a new AppEngineConfig for the
@@ -29,12 +28,6 @@ func (c *AppEngineConfig) NewTransport() oauth2.Transport {
 	return oauth2.NewAuthorizedTransport(c, nil)
 }
 
-// NewTransport returns a token-caching transport that authorizes
-// the requests with the application's service account.
-func (c *AppEngineConfig) NewTransportWithCache(cache oauth2.Cache) (oauth2.Transport, error) {
-	return oauth2.NewAuthorizedTransportWithCache(c, cache)
-}
-
 // FetchToken fetches a new access token for the provided scopes.
 func (c *AppEngineConfig) FetchToken(existing *oauth2.Token) (*oauth2.Token, error) {
 	token, expiry, err := appengine.AccessToken(c.context, strings.Join(c.scopes, " "))

google/example_test.go

@@ -45,23 +45,6 @@ func Example_webServer() {
 	}
 	client := http.Client{Transport: t}
 	client.Get("...")
-
-	// Alternatively you can initiate a new transport
-	// with a token from a cache.
-	cache := oauth2.NewFileCache("/path/to/file")
-	// NewTransportWithCache will try to read the cached
-	// token, if any error occurs, it returns the error.
-	// If a token is available at the cache, initiates
-	// a new transport authorized and authenticated with
-	// the read token. If token expires, and a new access
-	// token is retrieved, it writes the newly fetched
-	// token to the cache.
-	t, err = config.NewTransportWithCache(cache)
-	if err != nil {
-		log.Fatal(err)
-	}
-	client = http.Client{Transport: t}
-	client.Get("...")
 }
 
 func Example_serviceAccounts() {
@@ -92,20 +75,6 @@ func Example_serviceAccounts() {
 	// request will be made on the behalf of [email protected].
 	client = http.Client{Transport: config.NewTransportWithUser("[email protected]")}
 	client.Get("...")
-
-	// Alternatively you can iniate a transport with
-	// a token read from the cache.
-	// If the existing access token expires, and a new access token is
-	// retrieved, the newly fetched token will be written to the cache.
-	cache := oauth2.NewFileCache("/path/to/file")
-	t, err := config.NewTransportWithCache(cache)
-	if err != nil {
-		log.Fatal(err)
-	}
-	client = http.Client{Transport: t}
-	// The following request will be authorized by the token
-	// retrieved from the cache.
-	client.Get("...")
 }
 
 func Example_appEngine() {

jwt.go

@@ -70,13 +70,6 @@ func (c *JWTConfig) NewTransportWithUser(user string) Transport {
 	return NewAuthorizedTransport(c, &Token{Subject: user})
 }
 
-// NewTransportWithCache initializes a transport by reading the initial
-// token from the provided cache. If a token refreshing occurs, it
-// writes the newly fetched token back to the cache.
-func (c *JWTConfig) NewTransportWithCache(cache Cache) (Transport, error) {
-	return NewAuthorizedTransportWithCache(c, cache)
-}
-
 // fetchToken retrieves a new access token and updates the existing token
 // with the newly fetched credentials.
 func (c *JWTConfig) FetchToken(existing *Token) (token *Token, err error) {

oauth2.go

@@ -153,13 +153,6 @@ func (c *Config) NewTransportWithCode(exchangeCode string) (Transport, error) {
 	return NewAuthorizedTransport(c, token), nil
 }
 
-// NewTransportWithCache initializes a transport by reading the initial
-// token from the provided cache. If a token refreshing occurs, it
-// writes the newly fetched token back to the cache.
-func (c *Config) NewTransportWithCache(cache Cache) (Transport, error) {
-	return NewAuthorizedTransportWithCache(c, cache)
-}
-
 // FetchToken retrieves a new access token and updates the existing token
 // with the newly fetched credentials. If existing token doesn't
 // contain a refresh token, it returns an error.

oauth2_test.go

@@ -62,7 +62,7 @@ func TestExchangePayload(t *testing.T) {
 			return nil, errors.New("no response")
 		},
 	}
-	conf.Exchange("exchange-code")
+	conf.exchange("exchange-code")
 }
 
 func TestExchangingTransport(t *testing.T) {

transport.go

@@ -76,9 +76,6 @@ type Transport interface {
 }
 
 type authorizedTransport struct {
-	// Cache to persist changes to the token that
-	// authorizes the current transport.
-	cache   Cache
 	fetcher TokenFetcher
 	token   *Token
 
@@ -93,19 +90,6 @@ func NewAuthorizedTransport(fetcher TokenFetcher, token *Token) Transport {
 	return &authorizedTransport{fetcher: fetcher, token: token}
 }
 
-// NewAuthorizedTransportWithCache creates a new transport that uses
-// the provided token fetcher and cache. Before constructing the new
-// transport, it will try to read from the cache to see if there
-// is an existing token.
-func NewAuthorizedTransportWithCache(fetcher TokenFetcher, cache Cache) (transport Transport, err error) {
-	var token *Token
-	if token, err = cache.Read(); err != nil {
-		return
-	}
-	transport = &authorizedTransport{fetcher: fetcher, cache: cache, token: token}
-	return
-}
-
 // RoundTrip authorizes the request with the existing token.
 // If token is expired, tries to refresh/fetch a new token.
 func (t *authorizedTransport) RoundTrip(req *http.Request) (resp *http.Response, err error) {
@@ -176,9 +160,6 @@ func (t *authorizedTransport) RefreshToken() error {
 	}
 
 	t.token = token
-	if t.cache != nil {
-		return t.cache.Write(token)
-	}
 
 	return nil
 }