mirror of
https://github.com/Wei-Shaw/sub2api.git
synced 2026-09-01 15:02:58 +08:00
Revert "fix(risk-control): 风控后端异常时阻断提示词请求"
This commit is contained in:
@@ -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",
|
||||
|
||||
@@ -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{}
|
||||
|
||||
Reference in New Issue
Block a user