Upload 16 files

.dockerignore

@@ -0,0 +1,9 @@
+.env
+.git
+.gitignore
+README.md
+Dockerfile
+.dockerignore
+test.db
+*.log
+.DS_Store

.env

@@ -0,0 +1,12 @@
+# For local development, use sqlite
+DB_DIALECT=sqlite
+
+# For production, comment out the line above and use mysql
+# DB_DIALECT=mysql
+# DATABASE_URI="user:password@tcp(host:port)/dbname?charset=utf8mb4&parseTime=True&loc=Local"
+SECRET="asupersecretkey"
+
+ADMIN_USERNAME="admin"
+ADMIN_PASSWORD="password"
+
+CORS_ALLOWED_ORIGINS="http://localhost:3000,http://192.168.2.4:3000"

.env.example

@@ -0,0 +1,10 @@
+DB_DIALECT=mysql
+DATABASE_URI="user:password@tcp(host:port)/dbname?charset=utf8mb4&parseTime=True&loc=Local"
+
+REDIS_URI="rediss://user:password@host:port/db"
+SECRET="asupersecretkey"
+
+ADMIN_USERNAME="admin"
+ADMIN_PASSWORD="password"
+
+CORS_ALLOWED_ORIGINS="http://localhost:3000,http://192.168.2.4:3000"

Dockerfile

@@ -0,0 +1,37 @@
+# 使用官方 Go 镜像作为构建环境
+FROM golang:1.21-alpine AS builder
+
+# 设置工作目录
+WORKDIR /app
+
+# 复制 go mod 文件
+COPY go.mod go.sum ./
+
+# 下载依赖
+RUN go mod download
+
+# 复制源代码
+COPY . .
+
+# 构建应用
+RUN CGO_ENABLED=1 GOOS=linux go build -a -installsuffix cgo -o main .
+
+# 使用轻量级的 Alpine Linux 作为运行环境
+FROM alpine:latest
+
+# 安装必要的包
+RUN apk --no-cache add ca-certificates sqlite
+
+# 设置工作目录
+WORKDIR /root/
+
+# 从构建阶段复制可执行文件
+COPY --from=builder /app/main .
+
+# 环境变量将在运行时传入，而不是在构建时。
+
+# 暴露端口
+EXPOSE 8080
+
+# 运行应用
+CMD ["./main"]

controllers/auth.go

@@ -0,0 +1,55 @@
+package controllers
+
+import (
+	"net/http"
+	"os"
+	"time"
+	"uptime/backend/database"
+	"uptime/backend/models"
+
+	"github.com/gin-gonic/gin"
+	"github.com/golang-jwt/jwt/v5"
+	"golang.org/x/crypto/bcrypt"
+)
+
+func Login(c *gin.Context) {
+	var body struct {
+		Username string `json:"username"`
+		Password string `json:"password"`
+	}
+
+	if err := c.BindJSON(&body); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Failed to read body"})
+		return
+	}
+
+	var user models.User
+	database.DB.First(&user, "username = ?", body.Username)
+
+	if user.ID == 0 {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Invalid username or password"})
+		return
+	}
+
+	err := bcrypt.CompareHashAndPassword([]byte(user.Password), []byte(body.Password))
+	if err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Invalid username or password"})
+		return
+	}
+
+	token := jwt.NewWithClaims(jwt.SigningMethodHS256, jwt.MapClaims{
+		"sub": user.ID,
+		"exp": time.Now().Add(time.Hour * 24 * 30).Unix(),
+	})
+
+	tokenString, err := token.SignedString([]byte(os.Getenv("SECRET")))
+	if err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "Failed to create token"})
+		return
+	}
+
+	c.SetSameSite(http.SameSiteLaxMode)
+	c.SetCookie("Authorization", tokenString, 3600*24*30, "/", "", false, true)
+
+	c.JSON(http.StatusOK, gin.H{})
+}

controllers/monitor.go

