-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.go
97 lines (79 loc) · 2.46 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
package main
import (
"context"
"log"
"os"
"os/signal"
"syscall"
"time"
"github.com/diegoclair/go_boilerplate/application/service"
"github.com/diegoclair/go_boilerplate/infra/auth"
"github.com/diegoclair/go_boilerplate/infra/cache"
"github.com/diegoclair/go_boilerplate/infra/config"
"github.com/diegoclair/go_boilerplate/infra/data"
infraLogger "github.com/diegoclair/go_boilerplate/infra/logger"
"github.com/diegoclair/go_boilerplate/transport/rest"
"github.com/diegoclair/go_boilerplate/util/crypto"
"github.com/diegoclair/go_utils/logger"
"github.com/diegoclair/go_utils/validator"
)
const (
gracefulShutdownTimeout = 10 * time.Second
)
func main() {
cfg, err := config.GetConfigEnvironment(config.ProfileRun)
if err != nil {
log.Fatalf("Error to load config: %v", err)
}
defer cfg.Close()
ctx := context.Background()
log := infraLogger.New(cfg)
authToken, err := auth.NewAuthToken(cfg.App.Auth, log)
if err != nil {
log.Errorf(ctx, "Error getting NewAuthToken: %v", err)
return
}
data, err := data.Connect(ctx, cfg, log)
if err != nil {
log.Errorf(ctx, "Error to connect dataManager repositories: %v", err)
return
}
log.Infof(ctx, "Connecting to the cache server at %s:%d.", cfg.Cache.Redis.Host, cfg.Cache.Redis.Port)
cache, err := cache.Instance(ctx, cfg, log)
if err != nil {
log.Errorf(ctx, "Error connecting to cache server: %v", err)
return
}
c := crypto.NewCrypto()
v, err := validator.NewValidator()
if err != nil {
log.Errorf(ctx, "error to get validator: %v", err)
return
}
services, err := service.New(
service.WithDataManager(data),
service.WithConfig(cfg),
service.WithCacheManager(cache),
service.WithLogger(log),
service.WithCrypto(c),
service.WithValidator(v),
)
if err != nil {
log.Errorf(ctx, "error to get domain services: %v", err)
return
}
server := rest.StartRestServer(ctx, cfg, services, log, authToken)
gracefulShutdown(server, log)
}
// will wait for a SIGTERM or SIGINT signal and wait the server to finish processing requests or timeout after 10 seconds
func gracefulShutdown(server *rest.Server, log logger.Logger) {
stop := make(chan os.Signal, 1)
signal.Notify(stop, os.Interrupt, syscall.SIGTERM, syscall.SIGINT)
<-stop
ctx, cancel := context.WithTimeout(context.Background(), gracefulShutdownTimeout)
defer cancel()
log.Info(ctx, "Shutting down...")
if err := server.Router.Echo().Shutdown(ctx); err != nil {
log.Errorf(ctx, "Error to shutdown rest server: %v", err)
}
}