Add session middleware

server/router/middleware/session.go

@@ -1,33 +1,41 @@
 package middleware
 
 import (
+	"database/sql"
 	"net/http"
 
 	"git.ekzyis.com/ekzyis/delphi.market/server/router/context"
+	"git.ekzyis.com/ekzyis/delphi.market/types"
 	"github.com/labstack/echo/v4"
 )
 
 func Session(sc context.Context) echo.MiddlewareFunc {
 	return func(next echo.HandlerFunc) echo.HandlerFunc {
 		return func(c echo.Context) error {
-			// TODO: implement session middleware
+			var (
-			// var (
+				db     = sc.Db
-			//   cookie *http.Cookie
+				ctx    = c.Request().Context()
-			// 	 err    error
+				cookie *http.Cookie
-			// 	 s      *db.Session
+				err    error
-			// 	 u      *db.User
+				u      = types.User{}
-			// )
+			)
-			// if cookie, err = c.Cookie("session"); err != nil {
+			if cookie, err = c.Cookie("session"); err != nil {
-			// 	 // cookie not found
+				// cookie not found
-			// 	 return next(c)
+				return next(c)
-			// }
+			}
-			// s = &db.Session{SessionId: cookie.Value}
+			if err = db.QueryRowContext(
-			// if err = sc.Db.FetchSession(s); err == nil {
+				ctx,
-			// 	 // session found
+				""+
-			// 	 c.Set("session", *u)
+					"SELECT u.id, u.created_at, COALESCE(u.ln_pubkey, ''), COALESCE(u.nostr_pubkey, ''), u.msats "+
-			// } else if err != sql.ErrNoRows {
+					"FROM sessions s LEFT JOIN users u ON u.id = s.user_id "+
-			// 	 return err
+					"WHERE s.id = $1",
-			// }
+				cookie.Value).
+				Scan(&u.Id, &u.CreatedAt, &u.LnPubkey, &u.NostrPubkey, &u.Msats); err == nil {
+				// session found
+				c.Set("session", u)
+			} else if err != sql.ErrNoRows {
+				return err
+			}
 			return next(c)
 		}
 	}

server/router/router.go

@@ -5,12 +5,13 @@ import (
 
 	"git.ekzyis.com/ekzyis/delphi.market/server/router/context"
 	"git.ekzyis.com/ekzyis/delphi.market/server/router/handler"
+	"git.ekzyis.com/ekzyis/delphi.market/server/router/middleware"
 )
 
 type Context = context.Context
 
 func Init(e *echo.Echo, sc Context) {
-	// e.Use(middleware.Session(sc))
+	e.Use(middleware.Session(sc))
 
 	e.GET("/", handler.HandleIndex(sc))
 	e.GET("/about", handler.HandleAbout(sc))

types/types.go

@@ -0,0 +1,11 @@
+package types
+
+import "time"
+
+type User struct {
+	Id          int
+	CreatedAt   time.Time
+	LnPubkey    string
+	NostrPubkey string
+	Msats       int64
+}