@@ -0,0 +1,111 @@
+package controllers
+
+import (
+	"net/http"
+	"uptime/backend/database"
+	"uptime/backend/models"
+	"uptime/backend/services"
+
+	"github.com/gin-gonic/gin"
+)
+
+// CreateMonitor creates a new monitor
+func CreateMonitor(c *gin.Context) {
+	var monitor models.Monitor
+	if err := c.ShouldBindJSON(&monitor); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+		return
+	}
+
+	database.DB.Create(&monitor)
+	c.JSON(http.StatusOK, monitor)
+}
+
+// GetMonitors retrieves all monitors
+func GetMonitors(c *gin.Context) {
+	var monitors []models.Monitor
+	database.DB.Find(&monitors)
+
+	type MonitorWithLatency struct {
+		models.Monitor
+		Latency uint `json:"latency"`
+	}
+
+	var monitorsWithLatency []MonitorWithLatency
+
+	for _, m := range monitors {
+		var latency models.Latency
+		database.DB.Where("monitor_id = ?", m.ID).Order("created_at desc").First(&latency)
+		monitorsWithLatency = append(monitorsWithLatency, MonitorWithLatency{
+			Monitor: m,
+			Latency: latency.Latency,
+		})
+	}
+
+	c.JSON(http.StatusOK, monitorsWithLatency)
+}
+
+// GetMonitor retrieves a single monitor by ID
+func GetMonitor(c *gin.Context) {
+	id := c.Params.ByName("id")
+	var monitor models.Monitor
+	if err := database.DB.First(&monitor, id).Error; err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Monitor not found"})
+		return
+	}
+
+	var latencies []models.Latency
+	database.DB.Where("monitor_id = ?", monitor.ID).Order("created_at desc").Limit(100).Find(&latencies)
+
+	c.JSON(http.StatusOK, gin.H{
+		"monitor":   monitor,
+		"latencies": latencies,
+	})
+}
+
+// UpdateMonitor updates an existing monitor
+func UpdateMonitor(c *gin.Context) {
+	id := c.Params.ByName("id")
+	var monitor models.Monitor
+	if err := database.DB.First(&monitor, id).Error; err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Monitor not found"})
+		return
+	}
+
+	if err := c.ShouldBindJSON(&monitor); err != nil {
+		c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+		return
+	}
+
+	database.DB.Save(&monitor)
+	c.JSON(http.StatusOK, monitor)
+}
+
+// DeleteMonitor deletes a monitor
+func DeleteMonitor(c *gin.Context) {
+	id := c.Params.ByName("id")
+	var monitor models.Monitor
+	if err := database.DB.First(&monitor, id).Error; err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Monitor not found"})
+		return
+	}
+	database.DB.Unscoped().Delete(&monitor)
+	services.DeletedMonitorIDs <- monitor.ID
+	c.JSON(http.StatusOK, gin.H{"message": "Monitor deleted successfully"})
+}
+
+// ManualCheck triggers a manual check for a specific monitor
+func ManualCheck(c *gin.Context) {
+	id := c.Params.ByName("id")
+	var monitor models.Monitor
+	if err := database.DB.First(&monitor, id).Error; err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Monitor not found"})
+		return
+	}
+
+	// TODO: Trigger manual check - for now just update status to pending
+	monitor.Status = "pending"
+	database.DB.Save(&monitor)
+	
+	c.JSON(http.StatusOK, gin.H{"message": "Manual check triggered", "monitor": monitor})
+}

database/database.go

@@ -0,0 +1,36 @@
+package database
+
+import (
+	"log"
+	"os"
+	"strings"
+	"uptime/backend/models"
+
+	"github.com/glebarez/sqlite"
+	"gorm.io/driver/mysql"
+	"gorm.io/gorm"
+)
+
+var DB *gorm.DB
+
+func ConnectDatabase() {
+	var err error
+	dsn := os.Getenv("DATABASE_URI")
+	if dsn == "" {
+		log.Println("DATABASE_URI is not set, falling back to sqlite.")
+		DB, err = gorm.Open(sqlite.Open("test.db"), &gorm.Config{})
+	} else if strings.HasPrefix(dsn, "mysql://") {
+		// GORM's MySQL driver expects a DSN without the scheme.
+		// Example: user:pass@tcp(127.0.0.1:3306)/dbname?charset=utf8mb4&parseTime=True&loc=Local
+		mysqlDSN := strings.TrimPrefix(dsn, "mysql://")
+		DB, err = gorm.Open(mysql.Open(mysqlDSN), &gorm.Config{})
+	} else {
+		log.Fatalf("Unsupported database URI scheme: %s", dsn)
+	}
+
+	if err != nil {
+		log.Fatal("Failed to connect to database!", err)
+	}
+
+	DB.AutoMigrate(&models.Monitor{}, &models.Latency{}, &models.User{})
+}

database/redis.go

