From af6928a26870744da873a59f678b2afb0db6d5c9 Mon Sep 17 00:00:00 2001 From: Wesley Liddick Date: Mon, 10 Aug 2026 09:59:42 +0800 Subject: [PATCH] =?UTF-8?q?Revert=20"fix(risk-control):=20=E9=A3=8E?= =?UTF-8?q?=E6=8E=A7=E5=90=8E=E7=AB=AF=E5=BC=82=E5=B8=B8=E6=97=B6=E9=98=BB?= =?UTF-8?q?=E6=96=AD=E6=8F=90=E7=A4=BA=E8=AF=8D=E8=AF=B7=E6=B1=82"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../internal/service/content_moderation.go | 9 +------- .../service/content_moderation_test.go | 21 ------------------- 2 files changed, 1 insertion(+), 29 deletions(-) diff --git a/backend/internal/service/content_moderation.go b/backend/internal/service/content_moderation.go index d916b673ea..acf38bf49b 100644 --- a/backend/internal/service/content_moderation.go +++ b/backend/internal/service/content_moderation.go @@ -831,14 +831,7 @@ func (s *ContentModerationService) Check(ctx context.Context, input ContentModer "endpoint", input.Endpoint, "protocol", input.Protocol, "error", err) - return &ContentModerationDecision{ - Allowed: false, - Blocked: true, - Flagged: false, - Message: "风控系统暂时不可用，请稍后重试", - StatusCode: http.StatusInternalServerError, - Action: ContentModerationActionError, - }, nil + return allow, nil } if !runtimeSnapshot.riskControlEnabled { slog.Info("content_moderation.skip_feature_disabled", diff --git a/backend/internal/service/content_moderation_test.go b/backend/internal/service/content_moderation_test.go index e910326900..1cacc67477 100644 --- a/backend/internal/service/content_moderation_test.go +++ b/backend/internal/service/content_moderation_test.go @@ -19,7 +19,6 @@ import ( type contentModerationTestSettingRepo struct { values map[string]string - err error } func (r *contentModerationTestSettingRepo) Get(ctx context.Context, key string) (*Setting, error) { @@ -45,9 +44,6 @@ func (r *contentModerationTestSettingRepo) Set(ctx context.Context, key, value s } func (r *contentModerationTestSettingRepo) GetMultiple(ctx context.Context, keys []string) (map[string]string, error) { - if r.err != nil { - return nil, r.err - } out := map[string]string{} for _, key := range keys { if value, ok := r.values[key]; ok { @@ -57,23 +53,6 @@ func (r *contentModerationTestSettingRepo) GetMultiple(ctx context.Context, keys return out, nil } -func TestContentModerationCheck_LoadRuntimeSnapshotFailureBlocks(t *testing.T) { - svc := &ContentModerationService{ - settingRepo: &contentModerationTestSettingRepo{err: fmt.Errorf("settings unavailable")}, - repo: &contentModerationTestRepo{}, - } - - decision, err := svc.Check(context.Background(), ContentModerationCheckInput{UserID: 1}) - - require.NoError(t, err) - require.False(t, decision.Allowed) - require.True(t, decision.Blocked) - require.False(t, decision.Flagged) - require.Equal(t, ContentModerationActionError, decision.Action) - require.Equal(t, "风控系统暂时不可用，请稍后重试", decision.Message) - require.Equal(t, http.StatusInternalServerError, decision.StatusCode) -} - func (r *contentModerationTestSettingRepo) SetMultiple(ctx context.Context, settings map[string]string) error { if r.values == nil { r.values = map[string]string{}