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
|
// main.go
package main
import (
"log"
"net/http"
"os"
)
func main() {
tokensPath := "tokens.json"
if v := os.Getenv("TOKENS_PATH"); v != "" {
tokensPath = v
}
tokens, err := loadTokens(tokensPath)
if err != nil {
log.Fatalf("failed to load tokens from %s: %v", tokensPath, err)
}
log.Printf("loaded %d tokens", len(tokens))
hub := NewHub(tokens)
adminAuth := newAdminAuthFromEnv()
http.HandleFunc("/ws", wsHandler(hub))
// admin routes (basic auth)
http.Handle("/admin", adminAuth.requireAdmin(http.HandlerFunc(adminPageHandler)))
http.Handle("/admin/", adminAuth.requireAdmin(http.HandlerFunc(adminPageHandler)))
http.Handle("/admin/api/tokens", adminAuth.requireAdmin(http.HandlerFunc(adminTokensHandler(hub, tokensPath))))
http.Handle("/admin/api/tokens/revoke", adminAuth.requireAdmin(http.HandlerFunc(adminTokenRevokeHandler(hub, tokensPath))))
http.Handle("/admin/api/events", adminAuth.requireAdmin(http.HandlerFunc(adminEventsHandler(hub))))
addr := ":8080"
if v := os.Getenv("BRIDGE_ADDR"); v != "" {
addr = v
}
log.Printf("bridge server listening on %s", addr)
if err := http.ListenAndServe(addr, nil); err != nil {
log.Fatalf("ListenAndServe: %v", err)
}
}
|
