This repository has been archived by the owner on Sep 26, 2021. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 68
/
Copy pathmain.go
76 lines (73 loc) · 2.01 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
package main
import (
"context"
"io"
"log"
"math/rand"
"net/http"
"os"
"os/signal"
"syscall"
"time"
"github.com/gin-contrib/sessions"
"github.com/gin-contrib/sessions/cookie"
"github.com/gin-gonic/gin"
_ "github.com/joho/godotenv/autoload"
"github.com/robfig/cron/v3"
"github.com/zjyl1994/livetv/global"
"github.com/zjyl1994/livetv/route"
"github.com/zjyl1994/livetv/service"
)
func main() {
rand.Seed(time.Now().UnixNano())
log.SetFlags(log.LstdFlags | log.Lshortfile)
log.Println("Server listen", os.Getenv("LIVETV_LISTEN"))
log.Println("Server datadir", os.Getenv("LIVETV_DATADIR"))
logFile, err := os.OpenFile(os.Getenv("LIVETV_DATADIR")+"/livetv.log", os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0644)
if err != nil {
log.Panicln(err)
}
log.SetOutput(io.MultiWriter(os.Stderr, logFile))
err = global.InitDB(os.Getenv("LIVETV_DATADIR") + "/livetv.db")
if err != nil {
log.Panicf("init: %s\n", err)
}
log.Println("LiveTV starting...")
go service.LoadChannelCache()
c := cron.New()
_, err = c.AddFunc("0 */4 * * *", service.UpdateURLCache)
if err != nil {
log.Panicf("preloadCron: %s\n", err)
}
c.Start()
sessionSecert, err := service.GetConfig("password")
if err != nil {
sessionSecert = "sessionSecert"
}
gin.SetMode(gin.ReleaseMode)
router := gin.Default()
store := cookie.NewStore([]byte(sessionSecert))
router.Use(sessions.Sessions("mysession", store))
router.Static("/assert", "./assert")
route.Register(router)
srv := &http.Server{
Addr: os.Getenv("LIVETV_LISTEN"),
Handler: router,
}
go func() {
if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
log.Panicf("listen: %s\n", err)
}
}()
quit := make(chan os.Signal, 1)
signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM)
<-quit
log.Println("Shuting down server...")
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
if err := srv.Shutdown(ctx); err != nil {
log.Panicf("Server forced to shutdown: %s\n", err)
}
log.Println("Server exiting")
logFile.Close()
}