wire.go 4.4 KB

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