feat(internal/nazha): use env
This commit is contained in:
parent
fc0567db35
commit
254a871307
0
configs/.gitkeep
Normal file
0
configs/.gitkeep
Normal file
@ -1,6 +0,0 @@
|
|||||||
package configs
|
|
||||||
|
|
||||||
const (
|
|
||||||
NEZHA_HOST = "192.178.7.123:8008"
|
|
||||||
SCHEME = "ws"
|
|
||||||
)
|
|
1
internal/export.go
Normal file
1
internal/export.go
Normal file
@ -0,0 +1 @@
|
|||||||
|
package internal
|
9
main.go
9
main.go
@ -11,13 +11,18 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
// init
|
||||||
internal.Recoder()
|
internal.Recoder()
|
||||||
|
|
||||||
|
// CRON
|
||||||
c := cron.New()
|
c := cron.New()
|
||||||
|
|
||||||
c.AddFunc("@every 1h", internal.Recoder)
|
c.AddFunc("@every 1h", internal.Recoder)
|
||||||
|
|
||||||
c.Start()
|
c.Start()
|
||||||
|
|
||||||
|
// Web API
|
||||||
|
// gin := gin.Default()
|
||||||
|
|
||||||
|
// 阻塞
|
||||||
sig := make(chan os.Signal, 1)
|
sig := make(chan os.Signal, 1)
|
||||||
signal.Notify(sig, os.Interrupt, syscall.SIGTERM)
|
signal.Notify(sig, os.Interrupt, syscall.SIGTERM)
|
||||||
<-sig // 阻塞直到收到信号
|
<-sig // 阻塞直到收到信号
|
||||||
|
10
pkg/nezha.go
10
pkg/nezha.go
@ -4,8 +4,8 @@ import (
|
|||||||
"encoding/json"
|
"encoding/json"
|
||||||
"log"
|
"log"
|
||||||
"net/url"
|
"net/url"
|
||||||
|
"os"
|
||||||
|
|
||||||
"git.mmeiblog.cn/mei/nezha-recoder/configs"
|
|
||||||
"github.com/gorilla/websocket"
|
"github.com/gorilla/websocket"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -40,7 +40,13 @@ type State struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func GetData() (servers Message) {
|
func GetData() (servers Message) {
|
||||||
u := url.URL{Scheme: configs.SCHEME, Host: configs.NEZHA_HOST, Path: "/api/v1/ws/server"}
|
nazha_host := os.Getenv("NEZHA_HOST")
|
||||||
|
if nazha_host == "" {
|
||||||
|
log.Fatal("NEZHA_HOST environment variable is not set")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
u := url.URL{Scheme: "ws", Host: nazha_host, Path: "/api/v1/ws/server"}
|
||||||
|
|
||||||
conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
|
conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user