@@ -0,0 +1,45 @@
+package database
+
+import (
+	"context"
+	"crypto/tls"
+	"log"
+	"os"
+	"strings"
+
+	"github.com/go-redis/redis/v8"
+)
+
+var RDB *redis.Client
+
+func ConnectRedis() {
+	redisURI := os.Getenv("REDIS_URI")
+	if redisURI == "" {
+		log.Println("REDIS_URI is not set, skipping Redis connection.")
+		return
+	}
+
+	opt, err := redis.ParseURL(redisURI)
+	if err != nil {
+		log.Fatalf("Failed to parse Redis URI: %v", err)
+	}
+
+	// The `rediss` scheme implies TLS. The go-redis library handles this automatically
+	// if the URI scheme is "rediss". For explicit clarity or custom TLS configs,
+	// you could add a TLS config to opt.TLSConfig.
+	if strings.HasPrefix(redisURI, "rediss://") {
+		opt.TLSConfig = &tls.Config{
+			MinVersion: tls.VersionTLS12,
+		}
+	}
+
+	RDB = redis.NewClient(opt)
+
+	ctx := context.Background()
+	_, err = RDB.Ping(ctx).Result()
+	if err != nil {
+		log.Fatalf("Failed to connect to Redis: %v", err)
+	}
+
+	log.Println("Successfully connected to Redis.")
+}

go.mod

@@ -0,0 +1,58 @@
+module uptime/backend
+
+go 1.24.1
+
+require (
+	filippo.io/edwards25519 v1.1.0 // indirect
+	github.com/bytedance/sonic v1.13.3 // indirect
+	github.com/bytedance/sonic/loader v0.3.0 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/cloudwego/base64x v0.1.5 // indirect
+	github.com/cloudwego/iasm v0.2.0 // indirect
+	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	github.com/dustin/go-humanize v1.0.1 // indirect
+	github.com/gabriel-vasile/mimetype v1.4.9 // indirect
+	github.com/gin-contrib/cors v1.7.6 // indirect
+	github.com/gin-contrib/sse v1.1.0 // indirect
+	github.com/gin-gonic/gin v1.10.1 // indirect
+	github.com/glebarez/go-sqlite v1.21.2 // indirect
+	github.com/glebarez/sqlite v1.11.0 // indirect
+	github.com/go-playground/locales v0.14.1 // indirect
+	github.com/go-playground/universal-translator v0.18.1 // indirect
+	github.com/go-playground/validator/v10 v10.27.0 // indirect
+	github.com/go-redis/redis/v8 v8.11.5 // indirect
+	github.com/go-sql-driver/mysql v1.9.3 // indirect
+	github.com/goccy/go-json v0.10.5 // indirect
+	github.com/golang-jwt/jwt/v5 v5.2.2 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/jinzhu/inflection v1.0.0 // indirect
+	github.com/jinzhu/now v1.1.5 // indirect
+	github.com/joho/godotenv v1.5.1 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/klauspost/cpuid/v2 v2.2.11 // indirect
+	github.com/leodido/go-urn v1.4.0 // indirect
+	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/mattn/go-sqlite3 v1.14.22 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/ncruces/go-strftime v0.1.9 // indirect
+	github.com/pelletier/go-toml/v2 v2.2.4 // indirect
+	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
+	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
+	github.com/ugorji/go/codec v1.3.0 // indirect
+	golang.org/x/arch v0.19.0 // indirect
+	golang.org/x/crypto v0.40.0 // indirect
+	golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0 // indirect
+	golang.org/x/net v0.42.0 // indirect
+	golang.org/x/sys v0.34.0 // indirect
+	golang.org/x/text v0.27.0 // indirect
+	google.golang.org/protobuf v1.36.6 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+	gorm.io/driver/mysql v1.6.0 // indirect
+	gorm.io/driver/sqlite v1.6.0 // indirect
+	gorm.io/gorm v1.30.0 // indirect
+	modernc.org/libc v1.65.10 // indirect
+	modernc.org/mathutil v1.7.1 // indirect
+	modernc.org/memory v1.11.0 // indirect
+	modernc.org/sqlite v1.38.0 // indirect
+)

go.sum

