main.go 1.8 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. package main
  2. import (
  3. "embed"
  4. "github.com/gin-contrib/sessions"
  5. "github.com/gin-contrib/sessions/cookie"
  6. "github.com/gin-contrib/sessions/redis"
  7. "github.com/gin-gonic/gin"
  8. "log"
  9. "one-api/common"
  10. "one-api/middleware"
  11. "one-api/model"
  12. "one-api/router"
  13. "os"
  14. "strconv"
  15. )
  16. //go:embed web/build
  17. var buildFS embed.FS
  18. //go:embed web/build/index.html
  19. var indexPage []byte
  20. func main() {
  21. common.SetupGinLog()
  22. common.SysLog("One API " + common.Version + " started")
  23. if os.Getenv("GIN_MODE") != "debug" {
  24. gin.SetMode(gin.ReleaseMode)
  25. }
  26. // Initialize SQL Database
  27. err := model.InitDB()
  28. if err != nil {
  29. common.FatalLog(err)
  30. }
  31. defer func() {
  32. err := model.CloseDB()
  33. if err != nil {
  34. common.FatalLog(err)
  35. }
  36. }()
  37. // Initialize Redis
  38. err = common.InitRedisClient()
  39. if err != nil {
  40. common.FatalLog(err)
  41. }
  42. // Initialize options
  43. model.InitOptionMap()
  44. if os.Getenv("SYNC_FREQUENCY") != "" {
  45. frequency, err := strconv.Atoi(os.Getenv("SYNC_FREQUENCY"))
  46. if err != nil {
  47. common.FatalLog(err)
  48. }
  49. go model.SyncOptions(frequency)
  50. }
  51. // Initialize HTTP server
  52. server := gin.Default()
  53. // This will cause SSE not to work!!!
  54. //server.Use(gzip.Gzip(gzip.DefaultCompression))
  55. server.Use(middleware.CORS())
  56. // Initialize session store
  57. if common.RedisEnabled {
  58. opt := common.ParseRedisOption()
  59. store, _ := redis.NewStore(opt.MinIdleConns, opt.Network, opt.Addr, opt.Password, []byte(common.SessionSecret))
  60. server.Use(sessions.Sessions("session", store))
  61. } else {
  62. store := cookie.NewStore([]byte(common.SessionSecret))
  63. server.Use(sessions.Sessions("session", store))
  64. }
  65. router.SetRouter(server, buildFS, indexPage)
  66. var port = os.Getenv("PORT")
  67. if port == "" {
  68. port = strconv.Itoa(*common.Port)
  69. }
  70. err = server.Run(":" + port)
  71. if err != nil {
  72. log.Println(err)
  73. }
  74. }