-
Notifications
You must be signed in to change notification settings - Fork 165
/
provider.go
59 lines (48 loc) · 1.49 KB
/
provider.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
package oauth
import (
"errors"
"fmt"
"github.com/ArtisanCloud/PowerLibs/v3/object"
"github.com/ArtisanCloud/PowerWeChat/v3/src/kernel"
"strings"
)
func RegisterProvider(app kernel.ApplicationInterface) (*Manager, error) {
config := *app.GetContainer().Config
globalConfig := app.GetConfig()
prepareCallbackURL, err := prepareCallbackUrl(app)
if err != nil {
return nil, err
}
managerConfig := &object.HashMap{
"client_id": config["corp_id"].(string),
"client_secret": "",
"corp_id": config["corp_id"].(string),
"corp_secret": config["secret"].(string),
"redirect": prepareCallbackURL,
}
providerConfig := object.MergeHashMap(globalConfig.All(), managerConfig)
socialite := NewManager(
&object.HashMap{
"wecom": managerConfig,
}, providerConfig, &app)
scopes := globalConfig.Get("oauth.scopes", []string{"snsapi_base"}).([]string)
if len(scopes) > 0 {
socialite.Provider.Scopes(scopes)
}
agentID := globalConfig.Get("agent_id", 0).(int)
if agentID > 0 {
socialite.Provider.SetAgentID(agentID)
}
return socialite, nil
}
func prepareCallbackUrl(app kernel.ApplicationInterface) (string, error) {
config := *app.GetContainer().Config
var callback string
if config["oauth.callbacks"] != nil {
callback = config["oauth.callbacks"].(string)
if strings.Index(callback, "http") == 0 {
return callback, nil
}
}
return callback, errors.New(fmt.Sprintf("OAuth callbacks format invalid, please make sure that schema 'http' added: %v", callback))
}