@@ -0,0 +1,125 @@
+filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
+filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
+github.com/bytedance/sonic v1.13.3 h1:MS8gmaH16Gtirygw7jV91pDCN33NyMrPbN7qiYhEsF0=
+github.com/bytedance/sonic v1.13.3/go.mod h1:o68xyaF9u2gvVBuGHPlUVCy+ZfmNNO5ETf1+KgkJhz4=
+github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
+github.com/bytedance/sonic/loader v0.3.0 h1:dskwH8edlzNMctoruo8FPTJDF3vLtDT0sXZwvZJyqeA=
+github.com/bytedance/sonic/loader v0.3.0/go.mod h1:N8A3vUdtUebEY2/VQC0MyhYeKUFosQU6FxH2JmUe6VI=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/cloudwego/base64x v0.1.5 h1:XPciSp1xaq2VCSt6lF0phncD4koWyULpl5bUxbfCyP4=
+github.com/cloudwego/base64x v0.1.5/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w=
+github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg=
+github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
+github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
+github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
+github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
+github.com/gabriel-vasile/mimetype v1.4.9 h1:5k+WDwEsD9eTLL8Tz3L0VnmVh9QxGjRmjBvAG7U/oYY=
+github.com/gabriel-vasile/mimetype v1.4.9/go.mod h1:WnSQhFKJuBlRyLiKohA/2DtIlPFAbguNaG7QCHcyGok=
+github.com/gin-contrib/cors v1.7.6 h1:3gQ8GMzs1Ylpf70y8bMw4fVpycXIeX1ZemuSQIsnQQY=
+github.com/gin-contrib/cors v1.7.6/go.mod h1:Ulcl+xN4jel9t1Ry8vqph23a60FwH9xVLd+3ykmTjOk=
+github.com/gin-contrib/sse v1.1.0 h1:n0w2GMuUpWDVp7qSpvze6fAu9iRxJY4Hmj6AmBOU05w=
+github.com/gin-contrib/sse v1.1.0/go.mod h1:hxRZ5gVpWMT7Z0B0gSNYqqsSCNIJMjzvm6fqCz9vjwM=
+github.com/gin-gonic/gin v1.10.1 h1:T0ujvqyCSqRopADpgPgiTT63DUQVSfojyME59Ei63pQ=
+github.com/gin-gonic/gin v1.10.1/go.mod h1:4PMNQiOhvDRa013RKVbsiNwoyezlm2rm0uX/T7kzp5Y=
+github.com/glebarez/go-sqlite v1.21.2 h1:3a6LFC4sKahUunAmynQKLZceZCOzUthkRkEAl9gAXWo=
+github.com/glebarez/go-sqlite v1.21.2/go.mod h1:sfxdZyhQjTM2Wry3gVYWaW072Ri1WMdWJi0k6+3382k=
+github.com/glebarez/sqlite v1.11.0 h1:wSG0irqzP6VurnMEpFGer5Li19RpIRi2qvQz++w0GMw=
+github.com/glebarez/sqlite v1.11.0/go.mod h1:h8/o8j5wiAsqSPoWELDUdJXhjAhsVliSn7bWZjOhrgQ=
+github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
+github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY=
+github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY=
+github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY=
+github.com/go-playground/validator/v10 v10.27.0 h1:w8+XrWVMhGkxOaaowyKH35gFydVHOvC0/uWoy2Fzwn4=
+github.com/go-playground/validator/v10 v10.27.0/go.mod h1:I5QpIEbmr8On7W0TktmJAumgzX4CA1XNl4ZmDuVHKKo=
+github.com/go-redis/redis/v8 v8.11.5 h1:AcZZR7igkdvfVmQTPnu9WE37LRrO/YrBH5zWyjDC0oI=
+github.com/go-redis/redis/v8 v8.11.5/go.mod h1:gREzHqY1hg6oD9ngVRbLStwAWKhA0FEgq8Jd4h5lpwo=
+github.com/go-sql-driver/mysql v1.9.3 h1:U/N249h2WzJ3Ukj8SowVFjdtZKfu9vlLZxjPXV1aweo=
+github.com/go-sql-driver/mysql v1.9.3/go.mod h1:qn46aNg1333BRMNU69Lq93t8du/dwxI64Gl8i5p1WMU=
+github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4=
+github.com/goccy/go-json v0.10.5/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
+github.com/golang-jwt/jwt/v5 v5.2.2 h1:Rl4B7itRWVtYIHFrSNd7vhTiz9UpLdi6gZhZ3wEeDy8=
+github.com/golang-jwt/jwt/v5 v5.2.2/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
+github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
+github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
+github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
+github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
+github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
+github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
+github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
+github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
+github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
+github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
+github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
+github.com/klauspost/cpuid/v2 v2.2.11 h1:0OwqZRYI2rFrjS4kvkDnqJkKHdHaRnCm68/DY4OxRzU=
+github.com/klauspost/cpuid/v2 v2.2.11/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
+github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M=
+github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
+github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
+github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
+github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
+github.com/mattn/go-sqlite3 v1.14.22 h1:2gZY6PC6kBnID23Tichd1K+Z0oS6nE/XwU+Vz/5o4kU=
+github.com/mattn/go-sqlite3 v1.14.22/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
+github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
+github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
+github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
+github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M=
+github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
+github.com/ncruces/go-strftime v0.1.9 h1:bY0MQC28UADQmHmaF5dgpLmImcShSi2kHU9XLdhx/f4=
+github.com/ncruces/go-strftime v0.1.9/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls=
+github.com/pelletier/go-toml/v2 v2.2.4 h1:mye9XuhQ6gvn5h28+VilKrrPoQVanw5PMw/TB0t5Ec4=
+github.com/pelletier/go-toml/v2 v2.2.4/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
+github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
+github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
+github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
+github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
+github.com/ugorji/go/codec v1.3.0 h1:Qd2W2sQawAfG8XSvzwhBeoGq71zXOC/Q1E9y/wUcsUA=
+github.com/ugorji/go/codec v1.3.0/go.mod h1:pRBVtBSKl77K30Bv8R2P+cLSGaTtex6fsA2Wjqmfxj4=
+golang.org/x/arch v0.19.0 h1:LmbDQUodHThXE+htjrnmVD73M//D9GTH6wFZjyDkjyU=
+golang.org/x/arch v0.19.0/go.mod h1:bdwinDaKcfZUGpH09BB7ZmOfhalA8lQdzl62l8gGWsk=
+golang.org/x/crypto v0.40.0 h1:r4x+VvoG5Fm+eJcxMaY8CQM7Lb0l1lsmjGBQ6s8BfKM=
+golang.org/x/crypto v0.40.0/go.mod h1:Qr1vMER5WyS2dfPHAlsOj01wgLbsyWtFn/aY+5+ZdxY=
+golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0 h1:R84qjqJb5nVJMxqWYb3np9L5ZsaDtB+a39EqjV0JSUM=
+golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0/go.mod h1:S9Xr4PYopiDyqSyp5NjCrhFrqg6A5zA2E/iPHPhqnS8=
+golang.org/x/net v0.42.0 h1:jzkYrhi3YQWD6MLBJcsklgQsoAcw89EcZbJw8Z614hs=
+golang.org/x/net v0.42.0/go.mod h1:FF1RA5d3u7nAYA4z2TkclSCKh68eSXtiFwcWQpPXdt8=
+golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.34.0 h1:H5Y5sJ2L2JRdyv7ROF1he/lPdvFsd0mJHFw2ThKHxLA=
+golang.org/x/sys v0.34.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/text v0.27.0 h1:4fGWRpyh641NLlecmyl4LOe6yDdfaYNrGb2zdfo4JV4=
+golang.org/x/text v0.27.0/go.mod h1:1D28KMCvyooCX9hBiosv5Tz/+YLxj0j7XhWjpSUF7CU=
+google.golang.org/protobuf v1.36.6 h1:z1NpPI8ku2WgiWnf+t9wTPsn6eP1L7ksHUlkfLvd9xY=
+google.golang.org/protobuf v1.36.6/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gorm.io/driver/mysql v1.6.0 h1:eNbLmNTpPpTOVZi8MMxCi2aaIm0ZpInbORNXDwyLGvg=
+gorm.io/driver/mysql v1.6.0/go.mod h1:D/oCC2GWK3M/dqoLxnOlaNKmXz8WNTfcS9y5ovaSqKo=
+gorm.io/driver/sqlite v1.6.0 h1:WHRRrIiulaPiPFmDcod6prc4l2VGVWHz80KspNsxSfQ=
+gorm.io/driver/sqlite v1.6.0/go.mod h1:AO9V1qIQddBESngQUKWL9yoH93HIeA1X6V633rBwyT8=
+gorm.io/gorm v1.30.0 h1:qbT5aPv1UH8gI99OsRlvDToLxW5zR7FzS9acZDOZcgs=
+gorm.io/gorm v1.30.0/go.mod h1:8Z33v652h4//uMA76KjeDH8mJXPm1QNCYrMeatR0DOE=
+modernc.org/libc v1.65.10 h1:ZwEk8+jhW7qBjHIT+wd0d9VjitRyQef9BnzlzGwMODc=
+modernc.org/libc v1.65.10/go.mod h1:StFvYpx7i/mXtBAfVOjaU0PWZOvIRoZSgXhrwXzr8Po=
+modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=
+modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=
+modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI=
+modernc.org/memory v1.11.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=
+modernc.org/sqlite v1.38.0 h1:+4OrfPQ8pxHKuWG4md1JpR/EYAh3Md7TdejuuzE7EUI=
+modernc.org/sqlite v1.38.0/go.mod h1:1Bj+yES4SVvBZ4cBOpVZ6QgesMCKpJZDq0nxYzOpmNE=
+nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50=
+rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=

