- NEW musicgen leaf package: blocking Generate over ACE-Step's async job
  queue (release_task -> poll query_result -> fetch file, all via
  /upstream); tolerant envelope parsing, double-encoded result handled
- NEW embeddings leaf package: EmbedModel + RerankModel as separate mints
  (two server instances on the host, llama.cpp #20085); InstructedQuery
  helper for Qwen3-style query/document asymmetry
- provider/llamaswap: /v1/embeddings + /v1/rerank clients with strict
  validation (index-ordered vectors, count mismatch and out-of-range
  index are hard errors; rerank sorted descending, minimal parser)

Co-Authored-By: Claude Fable 5 <[email protected]>

@@ -0,0 +39,4 @@
+}
+
+// Embed implements embeddings.EmbedModel via POST {base}/v1/embeddings.
+func (m *embedModel) Embed(ctx context.Context, req embeddings.EmbedRequest, opts ...embeddings.EmbedOption) (*embeddings.EmbedResult, error) {

@@ -0,0 +69,4 @@
+	}
+	// The OpenAI shape carries an index per entry; order by it rather than
+	// trusting response order.
+	vectors := make([][]float32, len(req.Inputs))

@@ -0,0 +103,4 @@
+// Rerank implements embeddings.RerankModel via POST {base}/v1/rerank. The
+// response parser reads only results[].index and results[].relevance_score —
+// llama-server documents the shape as "might change", so stay minimal.
+func (m *rerankModel) Rerank(ctx context.Context, req embeddings.RerankRequest, opts ...embeddings.RerankOption) (*embeddings.RerankResult, error) {

@@ -0,0 +26,4 @@
+// musicPollInterval is the delay between query_result polls. Long enough to
+// be polite to the queue, short enough that a ~10s xl-turbo song isn't
+// dominated by poll latency.
+const musicPollInterval = 2 * time.Second

@@ -0,0 +44,4 @@
+}
+
+// releaseTaskRequest is the ACE-Step POST /release_task shape. audio_duration
+// is the v1 param name; verify against docs/en/API.md at smoke time — an

@@ -0,0 +65,4 @@
+	Result string `json:"result"`
+}
+
+// musicFormatMIME maps ACE-Step's audio_format values to MIME types.

@@ -0,0 +73,4 @@
+	case "flac":
+		return "audio/flac"
+	case "opus":
+		return "audio/ogg"

@@ -0,0 +82,4 @@
+}
+
+// Generate implements musicgen.Model.
+func (m *musicModel) Generate(ctx context.Context, req musicgen.Request, opts ...musicgen.Option) (*musicgen.Result, error) {

@@ -0,0 +88,4 @@
+		return nil, fmt.Errorf("%w: music generation requires a prompt", llm.ErrUnsupported)
+	}
+	if req.DurationSeconds < 0 {
+		return nil, fmt.Errorf("%w: duration must be >= 0, got %d", llm.ErrUnsupported, req.DurationSeconds)

@@ -0,0 +146,4 @@
+		return nil, err
+	}
+	body := map[string]any{"task_id_list": []string{taskID}}
+	ticker := time.NewTicker(musicPollInterval)

@@ -0,0 +151,4 @@
+	for {
+		// Tolerant envelope: items under "data" or a bare array.
+		var raw json.RawMessage
+		if err := m.p.doJSON(ctx, http.MethodPost, path, m.id, body, &raw); err != nil {

@@ -0,0 +180,4 @@
+		Data json.RawMessage `json:"data"`
+	}
+	candidates := raw
+	if json.Unmarshal(raw, &env) == nil && len(env.Data) > 0 {

@@ -0,0 +192,4 @@
+		items = []queryItem{one}
+	}
+	for i := range items {
+		if items[i].TaskID == taskID || items[i].TaskID == "" && len(items) == 1 {

@@ -0,0 +210,4 @@
+	}
+	// The file URL is server-relative (e.g. "/v1/audio?path=..."); route it
+	// back through the same upstream.
+	path, err := upstreamPath(m.id, result.File)