本文整理汇总了Golang中code/google/com/p/goauth2/oauth.Transport类的典型用法代码示例。如果您正苦于以下问题:Golang Transport类的具体用法?Golang Transport怎么用?Golang Transport使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Transport类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: initTransport
func initTransport(transport *oauth.Transport) error {
// First: check the cache.
if token, err := transport.Config.TokenCache.Token(); err == nil {
// We have a token, refresh it. The lifetime is 1h, so we always
// refresh to ensure lengthy commands do not time out.
transport.Token = token
err := transport.Refresh()
if err == nil {
return nil
}
log.Infof("token refresh failed, requesting new one")
}
// Get a new token. Pops up a browser window (hopefully).
randState := fmt.Sprintf("st%d", time.Now().UnixNano())
authURL := transport.Config.AuthCodeURL(randState)
log.Infof("Opening auth URL in browser: %s", authURL)
log.Infof("If the URL doesn't open please open it manually and copy the code here.")
openURL(authURL)
code := getCodeFromStdin()
_, err := transport.Exchange(code)
if err != nil {
log.Infof("problem exchanging code: %v", err)
return err
}
return nil
}
开发者ID:bdarnell,项目名称:cockroach-prod,代码行数:29,代码来源:auth_util.go
示例2: VerifyClaim
// VerifyClaim checks that the printer has been claimed.
// If the printer is claimed, VerifyClaim returns no error.
// If the printer is unclaimed, VerifyClaim retruns ErrUnclaimed.
// It is possible for VerifyClaim to return other errors, such as
// in the case of network problems.
//
// A side effect of verifying that claim is that Google creates
// a synthetic account that is only useful in a future call to
// NewServer, to manage just this one printer.
// The information about that account can be retrieved
// from the Auth, Printer, and Server methods after VerifyClaim
// succeeds.
func (p *OpenPrinter) VerifyClaim() error {
if p.verify != nil {
return nil
}
var resp verifyResponse
if err := jsonRPC(&p.auth, "GET", p.register.PollingURL+p.auth.APIClientID, nil, &resp); err != nil {
return fmt.Errorf("VerifyClaim: %v", err)
}
var tr oauth.Transport
tr.Config = &oauth.Config{
ClientId: p.auth.APIClientID,
ClientSecret: p.auth.APIClientSecret,
Scope: "https://www.googleapis.com/auth/cloudprint https://www.googleapis.com/auth/googletalk",
AuthURL: "https://accounts.google.com/o/oauth2/auth",
TokenURL: "https://accounts.google.com/o/oauth2/token",
RedirectURL: "oob",
}
tok, err := tr.Exchange(resp.AuthorizationCode)
if err != nil {
return fmt.Errorf("VerifyClaim: oauth exchange: %v", err)
}
p.auth.Token = *tok
p.auth.TokenUser = resp.UserEmail
p.auth.XMPPJID = resp.XMPPJID
p.verify = &resp
return nil
}
开发者ID:0x7cc,项目名称:rsc,代码行数:42,代码来源:print.go
示例3: authenticate
func authenticate(transport *oauth.Transport) error {
code := make(chan string)
listener, err := net.Listen("tcp", "localhost:0")
if err != nil {
return err
}
go http.Serve(listener, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
fmt.Fprint(w, closeMessage)
code <- r.FormValue("code") // send code to OAuth flow
listener.Close() // shut down HTTP server
}))
transport.Config.RedirectURL = fmt.Sprintf("http://%s/", listener.Addr())
url := transport.Config.AuthCodeURL("")
if err := openURL(url); err != nil {
fmt.Fprintln(os.Stderr, visitMessage)
} else {
fmt.Fprintln(os.Stderr, openedMessage)
}
fmt.Fprintf(os.Stderr, "\n%s\n\n", url)
fmt.Fprintln(os.Stderr, resumeMessage)
_, err = transport.Exchange(<-code)
return err
}
开发者ID:harik,项目名称:streak,代码行数:26,代码来源:oauth.go
示例4: rtRoot
func rtRoot(w http.ResponseWriter, r *http.Request, args []string) error {
sess := getSession(r)
if sess == nil || sess.token == nil {
http.Redirect(w, r, "/oauth2/login", http.StatusFound)
return nil
}
t := oauth.Transport{
Config: oauthConfig,
Token: sess.token,
}
if er := t.Refresh(); er != nil {
return er
}
res, er := t.Client().Get("https://api.guildwars2.com/v2/account")
if er != nil {
return er
}
w.Header().Set("Content-Type", "application/json")
io.Copy(w, res.Body)
return nil
}
开发者ID:VictorJi,项目名称:api-cdi,代码行数:26,代码来源:main.go
示例5: get_profile_facebook
func get_profile_facebook(transport *oauth.Transport) (Profile, error) {
resp, err := transport.Client().Get("https://graph.facebook.com/me?fields=id,name,first_name,last_name,email,username,picture.width(256).height(256)")
if err != nil {
return nil, err
}
defer resp.Body.Close()
if resp.StatusCode/100 != 2 {
return nil, fmt.Errorf("http status: %d", resp.StatusCode)
}
data, err := ioutil.ReadAll(resp.Body)
if err != nil {
return nil, err
}
profile := &FacebookProfile{}
err = json.Unmarshal(data, &profile)
if err != nil {
return nil, err
}
profile.raw = data
return profile, nil
}
开发者ID:rogeriomarques,项目名称:oapx,代码行数:28,代码来源:p_facebook.go
示例6: get_profile_github
func get_profile_github(transport *oauth.Transport) (Profile, error) {
resp, err := transport.Client().Get("https://api.github.com/user")
if err != nil {
return nil, err
}
defer resp.Body.Close()
if resp.StatusCode/100 != 2 {
return nil, fmt.Errorf("http status: %d", resp.StatusCode)
}
data, err := ioutil.ReadAll(resp.Body)
if err != nil {
return nil, err
}
profile := &GithubProfile{}
err = json.Unmarshal(data, &profile)
if err != nil {
return nil, err
}
profile.raw = data
return profile, nil
}
开发者ID:rogeriomarques,项目名称:oapx,代码行数:28,代码来源:p_github.go
示例7: getToken
func getToken(t *oauth.Transport) {
var c string
authURL := config.AuthCodeURL("state")
log.Printf("Open in browser: %v\n", authURL)
log.Printf("Enter verification code: ")
fmt.Scanln(&c)
_, err := t.Exchange(c)
if err != nil {
log.Fatalf("An error occurred exchanging the code: %v\n", err)
}
}
开发者ID:nickpresta,项目名称:gowave,代码行数:11,代码来源:main.go
示例8: GetHttpClient
// GetHttpClient returns a http.Client which performs authenticated requests as
// the logged-in user.
func GetHttpClient(r *http.Request) *http.Client {
s, err := getSession(r)
if err != nil {
glog.Errorf("Failed to get session state; falling back to default http client.")
return &http.Client{}
}
t := oauth.Transport{
Config: oauthConfig,
Token: s.Token,
}
return t.Client()
}
开发者ID:Tiger66639,项目名称:skia-buildbot,代码行数:14,代码来源:login.go
示例9: fetch_all_contacts
// This function does the work of obtaining the contacts from the server
func fetch_all_contacts(transport *oauth.Transport) contacts_response {
// XXX: increase the max-results
request_url := fmt.Sprintf("https://www.google.com/m8/feeds/contacts/default/thin?alt=json&max-results=10000")
// fmt.Println("request_url is", request_url)
resp, _ := transport.Client().Get(request_url)
defer resp.Body.Close()
var result contacts_response
err := json.NewDecoder(resp.Body).Decode(&result)
if err != nil {
log.Fatal(err)
}
return result
}
开发者ID:matthewcosgrove,项目名称:gonetact,代码行数:15,代码来源:get_contacts.go
示例10: authorize
func authorize(w http.ResponseWriter, r *http.Request, t *oauth.Transport) (*oauth.Token, error) {
//Get the code from the response
code := r.FormValue("code")
if code == "" {
// Get an authorization code from the data provider.
// ("Please ask the user if I can access this resource.")
url := config.AuthCodeURL("")
http.Redirect(w, r, url, http.StatusFound)
return nil, nil
}
// Exchange the authorization code for an access token.
// ("Here's the code you gave the user, now give me a token!")
return t.Exchange(code)
}
开发者ID:rjourde,项目名称:go.authentication,代码行数:15,代码来源:sessions_controllers.go
示例11: userData
// obtain user data from constant REQUEST_API
// UserInfo is used to Unmarshal the json response
// returns UserInfor strct for display
func userData(w http.ResponseWriter, transport *oauth.Transport, token string, ui *UserInfo) (UserInfo, error) {
url := REQUEST_API + token
resp, err := transport.Client().Get(url)
if err != nil {
http.Error(w, "api error", http.StatusInternalServerError)
return *ui, errors.New("api error")
}
defer resp.Body.Close()
d, _ := ioutil.ReadAll(resp.Body)
err = json.Unmarshal(d, &ui)
return *ui, nil
}
开发者ID:scirelli,项目名称:go-google-oauth2,代码行数:18,代码来源:server.go
示例12: handleOAuth2Callback
func handleOAuth2Callback(t *oauth.Transport, s sessions.Session, w http.ResponseWriter, r *http.Request) {
next := extractPath(r.URL.Query().Get("state"))
code := r.URL.Query().Get("code")
tk, err := t.Exchange(code)
if err != nil {
// Pass the error message, or allow dev to provide its own
// error handler.
http.Redirect(w, r, PathError, codeRedirect)
return
}
// Store the credentials in the session.
val, _ := json.Marshal(tk)
s.Set(keyToken, val)
http.Redirect(w, r, next, codeRedirect)
}
开发者ID:jinpeng,项目名称:oauth2,代码行数:15,代码来源:oauth2.go
示例13: initializeApiService
func initializeApiService(c appengine.Context) (*api.Service, error) {
d := datastore.New(c)
token, err := d.FindToken(user.Current(c).Email)
if err != nil {
return nil, err
}
transport := oauth.Transport{
Token: &token,
Config: &cfg,
Transport: urlfetch.Client(c).Transport,
}
return api.NewFromClient(transport.Client(), token.AccessToken), nil
}
开发者ID:pcarleton,项目名称:vensplit,代码行数:15,代码来源:app.go
示例14: newOauthClient
func newOauthClient(storePath string) *http.Client {
config := &oauth.Config{
ClientId: ClientId,
ClientSecret: ClientSecret,
Scope: raw.ComputeScope,
AuthURL: AuthURL,
TokenURL: TokenURL,
}
token := token(storePath, config)
t := oauth.Transport{
Token: token,
Config: config,
Transport: http.DefaultTransport,
}
return t.Client()
}
开发者ID:ajoy123,项目名称:docker-machine,代码行数:16,代码来源:auth_util.go
示例15: hasValidToken
// Returns true if we have a valid cached token
func hasValidToken(cacheFile oauth.CacheFile, transport *oauth.Transport) bool {
// Check if we have a cached token
token, err := cacheFile.Token()
if err != nil {
return false
}
// Refresh token if its expired
if token.Expired() {
transport.Token = token
err = transport.Refresh()
if err != nil {
fmt.Println(err)
return false
}
}
return true
}
开发者ID:hyenadog,项目名称:gdrive,代码行数:19,代码来源:auth.go
示例16: httpGET
func httpGET(auth *Auth, url string) ([]byte, error) {
verb := "GET"
req, err := http.NewRequest("GET", url, nil)
if err != nil {
return nil, err
}
if i := strings.Index(url, "?"); i >= 0 {
url = url[:i]
}
req.Header.Set("X-CloudPrint-Proxy", auth.ProxyID)
var client *http.Client
if auth.Token.AccessToken != "" {
var tr oauth.Transport
tr.Config = &oauth.Config{
ClientId: auth.APIClientID,
ClientSecret: auth.APIClientSecret,
Scope: "https://www.googleapis.com/auth/cloudprint https://www.googleapis.com/auth/googletalk",
AuthURL: "https://accounts.google.com/o/oauth2/auth",
TokenURL: "https://accounts.google.com/o/oauth2/token",
RedirectURL: "oob",
}
tr.Token = &auth.Token
client = tr.Client()
} else {
client = http.DefaultClient
}
resp, err := client.Do(req)
if err != nil {
return nil, fmt.Errorf("%s %s: %v", verb, url, err)
}
defer resp.Body.Close()
var buf bytes.Buffer
_, err = io.Copy(&buf, resp.Body)
if err != nil {
return nil, fmt.Errorf("%s %s: reading HTTP response: %v", verb, url, err)
}
// TODO: Check 200
return buf.Bytes(), nil
}
开发者ID:0x7cc,项目名称:rsc,代码行数:43,代码来源:rpc.go
示例17: Fetch
func (self *GoogleUser) Fetch(transport *oauth.Transport) (*GoogleUser, error) {
r, err := transport.Client().Get(GOOGLE_USER_INFO)
if err != nil {
return nil, err
}
defer r.Body.Close()
body, _ := ioutil.ReadAll(r.Body)
if err != nil {
return nil, err
}
s := string(body)
decoder := json.NewDecoder(strings.NewReader(s))
result := &GoogleUser{}
err = decoder.Decode(&result)
if err != nil {
return nil, err
}
return result, nil
}
开发者ID:hanswry,项目名称:seven5,代码行数:19,代码来源:goog.go
示例18: obtainToken
func obtainToken(transport *oauth.Transport) {
t, _ := config.TokenCache.Token()
if t != nil {
return
}
authUrl := config.AuthCodeURL("state")
fmt.Printf("Go to the following link in your browser: %v\n", authUrl)
fmt.Printf("Enter verification code: ")
var code string
fmt.Scanln(&code)
// Read the code, and exchange it for a token.
_, err := transport.Exchange(code)
if err != nil {
log.Errorf("An error occurred exchanging the token: %v\n", err)
panic(-2)
}
}
开发者ID:santeriv,项目名称:gdrive-webdav,代码行数:20,代码来源:gdrive.go
示例19: getBaseUserInfo
func (a *GoogleOAuthHandler) getBaseUserInfo(t *oauth.Transport) *googleUserInfoJSON {
req, err := t.Client().Get("https://www.googleapis.com/oauth2/v1/userinfo")
if err != nil {
panic(err)
}
defer req.Body.Close()
body, _ := ioutil.ReadAll(req.Body)
var user_info googleUserInfoJSON
json_err := json.Unmarshal(body, &user_info)
if json_err != nil {
panic(json_err)
}
if user_info.Id == "" {
panic(errors.New(fmt.Sprintf("Incorrect JSON response from Google: %s", body)))
}
return &user_info
}
开发者ID:felipeweb,项目名称:httpapp,代码行数:21,代码来源:google-oauth-handler.go
示例20: getExtendedUserInfo
func (a *GoogleOAuthHandler) getExtendedUserInfo(t *oauth.Transport, info *googleUserInfoJSON) *googlePeopleInfoJSON {
req, err := t.Client().Get(fmt.Sprintf("https://www.googleapis.com/plus/v1/people/%s", info.Id))
if err != nil {
panic(err)
}
defer req.Body.Close()
body, _ := ioutil.ReadAll(req.Body)
var user_info googlePeopleInfoJSON
json_err := json.Unmarshal(body, &user_info)
if json_err != nil {
panic(json_err)
}
if user_info.Id != info.Id {
panic(errors.New(fmt.Sprintf("Incorrect JSON response from Google: %s", body)))
}
return &user_info
}
开发者ID:felipeweb,项目名称:httpapp,代码行数:21,代码来源:google-oauth-handler.go
注:本文中的code/google/com/p/goauth2/oauth.Transport类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论