Albums in the Rust edge, and the batch-counter rule (design 3)

A release the window closed on with one file named by its stem or post, the
name with a number and no archive, volume, sidecar or random name, waits in
the album of its poster and template (the name's digit runs as #, the
extension apart) posted within the window of the album's first file; the
album closes a window after that span and is written as one release
(source album, no file total) named by the members' shared numbers, a lone
member as the release it was. The batch store writes an album's member
names as release_texts kind 6 (member). A counter total of 100 or more under
which one poster started 20 or more releases is a batch counter: those
releases get no file total.

Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>

app/services/batch_store.ts

@@ -8,7 +8,7 @@ import { decodeChunk } from '#lib/chunks/index'
 import { SIDECAR } from '#services/sidecar_folder'
 import { identityKey, releaseKey } from '#lib/release/keys'
 import { sourceCode } from '#lib/release/source'
-import { TEXT_KINDS, TEXT_MAX } from '#lib/release/text_kind'
+import { TEXT_KINDS, TEXT_MAX, textsToStore } from '#lib/release/text_kind'
 
 /**
  * A small new release (at most 3 files, under 1 MB) whose files are all sidecars (.nfo, .sfv, .nzb, …): the sidecar
@@ -237,7 +237,7 @@ class BatchStore {
           ]
         )
       )
-      const texts: { release_id: number; text: string }[] = []
+      const texts: { release_id: number; kind: number; text: string }[] = []
       for (const row of rows) {
         const w = byKey.get(row.release_key)
         if (!w) continue
@@ -248,15 +248,21 @@ class BatchStore {
           out.finalized++
           finalized.add(w.id)
         }
-        texts.push({ release_id: w.id, text: row.name.slice(0, TEXT_MAX) })
+        texts.push({ release_id: w.id, kind: TEXT_KINDS.name, text: row.name.slice(0, TEXT_MAX) })
+        // An album's members stay findable by their own names (the first TEXTS_PER_KIND of them).
+        if (r.source === 'album' && r.files > 0) {
+          for (const text of textsToStore(decodeChunk(r.payload).map((f) => f.name))) {
+            texts.push({ release_id: w.id, kind: TEXT_KINDS.member, text })
+          }
+        }
       }
-      // The name, searchable (release_texts; a name sent again is a no-op).
+      // The name (and an album's members), searchable (release_texts; a text sent again is a no-op).
       if (texts.length > 0) {
         await trx.rawQuery(
           `INSERT INTO release_texts (release_id, kind, text)
-           SELECT v.release_id, ?, v.text FROM jsonb_to_recordset(?::jsonb) AS v(release_id bigint, text text) WHERE v.text <> ''
+           SELECT v.release_id, v.kind, v.text FROM jsonb_to_recordset(?::jsonb) AS v(release_id bigint, kind int, text text) WHERE v.text <> ''
            ON CONFLICT DO NOTHING`,
-          [TEXT_KINDS.name, JSON.stringify(texts)]
+          [JSON.stringify(texts)]
         )
       }
     }