main.go

@@ -0,0 +1,98 @@
+package main
+
+import (
+	"log"
+	"os"
+	"strings"
+	"uptime/backend/controllers"
+	"uptime/backend/database"
+	"uptime/backend/middleware"
+	"uptime/backend/models"
+	"uptime/backend/services"
+
+	"github.com/gin-contrib/cors"
+	"github.com/gin-gonic/gin"
+	"github.com/joho/godotenv"
+	"golang.org/x/crypto/bcrypt"
+)
+
+func main() {
+	// 在开发环境中加载 .env 文件，如果文件不存在则忽略错误
+	// 在生产环境中，变量将通过环境变量直接提供
+	if err := godotenv.Load(); err != nil {
+		log.Println("No .env file found, using environment variables")
+	}
+
+	database.ConnectDatabase()
+	database.ConnectRedis()
+
+	createAdminUser()
+
+	go services.StartMonitoring()
+
+	r := gin.Default()
+	config := cors.DefaultConfig()
+	origins := os.Getenv("CORS_ALLOWED_ORIGINS")
+	if origins == "" {
+		origins = "http://localhost:3000" // Default for local development
+	}
+	config.AllowOrigins = strings.Split(origins, ",")
+	config.AllowCredentials = true
+	r.Use(cors.New(config))
+
+	api := r.Group("/api")
+	{
+		api.POST("/login", controllers.Login)
+
+		authorized := api.Group("/")
+		authorized.Use(middleware.RequireAuth)
+		{
+			authorized.POST("/monitors", controllers.CreateMonitor)
+			authorized.GET("/monitors", controllers.GetMonitors)
+			authorized.GET("/monitors/:id", controllers.GetMonitor)
+			authorized.PUT("/monitors/:id", controllers.UpdateMonitor)
+			authorized.DELETE("/monitors/:id", controllers.DeleteMonitor)
+			authorized.POST("/monitors/:id/check", controllers.ManualCheck)
+		}
+	}
+
+	r.GET("/ping", func(c *gin.Context) {
+		c.JSON(200, gin.H{
+			"message": "pong",
+		})
+	})
+	r.Run() // listen and serve on 0.0.0.0:8080
+}
+
+func createAdminUser() {
+	username := os.Getenv("ADMIN_USERNAME")
+	password := os.Getenv("ADMIN_PASSWORD")
+
+	if username == "" || password == "" {
+		log.Println("ADMIN_USERNAME or ADMIN_PASSWORD not set, skipping admin user creation.")
+		return
+	}
+
+	var user models.User
+	database.DB.First(&user, "username = ?", username)
+
+	hashedPassword, err := bcrypt.GenerateFromPassword([]byte(password), 10)
+	if err != nil {
+		log.Fatalf("Failed to hash password: %v", err)
+	}
+
+	if user.ID == 0 {
+		// Create new admin user
+		admin := models.User{Username: username, Password: string(hashedPassword)}
+		if err := database.DB.Create(&admin).Error; err != nil {
+			log.Fatalf("Failed to create admin user: %v", err)
+		}
+		log.Println("Admin user created successfully.")
+	} else {
+		// Update existing admin user's password
+		if err := database.DB.Model(&user).Update("password", string(hashedPassword)).Error; err != nil {
+			log.Fatalf("Failed to update admin user: %v", err)
+		}
+		log.Println("Admin user password updated successfully.")
+	}
+}

