package handler import ( "encoding/xml" "fmt" "io" "io/ioutil" "net/http" "strings" "text/template" "github.com/bjdgyc/anylink/base" "github.com/bjdgyc/anylink/dbdata" "github.com/bjdgyc/anylink/sessdata" ) func LinkAuth(w http.ResponseWriter, r *http.Request) { // 判断anyconnect客户端 userAgent := strings.ToLower(r.UserAgent()) xAggregateAuth := r.Header.Get("X-Aggregate-Auth") xTranscendVersion := r.Header.Get("X-Transcend-Version") if !(strings.Contains(userAgent, "anyconnect") && xAggregateAuth == "1" && xTranscendVersion == "1") { w.WriteHeader(http.StatusForbidden) fmt.Fprintf(w, "error request") return } body, err := ioutil.ReadAll(r.Body) if err != nil { w.WriteHeader(http.StatusBadRequest) return } defer r.Body.Close() cr := ClientRequest{} err = xml.Unmarshal(body, &cr) if err != nil { w.WriteHeader(http.StatusBadRequest) return } // fmt.Printf("%+v \n", cr) setCommonHeader(w) if cr.Type == "logout" { // 退出删除session信息 if cr.SessionToken != "" { sessdata.DelSessByStoken(cr.SessionToken) } w.WriteHeader(http.StatusOK) return } if cr.Type == "init" { w.WriteHeader(http.StatusOK) data := RequestData{Group: cr.GroupSelect, Groups: dbdata.GetGroupNames()} tplRequest(tpl_request, w, data) return } // 登陆参数判断 if cr.Type != "auth-reply" { w.WriteHeader(http.StatusBadRequest) return } // TODO 用户密码校验 err = dbdata.CheckUser(cr.Auth.Username, cr.Auth.Password, cr.GroupSelect) if err != nil { base.Warn(err) w.WriteHeader(http.StatusOK) data := RequestData{Group: cr.GroupSelect, Groups: dbdata.GetGroupNames(), Error: "用户名或密码错误"} tplRequest(tpl_request, w, data) return } // if !ok { // w.WriteHeader(http.StatusOK) // data := RequestData{Group: cr.GroupSelect, Groups: base.Cfg.UserGroups, Error: "请先激活用户"} // tplRequest(tpl_request, w, data) // return // } // 创建新的session信息 sess := sessdata.NewSession("") sess.Username = cr.Auth.Username sess.Group = cr.GroupSelect sess.MacAddr = strings.ToLower(cr.MacAddressList.MacAddress) sess.UniqueIdGlobal = cr.DeviceId.UniqueIdGlobal other := &dbdata.SettingOther{} _ = dbdata.SettingGet(other) rd := RequestData{SessionId: sess.Sid, SessionToken: sess.Sid + "@" + sess.Token, Banner: other.Banner} w.WriteHeader(http.StatusOK) tplRequest(tpl_complete, w, rd) base.Debug("login", cr.Auth.Username) } const ( tpl_request = iota tpl_complete ) func tplRequest(typ int, w io.Writer, data RequestData) { if typ == tpl_request { t, _ := template.New("auth_request").Parse(auth_request) _ = t.Execute(w, data) return } if strings.Contains(data.Banner, "\n") { // 替换xml文件的换行符 data.Banner = strings.ReplaceAll(data.Banner, "\n", " ") } t, _ := template.New("auth_complete").Parse(auth_complete) _ = t.Execute(w, data) } // 设置输出信息 type RequestData struct { Groups []string Group string Error string // complete SessionId string SessionToken string Banner string } var auth_request = ` {{.Group}} {{.Group}} 168179266 1595829378234 multiple-cert single-sign-on-v2 Login 请输入你的用户名和密码 {{if .Error}} 登陆失败: %s {{end}}
` var auth_complete = ` {{.SessionId}} {{.SessionToken}} {{.Banner}} ssl-dhe 240B97A685B2BFA66AD699B90AAC49EA66495D69 /profile.xml A8B0B07FBA93D06E8501E40AB807AEE2464E73B7 ` var auth_profile = ` false false false IPSec true AllowRemoteUsers pinAllowed Digital_Signature ClientAuth localhost VPN Server localhost `