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{}