middleware/requireAuth.go

@@ -0,0 +1,56 @@
+package middleware
+
+import (
+	"fmt"
+	"net/http"
+	"os"
+	"time"
+	"uptime/backend/database"
+	"uptime/backend/models"
+
+	"github.com/gin-gonic/gin"
+	"github.com/golang-jwt/jwt/v5"
+)
+
+func RequireAuth(c *gin.Context) {
+	tokenString, err := c.Cookie("Authorization")
+
+	if err != nil {
+		c.AbortWithStatus(http.StatusUnauthorized)
+		return
+	}
+
+	token, err := jwt.Parse(tokenString, func(token *jwt.Token) (interface{}, error) {
+		if _, ok := token.Method.(*jwt.SigningMethodHMAC); !ok {
+			return nil, fmt.Errorf("Unexpected signing method: %v", token.Header["alg"])
+		}
+
+		return []byte(os.Getenv("SECRET")), nil
+	})
+
+	if err != nil {
+		c.AbortWithStatus(http.StatusUnauthorized)
+		return
+	}
+
+	if claims, ok := token.Claims.(jwt.MapClaims); ok && token.Valid {
+		if float64(time.Now().Unix()) > claims["exp"].(float64) {
+			c.AbortWithStatus(http.StatusUnauthorized)
+			return
+		}
+
+		var user models.User
+		database.DB.First(&user, claims["sub"])
+
+		if user.ID == 0 {
+			c.AbortWithStatus(http.StatusUnauthorized)
+			return
+		}
+
+		c.Set("user", user)
+
+		c.Next()
+	} else {
+		c.AbortWithStatus(http.StatusUnauthorized)
+	}
+}

