优化跨盘秒传

internal/api/cross_transfer_admin.go

@@ -41,6 +41,27 @@ func (h *Handler) crossTransferScan(w http.ResponseWriter, r *http.Request) {
 	writeOK(w, result)
 }
 
+func (h *Handler) crossTransferScanStream(w http.ResponseWriter, r *http.Request) {
+	if !ensureServiceReady(w, h.crossTransfer != nil) {
+		return
+	}
+	var req crossTransferScanReq
+	if err := decodeJSON(r, &req); err != nil {
+		writeErr(w, err)
+		return
+	}
+	h.streamCrossTransferNDJSON(w, r, func(emit func(crosstransfer.StreamEvent) error) error {
+		return h.crossTransfer.ScanSourceStream(
+			r.Context(),
+			req.SourceAccountID,
+			req.SourceParentID,
+			req.Method,
+			req.SourceDisplayPath,
+			emit,
+		)
+	})
+}
+
 type crossTransferProbeFile struct {
 	SourceFileID string `json:"source_file_id"`
 	RelPath      string `json:"rel_path"`

internal/api/router.go

@@ -25,9 +25,9 @@ import (
 	"litepan/internal/crosstransfer"
 	"litepan/internal/domain"
 	"litepan/internal/embyproxy"
-	"litepan/internal/fnosproxy"
 	"litepan/internal/favorites"
 	"litepan/internal/file"
+	"litepan/internal/fnosproxy"
 	"litepan/internal/fusemount"
 	"litepan/internal/logx"
 	"litepan/internal/mediaorganize"
@@ -171,6 +171,7 @@ func NewRouter(d Deps) http.Handler {
 			r.Route("/cross-transfer", func(r chi.Router) {
 				r.Get("/routes", h.crossTransferRoutes)
 				r.Post("/scan", h.crossTransferScan)
+				r.Post("/scan/stream", h.crossTransferScanStream)
 				r.Post("/probe", h.crossTransferProbe)
 				r.Post("/execute", h.crossTransferExecute)
 				r.Get("/relay/tasks", h.crossTransferRelayTasks)