wire.go 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  1. //go:build wireinject
  2. // +build wireinject
  3. package wire
  4. import (
  5. "github.com/go-nunu/nunu-layout-advanced/internal/handler"
  6. waf3 "github.com/go-nunu/nunu-layout-advanced/internal/handler/api/waf"
  7. "github.com/go-nunu/nunu-layout-advanced/internal/middleware"
  8. "github.com/go-nunu/nunu-layout-advanced/internal/repository"
  9. waf2 "github.com/go-nunu/nunu-layout-advanced/internal/repository/api/waf"
  10. "github.com/go-nunu/nunu-layout-advanced/internal/server"
  11. "github.com/go-nunu/nunu-layout-advanced/internal/service"
  12. "github.com/go-nunu/nunu-layout-advanced/internal/service/api/gameShield"
  13. "github.com/go-nunu/nunu-layout-advanced/internal/service/api/waf"
  14. "github.com/go-nunu/nunu-layout-advanced/pkg/app"
  15. "github.com/go-nunu/nunu-layout-advanced/pkg/jwt"
  16. "github.com/go-nunu/nunu-layout-advanced/pkg/limiter"
  17. "github.com/go-nunu/nunu-layout-advanced/pkg/log"
  18. "github.com/go-nunu/nunu-layout-advanced/pkg/server/http"
  19. "github.com/go-nunu/nunu-layout-advanced/pkg/sid"
  20. "github.com/google/wire"
  21. "github.com/spf13/viper"
  22. )
  23. var repositorySet = wire.NewSet(
  24. repository.NewDB,
  25. repository.NewRedis,
  26. repository.NewCasbinEnforcer,
  27. repository.NewMongoClient,
  28. repository.NewMongoDB,
  29. repository.NewRabbitMQ,
  30. repository.NewRepository,
  31. repository.NewTransaction,
  32. repository.NewAdminRepository,
  33. repository.NewUserRepository,
  34. repository.NewGameShieldRepository,
  35. repository.NewGameShieldPublicIpRepository,
  36. waf2.NewWebForwardingRepository,
  37. waf2.NewTcpforwardingRepository,
  38. waf2.NewUdpForWardingRepository,
  39. repository.NewGameShieldUserIpRepository,
  40. repository.NewGameShieldBackendRepository,
  41. repository.NewGameShieldSdkIpRepository,
  42. repository.NewHostRepository,
  43. waf2.NewGlobalLimitRepository,
  44. repository.NewGatewayGroupRepository,
  45. repository.NewGateWayGroupIpRepository,
  46. repository.NewCdnRepository,
  47. waf2.NewAllowAndDenyIpRepository,
  48. repository.NewProxyRepository,
  49. repository.NewCcRepository,
  50. repository.NewExpiredRepository,
  51. repository.NewLogRepository,
  52. waf2.NewGatewayipRepository,
  53. )
  54. var serviceSet = wire.NewSet(
  55. service.NewService,
  56. service.NewUserService,
  57. service.NewAdminService,
  58. gameShield.NewGameShieldService,
  59. service.NewAoDunService,
  60. service.NewGameShieldPublicIpService,
  61. service.NewDuedateService,
  62. service.NewFormatterService,
  63. service.NewParserService,
  64. service.NewRequiredService,
  65. service.NewCrawlerService,
  66. waf.NewWebForwardingService,
  67. waf.NewTcpforwardingService,
  68. waf.NewUdpForWardingService,
  69. service.NewGameShieldUserIpService,
  70. gameShield.NewGameShieldBackendService,
  71. service.NewGameShieldSdkIpService,
  72. service.NewHostService,
  73. waf.NewGlobalLimitService,
  74. service.NewGatewayGroupService,
  75. waf.NewWafFormatterService,
  76. service.NewGateWayGroupIpService,
  77. service.NewRequestService,
  78. service.NewCdnService,
  79. waf.NewAllowAndDenyIpService,
  80. service.NewProxyService,
  81. service.NewSslCertService,
  82. service.NewWebsocketService,
  83. service.NewCcService,
  84. service.NewLogService,
  85. waf.NewGatewayipService,
  86. )
  87. var handlerSet = wire.NewSet(
  88. handler.NewHandler,
  89. handler.NewUserHandler,
  90. handler.NewAdminHandler,
  91. handler.NewGameShieldHandler,
  92. handler.NewGameShieldPublicIpHandler,
  93. waf3.NewWebForwardingHandler,
  94. waf3.NewTcpforwardingHandler,
  95. waf3.NewUdpForWardingHandler,
  96. handler.NewGameShieldUserIpHandler,
  97. handler.NewGameShieldBackendHandler,
  98. handler.NewGameShieldSdkIpHandler,
  99. handler.NewHostHandler,
  100. waf3.NewGlobalLimitHandler,
  101. handler.NewGatewayGroupHandler,
  102. handler.NewGateWayGroupIpHandler,
  103. waf3.NewAllowAndDenyIpHandler,
  104. handler.NewCcHandler,
  105. waf3.NewGatewayipHandler,
  106. )
  107. // 限流器依赖集
  108. var limiterSet = wire.NewSet(
  109. limiter.NewLimiter,
  110. middleware.NewRateLimitMiddleware,
  111. )
  112. var serverSet = wire.NewSet(
  113. server.NewHTTPServer,
  114. )
  115. // build App
  116. func newApp(
  117. httpServer *http.Server,
  118. ) *app.App {
  119. return app.NewApp(
  120. app.WithServer(httpServer),
  121. app.WithName("demo-server"),
  122. )
  123. }
  124. func NewWire(*viper.Viper, *log.Logger) (*app.App, func(), error) {
  125. panic(wire.Build(
  126. repositorySet,
  127. serviceSet,
  128. handlerSet,
  129. serverSet,
  130. limiterSet,
  131. sid.NewSid,
  132. jwt.NewJwt,
  133. newApp,
  134. ))
  135. }