fix(pricing): skip remote scheduler without URL

This commit is contained in:
404QAQ
2026-07-23 22:43:36 +08:00
parent cb24522dd5
commit 38cc916f7d
2 changed files with 36 additions and 0 deletions
@@ -218,6 +218,11 @@ func (s *PricingService) Stop() {
// startUpdateScheduler 启动定时更新调度器
func (s *PricingService) startUpdateScheduler() {
if s == nil || s.cfg == nil || strings.TrimSpace(s.cfg.Pricing.RemoteURL) == "" {
logger.LegacyPrintf("service.pricing", "%s", "[Pricing] Remote sync disabled: pricing remote URL is empty")
return
}
// 定期检查哈希更新
hashInterval := time.Duration(s.cfg.Pricing.HashCheckIntervalMinutes) * time.Minute
if hashInterval < time.Minute {
@@ -5,11 +5,42 @@ import (
"os"
"path/filepath"
"testing"
"time"
"github.com/Wei-Shaw/sub2api/internal/config"
"github.com/stretchr/testify/require"
)
func TestPricingSchedulerBlankRemoteURLDoesNotStart(t *testing.T) {
svc := NewPricingService(&config.Config{Pricing: config.PricingConfig{RemoteURL: " \t "}}, nil)
defer svc.Stop()
svc.startUpdateScheduler()
done := make(chan struct{})
go func() {
svc.wg.Wait()
close(done)
}()
select {
case <-done:
case <-time.After(100 * time.Millisecond):
t.Fatal("blank remote URL must not start scheduler")
}
}
func TestPricingNonEmptyInvalidRemoteURLStillReturnsValidationError(t *testing.T) {
svc := NewPricingService(&config.Config{Pricing: config.PricingConfig{
RemoteURL: "://invalid",
DataDir: t.TempDir(),
}}, nil)
err := svc.ForceUpdate()
require.Error(t, err)
require.Contains(t, err.Error(), "invalid pricing url")
}
func TestParsePricingData_ParsesPriorityAndServiceTierFields(t *testing.T) {
svc := &PricingService{}
body := []byte(`{