update: export from starry-refactor 2026-02-21 (add example score seed)

.gitattributes

@@ -38,3 +38,4 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
 *.eot filter=lfs diff=lfs merge=lfs -text
 *.otf filter=lfs diff=lfs merge=lfs -text
 *.woff2 filter=lfs diff=lfs merge=lfs -text
+*.png filter=lfs diff=lfs merge=lfs -text

Dockerfile

@@ -123,6 +123,11 @@ COPY --chown=node backend/python-services/ ./backend/python-services/
 # --- Supervisord config ---
 COPY --chown=node supervisord.conf ./supervisord.conf
 
+# --- Example score for seeding ---
+COPY --chown=node example-score/ ./example-score/
+COPY --chown=node seed-example.sh ./seed-example.sh
+RUN chmod +x seed-example.sh
+
 # --- Config files ---
 COPY --chown=node docker-entrypoint.sh ./docker-entrypoint.sh
 COPY --chown=node nginx.conf /etc/nginx/nginx.conf

backend/omr-service/src/db/client.ts

@@ -9,9 +9,9 @@ export const pool = new Pool({
 	database: config.database.database,
 	user: config.database.user,
 	password: config.database.password,
-	max: 10,
+	max: 20,
 	idleTimeoutMillis: 30000,
-	connectionTimeoutMillis: 2000,
+	connectionTimeoutMillis: 10000,
 });
 
 export async function query<T extends pg.QueryResultRow = any>(text: string, params?: any[]): Promise<pg.QueryResult<T>> {

backend/omr-service/src/lib/dbSolutionStore.ts

@@ -7,7 +7,11 @@ export const DbSolutionStore = {
 		return result ?? null;
 	},
 	async set(key: string, val: any) {
-		await solutionCacheService.set(key, val);
+		try {
+			await solutionCacheService.set(key, val);
+		} catch (err) {
+			console.error('[DbSolutionStore] set failed (non-fatal):', (err as Error).message);
+		}
 	},
 	async batchGet(keys: string[]) {
 		return solutionCacheService.batchGet(keys);

backend/omr-service/src/routes/issueMeasures.ts

@@ -51,4 +51,10 @@ export default async function issueMeasuresRoutes(fastify: FastifyInstance) {
 
 		return { code: 0, data: result };
 	});
+
+	// Delete all issue measures for a score
+	fastify.delete<{ Params: ScoreParams }>('/scores/:id/issueMeasures', async (request) => {
+		const count = await issueMeasureService.deleteByScore(request.params.id);
+		return { code: 0, data: { deleted: count } };
+	});
 }

backend/omr-service/src/services/issueMeasure.service.ts

@@ -97,3 +97,8 @@ export async function upsert(scoreId: string, measureIndex: number, measure: any
 
 	return rowToResult(row);
 }
+
+export async function deleteByScore(scoreId: string): Promise<number> {
+	const result = await query('DELETE FROM issue_measures WHERE score_id = $1', [scoreId]);
+	return result.rowCount ?? 0;
+}

backend/omr-service/src/services/musicSet.service.ts

