Compare commits
4 commits
0e2803df9e
...
baeec24df2
Author | SHA1 | Date | |
---|---|---|---|
baeec24df2 | |||
ba49afe04a | |||
3c1170bd87 | |||
23fd877a98 |
6 changed files with 298 additions and 46 deletions
|
@ -22,8 +22,6 @@ import (
|
||||||
"git.smarteching.com/goffee/cup/utils"
|
"git.smarteching.com/goffee/cup/utils"
|
||||||
"github.com/google/uuid"
|
"github.com/google/uuid"
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
|
|
||||||
"git.smarteching.com/goffee/core/template/components"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func Signup(c *core.Context) *core.Response {
|
func Signup(c *core.Context) *core.Response {
|
||||||
|
@ -223,6 +221,12 @@ func Signin(c *core.Context) *core.Response {
|
||||||
userAgent := c.GetUserAgent()
|
userAgent := c.GetUserAgent()
|
||||||
hashedCacheKey := utils.CreateAuthTokenHashedCacheKey(user.ID, userAgent)
|
hashedCacheKey := utils.CreateAuthTokenHashedCacheKey(user.ID, userAgent)
|
||||||
err = c.GetCache().Set(hashedCacheKey, token)
|
err = c.GetCache().Set(hashedCacheKey, token)
|
||||||
|
|
||||||
|
// delete data from old sessions
|
||||||
|
sessionKey := fmt.Sprintf("sess_%v", userAgent)
|
||||||
|
hashedSessionKey := utils.CreateAuthTokenHashedCacheKey(user.ID, sessionKey)
|
||||||
|
_ = c.GetCache().Delete(hashedSessionKey)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.GetLogger().Error(err.Error())
|
c.GetLogger().Error(err.Error())
|
||||||
if TemplateEnable {
|
if TemplateEnable {
|
||||||
|
@ -448,43 +452,3 @@ func Signout(c *core.Context) *core.Response {
|
||||||
"message": "signed out successfully",
|
"message": "signed out successfully",
|
||||||
}))
|
}))
|
||||||
}
|
}
|
||||||
|
|
||||||
// Show basic app login
|
|
||||||
func AppLogin(c *core.Context) *core.Response {
|
|
||||||
|
|
||||||
// first, include all compoments
|
|
||||||
// first, include all compoments
|
|
||||||
type templateData struct {
|
|
||||||
PageCard components.PageCard
|
|
||||||
}
|
|
||||||
|
|
||||||
// now fill data of the components
|
|
||||||
tmplData := templateData{
|
|
||||||
PageCard: components.PageCard{
|
|
||||||
CardTitle: "Card title",
|
|
||||||
CardBody: "Loerm ipsum at deim",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
return c.Response.Template("login.html", tmplData)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Show basic app sample
|
|
||||||
func AppSample(c *core.Context) *core.Response {
|
|
||||||
|
|
||||||
// first, include all compoments
|
|
||||||
type templateData struct {
|
|
||||||
PageCard components.PageCard
|
|
||||||
}
|
|
||||||
|
|
||||||
// now fill data of the components
|
|
||||||
tmplData := templateData{
|
|
||||||
PageCard: components.PageCard{
|
|
||||||
CardTitle: "Protected page",
|
|
||||||
CardBody: "If you can see this page, your are loggedin",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
//fmt.Printf("Outside cookie user is: %s", user.Email)
|
|
||||||
|
|
||||||
return c.Response.Template("app.html", tmplData)
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
|
@ -5,8 +5,11 @@
|
||||||
package controllers
|
package controllers
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
"git.smarteching.com/goffee/core"
|
"git.smarteching.com/goffee/core"
|
||||||
"git.smarteching.com/goffee/core/template/components"
|
"git.smarteching.com/goffee/core/template/components"
|
||||||
|
"git.smarteching.com/goffee/cup/utils"
|
||||||
)
|
)
|
||||||
|
|
||||||
// Show basic template
|
// Show basic template
|
||||||
|
@ -28,3 +31,103 @@ func Sample(c *core.Context) *core.Response {
|
||||||
return c.Response.Template("basic.html", tmplData)
|
return c.Response.Template("basic.html", tmplData)
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Show basic app login
|
||||||
|
func AppLogin(c *core.Context) *core.Response {
|
||||||
|
|
||||||
|
// first, include all compoments
|
||||||
|
// first, include all compoments
|
||||||
|
type templateData struct {
|
||||||
|
PageCard components.PageCard
|
||||||
|
}
|
||||||
|
|
||||||
|
// now fill data of the components
|
||||||
|
tmplData := templateData{
|
||||||
|
PageCard: components.PageCard{
|
||||||
|
CardTitle: "Card title",
|
||||||
|
CardBody: "Loerm ipsum at deim",
|
||||||
|
},
|
||||||
|
}
|
||||||
|
return c.Response.Template("login.html", tmplData)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Show basic app login
|
||||||
|
func AppSession(c *core.Context) *core.Response {
|
||||||
|
|
||||||
|
var session = new(utils.SessionUser)
|
||||||
|
|
||||||
|
// true if session is active
|
||||||
|
hassession := session.Init(c)
|
||||||
|
|
||||||
|
//session.Set("numberdos", 66)
|
||||||
|
|
||||||
|
type templateData struct {
|
||||||
|
PageCard components.PageCard
|
||||||
|
}
|
||||||
|
|
||||||
|
// now fill data of the components
|
||||||
|
tmplData := templateData{}
|
||||||
|
|
||||||
|
if hassession {
|
||||||
|
|
||||||
|
sesiondata := ""
|
||||||
|
cardtitle := fmt.Sprintf("Session user id: %v", session.GetUserID())
|
||||||
|
numberdos, ok := session.Get("numberdos")
|
||||||
|
|
||||||
|
if numberdos != nil {
|
||||||
|
numberdos = numberdos.(float64) + 10
|
||||||
|
} else {
|
||||||
|
numberdos = 10
|
||||||
|
}
|
||||||
|
|
||||||
|
session.Set("numberdos", numberdos)
|
||||||
|
|
||||||
|
if ok {
|
||||||
|
sesiondata = fmt.Sprintf("OK, Session numberdos has %v", numberdos)
|
||||||
|
} else {
|
||||||
|
sesiondata = fmt.Sprintf("No ok, session numberdos has %v", numberdos)
|
||||||
|
}
|
||||||
|
|
||||||
|
// delete single
|
||||||
|
//session.Delete("numberdos")
|
||||||
|
|
||||||
|
// delete all data
|
||||||
|
//session.Flush()
|
||||||
|
|
||||||
|
tmplData = templateData{
|
||||||
|
PageCard: components.PageCard{
|
||||||
|
CardTitle: cardtitle,
|
||||||
|
CardBody: sesiondata,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
return c.Response.Template("appsession.html", tmplData)
|
||||||
|
|
||||||
|
} else {
|
||||||
|
|
||||||
|
return c.Response.Template("login.html", tmplData)
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
// Show basic app sample
|
||||||
|
func AppSample(c *core.Context) *core.Response {
|
||||||
|
|
||||||
|
// first, include all compoments
|
||||||
|
type templateData struct {
|
||||||
|
PageCard components.PageCard
|
||||||
|
}
|
||||||
|
|
||||||
|
// now fill data of the components
|
||||||
|
tmplData := templateData{
|
||||||
|
PageCard: components.PageCard{
|
||||||
|
CardTitle: "Protected page",
|
||||||
|
CardBody: "If you can see this page, your are loggedin",
|
||||||
|
},
|
||||||
|
}
|
||||||
|
//fmt.Printf("Outside cookie user is: %s", user.Email)
|
||||||
|
|
||||||
|
return c.Response.Template("app.html", tmplData)
|
||||||
|
|
||||||
|
}
|
||||||
|
|
|
@ -114,10 +114,10 @@ func Themeform(c *core.Context) *core.Response {
|
||||||
optionc.Value = "buenosaires"
|
optionc.Value = "buenosaires"
|
||||||
optionc.Label = "Buenos Aires"
|
optionc.Label = "Buenos Aires"
|
||||||
allOptionsc = append(allOptionsc, optionc)
|
allOptionsc = append(allOptionsc, optionc)
|
||||||
optionc.ID = "sogas"
|
optionc.ID = "london"
|
||||||
optionc.Name = "sogas"
|
optionc.Name = "london"
|
||||||
optionc.Value = "Sogamoso"
|
optionc.Value = "london"
|
||||||
optionc.Label = "Sogamoso"
|
optionc.Label = "London"
|
||||||
//optionc.IsChecked = true
|
//optionc.IsChecked = true
|
||||||
allOptionsc = append(allOptionsc, optionc)
|
allOptionsc = append(allOptionsc, optionc)
|
||||||
|
|
||||||
|
|
|
@ -41,4 +41,7 @@ func registerRoutes() {
|
||||||
|
|
||||||
controller.Get("/applogin", controllers.AppLogin, hooks.CheckSessionCookie)
|
controller.Get("/applogin", controllers.AppLogin, hooks.CheckSessionCookie)
|
||||||
controller.Post("/applogin", controllers.AppLogin, hooks.CheckSessionCookie)
|
controller.Post("/applogin", controllers.AppLogin, hooks.CheckSessionCookie)
|
||||||
|
|
||||||
|
controller.Get("/appsession", controllers.AppSession)
|
||||||
|
controller.Post("/appsession", controllers.AppSession)
|
||||||
}
|
}
|
||||||
|
|
12
storage/templates/appsession.html
Normal file
12
storage/templates/appsession.html
Normal file
|
@ -0,0 +1,12 @@
|
||||||
|
<!DOCTYPE html>
|
||||||
|
<html lang="en">
|
||||||
|
{{template "page_head" "Sample page test session vars"}}
|
||||||
|
<body>
|
||||||
|
<div class="container">
|
||||||
|
<div class="row">
|
||||||
|
{{template "page_card" .PageCard}}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
{{template "page_footer"}}
|
||||||
|
</body>
|
||||||
|
</html>
|
170
utils/session.go
Normal file
170
utils/session.go
Normal file
|
@ -0,0 +1,170 @@
|
||||||
|
// Copyright (c) 2024 Zeni Kim <zenik@smarteching.com>
|
||||||
|
// Use of this source code is governed by MIT-style
|
||||||
|
// license that can be found in the LICENSE file.
|
||||||
|
|
||||||
|
package utils
|
||||||
|
|
||||||
|
import (
|
||||||
|
"errors"
|
||||||
|
"fmt"
|
||||||
|
"sync"
|
||||||
|
"time"
|
||||||
|
|
||||||
|
"encoding/json"
|
||||||
|
|
||||||
|
"git.smarteching.com/goffee/core"
|
||||||
|
"git.smarteching.com/goffee/cup/models"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
)
|
||||||
|
|
||||||
|
type SessionUser struct {
|
||||||
|
mu sync.RWMutex
|
||||||
|
context *core.Context
|
||||||
|
userID uint
|
||||||
|
hashedSessionKey string
|
||||||
|
authenticated bool
|
||||||
|
sessionStart time.Time
|
||||||
|
values map[string]interface{}
|
||||||
|
}
|
||||||
|
|
||||||
|
// start the struct
|
||||||
|
func (s *SessionUser) Init(c *core.Context) bool {
|
||||||
|
|
||||||
|
// check session cookie
|
||||||
|
pass := true
|
||||||
|
token := ""
|
||||||
|
s.context = c
|
||||||
|
|
||||||
|
payload := make(map[string]interface{})
|
||||||
|
// get cookie
|
||||||
|
usercookie, err := c.GetCookie()
|
||||||
|
if err != nil {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
token = usercookie.Token
|
||||||
|
|
||||||
|
if token == "" {
|
||||||
|
|
||||||
|
pass = false
|
||||||
|
|
||||||
|
} else {
|
||||||
|
|
||||||
|
payload, err = c.GetJWT().DecodeToken(token)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
|
||||||
|
pass = false
|
||||||
|
|
||||||
|
} else {
|
||||||
|
|
||||||
|
userID := uint(c.CastToInt(payload["userID"]))
|
||||||
|
userAgent := c.GetUserAgent()
|
||||||
|
|
||||||
|
// get data from redis
|
||||||
|
hashedCacheKey := CreateAuthTokenHashedCacheKey(userID, userAgent)
|
||||||
|
cachedToken, err := c.GetCache().Get(hashedCacheKey)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
pass = false
|
||||||
|
} else if cachedToken != token {
|
||||||
|
pass = false
|
||||||
|
} else {
|
||||||
|
var user models.User
|
||||||
|
res := c.GetGorm().Where("id = ?", userID).First(&user)
|
||||||
|
if res.Error != nil && !errors.Is(res.Error, gorm.ErrRecordNotFound) {
|
||||||
|
pass = false
|
||||||
|
}
|
||||||
|
// if have session start the struct
|
||||||
|
if pass {
|
||||||
|
userAgent := c.GetUserAgent()
|
||||||
|
sessionKey := fmt.Sprintf("sess_%v", userAgent)
|
||||||
|
s.hashedSessionKey = CreateAuthTokenHashedCacheKey(userID, sessionKey)
|
||||||
|
|
||||||
|
s.values = make(map[string]interface{})
|
||||||
|
s.authenticated = true
|
||||||
|
s.userID = userID
|
||||||
|
value, _ := c.GetCache().Get(s.hashedSessionKey)
|
||||||
|
|
||||||
|
if len(value) > 0 {
|
||||||
|
_ = json.Unmarshal([]byte(value), &s.values)
|
||||||
|
}
|
||||||
|
|
||||||
|
return true
|
||||||
|
|
||||||
|
} else {
|
||||||
|
|
||||||
|
s.hashedSessionKey = ""
|
||||||
|
s.authenticated = false
|
||||||
|
s.userID = 0
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionUser) Set(key string, value interface{}) error {
|
||||||
|
s.mu.Lock()
|
||||||
|
s.values[key] = value
|
||||||
|
s.mu.Unlock()
|
||||||
|
return s.Save()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionUser) Get(key string) (interface{}, bool) {
|
||||||
|
s.mu.RLock()
|
||||||
|
defer s.mu.RUnlock()
|
||||||
|
val, ok := s.values[key]
|
||||||
|
return val, ok
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionUser) Delete(key string) interface{} {
|
||||||
|
s.mu.RLock()
|
||||||
|
v, ok := s.values[key]
|
||||||
|
s.mu.RUnlock()
|
||||||
|
if ok {
|
||||||
|
s.mu.Lock()
|
||||||
|
delete(s.values, key)
|
||||||
|
s.mu.Unlock()
|
||||||
|
}
|
||||||
|
s.Save()
|
||||||
|
return v
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionUser) Flush() error {
|
||||||
|
s.mu.Lock()
|
||||||
|
s.context.GetCache().Delete(s.hashedSessionKey)
|
||||||
|
s.mu.Unlock()
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionUser) Save() error {
|
||||||
|
|
||||||
|
var value string
|
||||||
|
|
||||||
|
s.mu.RLock()
|
||||||
|
|
||||||
|
if len(s.values) > 0 {
|
||||||
|
buf, err := json.Marshal(&s.values)
|
||||||
|
if err != nil {
|
||||||
|
s.mu.RUnlock()
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
value = string(buf)
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(value) > 0 {
|
||||||
|
s.context.GetCache().Set(s.hashedSessionKey, value)
|
||||||
|
} else {
|
||||||
|
s.context.GetCache().Delete(s.hashedSessionKey)
|
||||||
|
}
|
||||||
|
s.mu.RUnlock()
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *SessionUser) GetUserID() uint {
|
||||||
|
|
||||||
|
return s.userID
|
||||||
|
}
|
Loading…
Reference in a new issue