models/latency.go

@@ -0,0 +1,9 @@
+package models
+
+import "gorm.io/gorm"
+
+type Latency struct {
+	gorm.Model
+	MonitorID uint `json:"monitorId"`
+	Latency   uint `json:"latency"` // Latency in milliseconds
+}

models/monitor.go

@@ -0,0 +1,22 @@
+package models
+
+import "gorm.io/gorm"
+
+type Monitor struct {
+	gorm.Model
+	Name           string `json:"name"`
+	URL            string `json:"url"`
+	Interval       uint   `json:"interval"` // Interval in seconds
+	Status         string `json:"status"`   // "up", "down", "pending"
+	Timeout        uint   `json:"timeout"`
+	Retries        uint   `json:"retries"`
+	RetryInterval  uint   `json:"retryInterval"`
+	IgnoreTLS      bool   `json:"ignoreTls"`
+	HttpMethod     string `json:"httpMethod"`
+	HttpBody       string `json:"httpBody"`
+	HttpHeaders    string `json:"httpHeaders"`
+	AuthMethod     string `json:"authMethod"`
+	AuthUsername   string `json:"authUsername"`
+	AuthPassword   string `json:"authPassword"`
+	Delay          uint   `json:"delay"` // Delay in seconds before check
+}

models/user.go

@@ -0,0 +1,9 @@
+package models
+
+import "gorm.io/gorm"
+
+type User struct {
+	gorm.Model
+	Username string `gorm:"unique"`
+	Password string
+}

services/monitor.go

