build: 4.0.6

Author: Mecozea

.goreleaser.yml

@@ -144,10 +144,13 @@ release:
   replace_existing_draft: true
   # 发布说明
   header: |
-    ## NodePassDash Release Notes (v4.0.5)
+    ## NodePassDash Release Notes (v4.0.6)
     
-    ### Optimize
-    - Refactor PostgreSQL database connection logic
+    ### Fix
+    - repair hourly traffic statistics across SQLite and PostgreSQL
+
+    ### Feature
+    - endpoint page add update config menu 
 
   footer: |
 

README.md

@@ -4,7 +4,7 @@
 
 **Language:** English | [简体中文](docs/zh-CN/README.md)
 
-![Version](https://img.shields.io/badge/version-4.0.5-blue.svg)
+![Version](https://img.shields.io/badge/version-4.0.6-blue.svg)
 ![GitHub license](https://img.shields.io/github/license/NodePassProject/NodePassDash)
 ![GitHub downloads](https://img.shields.io/github/downloads/NodePassProject/nodepassdash/total.svg)
 ![Docker Pulls](https://img.shields.io/badge/docker_pulls-18k+-blue?logo=docker&logoColor=white)

cmd/server/main.go

@@ -27,8 +27,8 @@ import (
 	"time"
 
 	"github.com/gin-gonic/gin"
-	"github.com/joho/godotenv"
 	"github.com/glebarez/sqlite"
+	"github.com/joho/godotenv"
 	"gorm.io/gorm"
 )
 
@@ -372,12 +372,7 @@ func startBackgroundServices(gormDB *gorm.DB, sseService *sse.Service, sseManage
 	// 启动SSE相关服务
 	go func() {
 		sseManager.StartDaemon()
-
-		// 初始化SSE系统
-		if err := sseManager.InitializeSystem(); err != nil {
-			log.Errorf("初始化SSE系统失败: %v", err)
-		}
-		log.Info("SSE系统已启动")
+		log.Info("SSE守护进程已启动")
 	}()
 
 	// 启动WebSocket服务

internal/dashboard/traffic_service.go

@@ -88,19 +88,17 @@ func (s *TrafficService) AggregateTrafficDataForHour(hourStart time.Time) error
 				1 as record_count,
 				CURRENT_TIMESTAMP,
 				CURRENT_TIMESTAMP
-			FROM service_history sh
-			INNER JOIN (
+			FROM (
 				SELECT
-					endpoint_id,
-					instance_id,
-					MAX(record_time) as max_record_time
-				FROM service_history
-				WHERE record_time >= ? AND record_time < ?
-				GROUP BY endpoint_id, instance_id
-			) latest ON sh.endpoint_id = latest.endpoint_id
-				AND sh.instance_id = latest.instance_id
-				AND sh.record_time = latest.max_record_time
-			WHERE sh.record_time >= ? AND sh.record_time < ?
+					sh.*,
+					ROW_NUMBER() OVER (
+						PARTITION BY sh.endpoint_id, sh.instance_id
+						ORDER BY sh.record_time DESC, sh.id DESC
+					) AS row_num
+				FROM service_history sh
+				WHERE sh.record_time >= ? AND sh.record_time < ?
+			) sh
+			WHERE sh.row_num = 1
 			ON CONFLICT(hour_time, endpoint_id, instance_id) DO UPDATE SET
 				tcp_rx_total = excluded.tcp_rx_total,
 				tcp_tx_total = excluded.tcp_tx_total,
@@ -112,7 +110,7 @@ func (s *TrafficService) AggregateTrafficDataForHour(hourStart time.Time) error
 				udp_tx_increment = excluded.udp_tx_increment,
 				record_count = excluded.record_count,
 				updated_at = CURRENT_TIMESTAMP`,
-			hourStart, hourStart, hourEnd, hourStart, hourEnd).Error; err != nil {
+			hourStart, hourStart, hourEnd).Error; err != nil {
 			return fmt.Errorf("插入汇总数据失败: %v", err)
 		}
 

internal/dashboard/traffic_service_test.go

@@ -57,6 +57,12 @@ func TestAggregateTrafficDataForHourNormalizesUTCAndKeepsInt64(t *testing.T) {
 			EndpointID: 2, InstanceID: "b", RecordTime: hourStart.Add(59 * time.Minute).UTC(),
 			DeltaTCPIn: 30, DeltaTCPOut: 1_200_000_000,
 		},
+		{
+			// Duplicate latest timestamps are possible when an SSE event is
+			// dispatched more than once. The higher ID must win deterministically.
+			EndpointID: 1, InstanceID: "a", RecordTime: hourStart.Add(59 * time.Minute).UTC(),
+			DeltaTCPIn: 25, DeltaTCPOut: 2_900_000_000,
+		},
 	}
 	if err := db.Create(&history).Error; err != nil {
 		t.Fatalf("insert service history: %v", err)
@@ -81,8 +87,8 @@ func TestAggregateTrafficDataForHourNormalizesUTCAndKeepsInt64(t *testing.T) {
 	if !summary.HourTime.Equal(hourStart.UTC()) {
 		t.Fatalf("hour time = %s, want %s", summary.HourTime, hourStart.UTC())
 	}
-	if summary.TCPTxTotal != 4_000_000_000 {
-		t.Fatalf("tcp tx total = %d, want 4000000000", summary.TCPTxTotal)
+	if summary.TCPTxTotal != 4_100_000_000 {
+		t.Fatalf("tcp tx total = %d, want 4100000000", summary.TCPTxTotal)
 	}
 	if summary.InstanceCount != 2 {
 		t.Fatalf("instance count = %d, want 2", summary.InstanceCount)
@@ -92,8 +98,8 @@ func TestAggregateTrafficDataForHourNormalizesUTCAndKeepsInt64(t *testing.T) {
 	if err := db.Where("instance_id = ?", "a").First(&instanceA).Error; err != nil {
 		t.Fatalf("load instance a summary: %v", err)
 	}
-	if instanceA.TCPTxIncrement != 300_000_000 {
-		t.Fatalf("tcp tx increment = %d, want 300000000", instanceA.TCPTxIncrement)
+	if instanceA.TCPTxIncrement != 400_000_000 {
+		t.Fatalf("tcp tx increment = %d, want 400000000", instanceA.TCPTxIncrement)
 	}
 }
 

web/package.json

@@ -1,7 +1,7 @@
 {
   "name": "NodePassDash",
   "private": true,
-  "version": "4.0.5",
+  "version": "4.0.6",
   "packageManager": "pnpm@10.23.0",
   "type": "module",
   "scripts": {