GraphQLを使用するように

backend/cfg/cfg.go

@@ -25,7 +25,7 @@ type Config struct {
 	DBReadName string `env:"DB_READ_NAME"`
 
 	// UserMaxResources UserMaxResources
-	SecretMey string `env:"SECRET_KEY,unset,required"`
+	SecretKey string `env:"SECRET_KEY,unset,required"`
 }
 
 /*

backend/cmd/di/di.go

@@ -1,13 +1,10 @@
 package di
 
 import (
-	"fmt"
-
 	"golang.org/x/crypto/bcrypt"
 
 	config "github.com/FlowingSPDG/get5loader/backend/cfg"
 	gin_controller "github.com/FlowingSPDG/get5loader/backend/controller/gin"
-	"github.com/FlowingSPDG/get5loader/backend/gateway/database"
 	mysqlconnector "github.com/FlowingSPDG/get5loader/backend/gateway/database/mysql/connector"
 	gin_presenter "github.com/FlowingSPDG/get5loader/backend/presenter/gin"
 	"github.com/FlowingSPDG/get5loader/backend/service/jwt"
@@ -16,49 +13,13 @@ import (
 	"github.com/FlowingSPDG/get5loader/backend/usecase"
 )
 
-// TODO: wire
-
-var (
-	mapPool = []string{
-		"de_inferno",
-		"de_mirage",
-		"de_nuke",
-		"de_overpass",
-		"de_vertigo",
-		"de_ancient",
-		"de_anubis",
-	}
-)
-
-func mustGetWriteConnector(cfg config.Config) database.DBConnector {
-	dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?parseTime=true&loc=Local&charset=utf8mb4", cfg.DBWriteUser, cfg.DBWritePass, cfg.DBWriteHost, cfg.DBWritePort, cfg.DBWriteName)
-	return mysqlconnector.NewMysqlConnector(dsn)
-}
-
-func InitializeGetMatchController(cfg config.Config) gin_controller.GetMatchController {
-	uuidGenerator := uuid.NewUUIDGenerator()
-	mysqlConnector := mustGetWriteConnector(cfg)
-	mysqlUsersRepositoryConnector := mysqlconnector.NewMySQLRepositoryConnector(uuidGenerator, mysqlConnector)
-	uc := usecase.NewGetMatch(mysqlUsersRepositoryConnector)
-	presenter := gin_presenter.NewMatchPresenter()
-	return gin_controller.NewGetMatchController(uc, presenter)
-}
-
-func InitializeGetVersionController() gin_controller.GetVersionController {
-	return gin_controller.NewGetVersionController()
-}
-
-func InitializeGetMaplistController() gin_controller.GetMaplistController {
-	return gin_controller.NewGetMaplistController(mapPool, []string{})
-}
-
 func InitializeUserLoginController(cfg config.Config) gin_controller.UserLoginController {
 	uuidGenerator := uuid.NewUUIDGenerator()
 	mysqlConnector := mustGetWriteConnector(cfg)
 	mysqlUsersRepositoryConnector := mysqlconnector.NewMySQLRepositoryConnector(uuidGenerator, mysqlConnector)
-	jwtService := jwt.NewJWTGateway([]byte(cfg.SecretMey))
+	jwtService := jwt.NewJWTGateway([]byte(cfg.SecretKey))
 	passwordHasher := hash.NewPasswordHasher(bcrypt.DefaultCost)
-	uc := usecase.NewUserLogin(jwtService, passwordHasher, mysqlUsersRepositoryConnector)
+	uc := usecase.NewUser(jwtService, passwordHasher, mysqlUsersRepositoryConnector)
 	presenter := gin_presenter.NewJWTPresenter()
 	return gin_controller.NewUserLoginController(uc, presenter)
 }
@@ -67,15 +28,9 @@ func InitializeUserRegisterController(cfg config.Config) gin_controller.UserRegi
 	uuidGenerator := uuid.NewUUIDGenerator()
 	mysqlConnector := mustGetWriteConnector(cfg)
 	mysqlUsersRepositoryConnector := mysqlconnector.NewMySQLRepositoryConnector(uuidGenerator, mysqlConnector)
-	jwtService := jwt.NewJWTGateway([]byte(cfg.SecretMey))
+	jwtService := jwt.NewJWTGateway([]byte(cfg.SecretKey))
 	passwordHasher := hash.NewPasswordHasher(bcrypt.DefaultCost)
-	uc := usecase.NewUserRegister(jwtService, passwordHasher, mysqlUsersRepositoryConnector)
+	uc := usecase.NewUser(jwtService, passwordHasher, mysqlUsersRepositoryConnector)
 	presenter := gin_presenter.NewJWTPresenter()
 	return gin_controller.NewUserRegisterController(uc, presenter)
 }
-
-func InitializeJWTAuthController(cfg config.Config) gin_controller.JWTAuthController {
-	jwtService := jwt.NewJWTGateway([]byte(cfg.SecretMey))
-	uc := usecase.NewValidateJWT(jwtService)
-	return gin_controller.NewJWTAuthController(uc)
-}

backend/cmd/di/gql.go

@@ -0,0 +1,72 @@
+package di
+
+import (
+	"net/http"
+	"strings"
+
+	"github.com/99designs/gqlgen/graphql/handler"
+	"github.com/99designs/gqlgen/graphql/playground"
+	"github.com/gin-gonic/gin"
+	"golang.org/x/crypto/bcrypt"
+
+	config "github.com/FlowingSPDG/get5loader/backend/cfg"
+	"github.com/FlowingSPDG/get5loader/backend/g5ctx"
+	mysqlconnector "github.com/FlowingSPDG/get5loader/backend/gateway/database/mysql/connector"
+	"github.com/FlowingSPDG/get5loader/backend/graph"
+	"github.com/FlowingSPDG/get5loader/backend/service/jwt"
+	hash "github.com/FlowingSPDG/get5loader/backend/service/password_hash"
+	"github.com/FlowingSPDG/get5loader/backend/service/uuid"
+	"github.com/FlowingSPDG/get5loader/backend/usecase"
+)
+
+func InitializeGraphQLHandler(cfg config.Config) gin.HandlerFunc {
+	// dependencies
+	uuidGenerator := uuid.NewUUIDGenerator()
+	jwtService := jwt.NewJWTGateway([]byte(cfg.SecretKey))
+	passwordHasher := hash.NewPasswordHasher(bcrypt.DefaultCost)
+	mysqlConnector := mustGetWriteConnector(cfg)
+	mysqlUsersRepositoryConnector := mysqlconnector.NewMySQLRepositoryConnector(uuidGenerator, mysqlConnector)
+
+	// usecases
+	gameServerUc := usecase.NewGameServer(mysqlUsersRepositoryConnector)
+	matchUc := usecase.NewMatch(mysqlUsersRepositoryConnector)
+	userUc := usecase.NewUser(jwtService, passwordHasher, mysqlUsersRepositoryConnector)
+	teamUc := usecase.NewTeam(mysqlUsersRepositoryConnector)
+
+	// handler
+	h := handler.NewDefaultServer(graph.NewExecutableSchema(graph.Config{Resolvers: &graph.Resolver{
+		GameServerUsecase: gameServerUc,
+		MatchUsecase:      matchUc,
+		UserUsecase:       userUc,
+		TeamUsecase:       teamUc,
+	}}))
+
+	// middleware
+	validateJWTusecase := usecase.NewValidateJWT(jwtService)
+	return func(c *gin.Context) {
+		authorization := c.GetHeader("Authorization")
+		authorization, _ = strings.CutPrefix(authorization, "Bearer ")
+		token, err := validateJWTusecase.Validate(authorization)
+		if err != nil {
+			c.AbortWithStatusJSON(http.StatusUnauthorized, gin.H{
+				"error": "unauthorized",
+			})
+			return
+		}
+
+		// contextにuserIDを入れる
+		g5ctx.SetUserTokenGinContext(c, token)
+		g5ctx.SetOperationGinContext(c, g5ctx.OperationTypeUser)
+		c.Request = c.Request.WithContext(c)
+		h.ServeHTTP(c.Writer, c.Request)
+	}
+}
+
+// Defining the Playground handler
+func InitializePlaygroundHandler() gin.HandlerFunc {
+	h := playground.Handler("GraphQL", "/query")
+
+	return func(c *gin.Context) {
+		h.ServeHTTP(c.Writer, c.Request)
+	}
+}

backend/cmd/di/must.go

@@ -0,0 +1,14 @@
+package di
+
+import (
+	"fmt"
+
+	config "github.com/FlowingSPDG/get5loader/backend/cfg"
+	"github.com/FlowingSPDG/get5loader/backend/gateway/database"
+	mysqlconnector "github.com/FlowingSPDG/get5loader/backend/gateway/database/mysql/connector"
+)
+
+func mustGetWriteConnector(cfg config.Config) database.DBConnector {
+	dsn := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?parseTime=true&loc=Local&charset=utf8mb4", cfg.DBWriteUser, cfg.DBWritePass, cfg.DBWriteHost, cfg.DBWritePort, cfg.DBWriteName)
+	return mysqlconnector.NewMysqlConnector(dsn)
+}

backend/cmd/main.go

@@ -17,74 +17,11 @@ func main() {
 	cfg := config.GetConfig()
 
 	v1 := r.Group("/api/v1")
-
-	// misc
-	// TODO: Steamでログイン・会員登録できるようにする
 	v1.POST("/login", di.InitializeUserLoginController(cfg).Handle)
 	v1.POST("/register", di.InitializeUserRegisterController(cfg).Handle)
-	// v1.POST("/logout", db.LogoutHandler)
-	v1.GET("/version", di.InitializeGetVersionController().Handle)
-	v1.GET("/maps", di.InitializeGetMaplistController().Handle)
-	v1auth := v1.Group("/")
-	v1auth.Use(di.InitializeJWTAuthController(cfg).Handle)
-	/*
-		// session handling
-		v1.GET("/login", db.LoginHandler)
-		v1.GET("/logout", db.LogoutHandler)
-
-		v1.GET("/GetMatches", api.GetMatches)
-		v1.GET("/GetMetrics", api.GetMetrics)
-		v1.GET("/GetSteamName", api.GetSteamName)
-		v1.GET("/GetTeamList", api.GetTeamList)
-		v1.GET("/GetServerList", api.GetServerList)
-		v1.GET("/CheckLoggedIn", api.CheckLoggedIn)
-	*/
-
-	// Match API for front
-	match := v1auth.Group("/match")
-	match.GET("/:matchID", di.InitializeGetMatchController(cfg).Handle)
-	/*
-		match.GET("/:matchID/GetPlayerStatInfo", api.GetPlayerStatInfo)
-
-			match.GET("/:matchID/GetStatusString", api.GetStatusString)
-			match.POST("/:matchID", api.CreateMatch) // avoid conflicts...
-
-			match.POST("/:matchID/cancel", api.MatchCancelHandler)
-			match.POST("/:matchID/rcon", api.MatchRconHandler)
-			match.POST("/:matchID/pause", api.MatchPauseHandler)
-			match.POST("/:matchID/unpause", api.MatchUnpauseHandler)
-			match.POST("/:matchID/adduser", api.MatchAddUserHandler)
-			match.GET("/:matchID/backup", api.MatchListBackupsHandler)
-			match.POST("/:matchID/backup", api.MatchLoadBackupsHandler)
-
-			// match.POST("/:matchID/vetoUpdate", api.MatchVetoUpdateHandler)
-			// match.POST("/:matchID/map/:mapNumber/demo", api.MatchDemoUploadHandler)
-	*/
-
-	/*
-		team := v1.Group("/team")
-		{
-			team.GET("/:teamID/GetTeamInfo", api.GetTeamInfo)
-			team.GET("/:teamID/GetRecentMatches", api.GetRecentMatches)
-			team.GET("/:teamID/CheckUserCanEdit", api.CheckUserCanEdit)
-			team.POST("/create", api.CreateTeam)
-			team.PUT("/:teamID/edit", api.EditTeam)
-			team.DELETE("/:teamID/delete", api.DeleteTeam)
-		}
-
-		user := v1.Group("/user")
-		{
-			user.GET("/:userID/GetUserInfo", api.GetUserInfo)
-		}
 
-		server := v1.Group("/server")
-		{
-			server.GET("/:serverID/GetServerInfo", api.GetServerInfo)
-			server.POST("/create", api.CreateServer)
-			server.PUT("/:serverID/edit", api.EditServer)
-			server.DELETE("/:serverID/delete", api.DeleteServer)
-		}
-	*/
+	v1.POST("/query", di.InitializeGraphQLHandler(cfg))
+	v1.GET("/playground", di.InitializePlaygroundHandler())
 
 	g5 := v1.Group("/get5_event")
 	evh := got5.NewGot5EventController()