-
Notifications
You must be signed in to change notification settings - Fork 150
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #92 from JesusIslam/master
[Feature] Adding Gitlab Provider
- Loading branch information
Showing
8 changed files
with
487 additions
and
18 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,106 @@ | ||
| package oauth2 | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "fmt" | ||
| "io/ioutil" | ||
| "net/http" | ||
| "strings" | ||
|
|
||
| "github.com/tarent/loginsrv/model" | ||
| ) | ||
|
|
||
| var gitlabAPI = "https://gitlab.com/api/v4" | ||
|
|
||
| func init() { | ||
| RegisterProvider(providerGitlab) | ||
| } | ||
|
|
||
| // GitlabUser is used for parsing the gitlab response | ||
| type GitlabUser struct { | ||
| Username string `json:"username,omitempty"` | ||
| AvatarURL string `json:"avatar_url,omitempty"` | ||
| Name string `json:"name,omitempty"` | ||
| Email string `json:"email,omitempty"` | ||
| } | ||
|
|
||
| type GitlabGroup struct { | ||
| FullPath string `json:"full_path,omitempty"` | ||
| } | ||
|
|
||
| var providerGitlab = Provider{ | ||
| Name: "gitlab", | ||
| AuthURL: "https://gitlab.com/oauth/authorize", | ||
| TokenURL: "https://gitlab.com/oauth/token", | ||
| GetUserInfo: func(token TokenInfo) (model.UserInfo, string, error) { | ||
| gu := GitlabUser{} | ||
| url := fmt.Sprintf("%v/user?access_token=%v", gitlabAPI, token.AccessToken) | ||
|
|
||
| var respUser *http.Response | ||
| respUser, err := http.Get(url) | ||
| if err != nil { | ||
| return model.UserInfo{}, "", err | ||
| } | ||
| defer respUser.Body.Close() | ||
|
|
||
| if !strings.Contains(respUser.Header.Get("Content-Type"), "application/json") { | ||
| return model.UserInfo{}, "", fmt.Errorf("wrong content-type on gitlab get user info: %v", respUser.Header.Get("Content-Type")) | ||
| } | ||
|
|
||
| if respUser.StatusCode != 200 { | ||
| return model.UserInfo{}, "", fmt.Errorf("got http status %v on gitlab get user info", respUser.StatusCode) | ||
| } | ||
|
|
||
| b, err := ioutil.ReadAll(respUser.Body) | ||
| if err != nil { | ||
| return model.UserInfo{}, "", fmt.Errorf("error reading gitlab get user info: %v", err) | ||
| } | ||
|
|
||
| err = json.Unmarshal(b, &gu) | ||
| if err != nil { | ||
| return model.UserInfo{}, "", fmt.Errorf("error parsing gitlab get user info: %v", err) | ||
| } | ||
|
|
||
| gg := []*GitlabGroup{} | ||
| url = fmt.Sprintf("%v/groups?access_token=%v", gitlabAPI, token.AccessToken) | ||
|
|
||
| var respGroup *http.Response | ||
| respGroup, err = http.Get(url) | ||
| if err != nil { | ||
| return model.UserInfo{}, "", err | ||
| } | ||
| defer respGroup.Body.Close() | ||
|
|
||
| if !strings.Contains(respGroup.Header.Get("Content-Type"), "application/json") { | ||
| return model.UserInfo{}, "", fmt.Errorf("wrong content-type on gitlab get groups info: %v", respGroup.Header.Get("Content-Type")) | ||
| } | ||
|
|
||
| if respGroup.StatusCode != 200 { | ||
| return model.UserInfo{}, "", fmt.Errorf("got http status %v on gitlab get groups info", respGroup.StatusCode) | ||
| } | ||
|
|
||
| g, err := ioutil.ReadAll(respGroup.Body) | ||
| if err != nil { | ||
| return model.UserInfo{}, "", fmt.Errorf("error reading gitlab get groups info: %v", err) | ||
| } | ||
|
|
||
| err = json.Unmarshal(g, &gg) | ||
| if err != nil { | ||
| return model.UserInfo{}, "", fmt.Errorf("error parsing gitlab get groups info: %v", err) | ||
| } | ||
|
|
||
| groups := make([]string, len(gg)) | ||
| for i := 0; i < len(gg); i++ { | ||
| groups[i] = gg[i].FullPath | ||
| } | ||
|
|
||
| return model.UserInfo{ | ||
| Sub: gu.Username, | ||
| Picture: gu.AvatarURL, | ||
| Name: gu.Name, | ||
| Email: gu.Email, | ||
| Groups: groups, | ||
| Origin: "gitlab", | ||
| }, `{"user":` + string(b) + `,"groups":` + string(g) + `}`, nil | ||
| }, | ||
| } |
Oops, something went wrong.