wire.go 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  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/job"
  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/log"
  13. "github.com/go-nunu/nunu-layout-advanced/pkg/server/http"
  14. "github.com/go-nunu/nunu-layout-advanced/pkg/sid"
  15. "github.com/google/wire"
  16. "github.com/spf13/viper"
  17. )
  18. var repositorySet = wire.NewSet(
  19. repository.NewDB,
  20. //repository.NewRedis,
  21. repository.NewRepository,
  22. repository.NewTransaction,
  23. repository.NewUserRepository,
  24. repository.NewGameShieldRepository,
  25. repository.NewGameShieldPublicIpRepository,
  26. repository.NewWebForwardingRepository,
  27. repository.NewTcpforwardingRepository,
  28. repository.NewUdpForWardingRepository,
  29. )
  30. var serviceSet = wire.NewSet(
  31. service.NewService,
  32. service.NewUserService,
  33. service.NewGameShieldService,
  34. service.NewCrawlerService,
  35. service.NewGameShieldPublicIpService,
  36. service.NewDuedateService,
  37. service.NewFormatterService,
  38. service.NewParserService,
  39. service.NewRequiredService,
  40. service.NewWebForwardingService,
  41. service.NewTcpforwardingService,
  42. service.NewUdpForWardingService,
  43. )
  44. var handlerSet = wire.NewSet(
  45. handler.NewHandler,
  46. handler.NewUserHandler,
  47. handler.NewGameShieldHandler,
  48. handler.NewGameShieldPublicIpHandler,
  49. handler.NewWebForwardingHandler,
  50. handler.NewTcpforwardingHandler,
  51. handler.NewUdpForWardingHandler,
  52. )
  53. var jobSet = wire.NewSet(
  54. job.NewJob,
  55. job.NewUserJob,
  56. )
  57. var serverSet = wire.NewSet(
  58. server.NewHTTPServer,
  59. server.NewJobServer,
  60. )
  61. // build App
  62. func newApp(
  63. httpServer *http.Server,
  64. jobServer *server.JobServer,
  65. // task *server.Task,
  66. ) *app.App {
  67. return app.NewApp(
  68. app.WithServer(httpServer, jobServer),
  69. app.WithName("demo-server"),
  70. )
  71. }
  72. func NewWire(*viper.Viper, *log.Logger) (*app.App, func(), error) {
  73. panic(wire.Build(
  74. repositorySet,
  75. serviceSet,
  76. handlerSet,
  77. jobSet,
  78. serverSet,
  79. sid.NewSid,
  80. jwt.NewJwt,
  81. newApp,
  82. ))
  83. }