oadmin/new-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add video channel kling fix

Browse Source
This commit is contained in:
skynono
2025-06-17 13:37:07 +08:00
parent 8a79de333a
commit b7c77777a5
2 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
controller/task_video.go
View File

@@ -104,9 +104,7 @@ func updateVideoSingleTask(ctx context.Context, adaptor channel.TaskAdaptor, cha
case "succeed": case "succeed":
task.Status = model.TaskStatusSuccess task.Status = model.TaskStatusSuccess
task.Progress = "100%" task.Progress = "100%"
if url, err := adaptor.(interface { if url, err := adaptor.ParseResultUrl(responseItem); err == nil {
ParseResultUrl(map[string]any) (string, error)
}).ParseResultUrl(responseItem); err == nil {
task.FailReason = url task.FailReason = url
} else { } else {
common.LogWarn(ctx, fmt.Sprintf("Failed to get url from body for task %s: %s", task.TaskID, err.Error())) common.LogWarn(ctx, fmt.Sprintf("Failed to get url from body for task %s: %s", task.TaskID, err.Error()))

2
relay/channel/task/kling/adaptor.go
View File

@@ -107,7 +107,7 @@ func (a *TaskAdaptor) BuildRequestURL(info *relaycommon.TaskRelayInfo) (string,
func (a *TaskAdaptor) BuildRequestHeader(c *gin.Context, req *http.Request, info *relaycommon.TaskRelayInfo) error { func (a *TaskAdaptor) BuildRequestHeader(c *gin.Context, req *http.Request, info *relaycommon.TaskRelayInfo) error {
token, err := a.createJWTToken() token, err := a.createJWTToken()
if err != nil { if err != nil {
token = info.ApiKey // fallback return fmt.Errorf("failed to create JWT token: %w", err)
} }
req.Header.Set("Content-Type", "application/json") req.Header.Set("Content-Type", "application/json")