LanQin_
31435c1e97
- 新增权限目录、系统权限组与用户权限组分配，后台路由改为按权限粒度控制。 - 支持创建、编辑、查看和删除自定义权限组，并为用户绑定权限组。 - 前端后台界面按权限动态展示菜单与操作项，补充用户/权限组相关类型与交互。
262 lines
8.1 KiB
Go
262 lines
8.1 KiB
Go
package app
|
|
|
|
import (
|
|
"context"
|
|
"crypto/hmac"
|
|
"crypto/rand"
|
|
"crypto/sha1"
|
|
"database/sql"
|
|
"encoding/base32"
|
|
"encoding/binary"
|
|
"errors"
|
|
"fmt"
|
|
"net/http"
|
|
"net/url"
|
|
"strings"
|
|
"time"
|
|
)
|
|
|
|
type loginChallenge struct {
|
|
ID string
|
|
UserID string
|
|
ExpiresAt time.Time
|
|
}
|
|
|
|
func newTOTPSecret() (string, error) {
|
|
buf := make([]byte, 20)
|
|
if _, err := rand.Read(buf); err != nil {
|
|
return "", err
|
|
}
|
|
return base32.StdEncoding.WithPadding(base32.NoPadding).EncodeToString(buf), nil
|
|
}
|
|
|
|
func totpProvisioningURI(issuer, account, secret string) string {
|
|
issuer = strings.TrimSpace(issuer)
|
|
account = strings.TrimSpace(account)
|
|
secret = strings.TrimSpace(secret)
|
|
label := url.PathEscape(issuer + ":" + account)
|
|
return fmt.Sprintf("otpauth://totp/%s?secret=%s&issuer=%s&digits=6&period=30", label, url.QueryEscape(secret), url.QueryEscape(issuer))
|
|
}
|
|
|
|
func generateTOTP(secret string, now time.Time) (string, error) {
|
|
key, err := decodeTOTPSecret(secret)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
counter := now.Unix() / 30
|
|
return generateTOTPForCounter(key, counter), nil
|
|
}
|
|
|
|
func verifyTOTP(secret, code string, now time.Time) bool {
|
|
code = strings.TrimSpace(code)
|
|
if len(code) != 6 {
|
|
return false
|
|
}
|
|
for _, r := range code {
|
|
if r < '0' || r > '9' {
|
|
return false
|
|
}
|
|
}
|
|
key, err := decodeTOTPSecret(secret)
|
|
if err != nil {
|
|
return false
|
|
}
|
|
counter := now.Unix() / 30
|
|
for delta := int64(-1); delta <= 1; delta++ {
|
|
if generateTOTPForCounter(key, counter+delta) == code {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
func decodeTOTPSecret(secret string) ([]byte, error) {
|
|
secret = strings.ToUpper(strings.TrimSpace(secret))
|
|
if secret == "" {
|
|
return nil, errors.New("empty secret")
|
|
}
|
|
return base32.StdEncoding.WithPadding(base32.NoPadding).DecodeString(secret)
|
|
}
|
|
|
|
func generateTOTPForCounter(key []byte, counter int64) string {
|
|
var msg [8]byte
|
|
binary.BigEndian.PutUint64(msg[:], uint64(counter))
|
|
mac := hmac.New(sha1.New, key)
|
|
_, _ = mac.Write(msg[:])
|
|
sum := mac.Sum(nil)
|
|
offset := sum[len(sum)-1] & 0x0f
|
|
value := binary.BigEndian.Uint32(sum[offset : offset+4])
|
|
value &= 0x7fffffff
|
|
return fmt.Sprintf("%06d", value%1000000)
|
|
}
|
|
|
|
func (a *App) createLoginChallenge(ctx context.Context, userID string) (string, error) {
|
|
token := randomToken()
|
|
now := a.now().UTC()
|
|
expires := now.Add(5 * time.Minute)
|
|
_, err := a.db.ExecContext(ctx, `INSERT INTO login_challenges(id,user_id,token_hash,expires_at,created_at) VALUES(?,?,?,?,?)`,
|
|
newID("lch"), userID, hashToken(token), expires.Format(time.RFC3339Nano), now.Format(time.RFC3339Nano))
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
return token, nil
|
|
}
|
|
|
|
func (a *App) loginChallengeByToken(ctx context.Context, token string) (*loginChallenge, error) {
|
|
row := a.db.QueryRowContext(ctx, `SELECT id,user_id,expires_at FROM login_challenges WHERE token_hash=?`, hashToken(token))
|
|
var challenge loginChallenge
|
|
var expires string
|
|
if err := row.Scan(&challenge.ID, &challenge.UserID, &expires); err != nil {
|
|
return nil, err
|
|
}
|
|
challenge.ExpiresAt = parseTime(expires)
|
|
if !challenge.ExpiresAt.IsZero() && !challenge.ExpiresAt.After(a.now().UTC()) {
|
|
_, _ = a.db.ExecContext(ctx, `DELETE FROM login_challenges WHERE id=?`, challenge.ID)
|
|
return nil, errors.New("challenge expired")
|
|
}
|
|
return &challenge, nil
|
|
}
|
|
|
|
func (a *App) deleteLoginChallenge(ctx context.Context, id string) {
|
|
_, _ = a.db.ExecContext(ctx, `DELETE FROM login_challenges WHERE id=?`, id)
|
|
}
|
|
|
|
func (a *App) loadUserAuthByID(ctx context.Context, id string) (*User, string, error) {
|
|
row := a.db.QueryRowContext(ctx, `SELECT id,email,display_name,role,disabled,two_factor_enabled,two_factor_secret,created_at FROM users WHERE id=?`, id)
|
|
var u User
|
|
var disabled, twoFactorEnabled int
|
|
var secret, created string
|
|
if err := row.Scan(&u.ID, &u.Email, &u.DisplayName, &u.Role, &disabled, &twoFactorEnabled, &secret, &created); err != nil {
|
|
if errors.Is(err, sql.ErrNoRows) {
|
|
return nil, "", errNotFound
|
|
}
|
|
return nil, "", err
|
|
}
|
|
u.Disabled = intBool(disabled)
|
|
u.TwoFactorEnabled = intBool(twoFactorEnabled)
|
|
u.CreatedAt = parseTime(created)
|
|
if err := a.attachUserAuthorization(ctx, &u); err != nil {
|
|
return nil, "", err
|
|
}
|
|
return &u, secret, nil
|
|
}
|
|
|
|
func (a *App) handleTwoFactorSetup(w http.ResponseWriter, r *http.Request) {
|
|
if !a.cfg.TwoFactorEnabled {
|
|
respondError(w, http.StatusBadRequest, "双因素认证已关闭")
|
|
return
|
|
}
|
|
user := currentUser(r)
|
|
if user == nil {
|
|
respondError(w, http.StatusUnauthorized, "需要登录后才能操作")
|
|
return
|
|
}
|
|
current, _, err := a.loadUserAuthByID(r.Context(), user.ID)
|
|
if err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to load user")
|
|
return
|
|
}
|
|
if current.TwoFactorEnabled {
|
|
respondError(w, http.StatusBadRequest, "two-factor authentication is already enabled")
|
|
return
|
|
}
|
|
secret, err := newTOTPSecret()
|
|
if err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to generate secret")
|
|
return
|
|
}
|
|
now := a.now().UTC().Format(time.RFC3339Nano)
|
|
if _, err := a.db.ExecContext(r.Context(), `UPDATE users SET two_factor_secret=?, two_factor_enabled=0, updated_at=? WHERE id=?`, secret, now, user.ID); err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to save secret")
|
|
return
|
|
}
|
|
respondJSON(w, http.StatusOK, map[string]any{
|
|
"secret": secret,
|
|
"otpauthUrl": totpProvisioningURI("LanQin Email", current.Email, secret),
|
|
})
|
|
}
|
|
|
|
func (a *App) handleTwoFactorEnable(w http.ResponseWriter, r *http.Request) {
|
|
if !a.cfg.TwoFactorEnabled {
|
|
respondError(w, http.StatusBadRequest, "双因素认证已关闭")
|
|
return
|
|
}
|
|
user := currentUser(r)
|
|
if user == nil {
|
|
respondError(w, http.StatusUnauthorized, "需要登录后才能操作")
|
|
return
|
|
}
|
|
var req struct {
|
|
Code string `json:"code"`
|
|
}
|
|
if err := decodeJSON(r, &req); err != nil {
|
|
badRequest(w, err)
|
|
return
|
|
}
|
|
current, secret, err := a.loadUserAuthByID(r.Context(), user.ID)
|
|
if err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to load user")
|
|
return
|
|
}
|
|
if current.TwoFactorEnabled {
|
|
respondJSON(w, http.StatusOK, map[string]any{"user": current})
|
|
return
|
|
}
|
|
if strings.TrimSpace(secret) == "" {
|
|
badRequest(w, errors.New("two-factor secret not set"))
|
|
return
|
|
}
|
|
if !verifyTOTP(secret, req.Code, a.now().UTC()) {
|
|
respondError(w, http.StatusUnauthorized, "invalid verification code")
|
|
return
|
|
}
|
|
if _, err := a.db.ExecContext(r.Context(), `UPDATE users SET two_factor_enabled=1, updated_at=? WHERE id=?`, a.now().UTC().Format(time.RFC3339Nano), user.ID); err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to enable two-factor authentication")
|
|
return
|
|
}
|
|
updated, _, err := a.loadUserAuthByID(r.Context(), user.ID)
|
|
if err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to load user")
|
|
return
|
|
}
|
|
respondJSON(w, http.StatusOK, map[string]any{"user": updated})
|
|
}
|
|
|
|
func (a *App) handleTwoFactorDisable(w http.ResponseWriter, r *http.Request) {
|
|
user := currentUser(r)
|
|
if user == nil {
|
|
respondError(w, http.StatusUnauthorized, "需要登录后才能操作")
|
|
return
|
|
}
|
|
var req struct {
|
|
Code string `json:"code"`
|
|
}
|
|
if err := decodeJSON(r, &req); err != nil {
|
|
badRequest(w, err)
|
|
return
|
|
}
|
|
current, secret, err := a.loadUserAuthByID(r.Context(), user.ID)
|
|
if err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to load user")
|
|
return
|
|
}
|
|
if !current.TwoFactorEnabled && strings.TrimSpace(secret) == "" {
|
|
respondJSON(w, http.StatusOK, map[string]any{"user": current})
|
|
return
|
|
}
|
|
if strings.TrimSpace(secret) != "" && current.TwoFactorEnabled && !verifyTOTP(secret, req.Code, a.now().UTC()) {
|
|
respondError(w, http.StatusUnauthorized, "invalid verification code")
|
|
return
|
|
}
|
|
if _, err := a.db.ExecContext(r.Context(), `UPDATE users SET two_factor_secret='', two_factor_enabled=0, updated_at=? WHERE id=?`, a.now().UTC().Format(time.RFC3339Nano), user.ID); err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to disable two-factor authentication")
|
|
return
|
|
}
|
|
updated, _, err := a.loadUserAuthByID(r.Context(), user.ID)
|
|
if err != nil {
|
|
respondError(w, http.StatusInternalServerError, "failed to load user")
|
|
return
|
|
}
|
|
respondJSON(w, http.StatusOK, map[string]any{"user": updated})
|
|
}
|