(c *gin.Context, relayMode int)
| 428 | } |
| 429 | |
| 430 | func taskRelayHandler(c *gin.Context, relayMode int) *dto.TaskError { |
| 431 | var err *dto.TaskError |
| 432 | switch relayMode { |
| 433 | case relayconstant.RelayModeSunoFetch, relayconstant.RelayModeSunoFetchByID, relayconstant.RelayModeKlingFetchByID: |
| 434 | err = relay.RelayTaskFetch(c, relayMode) |
| 435 | default: |
| 436 | err = relay.RelayTaskSubmit(c, relayMode) |
| 437 | } |
| 438 | return err |
| 439 | } |
| 440 | |
| 441 | func shouldRetryTaskRelay(c *gin.Context, channelId int, taskErr *dto.TaskError, retryTimes int) bool { |
| 442 | if taskErr == nil { |
no test coverage detected