wire.go 3.4 KB

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