1
0
forked from sm/vain
vain/cmd/vaind/main.go

120 lines
2.6 KiB
Go
Raw Normal View History

2016-02-07 23:54:55 -08:00
package main
2016-02-08 00:15:22 -08:00
import (
"fmt"
"log"
"net/http"
"os"
"os/signal"
"syscall"
"time"
2016-02-08 00:15:22 -08:00
2016-02-11 11:57:16 -08:00
"mcquay.me/vain"
2016-02-08 00:15:22 -08:00
"github.com/kelseyhightower/envconfig"
)
const usage = "vaind <dbname>"
2016-02-08 00:15:22 -08:00
type config struct {
Port int
Insecure bool
Cert string
Key string
Static string
EmailTimeout time.Duration `envconfig:"email_timeout"`
SMTPHost string `envconfig:"smtp_host"`
SMTPPort int `envconfig:"smtp_port"`
From string
2016-02-08 00:15:22 -08:00
}
2016-02-07 23:54:55 -08:00
func main() {
log.SetFlags(log.Lshortfile)
if len(os.Args) < 2 {
fmt.Fprintf(os.Stderr, "%s\n", usage)
os.Exit(1)
}
2016-02-08 00:15:22 -08:00
c := &config{
Port: 4040,
EmailTimeout: 5 * time.Minute,
SMTPPort: 25,
2016-02-08 00:15:22 -08:00
}
if err := envconfig.Process("vain", c); err != nil {
2016-02-08 00:15:22 -08:00
fmt.Fprintf(os.Stderr, "problem processing environment: %v", err)
os.Exit(1)
}
if len(os.Args) > 1 {
switch os.Args[1] {
case "env", "e":
fmt.Printf("VAIN_PORT: %v\n", c.Port)
fmt.Printf("VAIN_INSECURE: %v\n", c.Insecure)
fmt.Printf("VAIN_CERT: %v\n", c.Cert)
fmt.Printf("VAIN_KEY: %v\n", c.Key)
fmt.Printf("VAIN_STATIC: %v\n", c.Static)
fmt.Printf("VAIN_EMAIL_TIMEOUT: %v\n", c.EmailTimeout)
fmt.Printf("VAIN_SMTP_HOST: %v\n", c.SMTPHost)
fmt.Printf("VAIN_SMTP_PORT: %v\n", c.SMTPPort)
fmt.Printf("VAIN_FROM: %v\n", c.From)
os.Exit(0)
case "help", "h":
fmt.Printf("%s\n", usage)
os.Exit(0)
2016-02-08 00:15:22 -08:00
}
}
log.Printf("%+v", c)
db, err := vain.NewMemDB(os.Args[1])
if err != nil {
fmt.Fprintf(os.Stderr, "couldn't open db: %v\n", err)
os.Exit(1)
}
sigs := make(chan os.Signal)
signal.Notify(sigs, os.Interrupt, syscall.SIGTERM)
go func() {
s := <-sigs
log.Printf("signal: %+v", s)
if err := db.Sync(); err != nil {
log.Printf("problem syncing db to disk: %+v", err)
os.Exit(1)
}
os.Exit(0)
}()
m, err := vain.NewMail(c.From, c.SMTPHost, c.SMTPPort)
if err != nil {
fmt.Fprintf(os.Stderr, "problem initializing mailer: %v", err)
os.Exit(1)
}
2016-02-08 00:15:22 -08:00
hostname := "localhost"
if hn, err := os.Hostname(); err != nil {
log.Printf("problem getting hostname: %v", err)
2016-02-08 00:15:22 -08:00
} else {
hostname = hn
}
log.Printf("serving at: http://%s:%d/", hostname, c.Port)
sm := http.NewServeMux()
vain.NewServer(sm, db, m, c.Static, c.EmailTimeout, c.Insecure)
2016-02-08 00:15:22 -08:00
addr := fmt.Sprintf(":%d", c.Port)
if c.Cert == "" || c.Key == "" {
log.Printf("INSECURE MODE")
if err := http.ListenAndServe(addr, sm); err != nil {
log.Printf("problem with http server: %v", err)
os.Exit(1)
}
} else {
if err := http.ListenAndServeTLS(addr, c.Cert, c.Key, sm); err != nil {
log.Printf("problem with http server: %v", err)
os.Exit(1)
}
2016-02-08 00:15:22 -08:00
}
2016-02-07 23:54:55 -08:00
}