/
main.go
155 lines (132 loc) · 3.66 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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
package main
import (
"context"
"database/sql"
"expvar"
"flag"
"fmt"
_ "net/http"
"os"
"runtime"
"strings"
"sync"
"time"
// "os"
// "time"
"github.com/cwyang/letsgo/furthur/internal/data"
"github.com/cwyang/letsgo/furthur/internal/jsonlog"
"github.com/cwyang/letsgo/furthur/internal/mailer"
_ "github.com/lib/pq"
)
var (
buildTime string
version string
)
type config struct {
port int
env string
db struct {
dsn string
maxOpenConns int
maxIdleConns int
maxIdleTime string
}
limiter struct {
rps float64
burst int
enabled bool
}
smtp struct {
host string
port int
username string
password string
sender string
}
cors struct {
trustedOrigins []string
}
}
type application struct {
config config
logger *jsonlog.Logger
models data.Models
mailer mailer.Mailer
wg sync.WaitGroup
}
func main() {
var cfg config
flag.IntVar(&cfg.port, "port", 4000, "API server port")
flag.StringVar(&cfg.env, "env", "development", "Environment(development|staging|production)")
flag.StringVar(&cfg.db.dsn, "db-dsn", "", "PostgreSQL DSN")
flag.IntVar(&cfg.db.maxOpenConns, "db-max-open-conns", 25, "max open connections")
flag.IntVar(&cfg.db.maxIdleConns, "db-max-idle-conns", 25, "max idle connections")
flag.StringVar(&cfg.db.maxIdleTime, "db-max-idle-time", "15m", "max connection idle time")
flag.Float64Var(&cfg.limiter.rps, "limiter-rps", 2, "ratelimiter max rps")
flag.IntVar(&cfg.limiter.burst, "limiter-burst", 4, "ratelimiter max burst")
flag.BoolVar(&cfg.limiter.enabled, "limiter-enabled", true, "enable ratelimiter")
flag.StringVar(&cfg.smtp.host, "smtp-host", "sandbox.smtp.mailtrap.io", "smtp host")
flag.IntVar(&cfg.smtp.port, "smtp-port", 25, "smtp port")
flag.StringVar(&cfg.smtp.username, "smtp-username", "506df4db967786", "smtp username")
flag.StringVar(&cfg.smtp.password, "smtp-password", "33f0dc28fa9db1", "smtp password")
flag.StringVar(&cfg.smtp.sender, "smtp-sender", "Greenlight <no-reply@void.net>", "smtp sender")
flag.Func("cors-trusted-origins", "trusted cors origins (comma separated)", func(val string) error {
cfg.cors.trustedOrigins = strings.Split(val, ",")
return nil
})
displayVersion := flag.Bool("version", false, "Display version")
flag.Parse()
if *displayVersion {
fmt.Printf("Version:\t%s\n", version)
fmt.Printf("Build time:\t%s\n", buildTime)
os.Exit(0)
}
logger := jsonlog.New(os.Stdout, jsonlog.LevelInfo)
db, err := openDB(cfg)
if err != nil {
logger.PrintFatal(err, nil)
}
defer db.Close()
logger.PrintInfo("db connection pool established", nil)
// exported variables
expvar.NewString("version").Set(version)
expvar.Publish("goroutines", expvar.Func(func() interface{} {
return runtime.NumGoroutine()
}))
expvar.Publish("timestamp", expvar.Func(func() interface{} {
return time.Now().Unix()
}))
expvar.Publish("database", expvar.Func(func() interface{} {
return db.Stats()
}))
app := &application{
config: cfg,
logger: logger,
models: data.NewModels(db),
mailer: mailer.New(cfg.smtp.host, cfg.smtp.port, cfg.smtp.username, cfg.smtp.password, cfg.smtp.sender),
}
err = app.serve()
if err != nil {
logger.PrintFatal(err, nil)
}
}
func openDB(cfg config) (*sql.DB, error) {
db, err := sql.Open("postgres", cfg.db.dsn)
if err != nil {
return nil, err
}
db.SetMaxOpenConns(cfg.db.maxOpenConns)
db.SetMaxIdleConns(cfg.db.maxIdleConns)
duration, err := time.ParseDuration(cfg.db.maxIdleTime)
if err != nil {
return nil, err
}
db.SetConnMaxIdleTime(duration)
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
err = db.PingContext(ctx)
if err != nil {
return nil, err
}
return db, nil
}