Feat: login done

cmd/serve/backend.go

@@ -1,25 +1,35 @@
 package serve
 
 import (
+	"database/sql"
 	"log"
 	"net/http"
 
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
 	httpSwagger "github.com/swaggo/http-swagger"
+	"github.com/uptrace/bun"
+	"github.com/uptrace/bun/dialect/sqlitedialect"
+	"github.com/uptrace/bun/driver/sqliteshim"
+	"github.com/uptrace/bun/extra/bunotel"
 	"github.com/uptrace/bunrouter"
 	"go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp"
 	"go.uber.org/zap"
 
 	_ "gitea.konchin.com/ytshih/inp2025/game/backend/docs"
+	"gitea.konchin.com/ytshih/inp2025/game/backend/handlers/api"
+	"gitea.konchin.com/ytshih/inp2025/game/backend/handlers/auth"
 	"gitea.konchin.com/ytshih/inp2025/game/backend/middlewares"
+	"gitea.konchin.com/ytshih/inp2025/game/implements"
 	"gitea.konchin.com/ytshih/inp2025/game/tracing"
+	"gitea.konchin.com/ytshih/inp2025/game/utils"
 )
 
-// @title			NASAOJ v3
-// @version		2.0
-// @license.name	0BSD
-// @BasePath		/
+//	@title						Intro. to Network Programming Game
+//	@version					0.0.1-alpha
+//	@license.name				0BSD
+//	@securityDefinitions.basic	BasicAuth
+//	@BasePath					/
 var backendCmd = &cobra.Command{
 	Use:   "backend",
 	Short: "Game backend",
@@ -27,22 +37,60 @@ var backendCmd = &cobra.Command{
 		ctx := cmd.Context()
 		tracing.InitTracer("game backend")
 
-		router := bunrouter.New()
-		backend := router.NewGroup("").
-			Use(middlewares.ErrorHandler).
-			Use(middlewares.BunrouterOtel).
-			Use(middlewares.AccessLog)
-
 		tracing.Logger.Ctx(ctx).
-			Debug("nmsl",
-				zap.Bool("swagger", viper.GetBool("swagger")))
+			Debug("connect to sql",
+				zap.String("sql.url",
+					"file:"+viper.GetString("sqlite-file")+"?cache=shared&mode=rwc"))
+		sqldb, err := sql.Open(sqliteshim.ShimName,
+			"file:"+viper.GetString("sqlite-file")+"?cache=shared&mode=rwc")
+		if err != nil {
+			tracing.Logger.Ctx(ctx).
+				Panic("failed to init sqlite",
+					zap.Error(err))
+			panic(err)
+		}
+		bunDB := bun.NewDB(sqldb, sqlitedialect.New())
+		bunDB.AddQueryHook(bunotel.NewQueryHook(bunotel.WithDBName("sqlite")))
+		if err := utils.InitDB(ctx, bunDB); err != nil {
+			tracing.Logger.Ctx(ctx).
+				Panic("failed to init db schema",
+					zap.Error(err))
+			panic(err)
+		}
+
+		db := implements.NewBunDatabase(bunDB)
+		authHandlers := auth.NewHandlers(db)
+		apiHandlers := api.NewHandlers(db)
+		middlewareHandlers := middlewares.NewHandlers(db)
+
+		router := bunrouter.New()
 
 		if viper.GetBool("swagger") {
-			backend.GET("/swagger/*any",
+			router.GET("/swagger/*any",
 				bunrouter.HTTPHandlerFunc(
 					httpSwagger.Handler()))
 		}
 
+		backend := router.NewGroup("").
+			Use(middlewareHandlers.ErrorHandler).
+			Use(middlewareHandlers.BunrouterOtel).
+			Use(middlewareHandlers.AccessLog)
+
+		authGroup := backend.NewGroup("/auth")
+		authGroup.GET("/login",
+			middlewareHandlers.Auth(
+				authHandlers.GetLogin))
+		authGroup.POST("/logout",
+			middlewareHandlers.Auth(
+				authHandlers.PostLogout))
+		authGroup.POST("/register",
+			authHandlers.PostRegister)
+
+		apiGroup := backend.NewGroup("/api").
+			Use(middlewareHandlers.Auth)
+		apiGroup.GET("/lobby/users",
+			apiHandlers.GetLobbyUsers)
+
 		tracing.Logger.Ctx(ctx).
 			Info("http server up",
 				zap.String("http.port", viper.GetString("port")))
@@ -57,4 +105,6 @@ func init() {
 		String("port", "8080", "Port to listen on")
 	backendCmd.Flags().
 		Bool("swagger", false, "Enable swagger")
+	backendCmd.Flags().
+		String("sqlite-file", ":memory:", "File for sqlite")
 }