TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-12-16 07:46:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化访问日志策略测试时的失败提示

Browse Source
This commit is contained in:
刘祥超
2022-08-05 19:11:21 +08:00
parent e582e37c06
commit 14ba7f6899
3 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/rpc/services/service_http_access_log.go
View File

@@ -43,7 +43,7 @@ func (this *HTTPAccessLogService) CreateHTTPAccessLogs(ctx context.Context, req
return nil, err
}
if policyId > 0 {
err = accesslogs.SharedStorageManager.Write(policyId, req.HttpAccessLogs)
_, _, err = accesslogs.SharedStorageManager.Write(policyId, req.HttpAccessLogs)
if err != nil {
return nil, err
}

6
internal/rpc/services/service_http_access_log_policy.go
View File

@@ -2,6 +2,7 @@ package services
import (
"context"
"errors"
"github.com/TeaOSLab/EdgeAPI/internal/accesslogs"
"github.com/TeaOSLab/EdgeAPI/internal/db/models"
"github.com/TeaOSLab/EdgeCommon/pkg/rpc/pb"
@@ -153,9 +154,12 @@ func (this *HTTPAccessLogPolicyService) WriteHTTPAccessLogPolicy(ctx context.Con
return nil, err
}
err = accesslogs.SharedStorageManager.Write(req.HttpAccessLogPolicyId, []*pb.HTTPAccessLog{req.HttpAccessLog})
success, failMessage, err := accesslogs.SharedStorageManager.Write(req.HttpAccessLogPolicyId, []*pb.HTTPAccessLog{req.HttpAccessLog})
if err != nil {
return nil, err
}
if !success {
return nil, errors.New("test failed: " + failMessage)
}
return this.Success()
}