mirror of
https://github.com/astaxie/beego.git
synced 2024-11-30 03:51:28 +00:00
178 lines
4.3 KiB
Go
178 lines
4.3 KiB
Go
// Beego (http://beego.me/)
|
|
// @description beego is an open-source, high-performance web framework for the Go programming language.
|
|
// @link http://github.com/astaxie/beego for the canonical source repository
|
|
// @license http://github.com/astaxie/beego/blob/master/LICENSE
|
|
// @authors astaxie
|
|
|
|
package session
|
|
|
|
import (
|
|
"crypto/aes"
|
|
"crypto/cipher"
|
|
"encoding/json"
|
|
"net/http"
|
|
"net/url"
|
|
"sync"
|
|
)
|
|
|
|
var cookiepder = &CookieProvider{}
|
|
|
|
// Cookie SessionStore
|
|
type CookieSessionStore struct {
|
|
sid string
|
|
values map[interface{}]interface{} // session data
|
|
lock sync.RWMutex
|
|
}
|
|
|
|
// Set value to cookie session.
|
|
// the value are encoded as gob with hash block string.
|
|
func (st *CookieSessionStore) Set(key, value interface{}) error {
|
|
st.lock.Lock()
|
|
defer st.lock.Unlock()
|
|
st.values[key] = value
|
|
return nil
|
|
}
|
|
|
|
// Get value from cookie session
|
|
func (st *CookieSessionStore) Get(key interface{}) interface{} {
|
|
st.lock.RLock()
|
|
defer st.lock.RUnlock()
|
|
if v, ok := st.values[key]; ok {
|
|
return v
|
|
} else {
|
|
return nil
|
|
}
|
|
}
|
|
|
|
// Delete value in cookie session
|
|
func (st *CookieSessionStore) Delete(key interface{}) error {
|
|
st.lock.Lock()
|
|
defer st.lock.Unlock()
|
|
delete(st.values, key)
|
|
return nil
|
|
}
|
|
|
|
// Clean all values in cookie session
|
|
func (st *CookieSessionStore) Flush() error {
|
|
st.lock.Lock()
|
|
defer st.lock.Unlock()
|
|
st.values = make(map[interface{}]interface{})
|
|
return nil
|
|
}
|
|
|
|
// Return id of this cookie session
|
|
func (st *CookieSessionStore) SessionID() string {
|
|
return st.sid
|
|
}
|
|
|
|
// Write cookie session to http response cookie
|
|
func (st *CookieSessionStore) SessionRelease(w http.ResponseWriter) {
|
|
str, err := encodeCookie(cookiepder.block,
|
|
cookiepder.config.SecurityKey,
|
|
cookiepder.config.SecurityName,
|
|
st.values)
|
|
if err != nil {
|
|
return
|
|
}
|
|
cookie := &http.Cookie{Name: cookiepder.config.CookieName,
|
|
Value: url.QueryEscape(str),
|
|
Path: "/",
|
|
HttpOnly: true,
|
|
Secure: cookiepder.config.Secure,
|
|
MaxAge: cookiepder.config.Maxage}
|
|
http.SetCookie(w, cookie)
|
|
return
|
|
}
|
|
|
|
type cookieConfig struct {
|
|
SecurityKey string `json:"securityKey"`
|
|
BlockKey string `json:"blockKey"`
|
|
SecurityName string `json:"securityName"`
|
|
CookieName string `json:"cookieName"`
|
|
Secure bool `json:"secure"`
|
|
Maxage int `json:"maxage"`
|
|
}
|
|
|
|
// Cookie session provider
|
|
type CookieProvider struct {
|
|
maxlifetime int64
|
|
config *cookieConfig
|
|
block cipher.Block
|
|
}
|
|
|
|
// Init cookie session provider with max lifetime and config json.
|
|
// maxlifetime is ignored.
|
|
// json config:
|
|
// securityKey - hash string
|
|
// blockKey - gob encode hash string. it's saved as aes crypto.
|
|
// securityName - recognized name in encoded cookie string
|
|
// cookieName - cookie name
|
|
// maxage - cookie max life time.
|
|
func (pder *CookieProvider) SessionInit(maxlifetime int64, config string) error {
|
|
pder.config = &cookieConfig{}
|
|
err := json.Unmarshal([]byte(config), pder.config)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if pder.config.BlockKey == "" {
|
|
pder.config.BlockKey = string(generateRandomKey(16))
|
|
}
|
|
if pder.config.SecurityName == "" {
|
|
pder.config.SecurityName = string(generateRandomKey(20))
|
|
}
|
|
pder.block, err = aes.NewCipher([]byte(pder.config.BlockKey))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
pder.maxlifetime = maxlifetime
|
|
return nil
|
|
}
|
|
|
|
// Get SessionStore in cooke.
|
|
// decode cooke string to map and put into SessionStore with sid.
|
|
func (pder *CookieProvider) SessionRead(sid string) (SessionStore, error) {
|
|
maps, _ := decodeCookie(pder.block,
|
|
pder.config.SecurityKey,
|
|
pder.config.SecurityName,
|
|
sid, pder.maxlifetime)
|
|
if maps == nil {
|
|
maps = make(map[interface{}]interface{})
|
|
}
|
|
rs := &CookieSessionStore{sid: sid, values: maps}
|
|
return rs, nil
|
|
}
|
|
|
|
// Cookie session is always existed
|
|
func (pder *CookieProvider) SessionExist(sid string) bool {
|
|
return true
|
|
}
|
|
|
|
// Implement method, no used.
|
|
func (pder *CookieProvider) SessionRegenerate(oldsid, sid string) (SessionStore, error) {
|
|
return nil, nil
|
|
}
|
|
|
|
// Implement method, no used.
|
|
func (pder *CookieProvider) SessionDestroy(sid string) error {
|
|
return nil
|
|
}
|
|
|
|
// Implement method, no used.
|
|
func (pder *CookieProvider) SessionGC() {
|
|
return
|
|
}
|
|
|
|
// Implement method, return 0.
|
|
func (pder *CookieProvider) SessionAll() int {
|
|
return 0
|
|
}
|
|
|
|
// Implement method, no used.
|
|
func (pder *CookieProvider) SessionUpdate(sid string) error {
|
|
return nil
|
|
}
|
|
|
|
func init() {
|
|
Register("cookie", cookiepder)
|
|
}
|