@@ -0,0 +1,148 @@
+package services
+
+import (
+	"crypto/tls"
+	"log"
+	"net/http"
+	"strings"
+	"time"
+	"uptime/backend/database"
+	"uptime/backend/models"
+)
+
+var DeletedMonitorIDs = make(chan uint, 100)
+
+func StartMonitoring() {
+	log.Printf("[INFO] Monitoring service started at %v", time.Now())
+	ticker := time.NewTicker(10 * time.Second) // Check for new monitors every 10 seconds
+	monitorTimers := make(map[uint]*time.Timer)
+
+	for {
+		select {
+		case <-ticker.C:
+			var monitors []models.Monitor
+			database.DB.Find(&monitors)
+
+			for i := range monitors {
+				monitor := &monitors[i]
+
+				// Skip if timer already exists for this monitor
+				if _, exists := monitorTimers[monitor.ID]; exists {
+					continue
+				}
+
+				// Create individual timer for each monitor based on its interval
+				interval := time.Duration(monitor.Interval) * time.Second
+				log.Printf("[INFO] Creating timer for monitor ID=%d Name=%s Interval=%v", monitor.ID, monitor.Name, interval)
+				monitorTimers[monitor.ID] = time.AfterFunc(0, func() {
+					scheduleMonitorCheck(monitor, monitorTimers, interval)
+				})
+			}
+		case id := <-DeletedMonitorIDs:
+			if timer, exists := monitorTimers[id]; exists {
+				timer.Stop()
+				delete(monitorTimers, id)
+				log.Printf("[INFO] Stopped and removed timer for monitor ID=%d", id)
+			}
+		}
+	}
+}
+
+func scheduleMonitorCheck(monitor *models.Monitor, timers map[uint]*time.Timer, interval time.Duration) {
+	// Add a delay before the check if specified
+	if monitor.Delay > 0 {
+		delay := time.Duration(monitor.Delay) * time.Second
+		log.Printf("[INFO] Monitor ID=%d Name=%s: Delaying check by %v", monitor.ID, monitor.Name, delay)
+		time.Sleep(delay)
+	}
+
+	checkMonitorWithRetries(monitor)
+
+	// Schedule next check
+	timers[monitor.ID] = time.AfterFunc(interval, func() {
+		scheduleMonitorCheck(monitor, timers, interval)
+	})
+}
+
+func checkMonitorWithRetries(monitor *models.Monitor) {
+	maxRetries := int(monitor.Retries)
+	retryInterval := time.Duration(monitor.RetryInterval) * time.Second
+	
+	for attempt := 0; attempt <= maxRetries; attempt++ {
+		success := checkMonitor(monitor)
+		if success || attempt == maxRetries {
+			break
+		}
+		
+		if attempt < maxRetries {
+			log.Printf("[WARN] Monitor ID=%d Name=%s failed (attempt %d/%d), retrying in %v",
+				monitor.ID, monitor.Name, attempt+1, maxRetries+1, retryInterval)
+			time.Sleep(retryInterval)
+		}
+	}
+}
+
+func checkMonitor(monitor *models.Monitor) bool {
+	client := &http.Client{
+		Timeout: time.Duration(monitor.Timeout) * time.Second,
+		Transport: &http.Transport{
+			TLSClientConfig: &tls.Config{InsecureSkipVerify: monitor.IgnoreTLS},
+		},
+	}
+
+	req, err := http.NewRequest(monitor.HttpMethod, monitor.URL, strings.NewReader(monitor.HttpBody))
+	if err != nil {
+		log.Printf("[ERROR] Monitor ID=%d Name=%s: Error creating request: %s", monitor.ID, monitor.Name, err.Error())
+		updateMonitorStatus(monitor, "down")
+		return false
+	}
+
+	// Add headers
+	// For simplicity, assuming headers are in "Key:Value\nKey2:Value2" format
+	if monitor.HttpHeaders != "" {
+		headers := strings.Split(monitor.HttpHeaders, "\n")
+		for _, header := range headers {
+			parts := strings.SplitN(header, ":", 2)
+			if len(parts) == 2 {
+				req.Header.Set(strings.TrimSpace(parts[0]), strings.TrimSpace(parts[1]))
+			}
+		}
+	}
+
+	// Add basic auth
+	if monitor.AuthMethod == "basic" && monitor.AuthUsername != "" {
+		req.SetBasicAuth(monitor.AuthUsername, monitor.AuthPassword)
+	}
+
+	start := time.Now()
+	resp, err := client.Do(req)
+	latency := time.Since(start).Milliseconds()
+
+	if err != nil {
+		log.Printf("[ERROR] Monitor ID=%d Name=%s: HTTP request failed: %s", monitor.ID, monitor.Name, err.Error())
+		updateMonitorStatus(monitor, "down")
+		return false
+	}
+	defer resp.Body.Close()
+
+	// Store latency
+	latencyRecord := models.Latency{MonitorID: monitor.ID, Latency: uint(latency)}
+	database.DB.Create(&latencyRecord)
+
+	if resp.StatusCode >= 200 && resp.StatusCode < 300 {
+		log.Printf("[INFO] Monitor ID=%d Name=%s: Status UP (HTTP %d), Latency: %dms", monitor.ID, monitor.Name, resp.StatusCode, latency)
+		updateMonitorStatus(monitor, "up")
+		return true
+	} else {
+		log.Printf("[WARN] Monitor ID=%d Name=%s: Status DOWN (HTTP %d), Latency: %dms", monitor.ID, monitor.Name, resp.StatusCode, latency)
+		updateMonitorStatus(monitor, "down")
+		return false
+	}
+}
+
+func updateMonitorStatus(monitor *models.Monitor, status string) {
+	oldStatus := monitor.Status
+	monitor.Status = status
+	database.DB.Save(monitor)
+	log.Printf("[INFO] Monitor ID=%d Name=%s: Status changed from %s to %s", monitor.ID, monitor.Name, oldStatus, status)
+}