app.go 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. package app
  2. import (
  3. "context"
  4. "github.com/go-nunu/nunu-layout-advanced/pkg/server"
  5. "log"
  6. "os"
  7. "os/signal"
  8. "syscall"
  9. )
  10. type App struct {
  11. name string
  12. servers []server.Server
  13. }
  14. type Option func(a *App)
  15. func NewApp(opts ...Option) *App {
  16. a := &App{}
  17. for _, opt := range opts {
  18. opt(a)
  19. }
  20. return a
  21. }
  22. func WithServer(servers ...server.Server) Option {
  23. return func(a *App) {
  24. a.servers = servers
  25. }
  26. }
  27. func WithName(name string) Option {
  28. return func(a *App) {
  29. a.name = name
  30. }
  31. }
  32. func (a *App) Run(ctx context.Context) error {
  33. ctx, cancel := context.WithCancel(ctx)
  34. signals := make(chan os.Signal, 1)
  35. signal.Notify(signals, syscall.SIGINT, syscall.SIGTERM)
  36. endpoints := make([]string, 0)
  37. for _, srv := range a.servers {
  38. if s, ok := srv.(server.Endpointer); ok {
  39. e, err := s.Endpoint()
  40. if err != nil {
  41. return err
  42. }
  43. endpoints = append(endpoints, e.String())
  44. }
  45. go func(srv server.Server) {
  46. err := srv.Start(ctx)
  47. if err != nil {
  48. cancel()
  49. log.Fatal("app start err:", err)
  50. }
  51. }(srv)
  52. }
  53. <-signals
  54. cancel()
  55. for _, srv := range a.servers {
  56. err := srv.Stop(ctx)
  57. if err != nil {
  58. log.Fatal("app stop err:", err)
  59. }
  60. }
  61. return nil
  62. }