mirror of
https://github.com/onsonr/sonr.git
synced 2025-03-10 21:09:11 +00:00
110 lines
2.2 KiB
Go
110 lines
2.2 KiB
Go
|
package middleware
|
||
|
|
||
|
import (
|
||
|
gocontext "context"
|
||
|
|
||
|
"github.com/labstack/echo/v4"
|
||
|
"github.com/onsonr/sonr/internal/context"
|
||
|
"github.com/onsonr/sonr/internal/database"
|
||
|
)
|
||
|
|
||
|
func NewSession(c echo.Context) error {
|
||
|
cc, ok := c.(*GatewayContext)
|
||
|
if !ok {
|
||
|
return nil
|
||
|
}
|
||
|
baseSessionCreateParams := database.BaseSessionCreateParams(cc)
|
||
|
cc.id = baseSessionCreateParams.ID
|
||
|
if _, err := cc.dbq.CreateSession(bgCtx(), baseSessionCreateParams); err != nil {
|
||
|
return err
|
||
|
}
|
||
|
// Set Cookie
|
||
|
if err := context.WriteCookie(c, context.SessionID, cc.id); err != nil {
|
||
|
return err
|
||
|
}
|
||
|
return nil
|
||
|
}
|
||
|
|
||
|
// ForbiddenDevice returns true if the device is unavailable
|
||
|
func ForbiddenDevice(c echo.Context) bool {
|
||
|
cc, ok := c.(*GatewayContext)
|
||
|
if !ok {
|
||
|
return true
|
||
|
}
|
||
|
return cc.agent.IsBot() || cc.agent.IsTV()
|
||
|
}
|
||
|
|
||
|
func GetOrigin(c echo.Context) string {
|
||
|
return c.Request().Host
|
||
|
}
|
||
|
|
||
|
func GetSessionID(c echo.Context) string {
|
||
|
// Check from context
|
||
|
cc, ok := c.(*GatewayContext)
|
||
|
if !ok {
|
||
|
return ""
|
||
|
}
|
||
|
// check from cookie
|
||
|
if cc.id == "" {
|
||
|
if ok := context.CookieExists(c, context.SessionID); !ok {
|
||
|
return ""
|
||
|
}
|
||
|
cc.id = context.ReadCookieUnsafe(c, context.SessionID)
|
||
|
}
|
||
|
return cc.id
|
||
|
}
|
||
|
|
||
|
func GetSessionChallenge(c echo.Context) string {
|
||
|
cc, ok := c.(*GatewayContext)
|
||
|
if !ok {
|
||
|
return ""
|
||
|
}
|
||
|
s, err := cc.dbq.GetChallengeBySessionID(bgCtx(), cc.id)
|
||
|
if err != nil {
|
||
|
return ""
|
||
|
}
|
||
|
return s
|
||
|
}
|
||
|
|
||
|
func GetHandle(c echo.Context) string {
|
||
|
// First check for the cookie
|
||
|
handle := context.ReadCookieUnsafe(c, context.UserHandle)
|
||
|
if handle != "" {
|
||
|
return handle
|
||
|
}
|
||
|
|
||
|
// Then check the session
|
||
|
cc, ok := c.(*GatewayContext)
|
||
|
if !ok {
|
||
|
return ""
|
||
|
}
|
||
|
s, err := cc.dbq.GetSessionByID(bgCtx(), cc.id)
|
||
|
if err != nil {
|
||
|
return ""
|
||
|
}
|
||
|
profile, err := cc.dbq.GetProfileByID(bgCtx(), s.ProfileID)
|
||
|
if err != nil {
|
||
|
return ""
|
||
|
}
|
||
|
return profile.Handle
|
||
|
}
|
||
|
|
||
|
//
|
||
|
// func GetHumanVerificationNumbers(c echo.Context) (int64, int64) {
|
||
|
// cc, ok := c.(*GatewayContext)
|
||
|
// if !ok {
|
||
|
// return 0, 0
|
||
|
// }
|
||
|
// s, err := cc.dbq.GetHumanVerificationNumbers(bgCtx(), cc.id)
|
||
|
// if err != nil {
|
||
|
// return 0, 0
|
||
|
// }
|
||
|
// return s.IsHumanFirst, s.IsHumanLast
|
||
|
// }
|
||
|
|
||
|
// utility function to get a context
|
||
|
func bgCtx() gocontext.Context {
|
||
|
ctx := gocontext.Background()
|
||
|
return ctx
|
||
|
}
|