Compare commits
No commits in common. "b3362d4a664d975997162d4bc3a9f888de687dd7" and "155deb889cc5d0dc30f8bff6e499a9606c239415" have entirely different histories.
b3362d4a66
...
155deb889c
|
@ -32,7 +32,7 @@ func main() {
|
||||||
r := gin.Default()
|
r := gin.Default()
|
||||||
docs.SwaggerInfo.BasePath = "/api"
|
docs.SwaggerInfo.BasePath = "/api"
|
||||||
r.Use(cors.New(cors.Config{
|
r.Use(cors.New(cors.Config{
|
||||||
AllowOrigins: []string{"http://localhost:5173"},
|
AllowOrigins: []string{"*"},
|
||||||
AllowMethods: []string{"GET", "DELETE", "PUT", "PATCH", "OPTIONS"},
|
AllowMethods: []string{"GET", "DELETE", "PUT", "PATCH", "OPTIONS"},
|
||||||
AllowHeaders: []string{"Origin", "Content-Type"},
|
AllowHeaders: []string{"Origin", "Content-Type"},
|
||||||
ExposeHeaders: []string{"Content-Length"},
|
ExposeHeaders: []string{"Content-Length"},
|
||||||
|
@ -44,7 +44,6 @@ func main() {
|
||||||
api := r.Group("/api")
|
api := r.Group("/api")
|
||||||
{
|
{
|
||||||
api.GET("/ping", handlers.PingGet)
|
api.GET("/ping", handlers.PingGet)
|
||||||
api.GET("/authping", middleware.AuthMiddleware(), handlers.PingGet)
|
|
||||||
userRoutes := api.Group("/user")
|
userRoutes := api.Group("/user")
|
||||||
{
|
{
|
||||||
userRoutes.POST("/register", handlers.UserRegister)
|
userRoutes.POST("/register", handlers.UserRegister)
|
||||||
|
|
|
@ -1,5 +0,0 @@
|
||||||
package consts
|
|
||||||
|
|
||||||
const (
|
|
||||||
COOKIE_SESSION = "session"
|
|
||||||
)
|
|
1
db/db.go
1
db/db.go
|
@ -53,6 +53,5 @@ func Connect() *gorm.DB {
|
||||||
gormDB.AutoMigrate(&Transfer{})
|
gormDB.AutoMigrate(&Transfer{})
|
||||||
gormDB.AutoMigrate(&User{})
|
gormDB.AutoMigrate(&User{})
|
||||||
gormDB.AutoMigrate(&Type{})
|
gormDB.AutoMigrate(&Type{})
|
||||||
gormDB.AutoMigrate(&Session{})
|
|
||||||
return newUDB
|
return newUDB
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,10 +0,0 @@
|
||||||
package db
|
|
||||||
|
|
||||||
import "time"
|
|
||||||
|
|
||||||
type Session struct {
|
|
||||||
ID string `gorm:"primaryKey"`
|
|
||||||
UserID uint
|
|
||||||
User *User
|
|
||||||
ExpireAt time.Time
|
|
||||||
}
|
|
|
@ -3,7 +3,6 @@ package handlers
|
||||||
import (
|
import (
|
||||||
"log"
|
"log"
|
||||||
|
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/consts"
|
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/db"
|
"git.qowevisa.me/Qowevisa/fin-check-api/db"
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/tokens"
|
"git.qowevisa.me/Qowevisa/fin-check-api/tokens"
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/types"
|
"git.qowevisa.me/Qowevisa/fin-check-api/types"
|
||||||
|
@ -48,11 +47,9 @@ func UserRegister(c *gin.Context) {
|
||||||
}
|
}
|
||||||
token1 = token
|
token1 = token
|
||||||
}
|
}
|
||||||
c.SetCookie(consts.COOKIE_SESSION, token1.Val, 3600, "/", "localhost", false, true)
|
|
||||||
acc := types.Account{
|
acc := types.Account{
|
||||||
ID: dbUser.ID,
|
ID: dbUser.ID,
|
||||||
Token: token1.Val,
|
Token: token1.Val,
|
||||||
Username: dbUser.Username,
|
|
||||||
}
|
}
|
||||||
c.JSON(200, acc)
|
c.JSON(200, acc)
|
||||||
}
|
}
|
||||||
|
@ -85,7 +82,7 @@ func UserLogin(c *gin.Context) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if foundUser.ID == 0 {
|
if foundUser.ID == 0 {
|
||||||
c.JSON(400, types.ErrorResponse{Message: "Credentials are incorrect"})
|
c.JSON(500, types.ErrorResponse{Message: "Credentials are incorrect"})
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
var token1 *tokens.Token
|
var token1 *tokens.Token
|
||||||
|
@ -100,13 +97,9 @@ func UserLogin(c *gin.Context) {
|
||||||
}
|
}
|
||||||
token1 = token
|
token1 = token
|
||||||
}
|
}
|
||||||
c.SetCookie(consts.COOKIE_SESSION, token1.Val, 3600, "/", "localhost", false, true)
|
|
||||||
acc := types.Account{
|
acc := types.Account{
|
||||||
ID: foundUser.ID,
|
ID: foundUser.ID,
|
||||||
Token: token1.Val,
|
Token: token1.Val,
|
||||||
Username: dbUser.Username,
|
|
||||||
}
|
}
|
||||||
c.JSON(200, acc)
|
c.JSON(200, acc)
|
||||||
}
|
}
|
||||||
|
|
||||||
func isSessionTokenForUserInvalid(userID uint) {}
|
|
||||||
|
|
|
@ -1,11 +1,8 @@
|
||||||
package middleware
|
package middleware
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"strings"
|
||||||
"log"
|
|
||||||
"net/http"
|
|
||||||
|
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/consts"
|
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/tokens"
|
"git.qowevisa.me/Qowevisa/fin-check-api/tokens"
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/types"
|
"git.qowevisa.me/Qowevisa/fin-check-api/types"
|
||||||
"github.com/gin-gonic/gin"
|
"github.com/gin-gonic/gin"
|
||||||
|
@ -14,25 +11,31 @@ import (
|
||||||
// Passes UserID with `c.Set("UserID")` as it gets id from token
|
// Passes UserID with `c.Set("UserID")` as it gets id from token
|
||||||
func AuthMiddleware() gin.HandlerFunc {
|
func AuthMiddleware() gin.HandlerFunc {
|
||||||
return func(c *gin.Context) {
|
return func(c *gin.Context) {
|
||||||
token, err := c.Cookie(consts.COOKIE_SESSION)
|
authHeader := c.GetHeader("Authorization")
|
||||||
if errors.Is(err, http.ErrNoCookie) {
|
if authHeader == "" {
|
||||||
c.JSON(401, types.ErrorResponse{Message: "Authorization cookie is required"})
|
c.JSON(401, types.ErrorResponse{Message: "Authorization header is required"})
|
||||||
c.Abort()
|
c.Abort()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if !tokens.ValidateSessionToken(token) {
|
|
||||||
c.JSON(401, types.ErrorResponse{Message: "Invalid authorization cookie"})
|
token := authHeader
|
||||||
|
if strings.Index(token, "Bearer ") == 0 {
|
||||||
|
token = strings.Split(token, " ")[1]
|
||||||
|
}
|
||||||
|
|
||||||
|
if !tokens.AmIAllowed(token) {
|
||||||
|
c.JSON(401, types.ErrorResponse{Message: "Token is invalid"})
|
||||||
c.Abort()
|
c.Abort()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
session, err := tokens.GetSession(token)
|
|
||||||
if err != nil {
|
if userID, err := tokens.GetID(token); err != nil {
|
||||||
log.Printf("ERROR: tokens.GetSession: %v\n", err)
|
c.JSON(401, types.ErrorResponse{Message: "Token is invalid ERR4001"})
|
||||||
c.JSON(500, types.ErrorResponse{Message: "Server error"})
|
|
||||||
c.Abort()
|
c.Abort()
|
||||||
return
|
return
|
||||||
|
} else {
|
||||||
|
c.Set("UserID", userID)
|
||||||
}
|
}
|
||||||
c.Set("UserID", session.UserID)
|
|
||||||
|
|
||||||
c.Next()
|
c.Next()
|
||||||
}
|
}
|
||||||
|
|
|
@ -138,7 +138,7 @@ func AddToken(id uint) (*Token, error) {
|
||||||
_, exists := toks.Tokmap[id]
|
_, exists := toks.Tokmap[id]
|
||||||
toks.Mu.RUnlock()
|
toks.Mu.RUnlock()
|
||||||
if exists {
|
if exists {
|
||||||
// return nil, ERROR_ALREADY_HAVE_TOKEN
|
return nil, ERROR_ALREADY_HAVE_TOKEN
|
||||||
}
|
}
|
||||||
val := generateTokenVal()
|
val := generateTokenVal()
|
||||||
token := &Token{
|
token := &Token{
|
||||||
|
|
|
@ -1,58 +0,0 @@
|
||||||
package tokens
|
|
||||||
|
|
||||||
import (
|
|
||||||
"crypto/sha256"
|
|
||||||
"log"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"git.qowevisa.me/Qowevisa/fin-check-api/db"
|
|
||||||
)
|
|
||||||
|
|
||||||
func getSalt() []byte {
|
|
||||||
return []byte("w40DJV3v1flySvFdxHWbBSJsIOaakkVs5FG7brq4oi1#nEz2fEZxpUfyBwkkww7f")
|
|
||||||
}
|
|
||||||
|
|
||||||
func CreateSessionFromToken(token string, userID uint) error {
|
|
||||||
salt := getSalt()
|
|
||||||
sessionID := sha256.New().Sum(append(salt, []byte(token)...))
|
|
||||||
dbc := db.Connect()
|
|
||||||
session := &db.Session{
|
|
||||||
ID: string(sessionID),
|
|
||||||
UserID: userID,
|
|
||||||
ExpireAt: time.Now().Add(time.Hour),
|
|
||||||
}
|
|
||||||
if err := dbc.Create(session).Error; err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func ValidateSessionToken(token string) bool {
|
|
||||||
salt := getSalt()
|
|
||||||
sessionID := sha256.New().Sum(append(salt, []byte(token)...))
|
|
||||||
dbc := db.Connect()
|
|
||||||
session := &db.Session{}
|
|
||||||
if err := dbc.Find(session, sessionID).Error; err != nil {
|
|
||||||
log.Printf("DBERROR: %v\n", err)
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
if session.ID == "" {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
if session.ExpireAt.Unix() < time.Now().Unix() {
|
|
||||||
dbc.Delete(session)
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
return session.ID != ""
|
|
||||||
}
|
|
||||||
|
|
||||||
func GetSession(token string) (*db.Session, error) {
|
|
||||||
salt := getSalt()
|
|
||||||
sessionID := sha256.New().Sum(append(salt, []byte(token)...))
|
|
||||||
dbc := db.Connect()
|
|
||||||
session := &db.Session{}
|
|
||||||
if err := dbc.Find(session, sessionID).Error; err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
return session, nil
|
|
||||||
}
|
|
|
@ -11,8 +11,7 @@ type User struct {
|
||||||
// User Account
|
// User Account
|
||||||
type Account struct {
|
type Account struct {
|
||||||
ID uint `json:"id" example:"1"`
|
ID uint `json:"id" example:"1"`
|
||||||
Token string `json:"token" example:"Fvs-MnxiEs5dnqMp2mSDIJigPbiIUs6Snk1xxiqPmUc"`
|
Token string `json:"token" example:"Fvs-MnxiEs5dnqMp2mSDIJigPbiIUs6Snk1xxiqPmUc="`
|
||||||
Username string `json:"username" example:"testUser"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type Message struct {
|
type Message struct {
|
||||||
|
@ -75,8 +74,3 @@ type DbPayment struct {
|
||||||
Note string `json:"not" example:"I'm a teapot"`
|
Note string `json:"not" example:"I'm a teapot"`
|
||||||
Date time.Time `json:"date" example:"29/11/2001 12:00"`
|
Date time.Time `json:"date" example:"29/11/2001 12:00"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type Session struct {
|
|
||||||
ID string `json:"id"`
|
|
||||||
UserID uint `json:"user_id" example:"1"`
|
|
||||||
}
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user