@@ -65,7 +65,7 @@ export async function createMusicSet(input: CreateMusicSetInput): Promise<MusicS
 
 export async function getMusicSet(id: string): Promise<MusicSet | null> {
 	const { rows } = await query<MusicSet>(
-		`SELECT ms.*,
+		`SELECT ms.*, ms.updated_at AS "lastUpdateAt",
 			(SELECT COALESCE(json_agg(json_build_object('id', t.id, 'name', t.name)), '[]'::json)
 			 FROM music_set_tags mst
 			 JOIN tags t ON mst.tag_id = t.id
@@ -98,8 +98,10 @@ export async function listMusicSets(params: ListParams): Promise<{ rows: MusicSe
 	const whereClause = conditions.length > 0 ? `WHERE ${conditions.join(' AND ')}` : '';
 
 	// Validate sortedBy to prevent SQL injection
+	const sortFieldMap: Record<string, string> = { lastUpdateAt: 'updated_at' };
 	const allowedSortFields = ['name', 'type', 'updated_at', 'created_at'];
-	const sortField = allowedSortFields.includes(sortedBy) ? sortedBy : 'updated_at';
+	const resolved = sortFieldMap[sortedBy] || sortedBy;
+	const sortField = allowedSortFields.includes(resolved) ? resolved : 'updated_at';
 	const sortOrder = sortedType === 'asc' ? 'ASC' : 'DESC';
 
 	// Get count
@@ -109,7 +111,7 @@ export async function listMusicSets(params: ListParams): Promise<{ rows: MusicSe
 	// Get rows with tags
 	values.push(limit, offset);
 	const { rows } = await query<MusicSet>(
-		`SELECT ms.*,
+		`SELECT ms.*, ms.updated_at AS "lastUpdateAt",
 			(SELECT COALESCE(json_agg(json_build_object('id', t.id, 'name', t.name)), '[]'::json)
 			 FROM music_set_tags mst
 			 JOIN tags t ON mst.tag_id = t.id
@@ -160,7 +162,7 @@ export async function updateMusicSet(id: string, input: UpdateMusicSetInput): Pr
 
 		// Return updated music set with tags
 		const { rows } = await client.query<MusicSet>(
-			`SELECT ms.*,
+			`SELECT ms.*, ms.updated_at AS "lastUpdateAt",
 				(SELECT COALESCE(json_agg(json_build_object('id', t.id, 'name', t.name)), '[]'::json)
 				 FROM music_set_tags mst
 				 JOIN tags t ON mst.tag_id = t.id

docker-entrypoint.sh

@@ -256,6 +256,11 @@ for i in $(seq 1 30); do
   sleep 1
 done
 
+# ── Seed example score (background — waits for ML predictors internally) ──
+if [ -f /home/node/app/seed-example.sh ]; then
+  /home/node/app/seed-example.sh &
+fi
+
 # ── Start nginx (port 7860, foreground) ──
 echo 'Starting nginx on port 7860...'
 exec nginx -g 'daemon off;'

seed-example.sh

@@ -0,0 +1,146 @@
+#!/bin/bash
+#
+# Seed the HF Space with a pre-recognized example score.
+#
+# Runs in background after services start. Waits for ML predictors,
+# then uploads example page images through predict/pages pipeline.
+#
+set -euo pipefail
+
+API_BASE="http://127.0.0.1:3080"
+SCRIPT_DIR="$(cd "$(dirname "$0")" && pwd)"
+IMAGE_DIR="$SCRIPT_DIR/example-score"
+SCORE_ID="c8d853b1-f18b-5692-a113-39692e17f395"
+SCORE_TITLE="One Summer's Day"
+MAX_WAIT=900   # 15 min for model download + load on CPU
+POLL_INTERVAL=5
+
+log() { echo "[seed] $*"; }
+
+# ── Step 0: Check if score already exists with data ──────────────────────
+log "Checking if example score already exists..."
+EXISTING=$(curl -sf "$API_BASE/api/scores/$SCORE_ID" 2>/dev/null || echo "")
+if echo "$EXISTING" | python3 -c "
+import json, sys
+try:
+    d = json.load(sys.stdin)
+    pages = d.get('data', d).get('pages', [])
+    if len(pages) > 0:
+        sys.exit(0)
+except: pass
+sys.exit(1)
+" 2>/dev/null; then
+  log "Example score already has pages, skipping seed."
+  exit 0
+fi
+
+# ── Step 1: Wait for ML predictors ──────────────────────────────────────
+log "Waiting for ML predictors to be ready (up to ${MAX_WAIT}s)..."
+ELAPSED=0
+while [ $ELAPSED -lt $MAX_WAIT ]; do
+  # Try a lightweight predict/layout call to check if the layout predictor is up.
+  # We send a tiny 1x1 PNG as a probe — if it responds (even with an error result),
+  # the predictor is loaded.
+  PROBE_RES=$(curl -sf -X POST "$API_BASE/api/predict/layout" \
+    -H "Content-Type: application/json" \
+    -d '{"images":["iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAADUlEQVR42mNk+M9QDwADhgGAWjR9awAAAABJRU5ErkJggg=="]}' \
+    2>/dev/null || echo "")
+  if [ -n "$PROBE_RES" ]; then
+    log "Predictors are ready."
+    break
+  fi
+  sleep 10
+  ELAPSED=$((ELAPSED + 10))
+  if [ $((ELAPSED % 60)) -eq 0 ]; then
+    log "  Still waiting... (${ELAPSED}s elapsed)"
+  fi
+done
+
+if [ $ELAPSED -ge $MAX_WAIT ]; then
+  log "WARNING: Timed out waiting for predictors. Attempting seed anyway..."
+fi
+
+# ── Step 2: Create score shell ───────────────────────────────────────────
+log "Creating score shell ($SCORE_ID)..."
+curl -sf -X PUT "$API_BASE/api/scores/$SCORE_ID/data" \
+  -H "Content-Type: application/json" \
+  -d '{"pages":[],"patches":[],"tags":[]}' > /dev/null
+
+# ── Step 3: Upload images + predict ──────────────────────────────────────
+log "Submitting predict/pages for 4 pages..."
+CURL_ARGS=(-F 'processes=["gauge","semantic","mask","brackets","text"]')
+for i in 0 1 2 3; do
+  IMG="$IMAGE_DIR/page-0${i}.png"
+  if [ ! -f "$IMG" ]; then
+    log "ERROR: Missing image: $IMG"
+    exit 1
+  fi
+  CURL_ARGS+=(-F "page${i}=@${IMG};type=image/png")
+done
+
+PREDICT_RES=$(curl -sf -X POST "$API_BASE/api/predict/pages/$SCORE_ID" "${CURL_ARGS[@]}")
+TASK_ID=$(echo "$PREDICT_RES" | python3 -c "import json,sys; print(json.load(sys.stdin)['task_id'])")
+log "Task ID: $TASK_ID"
+
+# ── Step 4: Poll task ────────────────────────────────────────────────────
+log "Polling task..."
+ELAPSED=0
+while [ $ELAPSED -lt $MAX_WAIT ]; do
+  POLL_RES=$(curl -sf "$API_BASE/api/tasks/$TASK_ID/poll" 2>/dev/null || echo '{"status":"unknown"}')
+  STATUS=$(echo "$POLL_RES" | python3 -c "import json,sys; print(json.load(sys.stdin).get('status','unknown'))" 2>/dev/null || echo "unknown")
+
+  case "$STATUS" in
+    completed)
+      log "Prediction completed!"
+      echo "$POLL_RES" | python3 -c "
+import json, sys
+r = json.load(sys.stdin).get('result', {})
+print(f'[seed]   Systems: {r.get(\"systems\",\"?\")}, Staves: {r.get(\"staves\",\"?\")}, StaffLayout: {r.get(\"staffLayout\",\"?\")}')
+" 2>/dev/null || true
+      break
+      ;;
+    failed|error)
+      log "ERROR: Prediction task failed!"
+      echo "$POLL_RES" | python3 -m json.tool 2>/dev/null || echo "$POLL_RES"
+      exit 1
+      ;;
+    *)
+      sleep $POLL_INTERVAL
+      ELAPSED=$((ELAPSED + POLL_INTERVAL))
+      ;;
+  esac
+done
+
+if [ $ELAPSED -ge $MAX_WAIT ]; then
+  log "ERROR: Task polling timed out after ${MAX_WAIT}s"
+  exit 1
+fi
+
+# ── Step 5: Set title ────────────────────────────────────────────────────
+log "Setting score title: $SCORE_TITLE"
+curl -sf -X PUT "$API_BASE/api/scores/$SCORE_ID" \
+  -H "Content-Type: application/json" \
+  -d "{\"title\":\"$SCORE_TITLE\"}" > /dev/null || log "WARNING: Failed to set title"
+
+# ── Step 6: Regulation (optional) ────────────────────────────────────────
+log "Running regulation..."
+REG_RES=$(curl -sf -X POST "$API_BASE/api/scores/$SCORE_ID/regulate" --max-time 600 2>/dev/null || echo "")
+if [ -n "$REG_RES" ]; then
+  echo "$REG_RES" | python3 -c "
+import json, sys
+r = json.load(sys.stdin)
+if r.get('code') == 0:
+    s = r['data']['stat']
+    qs = s.get('qualityScore', 0)
+    m = s.get('measures', {})
+    print(f'[seed]   Quality: {qs*100:.1f}%')
+    print(f'[seed]   Measures: solved={m.get(\"solved\",0)} issue={m.get(\"issue\",0)} fatal={m.get(\"fatal\",0)}')
+else:
+    print(f'[seed]   Regulation error: {r.get(\"message\",\"unknown\")}')
+" 2>/dev/null || true
+else
+  log "WARNING: Regulation failed or timed out (non-critical)."
+fi
+
+log "=== Seed complete ==="
+log "View at: /playground/$SCORE_ID"