wire.go 5.1 KB

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