857 lines
22 KiB
Go
857 lines
22 KiB
Go
package service
|
|
|
|
import (
|
|
"context"
|
|
"encoding/base64"
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
"io"
|
|
"mime"
|
|
"net"
|
|
"net/http"
|
|
"net/url"
|
|
"strconv"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/Wei-Shaw/sub2api/internal/config"
|
|
"github.com/gin-gonic/gin"
|
|
)
|
|
|
|
const soraImageInputMaxBytes = 20 << 20
|
|
const soraImageInputMaxRedirects = 3
|
|
const soraImageInputTimeout = 20 * time.Second
|
|
|
|
var soraImageSizeMap = map[string]string{
|
|
"gpt-image": "360",
|
|
"gpt-image-landscape": "540",
|
|
"gpt-image-portrait": "540",
|
|
}
|
|
|
|
var soraBlockedHostnames = map[string]struct{}{
|
|
"localhost": {},
|
|
"localhost.localdomain": {},
|
|
"metadata.google.internal": {},
|
|
"metadata.google.internal.": {},
|
|
}
|
|
|
|
var soraBlockedCIDRs = mustParseCIDRs([]string{
|
|
"0.0.0.0/8",
|
|
"10.0.0.0/8",
|
|
"100.64.0.0/10",
|
|
"127.0.0.0/8",
|
|
"169.254.0.0/16",
|
|
"172.16.0.0/12",
|
|
"192.168.0.0/16",
|
|
"224.0.0.0/4",
|
|
"240.0.0.0/4",
|
|
"::/128",
|
|
"::1/128",
|
|
"fc00::/7",
|
|
"fe80::/10",
|
|
})
|
|
|
|
// SoraGatewayService handles forwarding requests to Sora upstream.
|
|
type SoraGatewayService struct {
|
|
soraClient SoraClient
|
|
mediaStorage *SoraMediaStorage
|
|
rateLimitService *RateLimitService
|
|
cfg *config.Config
|
|
}
|
|
|
|
func NewSoraGatewayService(
|
|
soraClient SoraClient,
|
|
mediaStorage *SoraMediaStorage,
|
|
rateLimitService *RateLimitService,
|
|
cfg *config.Config,
|
|
) *SoraGatewayService {
|
|
return &SoraGatewayService{
|
|
soraClient: soraClient,
|
|
mediaStorage: mediaStorage,
|
|
rateLimitService: rateLimitService,
|
|
cfg: cfg,
|
|
}
|
|
}
|
|
|
|
func (s *SoraGatewayService) Forward(ctx context.Context, c *gin.Context, account *Account, body []byte, clientStream bool) (*ForwardResult, error) {
|
|
startTime := time.Now()
|
|
|
|
if s.soraClient == nil || !s.soraClient.Enabled() {
|
|
if c != nil {
|
|
c.JSON(http.StatusServiceUnavailable, gin.H{
|
|
"error": gin.H{
|
|
"type": "api_error",
|
|
"message": "Sora 上游未配置",
|
|
},
|
|
})
|
|
}
|
|
return nil, errors.New("sora upstream not configured")
|
|
}
|
|
|
|
var reqBody map[string]any
|
|
if err := json.Unmarshal(body, &reqBody); err != nil {
|
|
s.writeSoraError(c, http.StatusBadRequest, "invalid_request_error", "Failed to parse request body", clientStream)
|
|
return nil, fmt.Errorf("parse request: %w", err)
|
|
}
|
|
reqModel, _ := reqBody["model"].(string)
|
|
reqStream, _ := reqBody["stream"].(bool)
|
|
if strings.TrimSpace(reqModel) == "" {
|
|
s.writeSoraError(c, http.StatusBadRequest, "invalid_request_error", "model is required", clientStream)
|
|
return nil, errors.New("model is required")
|
|
}
|
|
|
|
mappedModel := account.GetMappedModel(reqModel)
|
|
if mappedModel != "" && mappedModel != reqModel {
|
|
reqModel = mappedModel
|
|
}
|
|
|
|
modelCfg, ok := GetSoraModelConfig(reqModel)
|
|
if !ok {
|
|
s.writeSoraError(c, http.StatusBadRequest, "invalid_request_error", "Unsupported Sora model", clientStream)
|
|
return nil, fmt.Errorf("unsupported model: %s", reqModel)
|
|
}
|
|
if modelCfg.Type == "prompt_enhance" {
|
|
s.writeSoraError(c, http.StatusBadRequest, "invalid_request_error", "Prompt-enhance 模型暂未支持", clientStream)
|
|
return nil, fmt.Errorf("prompt-enhance not supported")
|
|
}
|
|
|
|
prompt, imageInput, videoInput, remixTargetID := extractSoraInput(reqBody)
|
|
if strings.TrimSpace(prompt) == "" {
|
|
s.writeSoraError(c, http.StatusBadRequest, "invalid_request_error", "prompt is required", clientStream)
|
|
return nil, errors.New("prompt is required")
|
|
}
|
|
if strings.TrimSpace(videoInput) != "" {
|
|
s.writeSoraError(c, http.StatusBadRequest, "invalid_request_error", "Video input is not supported yet", clientStream)
|
|
return nil, errors.New("video input not supported")
|
|
}
|
|
|
|
reqCtx, cancel := s.withSoraTimeout(ctx, reqStream)
|
|
if cancel != nil {
|
|
defer cancel()
|
|
}
|
|
|
|
var imageData []byte
|
|
imageFilename := ""
|
|
if strings.TrimSpace(imageInput) != "" {
|
|
decoded, filename, err := decodeSoraImageInput(reqCtx, imageInput)
|
|
if err != nil {
|
|
s.writeSoraError(c, http.StatusBadRequest, "invalid_request_error", err.Error(), clientStream)
|
|
return nil, err
|
|
}
|
|
imageData = decoded
|
|
imageFilename = filename
|
|
}
|
|
|
|
mediaID := ""
|
|
if len(imageData) > 0 {
|
|
uploadID, err := s.soraClient.UploadImage(reqCtx, account, imageData, imageFilename)
|
|
if err != nil {
|
|
return nil, s.handleSoraRequestError(ctx, account, err, reqModel, c, clientStream)
|
|
}
|
|
mediaID = uploadID
|
|
}
|
|
|
|
taskID := ""
|
|
var err error
|
|
switch modelCfg.Type {
|
|
case "image":
|
|
taskID, err = s.soraClient.CreateImageTask(reqCtx, account, SoraImageRequest{
|
|
Prompt: prompt,
|
|
Width: modelCfg.Width,
|
|
Height: modelCfg.Height,
|
|
MediaID: mediaID,
|
|
})
|
|
case "video":
|
|
taskID, err = s.soraClient.CreateVideoTask(reqCtx, account, SoraVideoRequest{
|
|
Prompt: prompt,
|
|
Orientation: modelCfg.Orientation,
|
|
Frames: modelCfg.Frames,
|
|
Model: modelCfg.Model,
|
|
Size: modelCfg.Size,
|
|
MediaID: mediaID,
|
|
RemixTargetID: remixTargetID,
|
|
})
|
|
default:
|
|
err = fmt.Errorf("unsupported model type: %s", modelCfg.Type)
|
|
}
|
|
if err != nil {
|
|
return nil, s.handleSoraRequestError(ctx, account, err, reqModel, c, clientStream)
|
|
}
|
|
|
|
if clientStream && c != nil {
|
|
s.prepareSoraStream(c, taskID)
|
|
}
|
|
|
|
var mediaURLs []string
|
|
mediaType := modelCfg.Type
|
|
imageCount := 0
|
|
imageSize := ""
|
|
switch modelCfg.Type {
|
|
case "image":
|
|
urls, pollErr := s.pollImageTask(reqCtx, c, account, taskID, clientStream)
|
|
if pollErr != nil {
|
|
return nil, s.handleSoraRequestError(ctx, account, pollErr, reqModel, c, clientStream)
|
|
}
|
|
mediaURLs = urls
|
|
imageCount = len(urls)
|
|
imageSize = soraImageSizeFromModel(reqModel)
|
|
case "video":
|
|
urls, pollErr := s.pollVideoTask(reqCtx, c, account, taskID, clientStream)
|
|
if pollErr != nil {
|
|
return nil, s.handleSoraRequestError(ctx, account, pollErr, reqModel, c, clientStream)
|
|
}
|
|
mediaURLs = urls
|
|
default:
|
|
mediaType = "prompt"
|
|
}
|
|
|
|
finalURLs := s.normalizeSoraMediaURLs(mediaURLs)
|
|
if len(mediaURLs) > 0 && s.mediaStorage != nil && s.mediaStorage.Enabled() {
|
|
stored, storeErr := s.mediaStorage.StoreFromURLs(reqCtx, mediaType, mediaURLs)
|
|
if storeErr != nil {
|
|
return nil, s.handleSoraRequestError(ctx, account, storeErr, reqModel, c, clientStream)
|
|
}
|
|
finalURLs = s.normalizeSoraMediaURLs(stored)
|
|
}
|
|
|
|
content := buildSoraContent(mediaType, finalURLs)
|
|
var firstTokenMs *int
|
|
if clientStream {
|
|
ms, streamErr := s.writeSoraStream(c, reqModel, content, startTime)
|
|
if streamErr != nil {
|
|
return nil, streamErr
|
|
}
|
|
firstTokenMs = ms
|
|
} else if c != nil {
|
|
response := buildSoraNonStreamResponse(content, reqModel)
|
|
if len(finalURLs) > 0 {
|
|
response["media_url"] = finalURLs[0]
|
|
if len(finalURLs) > 1 {
|
|
response["media_urls"] = finalURLs
|
|
}
|
|
}
|
|
c.JSON(http.StatusOK, response)
|
|
}
|
|
|
|
return &ForwardResult{
|
|
RequestID: taskID,
|
|
Model: reqModel,
|
|
Stream: clientStream,
|
|
Duration: time.Since(startTime),
|
|
FirstTokenMs: firstTokenMs,
|
|
Usage: ClaudeUsage{},
|
|
MediaType: mediaType,
|
|
MediaURL: firstMediaURL(finalURLs),
|
|
ImageCount: imageCount,
|
|
ImageSize: imageSize,
|
|
}, nil
|
|
}
|
|
|
|
func (s *SoraGatewayService) withSoraTimeout(ctx context.Context, stream bool) (context.Context, context.CancelFunc) {
|
|
if s == nil || s.cfg == nil {
|
|
return ctx, nil
|
|
}
|
|
timeoutSeconds := s.cfg.Gateway.SoraRequestTimeoutSeconds
|
|
if stream {
|
|
timeoutSeconds = s.cfg.Gateway.SoraStreamTimeoutSeconds
|
|
}
|
|
if timeoutSeconds <= 0 {
|
|
return ctx, nil
|
|
}
|
|
return context.WithTimeout(ctx, time.Duration(timeoutSeconds)*time.Second)
|
|
}
|
|
|
|
func (s *SoraGatewayService) shouldFailoverUpstreamError(statusCode int) bool {
|
|
switch statusCode {
|
|
case 401, 402, 403, 429, 529:
|
|
return true
|
|
default:
|
|
return statusCode >= 500
|
|
}
|
|
}
|
|
|
|
func buildSoraNonStreamResponse(content, model string) map[string]any {
|
|
return map[string]any{
|
|
"id": fmt.Sprintf("chatcmpl-%d", time.Now().UnixNano()),
|
|
"object": "chat.completion",
|
|
"created": time.Now().Unix(),
|
|
"model": model,
|
|
"choices": []any{
|
|
map[string]any{
|
|
"index": 0,
|
|
"message": map[string]any{
|
|
"role": "assistant",
|
|
"content": content,
|
|
},
|
|
"finish_reason": "stop",
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
func soraImageSizeFromModel(model string) string {
|
|
modelLower := strings.ToLower(model)
|
|
if size, ok := soraImageSizeMap[modelLower]; ok {
|
|
return size
|
|
}
|
|
if strings.Contains(modelLower, "landscape") || strings.Contains(modelLower, "portrait") {
|
|
return "540"
|
|
}
|
|
return "360"
|
|
}
|
|
|
|
func soraProErrorMessage(model, upstreamMsg string) string {
|
|
modelLower := strings.ToLower(model)
|
|
if strings.Contains(modelLower, "sora2pro-hd") {
|
|
return "当前账号无法使用 Sora Pro-HD 模型,请更换模型或账号"
|
|
}
|
|
if strings.Contains(modelLower, "sora2pro") {
|
|
return "当前账号无法使用 Sora Pro 模型,请更换模型或账号"
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func firstMediaURL(urls []string) string {
|
|
if len(urls) == 0 {
|
|
return ""
|
|
}
|
|
return urls[0]
|
|
}
|
|
|
|
func (s *SoraGatewayService) buildSoraMediaURL(path string, rawQuery string) string {
|
|
if path == "" {
|
|
return path
|
|
}
|
|
prefix := "/sora/media"
|
|
values := url.Values{}
|
|
if rawQuery != "" {
|
|
if parsed, err := url.ParseQuery(rawQuery); err == nil {
|
|
values = parsed
|
|
}
|
|
}
|
|
|
|
signKey := ""
|
|
ttlSeconds := 0
|
|
if s != nil && s.cfg != nil {
|
|
signKey = strings.TrimSpace(s.cfg.Gateway.SoraMediaSigningKey)
|
|
ttlSeconds = s.cfg.Gateway.SoraMediaSignedURLTTLSeconds
|
|
}
|
|
values.Del("sig")
|
|
values.Del("expires")
|
|
signingQuery := values.Encode()
|
|
if signKey != "" && ttlSeconds > 0 {
|
|
expires := time.Now().Add(time.Duration(ttlSeconds) * time.Second).Unix()
|
|
signature := SignSoraMediaURL(path, signingQuery, expires, signKey)
|
|
if signature != "" {
|
|
values.Set("expires", strconv.FormatInt(expires, 10))
|
|
values.Set("sig", signature)
|
|
prefix = "/sora/media-signed"
|
|
}
|
|
}
|
|
|
|
encoded := values.Encode()
|
|
if encoded == "" {
|
|
return prefix + path
|
|
}
|
|
return prefix + path + "?" + encoded
|
|
}
|
|
|
|
func (s *SoraGatewayService) prepareSoraStream(c *gin.Context, requestID string) {
|
|
if c == nil {
|
|
return
|
|
}
|
|
c.Header("Content-Type", "text/event-stream")
|
|
c.Header("Cache-Control", "no-cache")
|
|
c.Header("Connection", "keep-alive")
|
|
c.Header("X-Accel-Buffering", "no")
|
|
if strings.TrimSpace(requestID) != "" {
|
|
c.Header("x-request-id", requestID)
|
|
}
|
|
}
|
|
|
|
func (s *SoraGatewayService) writeSoraStream(c *gin.Context, model, content string, startTime time.Time) (*int, error) {
|
|
if c == nil {
|
|
return nil, nil
|
|
}
|
|
writer := c.Writer
|
|
flusher, _ := writer.(http.Flusher)
|
|
|
|
chunk := map[string]any{
|
|
"id": fmt.Sprintf("chatcmpl-%d", time.Now().UnixNano()),
|
|
"object": "chat.completion.chunk",
|
|
"created": time.Now().Unix(),
|
|
"model": model,
|
|
"choices": []any{
|
|
map[string]any{
|
|
"index": 0,
|
|
"delta": map[string]any{
|
|
"content": content,
|
|
},
|
|
},
|
|
},
|
|
}
|
|
encoded, _ := json.Marshal(chunk)
|
|
if _, err := fmt.Fprintf(writer, "data: %s\n\n", encoded); err != nil {
|
|
return nil, err
|
|
}
|
|
if flusher != nil {
|
|
flusher.Flush()
|
|
}
|
|
ms := int(time.Since(startTime).Milliseconds())
|
|
finalChunk := map[string]any{
|
|
"id": chunk["id"],
|
|
"object": "chat.completion.chunk",
|
|
"created": time.Now().Unix(),
|
|
"model": model,
|
|
"choices": []any{
|
|
map[string]any{
|
|
"index": 0,
|
|
"delta": map[string]any{},
|
|
"finish_reason": "stop",
|
|
},
|
|
},
|
|
}
|
|
finalEncoded, _ := json.Marshal(finalChunk)
|
|
if _, err := fmt.Fprintf(writer, "data: %s\n\n", finalEncoded); err != nil {
|
|
return &ms, err
|
|
}
|
|
if _, err := fmt.Fprint(writer, "data: [DONE]\n\n"); err != nil {
|
|
return &ms, err
|
|
}
|
|
if flusher != nil {
|
|
flusher.Flush()
|
|
}
|
|
return &ms, nil
|
|
}
|
|
|
|
func (s *SoraGatewayService) writeSoraError(c *gin.Context, status int, errType, message string, stream bool) {
|
|
if c == nil {
|
|
return
|
|
}
|
|
if stream {
|
|
flusher, _ := c.Writer.(http.Flusher)
|
|
errorEvent := fmt.Sprintf(`event: error`+"\n"+`data: {"error": {"type": "%s", "message": "%s"}}`+"\n\n", errType, message)
|
|
_, _ = fmt.Fprint(c.Writer, errorEvent)
|
|
_, _ = fmt.Fprint(c.Writer, "data: [DONE]\n\n")
|
|
if flusher != nil {
|
|
flusher.Flush()
|
|
}
|
|
return
|
|
}
|
|
c.JSON(status, gin.H{
|
|
"error": gin.H{
|
|
"type": errType,
|
|
"message": message,
|
|
},
|
|
})
|
|
}
|
|
|
|
func (s *SoraGatewayService) handleSoraRequestError(ctx context.Context, account *Account, err error, model string, c *gin.Context, stream bool) error {
|
|
if err == nil {
|
|
return nil
|
|
}
|
|
var upstreamErr *SoraUpstreamError
|
|
if errors.As(err, &upstreamErr) {
|
|
if s.rateLimitService != nil && account != nil {
|
|
s.rateLimitService.HandleUpstreamError(ctx, account, upstreamErr.StatusCode, upstreamErr.Headers, upstreamErr.Body)
|
|
}
|
|
if s.shouldFailoverUpstreamError(upstreamErr.StatusCode) {
|
|
return &UpstreamFailoverError{StatusCode: upstreamErr.StatusCode}
|
|
}
|
|
msg := upstreamErr.Message
|
|
if override := soraProErrorMessage(model, msg); override != "" {
|
|
msg = override
|
|
}
|
|
s.writeSoraError(c, upstreamErr.StatusCode, "upstream_error", msg, stream)
|
|
return err
|
|
}
|
|
if errors.Is(err, context.DeadlineExceeded) {
|
|
s.writeSoraError(c, http.StatusGatewayTimeout, "timeout_error", "Sora generation timeout", stream)
|
|
return err
|
|
}
|
|
s.writeSoraError(c, http.StatusBadGateway, "api_error", err.Error(), stream)
|
|
return err
|
|
}
|
|
|
|
func (s *SoraGatewayService) pollImageTask(ctx context.Context, c *gin.Context, account *Account, taskID string, stream bool) ([]string, error) {
|
|
interval := s.pollInterval()
|
|
maxAttempts := s.pollMaxAttempts()
|
|
lastPing := time.Now()
|
|
for attempt := 0; attempt < maxAttempts; attempt++ {
|
|
status, err := s.soraClient.GetImageTask(ctx, account, taskID)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
switch strings.ToLower(status.Status) {
|
|
case "succeeded", "completed":
|
|
return status.URLs, nil
|
|
case "failed":
|
|
if status.ErrorMsg != "" {
|
|
return nil, errors.New(status.ErrorMsg)
|
|
}
|
|
return nil, errors.New("sora image generation failed")
|
|
}
|
|
if stream {
|
|
s.maybeSendPing(c, &lastPing)
|
|
}
|
|
if err := sleepWithContext(ctx, interval); err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
return nil, errors.New("sora image generation timeout")
|
|
}
|
|
|
|
func (s *SoraGatewayService) pollVideoTask(ctx context.Context, c *gin.Context, account *Account, taskID string, stream bool) ([]string, error) {
|
|
interval := s.pollInterval()
|
|
maxAttempts := s.pollMaxAttempts()
|
|
lastPing := time.Now()
|
|
for attempt := 0; attempt < maxAttempts; attempt++ {
|
|
status, err := s.soraClient.GetVideoTask(ctx, account, taskID)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
switch strings.ToLower(status.Status) {
|
|
case "completed", "succeeded":
|
|
return status.URLs, nil
|
|
case "failed":
|
|
if status.ErrorMsg != "" {
|
|
return nil, errors.New(status.ErrorMsg)
|
|
}
|
|
return nil, errors.New("sora video generation failed")
|
|
}
|
|
if stream {
|
|
s.maybeSendPing(c, &lastPing)
|
|
}
|
|
if err := sleepWithContext(ctx, interval); err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
return nil, errors.New("sora video generation timeout")
|
|
}
|
|
|
|
func (s *SoraGatewayService) pollInterval() time.Duration {
|
|
if s == nil || s.cfg == nil {
|
|
return 2 * time.Second
|
|
}
|
|
interval := s.cfg.Sora.Client.PollIntervalSeconds
|
|
if interval <= 0 {
|
|
interval = 2
|
|
}
|
|
return time.Duration(interval) * time.Second
|
|
}
|
|
|
|
func (s *SoraGatewayService) pollMaxAttempts() int {
|
|
if s == nil || s.cfg == nil {
|
|
return 600
|
|
}
|
|
maxAttempts := s.cfg.Sora.Client.MaxPollAttempts
|
|
if maxAttempts <= 0 {
|
|
maxAttempts = 600
|
|
}
|
|
return maxAttempts
|
|
}
|
|
|
|
func (s *SoraGatewayService) maybeSendPing(c *gin.Context, lastPing *time.Time) {
|
|
if c == nil {
|
|
return
|
|
}
|
|
interval := 10 * time.Second
|
|
if s != nil && s.cfg != nil && s.cfg.Concurrency.PingInterval > 0 {
|
|
interval = time.Duration(s.cfg.Concurrency.PingInterval) * time.Second
|
|
}
|
|
if time.Since(*lastPing) < interval {
|
|
return
|
|
}
|
|
if _, err := fmt.Fprint(c.Writer, ":\n\n"); err == nil {
|
|
if flusher, ok := c.Writer.(http.Flusher); ok {
|
|
flusher.Flush()
|
|
}
|
|
*lastPing = time.Now()
|
|
}
|
|
}
|
|
|
|
func (s *SoraGatewayService) normalizeSoraMediaURLs(urls []string) []string {
|
|
if len(urls) == 0 {
|
|
return urls
|
|
}
|
|
output := make([]string, 0, len(urls))
|
|
for _, raw := range urls {
|
|
raw = strings.TrimSpace(raw)
|
|
if raw == "" {
|
|
continue
|
|
}
|
|
if strings.HasPrefix(raw, "http://") || strings.HasPrefix(raw, "https://") {
|
|
output = append(output, raw)
|
|
continue
|
|
}
|
|
pathVal := raw
|
|
if !strings.HasPrefix(pathVal, "/") {
|
|
pathVal = "/" + pathVal
|
|
}
|
|
output = append(output, s.buildSoraMediaURL(pathVal, ""))
|
|
}
|
|
return output
|
|
}
|
|
|
|
func buildSoraContent(mediaType string, urls []string) string {
|
|
switch mediaType {
|
|
case "image":
|
|
parts := make([]string, 0, len(urls))
|
|
for _, u := range urls {
|
|
parts = append(parts, fmt.Sprintf("", u))
|
|
}
|
|
return strings.Join(parts, "\n")
|
|
case "video":
|
|
if len(urls) == 0 {
|
|
return ""
|
|
}
|
|
return fmt.Sprintf("```html\n<video src='%s' controls></video>\n```", urls[0])
|
|
default:
|
|
return ""
|
|
}
|
|
}
|
|
|
|
func extractSoraInput(body map[string]any) (prompt, imageInput, videoInput, remixTargetID string) {
|
|
if body == nil {
|
|
return "", "", "", ""
|
|
}
|
|
if v, ok := body["remix_target_id"].(string); ok {
|
|
remixTargetID = v
|
|
}
|
|
if v, ok := body["image"].(string); ok {
|
|
imageInput = v
|
|
}
|
|
if v, ok := body["video"].(string); ok {
|
|
videoInput = v
|
|
}
|
|
if v, ok := body["prompt"].(string); ok && strings.TrimSpace(v) != "" {
|
|
prompt = v
|
|
}
|
|
if messages, ok := body["messages"].([]any); ok {
|
|
builder := strings.Builder{}
|
|
for _, raw := range messages {
|
|
msg, ok := raw.(map[string]any)
|
|
if !ok {
|
|
continue
|
|
}
|
|
role, _ := msg["role"].(string)
|
|
if role != "" && role != "user" {
|
|
continue
|
|
}
|
|
content := msg["content"]
|
|
text, img, vid := parseSoraMessageContent(content)
|
|
if text != "" {
|
|
if builder.Len() > 0 {
|
|
_, _ = builder.WriteString("\n")
|
|
}
|
|
_, _ = builder.WriteString(text)
|
|
}
|
|
if imageInput == "" && img != "" {
|
|
imageInput = img
|
|
}
|
|
if videoInput == "" && vid != "" {
|
|
videoInput = vid
|
|
}
|
|
}
|
|
if prompt == "" {
|
|
prompt = builder.String()
|
|
}
|
|
}
|
|
return prompt, imageInput, videoInput, remixTargetID
|
|
}
|
|
|
|
func parseSoraMessageContent(content any) (text, imageInput, videoInput string) {
|
|
switch val := content.(type) {
|
|
case string:
|
|
return val, "", ""
|
|
case []any:
|
|
builder := strings.Builder{}
|
|
for _, item := range val {
|
|
itemMap, ok := item.(map[string]any)
|
|
if !ok {
|
|
continue
|
|
}
|
|
t, _ := itemMap["type"].(string)
|
|
switch t {
|
|
case "text":
|
|
if txt, ok := itemMap["text"].(string); ok && strings.TrimSpace(txt) != "" {
|
|
if builder.Len() > 0 {
|
|
_, _ = builder.WriteString("\n")
|
|
}
|
|
_, _ = builder.WriteString(txt)
|
|
}
|
|
case "image_url":
|
|
if imageInput == "" {
|
|
if urlVal, ok := itemMap["image_url"].(map[string]any); ok {
|
|
imageInput = fmt.Sprintf("%v", urlVal["url"])
|
|
} else if urlStr, ok := itemMap["image_url"].(string); ok {
|
|
imageInput = urlStr
|
|
}
|
|
}
|
|
case "video_url":
|
|
if videoInput == "" {
|
|
if urlVal, ok := itemMap["video_url"].(map[string]any); ok {
|
|
videoInput = fmt.Sprintf("%v", urlVal["url"])
|
|
} else if urlStr, ok := itemMap["video_url"].(string); ok {
|
|
videoInput = urlStr
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return builder.String(), imageInput, videoInput
|
|
default:
|
|
return "", "", ""
|
|
}
|
|
}
|
|
|
|
func decodeSoraImageInput(ctx context.Context, input string) ([]byte, string, error) {
|
|
raw := strings.TrimSpace(input)
|
|
if raw == "" {
|
|
return nil, "", errors.New("empty image input")
|
|
}
|
|
if strings.HasPrefix(raw, "data:") {
|
|
parts := strings.SplitN(raw, ",", 2)
|
|
if len(parts) != 2 {
|
|
return nil, "", errors.New("invalid data url")
|
|
}
|
|
meta := parts[0]
|
|
payload := parts[1]
|
|
decoded, err := base64.StdEncoding.DecodeString(payload)
|
|
if err != nil {
|
|
return nil, "", err
|
|
}
|
|
ext := ""
|
|
if strings.HasPrefix(meta, "data:") {
|
|
metaParts := strings.SplitN(meta[5:], ";", 2)
|
|
if len(metaParts) > 0 {
|
|
if exts, err := mime.ExtensionsByType(metaParts[0]); err == nil && len(exts) > 0 {
|
|
ext = exts[0]
|
|
}
|
|
}
|
|
}
|
|
filename := "image" + ext
|
|
return decoded, filename, nil
|
|
}
|
|
if strings.HasPrefix(raw, "http://") || strings.HasPrefix(raw, "https://") {
|
|
return downloadSoraImageInput(ctx, raw)
|
|
}
|
|
decoded, err := base64.StdEncoding.DecodeString(raw)
|
|
if err != nil {
|
|
return nil, "", errors.New("invalid base64 image")
|
|
}
|
|
return decoded, "image.png", nil
|
|
}
|
|
|
|
func downloadSoraImageInput(ctx context.Context, rawURL string) ([]byte, string, error) {
|
|
parsed, err := validateSoraImageURL(rawURL)
|
|
if err != nil {
|
|
return nil, "", err
|
|
}
|
|
req, err := http.NewRequestWithContext(ctx, http.MethodGet, parsed.String(), nil)
|
|
if err != nil {
|
|
return nil, "", err
|
|
}
|
|
client := &http.Client{
|
|
Timeout: soraImageInputTimeout,
|
|
CheckRedirect: func(req *http.Request, via []*http.Request) error {
|
|
if len(via) >= soraImageInputMaxRedirects {
|
|
return errors.New("too many redirects")
|
|
}
|
|
return validateSoraImageURLValue(req.URL)
|
|
},
|
|
}
|
|
resp, err := client.Do(req)
|
|
if err != nil {
|
|
return nil, "", err
|
|
}
|
|
defer func() { _ = resp.Body.Close() }()
|
|
if resp.StatusCode != http.StatusOK {
|
|
return nil, "", fmt.Errorf("download image failed: %d", resp.StatusCode)
|
|
}
|
|
data, err := io.ReadAll(io.LimitReader(resp.Body, soraImageInputMaxBytes))
|
|
if err != nil {
|
|
return nil, "", err
|
|
}
|
|
ext := fileExtFromURL(parsed.String())
|
|
if ext == "" {
|
|
ext = fileExtFromContentType(resp.Header.Get("Content-Type"))
|
|
}
|
|
filename := "image" + ext
|
|
return data, filename, nil
|
|
}
|
|
|
|
func validateSoraImageURL(raw string) (*url.URL, error) {
|
|
if strings.TrimSpace(raw) == "" {
|
|
return nil, errors.New("empty image url")
|
|
}
|
|
parsed, err := url.Parse(raw)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("invalid image url: %w", err)
|
|
}
|
|
if err := validateSoraImageURLValue(parsed); err != nil {
|
|
return nil, err
|
|
}
|
|
return parsed, nil
|
|
}
|
|
|
|
func validateSoraImageURLValue(parsed *url.URL) error {
|
|
if parsed == nil {
|
|
return errors.New("invalid image url")
|
|
}
|
|
scheme := strings.ToLower(strings.TrimSpace(parsed.Scheme))
|
|
if scheme != "http" && scheme != "https" {
|
|
return errors.New("only http/https image url is allowed")
|
|
}
|
|
if parsed.User != nil {
|
|
return errors.New("image url cannot contain userinfo")
|
|
}
|
|
host := strings.ToLower(strings.TrimSpace(parsed.Hostname()))
|
|
if host == "" {
|
|
return errors.New("image url missing host")
|
|
}
|
|
if _, blocked := soraBlockedHostnames[host]; blocked {
|
|
return errors.New("image url is not allowed")
|
|
}
|
|
if ip := net.ParseIP(host); ip != nil {
|
|
if isSoraBlockedIP(ip) {
|
|
return errors.New("image url is not allowed")
|
|
}
|
|
return nil
|
|
}
|
|
ips, err := net.LookupIP(host)
|
|
if err != nil {
|
|
return fmt.Errorf("resolve image url failed: %w", err)
|
|
}
|
|
for _, ip := range ips {
|
|
if isSoraBlockedIP(ip) {
|
|
return errors.New("image url is not allowed")
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func isSoraBlockedIP(ip net.IP) bool {
|
|
if ip == nil {
|
|
return true
|
|
}
|
|
for _, cidr := range soraBlockedCIDRs {
|
|
if cidr.Contains(ip) {
|
|
return true
|
|
}
|
|
}
|
|
return false
|
|
}
|
|
|
|
func mustParseCIDRs(values []string) []*net.IPNet {
|
|
out := make([]*net.IPNet, 0, len(values))
|
|
for _, val := range values {
|
|
_, cidr, err := net.ParseCIDR(val)
|
|
if err != nil {
|
|
continue
|
|
}
|
|
out = append(out, cidr)
|
|
}
|
|
return out
|
|
}
|