/
main.go
77 lines (68 loc) · 1.52 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
package main
import (
"encoding/json"
"fmt"
"log"
"os"
"github.com/factorysh/microdensity/application"
"github.com/factorysh/microdensity/conf"
"github.com/factorysh/microdensity/version"
"go.uber.org/zap"
)
func main() {
fmt.Println("Version", version.Version())
configPath := os.Getenv("CONFIG")
if configPath == "" {
configPath = "/etc/microdensity.yml"
}
logger, err := zap.NewProduction()
if err != nil {
log.Fatalf("can't initialize zap logger: %v", err)
}
defer logger.Sync()
l := logger.With(zap.String("config path", configPath))
cfg, err := conf.Open(configPath)
if err != nil {
l.Error("Opening conf", zap.Error(err))
os.Exit(1)
}
cfg.Defaults()
raw, err := json.Marshal(cfg)
if err != nil {
l.Error("Marshalling conf", zap.Error(err))
os.Exit(1)
}
var cfgPub conf.Conf
err = json.Unmarshal(raw, &cfgPub)
if err != nil {
l.Error("Marshalling conf", zap.Error(err))
os.Exit(1)
}
cfgPub.OAuth.AppSecret = "•••"
l = l.With(zap.Any("config", cfgPub))
a, err := application.New(cfg)
if err != nil {
l.Error("Application", zap.Error(err))
os.Exit(1)
}
logger.Info("starting")
err = a.Run(cfg.Listen)
if err != nil {
l.Error("Run", zap.Error(err))
os.Exit(1)
}
if cfg.AdminListen == "" {
cfg.AdminListen = "127.0.0.1:3615"
}
err = a.AdminRun(cfg.AdminListen)
if err != nil {
l.Error("AdminRun", zap.Error(err))
os.Exit(1)
}
<-a.Stopper
logger.Info("shutdown signal received")
err = a.Shutdown()
if err != nil {
l.Error("error on shutdown", zap.Error(err))
}
}