Scope chapter publication identities and test explicit work anchors

Reviewed-on: #42

.gitea/workflows/check.yml

@@ -12,7 +12,7 @@ jobs:
       - name: Verify metadata storage and query commands
         run: |
           python3 -B - <<'PY'
-          import io, os, pathlib, re, subprocess, tarfile, tempfile, urllib.request
+          import gzip, io, json, os, pathlib, re, subprocess, tarfile, tempfile, urllib.request
           sha = os.environ['ARCHIVE_SHA']
           if not re.fullmatch(r'[0-9a-fA-F]{40,64}', sha):
               raise SystemExit('Invalid source commit')
@@ -52,6 +52,19 @@ jobs:
               subprocess.run([python,'-I','-B','-m','paper_atlas','collect','aamas-proceedings','--help'],cwd=outside,check=True)
               subprocess.run([python,'-I','-B','-m','paper_atlas','collect','aamas-proceedings','--year','2025','--snapshots',str(src/'tests/fixtures/aamas2025'),'--out',str(root/'installed-aamas2025')],cwd=outside,check=True)
               subprocess.run([python,'-I','-B','-m','paper_atlas','collect','iclr-archive','--help'],cwd=outside,check=True)
+              subprocess.run([python,'-I','-B','-m','paper_atlas','collect','acl','--help'],cwd=outside,check=True)
+              subprocess.run([python,'-I','-B','-m','paper_atlas','collect','springer-selected','--help'],cwd=outside,check=True)
+              springer = json.loads(gzip.decompress((src/'tests/fixtures/springer-aistats1993-fixture.json.gz').read_bytes()))
+              for group in ('toc','chapters'):
+                  folder = root/'springer-snapshots'/group
+                  folder.mkdir(parents=True)
+                  for name, content in springer[group].items():
+                      (folder/name).write_text(content)
+              subprocess.run([python,'-I','-B','-m','paper_atlas','collect','springer-selected','--toc-snapshots',str(root/'springer-snapshots/toc'),'--chapter-snapshots',str(root/'springer-snapshots/chapters'),'--out',str(root/'installed-springer')],cwd=outside,check=True)
+              springer_report = json.loads((root/'installed-springer/collection-report.json').read_bytes())
+              assert springer_report['records'] == 49 and not springer_report['database_written']
+              springer_manifest, = springer_report['files']
+              assert springer_manifest['status'] == 'partial' and springer_manifest['missing_abstract_count'] == 0
               subprocess.run([python,'-I','-B','-m','paper_atlas','maintain','postgres','--help'],cwd=outside,check=True)
               subprocess.run([python,'-I','-B','-m','paper_atlas','maintain','edition-tracks','--help'],cwd=outside,check=True)
               subprocess.run([python,'-I','-B','-m','paper_atlas','maintain','joint-editions','--help'],cwd=outside,check=True)

README.md

@@ -8,8 +8,12 @@ Paper Atlas 将 arXiv、AI 会议论文集及公开投稿决定整理到可追
 
 历史 ICLR 2014–2016 官方录用页由 `collect iclr-archive` 适配，保留主会/workshop及重复展示证据；运行和身份核验边界见 [历史档案说明](docs/coverage/iclr-archive-2014-2016.md)。
 
+`collect springer-selected` 核验限定的会后选集，分开保存会议年份、出版年份及选集事件身份。目前支持 AISTATS 1993 对应的 1994 年出版选集，原始会议决定仍须单独核查；配置、证据和恢复见 [会后选集说明](docs/springer-selected-volumes.md)。
+
 ## 项目结构
 
+ACL 1978 的年会与 TINLAP-2 来源关系按精确卷适配，保留原系列和不明逐篇角色；1965 的替代关系不转成全局别名。来源、排除条目和恢复边界见 [ACL 早期来源核查](docs/coverage/acl-early-sources-2026-11-09.md)。
+
 ```text
 paper_atlas/
   cli.py                 统一命令入口

docs/coverage/acl-early-sources-2026-11-09.md

@@ -0,0 +1,52 @@
+# ACL 早期年份：会议存在、出版目录与逐篇资料分开核验
+
+固定普查中 ACL 1963–1978 仍有年份缺口。不能因为会议年表连续，就假设每年都有独立的正式论文集；也不能因为当前目录始于 1979，就断言此前没有摘要、通知或其他公开资料。本次不修改固定的 1,266 个目标年份基准。
+
+## 1978 年：限定 T78-1 的来源关系
+
+[同期年会通知](https://aclanthology.org/J77-4001.pdf)的 PDF 第 9–10 页（印刷页码 9–10）明确说明，1978 年 ACL 年会采用第二届 Theoretical Issues in Natural Language Processing 的形式，地点为 Urbana/Champaign，日期为 7 月 25–27 日。通知中的 ACM 联合赞助确认仍处于待确认状态，不能将该预告改写为已完成的行政决定。
+
+[1982 年 Donald E. Walker 的历史回顾](https://aclanthology.org/www.mt-archive.info/70/ACL-1982-Walker-1.pdf)第 3 页（印刷页码 91）的年会表及缩写说明，独立对应了 1978 年的时间、地点与 TNLP/TINLAP-2 关系。两份扫描件相关页已渲染并逐页目视核对，不仅依靠 OCR。
+
+[官方卷目录](https://aclanthology.org/volumes/T78-1/)与固定 XML `T78.xml` 保留原系列名 TINLAP、完整卷名、1978 年及编辑 David L. Waltz。适配仅接受精确的 collection `T78`、volume `1` 和上述字段组合；关键元数据变化会拒绝处理，等待重新核查。
+
+- 规范事件名使用 `ACL+TINLAP`，原系列名 `TINLAP`、原始 XML 的 `venue_codes: [tinlap]` 及证据均保留。
+- ACL/TINLAP 别名只挂在这一规范事件系列上，不把所有 TINLAP 年份都算成 ACL。T75、T87 及 T78 其他卷没有此例外。
+- 通知描述了邀请与提交论文两种参与方式，XML 没有逐篇角色。统一暂存为 `proceedings_unspecified`，不猜测每篇属于 invited、main 或 workshop。
+- XML 共 36 条条目，其中 T78-1036 是无作者的场次讨论问题列表。精确识别并在 manifest 的 `excluded_materials` 保留其标识、标题与原因；其余 35 条作为具名贡献整理。该排除不推广到所有无作者条目，已识别条目发生变化也须重新核查。
+- 全部 35 条 XML 均无摘要。出版目录中的 accepted 是来源观察；通知提及录用／不录用通知时间，不提供任何可识别的拒稿决定，不能制造 rejected 或 withdrawn。
+
+采集器仅生成元数据文件，不写业务数据库。真实来源逐条验收、PostgreSQL 身份预检、串行导入与独立验收仍是后续门槛。35 条来源不等于 35 个新增论文实体，更不等于完成全库去重。
+
+## 1965 年：替代关系不改写为别名
+
+Walker 回顾第 1 页（印刷页码 89）说明，1965 年 ICCL（后来称 COLING）替代了当年的年会。[官方 C65-1 目录](https://aclanthology.org/volumes/C65-1/)及 XML 仍以 COLING 标记该卷。这是限定年份的历史关系，不证明 COLING 与 ACL 是两个可全局互换的名字。
+
+本次保留 C65 原有 `COLING` 归属，不添加 ACL 全局别名、不重放已导入记录、不将某一年的日历关系推广到整个系列，也不据此悄悄减少固定普查缺口。其他 1963–1977 年资料仍须逐年核查；本次不能证明这些年份整体属于非归档例外。
+
+## 固定来源与恢复
+
+服务器证据目录：`/data/paper-index/collected/acl-early-source-evidence-v1`。五份官方响应均 HTTP 200，另有两份来自既有官方 XML checkout 的文件，已与 Git 对象逐字节核对。未下载论文全文集合；两份 PDF 是本次历史／行政取证资料，不进入论文全文库。
+
+| 文件 | SHA256 |
+|---|---|
+| `acl-venue.html` | `c60f64cb4d72e677aeb84a5844cde28a8d50579e1995f08e8c7801eed1e3fac5` |
+| `acl-history-1982.pdf` | `35c21bd4983975bcaccbb94bd8ab91c9019fc190feec1791255407cf18a7e49a` |
+| `acl-1978-notice.pdf` | `14b5deb471c55afb07d789529b95d0462a2a1a77df3dfba7fa1f5d3ab75eb411` |
+| `tinlap1978-volume.html` | `7e20d709f72f415819e4d17e3674b19dc7d871eabcf0cf8b4935f0392d775729` |
+| `coling1965-volume.html` | `0d2f2f49f2a311f9c0b80a8832f6476eb32f94f35abf36f6d2f2e10063ac880f` |
+| `T78.xml` | `f712f94cff0cba05f786b7ac31dad2ea9408fde2a17a04531130df623f57dd84` |
+| `C65.xml` | `572791610e20b7c6045d984d968e73a18a144bcb5c3da64112001c781826808e` |
+
+XML commit：`a7be623d01c48c61405dec31c871121cdbed5a01`。测试 fixture `tests/fixtures/acl-t78.xml` 是该原始文件，不是手工模拟论文；不包含 PDF。PDF 哈希建立完整性，不单独证明语义，语义依据是上述具体页面。
+
+在服务器使用既有命令，固定 checkout 并输出到新目录：
+
+```sh
+paper-atlas collect acl \
+  --checkout /data/paper-index/raw/metadata-checkouts/acl-anthology \
+  --collection T78 \
+  --out /data/paper-index/collected/acl-t78-source-v1
+```
+
+该命令会校验／更新官方 metadata checkout，实际 commit 必须以生成清单为准；严格重现本次取证时，使用已冻结的 XML 和上述 commit，不把更新后的内容冒充旧快照。不要将无 collection 限制的全部历史输出直接作为增量队列。采集完成不代表导入完成，恢复前先检查当前单元和报告，不因日志安静重启已执行的写入。

docs/springer-selected-volumes.md

@@ -0,0 +1,36 @@
+# 会后选集的元数据采集
+
+`collect springer-selected` 读取已冻结、带 HTTP 回执的公开 HTML，不访问 PDF、不写业务库。目前仅支持核验过的 *Selecting Models from Data: Artificial Intelligence and Statistics IV*，书籍 DOI 为 `10.1007/978-1-4612-2660-4`。增加其他卷前必须另行核对会议关系、目录、年份和字段格式。
+
+[会议官方旧站](https://www.gatsby.ucl.ac.uk/aistats/workshops.html)区分现场分发的 Preliminary Papers 与之后修订、再次评审的选集。[出版社卷说明](https://link.springer.com/book/10.1007/978-1-4612-2660-4)将本书关联到 1993 年 1 月的第四届 workshop，书籍出版年份为 1994。三页目录共有 49 个章节 DOI；分区 Front Matter 不作为章节论文导入。
+
+规范记录保留：
+
+- 会议年份 1993、独立 track `selected_volume` 与事件标识 `aistats-1993-selected-volume-1994`；出版年份单独记为 1994。
+- 章节本身的 DOI、作者原始引用写法及顺序、姓名首字母、标题、摘要、页码和逐页原始证据。不扩写作者首字母。
+- 明确提供本章 `publication_doi` 投稿出版标识，不把它转移到旧的原始会议评审记录，也不因短标题相同而强制合并实体。
+- `springer_selected_volume:publication_format` 标签与独立来源 namespace。
+- `accepted` 仅表示章节已列入这本出版选集，原始 1993 投稿评审决定、决定日期和全部录用清单均未知。后续原会议 main、拒稿或撤稿证据可以独立保留。
+
+不能据此宣称会议全部录用、全部投稿或公开拒稿覆盖完整，也不能把出版社机器添加的关键词视为作者标签。未命中选集不等于被拒。
+
+## 按需运行与恢复
+
+输入分别是卷目录/旧站说明和章节页的快照目录。每个目录的 `receipts.json` 包含 `responses` 列表，每条保留 `url`、`final_url`、`file`、`http_status`、`headers`、`bytes`、`sha256`、`at`。需要三页目录、官方旧站说明及全部 49 个章节页面。
+
+```sh
+paper-atlas collect springer-selected \
+  --toc-snapshots /data/paper-index/collected/aistats1993-book-evidence-v1 \
+  --chapter-snapshots /data/paper-index/collected/aistats1993-chapter-evidence-v1 \
+  --out /data/paper-index/collected/aistats1993-source-v1
+```
+
+采集器验证回执和内容哈希、文件路径、HTTP 类型、目录/章节 DOI 和标题、作者格式、出版年份及页码。Springer 对公开元数据返回的同路径 `cookies_not_supported` 诊断参数会原样保留；不接受其他域、路径、分页变化或未知查询参数。官方旧站说明固定哈希为 `6db205b9dbc82b4a096556efd2aa67e065cad8e0bd6351176b1962ffd1fca179`，变化时须重新审核。
+
+全部文件先核验，输出使用排他锁和暂存目录，完成报告最后发布。已有输出拒绝覆盖；发现不完整或已消费文件，应先查运行状态与报告，另建明确版本目录，不能重放生产导入。
+
+输出 JSONL 配套 manifest 始终为 `partial`。收集完成后还必须做 PostgreSQL 稳定标识/标题/作者身份预检、排除已导入记录、准备限定增量文件、保存旧数据保护基线、原生导入和独立验收。49 条来源不代表 49 个新增论文实体，全部来源处理后仍须全库去重审计。
+
+## 固定测试资料
+
+`tests/fixtures/springer-aistats1993-fixture.json.gz` 保存 4 份范围/目录 HTML、49 份章节 HTML、原始请求回执及独立原始字段审计的预期元数据，SHA256 为 `94028fd37080f9d8027e5790e379cc151ee6eab17ed0d1dcc0f59e6e75f9d4d0`。摘要按 HTML 段落边界分隔；未修改原始 HTML 或回执。它是压缩的公开元数据测试资料，不包含论文 PDF。测试覆盖全部真实章节字段、缺失和漂移输入、来源安全边界、幂等导入及旧拒稿历史保留。构建和测试只在已授权远程 runner 执行。

paper_atlas/cli.py

@@ -13,6 +13,7 @@ COMMANDS = {
     ('download',): ('paper_atlas.io.snapshots', {}, '下载并校验固定版本快照'),
     ('collect','pmlr'): ('paper_atlas.collectors.pmlr', {}, 'PMLR 官方元数据'),
     ('collect','acl'): ('paper_atlas.collectors.acl', {}, 'ACL Anthology XML'),
+    ('collect','springer-selected'): ('paper_atlas.collectors.springer_selected', {}, '核验限定的会后选集章节与原会议关系'),
     ('collect','iclr-archive'): ('paper_atlas.collectors.iclr_archive', {}, '核对ICLR 2014–2016官方历史录用档案'),
     ('collect','iclr-program'): ('paper_atlas.collectors.iclr', {}, 'ICLR 官方公开程序'),
     ('collect','iclr-snapshot'): ('paper_atlas.collectors.openreview', {}, 'ICLR 公开投稿与决定快照'),

paper_atlas/collectors/acl.py

@@ -6,6 +6,7 @@ import xml.etree.ElementTree as ET
 from pathlib import Path
 
 from paper_atlas.io.git_metadata import checkout_metadata
+from paper_atlas.collectors.acl_historical import event_scope, material_reason
 
 VENUES={'acl':'ACL','emnlp':'EMNLP','naacl':'NAACL','eacl':'EACL','coling':'COLING','conll':'CoNLL'}
 
@@ -29,7 +30,10 @@ def paper_id(collection,volume,number):
     return f'{collection}-{int(volume):0{width}d}{int(number):0{digits}d}'
 
 
-def volume_scope(meta,volume):
+def volume_scope(meta,volume,collection=None):
+    historical=event_scope(meta,volume,collection)
+    if historical:
+        return historical['canonical_venue'],historical['venue_aliases'],historical['track']
     codes=[text(n).lower() for n in meta.findall('venue')]
     book=text(meta.find('booktitle'))
     lower=book.lower()
@@ -59,7 +63,7 @@ def collect_xml(path,out,commit):
         vid=volume.attrib['id']
         meta=volume.find('meta')
         if meta is None:raise ValueError('Volume metadata missing')
-        scope=volume_scope(meta,vid)
+        scope=volume_scope(meta,vid,collection)
         key=f'{collection}-{vid}'
         if scope is None:
             results.append({'volume':key,'status':'excluded_by_venue','venue_codes':[text(n) for n in meta.findall('venue')],'booktitle':text(meta.find('booktitle')),'year':text(meta.find('year'))})
@@ -70,12 +74,18 @@ def collect_xml(path,out,commit):
         year=int(year_text)
         records=[]
         frontmatter=0
+        excluded_materials=[]
+        historical=event_scope(meta,vid,collection)
         for paper in volume.findall('paper'):
             pid=paper.attrib['id']
             if int(pid)==0:
                 frontmatter+=1
                 continue
             identifier=paper_id(collection,vid,pid)
+            reason=material_reason(collection,vid,paper)
+            if reason:
+                excluded_materials.append({'external_id':identifier,'title':text(paper.find('title')),'reason':reason})
+                continue
             doi=text(paper.find('doi'))
             if doi.startswith('10.18653/v1/') and doi.split('10.18653/v1/',1)[1].casefold()!=identifier.casefold():
                 raise ValueError('Official DOI disagrees with constructed Anthology ID: '+identifier)
@@ -83,6 +93,8 @@ def collect_xml(path,out,commit):
             if not title:raise ValueError('Missing paper title: '+identifier)
             authors=[{'given':text(a.find('first')),'family':text(a.find('last'))} for a in paper.findall('author')]
             records.append({'source':'acl_anthology','external_id':identifier,'url':f'https://aclanthology.org/{identifier}/','title':title,'abstract':text(paper.find('abstract')) or None,'authors':authors,'identifiers':{'acl':identifier,'doi':doi},'venue':venue,'venue_aliases':aliases if len(aliases)>1 else [],'year':year,'track':track,'status':'accepted','raw_decision':'listed in authoritative ACL Anthology proceedings XML','metadata':{'collection':collection,'volume':vid,'booktitle':text(meta.find('booktitle')),'venue_codes':[text(n) for n in meta.findall('venue')],'pages':text(paper.find('pages')),'publisher':text(meta.find('publisher')),'metadata_commit':commit,'source_xml':f'https://github.com/acl-org/acl-anthology/blob/{commit}/data/xml/{collection}.xml'}})
+            if historical:
+                records[-1]['metadata']['historical_event_scope']=historical
         if not records:
             results.append({'volume':key,'status':'unavailable','reason':'no research paper elements after excluding front matter'})
             continue
@@ -93,7 +105,7 @@ def collect_xml(path,out,commit):
             for record in records:output.write(json.dumps(record,ensure_ascii=False)+'\n')
         part.replace(target)
         missing=sum(not row['abstract'] for row in records)
-        manifest={'source':'acl_anthology','venue':venue,'year':year,'track':track,'count':len(records),'xml_paper_elements':len(volume.findall('paper')),'excluded_frontmatter':frontmatter,'missing_abstract_count':missing,'list_url':f'https://aclanthology.org/{key}/','metadata_commit':commit,'file':str(target),'status':'partial' if missing else 'collected'}
+        manifest={'source':'acl_anthology','venue':venue,'year':year,'track':track,'count':len(records),'xml_paper_elements':len(volume.findall('paper')),'excluded_frontmatter':frontmatter,'excluded_materials':excluded_materials,'missing_abstract_count':missing,'list_url':f'https://aclanthology.org/{key}/','metadata_commit':commit,'file':str(target),'status':'partial' if missing else 'collected'}
         target.with_suffix('.manifest.json').write_text(json.dumps(manifest,indent=2))
         results.append(manifest)
         print(json.dumps(manifest),flush=True)

paper_atlas/collectors/acl_historical.py

@@ -0,0 +1,45 @@
+"""Edition-specific historical scope; never alias every TINLAP year to ACL."""
+
+HISTORY_URL = 'https://aclanthology.org/www.mt-archive.info/70/ACL-1982-Walker-1.pdf'
+NOTICE_URL = 'https://aclanthology.org/J77-4001.pdf'
+BOOK = 'Theoretical Issues in Natural Language Processing-2'
+MATERIAL_TITLE = 'List of questions suggested for consideration in each session'
+
+
+def text(node):
+    return ' '.join(''.join(node.itertext()).split()) if node is not None else ''
+
+
+def event_scope(meta, volume, collection):
+    if (collection, volume) != ('T78', '1'):
+        return None
+    if ([text(n) for n in meta.findall('venue')] != ['tinlap']
+            or [text(n) for n in meta.findall('year')] != ['1978']
+            or [text(n) for n in meta.findall('booktitle')] != [BOOK]
+            or [(text(n.find('first')), text(n.find('last'))) for n in meta.findall('editor')]
+               != [('David L.', 'Waltz')]):
+        raise ValueError('Reviewed T78-1 scope metadata changed; independent review required')
+    return {
+        'collection': 'T78', 'volume': '1', 'original_venue': 'TINLAP',
+        'event_year': 1978, 'event_dates': ['1978-07-25', '1978-07-27'],
+        'relationship': 'ACL annual meeting took the form of TINLAP-2',
+        'canonical_venue': 'ACL+TINLAP', 'venue_aliases': ['ACL', 'TINLAP'],
+        'track': 'proceedings_unspecified',
+        'track_scope_note': 'Invited and submitted contributions are described at volume level; individual roles are not identified in XML.',
+        'evidence': [
+            {'url': NOTICE_URL, 'sha256': '14b5deb471c55afb07d789529b95d0462a2a1a77df3dfba7fa1f5d3ab75eb411',
+             'pdf_pages': [9, 10], 'printed_pages': ['9', '10'],
+             'scope': 'Contemporary annual meeting notice, not individual decision notes; ACM confirmation was pending in this notice.'},
+            {'url': HISTORY_URL, 'sha256': '35c21bd4983975bcaccbb94bd8ab91c9019fc190feec1791255407cf18a7e49a',
+             'pdf_pages': [3], 'printed_pages': ['91'],
+             'scope': 'Retrospective annual meeting table and TNLP abbreviation confirm the 1978 event association.'},
+        ],
+    }
+
+
+def material_reason(collection, volume, paper):
+    if (collection, volume, paper.attrib.get('id')) != ('T78', '1', '36'):
+        return None
+    if text(paper.find('title')) != MATERIAL_TITLE or paper.findall('author'):
+        raise ValueError('Reviewed T78-1036 material changed; independent review required')
+    return 'Session question list, not an authored research contribution; no decision inferred.'

paper_atlas/collectors/springer_selected.py

@@ -0,0 +1,231 @@
+"""Reviewed postconference selected volumes from frozen public HTML metadata."""
+import argparse
+from collections import defaultdict
+import fcntl
+import hashlib
+import json
+from pathlib import Path
+import re
+import tempfile
+from urllib.parse import parse_qs, urlsplit
+
+from paper_atlas.db.submissions import timestamp
+from paper_atlas.io.html import Document, clean
+
+SOURCE = 'springer_selected_volume'
+BOOK = '10.1007/978-1-4612-2660-4'
+BOOK_URL = 'https://link.springer.com/book/'+BOOK
+HISTORY_URL = 'https://www.gatsby.ucl.ac.uk/aistats/workshops.html'
+HISTORY_SHA = '6db205b9dbc82b4a096556efd2aa67e065cad8e0bd6351176b1962ffd1fca179'
+SCOPE = {
+    'venue': 'AISTATS', 'year': 1993, 'track': 'selected_volume',
+    'event_key': 'aistats-1993-selected-volume-1994',
+    'publication_year': 1994, 'book_doi': BOOK,
+    'book_title': 'Selecting Models from Data', 'expected_chapters': 49,
+    'relationship': 'Selected workshop papers were revised and rereviewed for later publication; this is not the original complete workshop decision list.',
+}
+
+
+def snapshot_index(root):
+    root = Path(root).resolve()
+    receipts = json.loads((root/'receipts.json').read_bytes())['responses']
+    index = {}
+    for receipt in receipts:
+        url = receipt['url']
+        if url in index:
+            raise ValueError('Duplicate snapshot URL')
+        index[url] = (root, receipt)
+    return index
+
+
+def read_page(index, url):
+    if url not in index:
+        raise ValueError('Missing required public HTML snapshot: '+url)
+    root, receipt = index[url]
+    filename = Path(receipt['file'])
+    path = root/filename
+    content_type = {k.lower():v for k,v in receipt.get('headers', {}).items()}.get('content-type', '')
+    requested, final = urlsplit(url), urlsplit(receipt.get('final_url', ''))
+    query = parse_qs(final.query, keep_blank_values=True)
+    original_query = parse_qs(requested.query, keep_blank_values=True)
+    # Springer returns the public metadata with an explicit cookie diagnostic.
+    # Retain that final URL verbatim; accept no other redirect or changed page.
+    if query != original_query and requested.netloc == 'link.springer.com':
+        if (query.pop('error', None) != ['cookies_not_supported']
+                or not re.fullmatch(r'[0-9a-f-]{36}', ''.join(query.pop('code', [])))):
+            raise ValueError('Unreviewed Springer redirect query')
+    if (filename.is_absolute() or '..' in filename.parts or not path.resolve().is_relative_to(root)
+            or receipt.get('http_status') != 200
+            or (final.scheme, final.netloc, final.path) != (requested.scheme, requested.netloc, requested.path)
+            or final.fragment or query != original_query
+            or 'text/html' not in content_type.lower()):
+        raise ValueError('Unsafe, redirected or unsuccessful public HTML snapshot')
+    raw = path.read_bytes()
+    digest = hashlib.sha256(raw).hexdigest()
+    if len(raw) > 2_000_000 or len(raw) != receipt['bytes'] or digest != receipt['sha256']:
+        raise ValueError('Snapshot checksum or size differs')
+    evidence = {'url':url, 'sha256':digest, 'bytes':len(raw),
+                'file':'evidence/'+digest+'.html', 'http_status':200,
+                'observed_at':timestamp(receipt['at']), 'response_receipt':receipt}
+    return raw, evidence
+
+
+def parse_toc(html, *, excluded_materials=None):
+    entries = {}
+    for node in Document(html).root.walk():
+        if node.tag != 'li' or node.attrs.get('data-test') != 'chapter':
+            continue
+        links = [n for n in node.walk() if n.tag == 'a' and re.fullmatch(
+            r'/chapter/'+re.escape(BOOK)+r'_[1-9]\d*', n.attrs.get('href', ''))]
+        if not links:
+            headings = [clean(n.text()) for n in node.walk() if n.tag in ('h3','h4')]
+            frontmatter = [n.attrs.get('href','') for n in node.walk()
+                           if n.tag == 'a' and n.attrs.get('data-test') == 'front-matter-pdf']
+            if headings == ['Front Matter'] and len(frontmatter) == 1:
+                if excluded_materials is not None:
+                    excluded_materials.append({'title':'Front Matter', 'url':frontmatter[0],
+                                               'reason':'Section front matter without a chapter DOI; not an authored chapter.'})
+                continue
+        if len(links) != 1:
+            raise ValueError('Chapter entry lacks one reviewed-book DOI')
+        link, = links
+        doi = link.attrs['href'].removeprefix('/chapter/')
+        if doi in entries or not clean(link.text()):
+            raise ValueError('Duplicate DOI or missing chapter title')
+        entries[doi] = clean(link.text())
+    return entries
+
+
+def parse_chapter(html, doi):
+    nodes = list(Document(html).root.walk())
+    meta = defaultdict(list)
+    for node in nodes:
+        if node.tag == 'meta' and node.attrs.get('name', '').startswith('citation_'):
+            meta[node.attrs['name']].append(node.attrs.get('content', ''))
+    def one(key):
+        values = meta[key]
+        if len(values) != 1 or not values[0]:
+            raise ValueError('Missing or ambiguous citation field: '+key)
+        return values[0]
+    if (one('citation_doi') != doi or one('citation_inbook_title') != SCOPE['book_title']
+            or one('citation_publication_date') != str(SCOPE['publication_year'])):
+        raise ValueError('Chapter DOI, book or publication year differs from reviewed scope')
+    raw_authors = meta['citation_author']
+    if not raw_authors:
+        raise ValueError('Missing named chapter authors')
+    authors = []
+    for raw in raw_authors:
+        if raw.count(',') != 1:
+            raise ValueError('Unreviewed citation author format')
+        family, given = [clean(s) for s in raw.split(',', 1)]
+        if not family or not given:
+            raise ValueError('Incomplete citation author')
+        authors.append({'given':given, 'family':family})
+    abstract_nodes = [n for n in nodes if n.attrs.get('id') == 'Abs1-content']
+    if len(abstract_nodes) > 1:
+        raise ValueError('Ambiguous abstract section')
+    abstract = clean(abstract_nodes[0].text()) if abstract_nodes else None
+    first, last = one('citation_firstpage'), one('citation_lastpage')
+    if not first.isdigit() or not last.isdigit() or int(first) > int(last):
+        raise ValueError('Invalid chapter pages')
+    return {'doi':doi, 'title':one('citation_title'), 'authors':authors,
+            'authors_citation_raw':list(raw_authors), 'abstract':abstract or None,
+            'first_page':first, 'last_page':last}
+
+
+def record_for(chapter, evidence, scope_evidence):
+    return {
+        'source':SOURCE, 'external_id':chapter['doi'],
+        'url':'https://link.springer.com/chapter/'+chapter['doi'],
+        'title':chapter['title'], 'abstract':chapter['abstract'], 'authors':chapter['authors'],
+        'identifiers':{'doi':chapter['doi']},
+        'submission_identifiers':[{'scheme':'publication_doi','value':chapter['doi']}],
+        **{k:SCOPE[k] for k in ('venue','year','track','event_key')},
+        'status':'accepted', 'observed_at':evidence['observed_at'],
+        'raw_decision':'listed in the 1994 selected postconference volume; original 1993 review decision not supplied',
+        'tags':[{'namespace':SOURCE+':publication_format','value':'selected_volume_chapter'}],
+        'metadata':{
+            'publication_format':'selected_volume_chapter', 'bibliographic_year':1994,
+            'related_workshop_year':1993, 'book_doi':BOOK, 'book_title':SCOPE['book_title'],
+            'year_basis':'Reviewed workshop year; bibliographic publication year is separately retained.',
+            'first_page':chapter['first_page'], 'last_page':chapter['last_page'],
+            'authors_citation_raw':chapter['authors_citation_raw'],
+            'publication_evidence':'Published selected-volume chapter, not an original workshop decision note.',
+            'scope_relationship':SCOPE['relationship'], 'decision_date_precision':'not_supplied',
+            'source_evidence':evidence, 'scope_evidence':scope_evidence,
+        },
+    }
+
+
+def collect(out, *, toc_snapshots, chapter_snapshots):
+    toc_index, chapter_index = snapshot_index(toc_snapshots), snapshot_index(chapter_snapshots)
+    frozen = {}
+    def read(index, url):
+        raw, evidence = read_page(index, url)
+        frozen[evidence['file']] = raw
+        return raw.decode('utf-8'), evidence
+    history, history_evidence = read(toc_index, HISTORY_URL)
+    if hashlib.sha256(history.encode()).hexdigest() != HISTORY_SHA:
+        raise ValueError('Reviewed selected-volume relationship evidence changed')
+    scope_evidence = [history_evidence]
+    titles, excluded = {}, []
+    for page in range(1, 4):
+        html, evidence = read(toc_index, BOOK_URL+('?page='+str(page) if page > 1 else ''))
+        scope_evidence.append(evidence)
+        entries = parse_toc(html, excluded_materials=excluded)
+        if titles.keys() & entries.keys():
+            raise ValueError('DOI repeated across TOC pages')
+        titles.update(entries)
+    expected = {BOOK+'_'+str(i) for i in range(1, 50)}
+    if titles.keys() != expected:
+        raise ValueError('Reviewed 49-chapter inventory changed')
+    chapter_urls = {'https://link.springer.com/chapter/'+doi for doi in expected}
+    if chapter_index.keys() != chapter_urls:
+        raise ValueError('Missing or extraneous chapter snapshot')
+    records = []
+    for doi in sorted(expected, key=lambda s:int(s.rsplit('_',1)[1])):
+        html, evidence = read(chapter_index, 'https://link.springer.com/chapter/'+doi)
+        chapter = parse_chapter(html, doi)
+        if chapter['title'] != titles[doi]:
+            raise ValueError('Chapter title disagrees with official TOC')
+        records.append(record_for(chapter, evidence, scope_evidence))
+    out = Path(out)
+    out.mkdir(parents=True, exist_ok=True)
+    with (out/'springer-selected.collect.lock').open('a') as lock:
+        fcntl.flock(lock, fcntl.LOCK_EX | fcntl.LOCK_NB)
+        if any(p.name != 'springer-selected.collect.lock' for p in out.iterdir()):
+            raise FileExistsError('Existing output must be inspected, not overwritten')
+        with tempfile.TemporaryDirectory(prefix='.springer-selected-', dir=out) as temporary:
+            stage = Path(temporary)
+            (stage/'evidence').mkdir()
+            for filename, raw in frozen.items():
+                (stage/filename).write_bytes(raw)
+            path = stage/'springer-aistats-1993-selected-volume.jsonl'
+            path.write_text(''.join(json.dumps(r,ensure_ascii=False)+'\n' for r in records))
+            manifest = {'source':SOURCE, 'parser_version':1,
+                        **{k:SCOPE[k] for k in ('venue','year','track','event_key')},
+                        'count':len(records), 'file':str(out/path.name),
+                        'file_sha256':hashlib.sha256(path.read_bytes()).hexdigest(),
+                        'list_url':BOOK_URL, 'status':'partial',
+                        'excluded_materials':excluded,
+                        'missing_abstract_count':sum(not r['abstract'] for r in records)}
+            path.with_suffix('.manifest.json').write_text(json.dumps(manifest,indent=2)+'\n')
+            report = {'status':'collected_pending_identity_review', 'records':len(records),
+                      'files':[manifest], 'reviewed_scope':SCOPE, 'database_written':False,
+                      'pdfs_downloaded':False, 'scope_evidence':scope_evidence}
+            (stage/'collection-report.json').write_text(json.dumps(report,ensure_ascii=False,indent=2)+'\n')
+            for item in stage.iterdir():
+                if item.name != 'collection-report.json':
+                    item.replace(out/item.name)
+            (stage/'collection-report.json').replace(out/'collection-report.json')
+    return report
+
+
+def main(argv=None, *, prog=None):
+    parser = argparse.ArgumentParser(prog=prog)
+    parser.add_argument('--toc-snapshots', required=True)
+    parser.add_argument('--chapter-snapshots', required=True)
+    parser.add_argument('--out', required=True)
+    args = parser.parse_args(argv)
+    print(json.dumps(collect(args.out, toc_snapshots=args.toc_snapshots,
+                             chapter_snapshots=args.chapter_snapshots),ensure_ascii=False))

tests/fixtures/acl-t78.xml

@@ -0,0 +1,273 @@
+<?xml version='1.0' encoding='UTF-8'?>
+<collection id="T78">
+  <volume id="1" type="proceedings">
+    <!-- https://aclanthology.org/T78-1/ -->
+    <meta>
+      <booktitle>Theoretical Issues in Natural Language <fixed-case>P</fixed-case>rocessing-2</booktitle>
+      <editor id="david-l-waltz"><first>David L.</first><last>Waltz</last></editor>
+      <venue>tinlap</venue>
+      <year>1978</year>
+    </meta>
+    <frontmatter>
+      <!-- https://aclanthology.org/T78-1000/ -->
+      <pdf hash="fb6164ad"/>
+      <bibkey>tinlap-1978-theoretical</bibkey>
+    </frontmatter>
+    <paper id="1">
+      <!-- https://aclanthology.org/T78-1001/ -->
+      <title>Testing The Psychological Reality of a Representational Model</title>
+      <author><first>Dedre</first><last>Gentner</last></author>
+      <pdf hash="f723a956"/>
+      <bibkey>gentner-1978-testing-psychological</bibkey>
+    </paper>
+    <paper id="2">
+      <!-- https://aclanthology.org/T78-1002/ -->
+      <title>What Makes Something “Ad Hoc”</title>
+      <author id="roger-c-schank"><first>Roger C.</first><last>Schank</last></author>
+      <pdf hash="636853f9"/>
+      <bibkey>schank-1978-makes-something</bibkey>
+    </paper>
+    <paper id="3">
+      <!-- https://aclanthology.org/T78-1003/ -->
+      <title>The Relation of Grammar to Cognition–a Synopsis</title>
+      <author><first>Leonard</first><last>Talmy</last></author>
+      <pdf hash="101c67dc"/>
+      <bibkey>talmy-1978-relation-grammar</bibkey>
+    </paper>
+    <paper id="4">
+      <!-- https://aclanthology.org/T78-1004/ -->
+      <title>On primitives, prototypes, and other semantic anomalies</title>
+      <author><first>Terry</first><last>Winograd</last></author>
+      <pdf hash="f8e47023"/>
+      <bibkey>winograd-1978-primitives-prototypes</bibkey>
+    </paper>
+    <paper id="5">
+      <!-- https://aclanthology.org/T78-1005/ -->
+      <title>Taxonomic Lattice Structures for Situation Recognition</title>
+      <author id="william-a-woods"><first>William A.</first><last>Woods</last></author>
+      <pdf hash="92957ddf"/>
+      <bibkey>woods-1978-taxonomic-lattice</bibkey>
+    </paper>
+    <paper id="6">
+      <!-- https://aclanthology.org/T78-1006/ -->
+      <title>Description Formation and Discourse Model Synthesis</title>
+      <author id="bonnie-webber"><first>Bonnie Lynn</first><last>Webber</last></author>
+      <pdf hash="ffded1d2"/>
+      <bibkey>webber-1978-description-formation</bibkey>
+    </paper>
+    <paper id="7">
+      <!-- https://aclanthology.org/T78-1007/ -->
+      <title>The Processing of Referring Expressions within a Semantic Network</title>
+      <author><first>John R.</first><last>Anderson</last></author>
+      <pdf hash="8bcc083a"/>
+      <bibkey>anderson-1978-processing-referring</bibkey>
+    </paper>
+    <paper id="8">
+      <!-- https://aclanthology.org/T78-1008/ -->
+      <title>Reference Diaries</title>
+      <author><first>Herbert H.</first><last>Clark</last></author>
+      <author><first>Catherine</first><last>Marshall</last></author>
+      <pdf hash="d06b7ea2"/>
+      <bibkey>clark-marshall-1978-reference-diaries</bibkey>
+    </paper>
+    <paper id="9">
+      <!-- https://aclanthology.org/T78-1009/ -->
+      <title>Subsequent Reference: Syntactic and Rhetorical Constraints</title>
+      <author id="david-d-mcdonald"><first>David D.</first><last>McDonald</last></author>
+      <pdf hash="2d424559"/>
+      <bibkey>mcdonald-1978-subsequent-reference</bibkey>
+    </paper>
+    <paper id="10">
+      <!-- https://aclanthology.org/T78-1010/ -->
+      <title>Some Psycholinguistic Constraints on the Construction and Interpretation of Definite Descriptions</title>
+      <author><first>Andrew</first><last>Ortony</last></author>
+      <pdf hash="69807727"/>
+      <bibkey>ortony-1978-psycholinguistic-constraints</bibkey>
+    </paper>
+    <paper id="11">
+      <!-- https://aclanthology.org/T78-1011/ -->
+      <title>Bound Variables and Other Anaphors</title>
+      <author id="barbara-h-partee"><first>Barbara H.</first><last>Partee</last></author>
+      <pdf hash="e8e6a510"/>
+      <bibkey>partee-1978-bound-variables</bibkey>
+    </paper>
+    <paper id="12">
+      <!-- https://aclanthology.org/T78-1012/ -->
+      <title>The Use of Focus as a Tool for Disambiguation of Definite Noun Phrases</title>
+      <author id="candace-l-sidner"><first>Candace L.</first><last>Sidner</last></author>
+      <pdf hash="7b96d2b7"/>
+      <bibkey>sidner-1978-use-focus</bibkey>
+    </paper>
+    <paper id="13">
+      <!-- https://aclanthology.org/T78-1013/ -->
+      <title>Focusing in Dialog</title>
+      <author id="barbara-j-grosz"><first>Barbara J.</first><last>Grosz</last></author>
+      <pdf hash="8c8d4c2e"/>
+      <bibkey>grosz-1978-focusing-dialog</bibkey>
+    </paper>
+    <paper id="14">
+      <!-- https://aclanthology.org/T78-1014/ -->
+      <title>Topic Levels</title>
+      <author><first>Joseph E.</first><last>Grimes</last></author>
+      <pdf hash="f485b2ba"/>
+      <bibkey>grimes-1978-topic-levels</bibkey>
+    </paper>
+    <paper id="15">
+      <!-- https://aclanthology.org/T78-1015/ -->
+      <title>Toward a Rational Model of Discourse Comprehension</title>
+      <author><first>Jerry L.</first><last>Morgan</last></author>
+      <pdf hash="5e12a597"/>
+      <bibkey>morgan-1978-toward-rational</bibkey>
+    </paper>
+    <paper id="16">
+      <!-- https://aclanthology.org/T78-1016/ -->
+      <title>Assent and Compliance in Children’s Language Comprehension</title>
+      <author><first>David R.</first><last>Olson</last></author>
+      <pdf hash="708bc4a0"/>
+      <bibkey>olson-1978-assent-compliance</bibkey>
+    </paper>
+    <paper id="17">
+      <!-- https://aclanthology.org/T78-1017/ -->
+      <title>Speech Acts as a Basis for Understanding Dialogue Coherence</title>
+      <author id="c-raymond-perrault"><first>C. Raymond</first><last>Perrault</last></author>
+      <author id="james-allen"><first>James F.</first><last>Allen</last></author>
+      <pdf hash="d111402b"/>
+      <bibkey>perrault-allen-1978-speech</bibkey>
+    </paper>
+    <paper id="18">
+      <!-- https://aclanthology.org/T78-1018/ -->
+      <title>A Framework for Comparing Language Experiences (with particular emphasis on: The Effect of Audience on Discourse Models)</title>
+      <author><first>Andee</first><last>Rubin</last></author>
+      <pdf hash="5d9a6150"/>
+      <bibkey>rubin-1978-framework-comparing</bibkey>
+    </paper>
+    <paper id="19">
+      <!-- https://aclanthology.org/T78-1019/ -->
+      <title>Intentlonallty and Human Conversations</title>
+      <author id="jaime-g-carbonell"><first>Jaime G.</first><last>Carbonell Jr</last></author>
+      <pdf hash="c50fc619"/>
+      <bibkey>carbonell-jr-1978-intentlonallty-human</bibkey>
+    </paper>
+    <paper id="20">
+      <!-- https://aclanthology.org/T78-1020/ -->
+      <title>On the Interdependence of Language and Perception</title>
+      <author id="david-l-waltz"><first>David L.</first><last>Waltz</last></author>
+      <pdf hash="3c708191"/>
+      <bibkey>waltz-1978-interdependence-language</bibkey>
+    </paper>
+    <paper id="21">
+      <!-- https://aclanthology.org/T78-1021/ -->
+      <title>The Problem of Naming Shapes: Vision-Language Interface</title>
+      <author id="ruzena-bajcsy"><first>R.</first><last>Bajcsy</last></author>
+      <author id="aravind-joshi"><first>A. K.</first><last>Joshi</last></author>
+      <pdf hash="50331b4e"/>
+      <bibkey>bajcsy-joshi-1978-problem-naming</bibkey>
+    </paper>
+    <paper id="22">
+      <!-- https://aclanthology.org/T78-1022/ -->
+      <title>An Argument about the Composition of Conceptual Structure</title>
+      <author><first>Ray</first><last>Jackendoff</last></author>
+      <pdf hash="57d001f8"/>
+      <bibkey>jackendoff-1978-argument-composition</bibkey>
+    </paper>
+    <paper id="23">
+      <!-- https://aclanthology.org/T78-1023/ -->
+      <title>On the Ontological Status of Visual Mental Images</title>
+      <author><first>Stephen Michael</first><last>Kosslyn</last></author>
+      <pdf hash="fd06e265"/>
+      <bibkey>kosslyn-1978-ontological-status</bibkey>
+    </paper>
+    <paper id="24">
+      <!-- https://aclanthology.org/T78-1024/ -->
+      <title>What has language to do with perception? Some speculations on the <i>Lingua Mentis</i></title>
+      <author><first>Zenon W.</first><last>Pylyshyn</last></author>
+      <pdf hash="a2f3a044"/>
+      <bibkey>pylyshyn-1978-language-perception</bibkey>
+    </paper>
+    <paper id="25">
+      <!-- https://aclanthology.org/T78-1025/ -->
+      <title>Semantic Primitives in Language and Vision</title>
+      <author id="yorick-wilks"><first>Yorick</first><last>Wilks</last></author>
+      <pdf hash="b4e13896"/>
+      <bibkey>wilks-1978-semantic-primitives</bibkey>
+    </paper>
+    <paper id="26">
+      <!-- https://aclanthology.org/T78-1026/ -->
+      <title>A Note on Partial Match of Descriptions. Can One Simultaneously Question (Retrieve) and Inform (Update)?</title>
+      <author id="aravind-joshi"><first>Aravind K.</first><last>Joshi</last></author>
+      <pdf hash="74969243"/>
+      <bibkey>joshi-1978-note-partial</bibkey>
+    </paper>
+    <paper id="27">
+      <!-- https://aclanthology.org/T78-1027/ -->
+      <title>With a Spoon in Hand This Must Be the Eating Frame</title>
+      <author><first>Eugene</first><last>Charniak</last></author>
+      <pdf hash="f1be68bb"/>
+      <bibkey>charniak-1978-spoon-hand</bibkey>
+    </paper>
+    <paper id="28">
+      <!-- https://aclanthology.org/T78-1028/ -->
+      <title>Fragments of a Theory of Human Plausible Reasoning</title>
+      <author><first>Allan</first><last>Collins</last></author>
+      <pdf hash="67b4bca2"/>
+      <bibkey>collins-1978-fragments-theory</bibkey>
+    </paper>
+    <paper id="29">
+      <!-- https://aclanthology.org/T78-1029/ -->
+      <title>Indirect Responses to Loaded Questions</title>
+      <author><first>S. Jerrold</first><last>Kaplan</last></author>
+      <pdf hash="135037f9"/>
+      <bibkey>kaplan-1978-indirect-responses</bibkey>
+    </paper>
+    <paper id="30">
+      <!-- https://aclanthology.org/T78-1030/ -->
+      <title>On Reasoning by Default</title>
+      <author><first>Raymond</first><last>Reiter</last></author>
+      <pdf hash="0de53d33"/>
+      <bibkey>reiter-1978-reasoning-default</bibkey>
+    </paper>
+    <paper id="31">
+      <!-- https://aclanthology.org/T78-1031/ -->
+      <title>Path-Based and Node-Based Inference in Semantic Networks</title>
+      <author id="stuart-c-shapiro"><first>Stuart C.</first><last>Shapiro</last></author>
+      <pdf hash="2ddc5535"/>
+      <bibkey>shapiro-1978-path-based</bibkey>
+    </paper>
+    <paper id="32">
+      <!-- https://aclanthology.org/T78-1032/ -->
+      <title>The Representation of Derivable Information in Memory: When What Might Have Been Left Unsaid Is Said</title>
+      <author><first>Rand J.</first><last>Spiro</last></author>
+      <author><first>Joseph</first><last>Esposito</last></author>
+      <author><first>Richard J.</first><last>Vondruska</last></author>
+      <pdf hash="7758fb45"/>
+      <bibkey>spiro-etal-1978-representation-derivable</bibkey>
+    </paper>
+    <paper id="33">
+      <!-- https://aclanthology.org/T78-1033/ -->
+      <title>A Heuristic for Paradigms</title>
+      <author><first>Joseph E.</first><last>Grimes</last></author>
+      <pdf hash="53b42c16"/>
+      <bibkey>grimes-1978-heuristic-paradigms</bibkey>
+    </paper>
+    <paper id="34">
+      <!-- https://aclanthology.org/T78-1034/ -->
+      <title>A Computational Account of Some Constraints on Language</title>
+      <author id="mitch-marcus"><first>Mitchell</first><last>Marcus</last></author>
+      <pdf hash="c9724c43"/>
+      <bibkey>marcus-1978-computational-account</bibkey>
+    </paper>
+    <paper id="35">
+      <!-- https://aclanthology.org/T78-1035/ -->
+      <title>Remarks on Processing, Constraints, and the Lexicon</title>
+      <author id="thomas-wasow"><first>Thomas</first><last>Wasow</last></author>
+      <pdf hash="8beed275"/>
+      <bibkey>wasow-1978-remarks-processing</bibkey>
+    </paper>
+    <paper id="36">
+      <!-- https://aclanthology.org/T78-1036/ -->
+      <title>List of questions suggested for consideration in each session</title>
+      <pdf hash="1950b908"/>
+      <bibkey>nn-1978-list-questions</bibkey>
+    </paper>
+  </volume>
+</collection>

tests/test_acl_historical.py

@@ -0,0 +1,114 @@
+"""Pinned T78 evidence, edition-local aliases and an explicitly identified material."""
+import copy
+import hashlib
+import json
+from pathlib import Path
+import sqlite3
+import tempfile
+import unittest
+import xml.etree.ElementTree as ET
+
+from paper_atlas.collectors.acl import collect_xml, volume_scope
+from paper_atlas.collectors.acl_historical import event_scope, material_reason
+from paper_atlas.db.store import Store
+from paper_atlas.ingestion.records import ingest_file
+
+FIXTURE = Path(__file__).parent/'fixtures/acl-t78.xml'
+COMMIT = 'a7be623d01c48c61405dec31c871121cdbed5a01'
+
+
+class AclHistoricalTests(unittest.TestCase):
+    def setUp(self):
+        self.root = ET.parse(FIXTURE).getroot()
+        self.volume = self.root.find('volume')
+        self.meta = self.volume.find('meta')
+
+    def test_frozen_volume_matches_official_snapshot(self):
+        self.assertEqual(hashlib.sha256(FIXTURE.read_bytes()).hexdigest(), 'f712f94cff0cba05f786b7ac31dad2ea9408fde2a17a04531130df623f57dd84')
+        self.assertEqual(len(self.volume.findall('paper')), 36)
+        self.assertEqual(volume_scope(self.meta, '1', 'T78'), ('ACL+TINLAP', ['ACL', 'TINLAP'], 'proceedings_unspecified'))
+
+    def test_unknown_year_collection_or_volume_is_not_globally_aliased(self):
+        for collection, volume in [('T75', '1'), ('T87', '1'), ('T78', '2'), ('C65', '1')]:
+            with self.subTest(collection=collection, volume=volume):
+                self.assertIsNone(event_scope(self.meta, volume, collection))
+                self.assertIsNone(volume_scope(self.meta, volume, collection))
+        self.assertIsNone(volume_scope(self.meta, '1'))
+
+    def test_known_volume_scope_rejects_critical_metadata_drift(self):
+        for field, replacement in [('venue', 'acl'), ('year', '1979'), ('booktitle', 'Another TINLAP'), ('editor/first', 'Another')]:
+            changed = copy.deepcopy(self.meta)
+            changed.find(field).text = replacement
+            with self.subTest(field=field), self.assertRaises(ValueError):
+                event_scope(changed, '1', 'T78')
+        changed = copy.deepcopy(self.meta)
+        ET.SubElement(changed, 'year').text = '1978'
+        with self.assertRaises(ValueError):
+            event_scope(changed, '1', 'T78')
+
+    def test_evidence_retains_original_series_dates_and_role_boundary(self):
+        scope = event_scope(self.meta, '1', 'T78')
+        self.assertEqual(scope['original_venue'], 'TINLAP')
+        self.assertEqual(scope['event_dates'], ['1978-07-25', '1978-07-27'])
+        self.assertEqual([e['pdf_pages'] for e in scope['evidence']], [[9, 10], [3]])
+        self.assertIn('not identified', scope['track_scope_note'])
+        self.assertIn('pending', scope['evidence'][0]['scope'])
+
+    def test_only_exact_session_questions_material_is_excluded(self):
+        paper = copy.deepcopy(self.volume.findall('paper')[-1])
+        self.assertIn('Session question list', material_reason('T78', '1', paper))
+        self.assertIsNone(material_reason('C65', '1', paper))
+        self.assertIsNone(material_reason('T78', '2', paper))
+        paper.set('id', '37')
+        self.assertIsNone(material_reason('T78', '1', paper))
+        paper.set('id', '36')
+        ET.SubElement(paper, 'author')
+        with self.assertRaises(ValueError):
+            material_reason('T78', '1', paper)
+
+    def test_all_authored_source_fields_and_material_receipt_survive_collection(self):
+        with tempfile.TemporaryDirectory() as temporary:
+            manifest, = collect_xml(FIXTURE, temporary, COMMIT)
+            rows = [json.loads(raw) for raw in Path(manifest['file']).read_text().splitlines()]
+        self.assertEqual(manifest['count'], 35)
+        self.assertEqual(manifest['xml_paper_elements'], 36)
+        self.assertEqual(manifest['missing_abstract_count'], 35)
+        self.assertEqual(manifest['excluded_materials'][0]['external_id'], 'T78-1036')
+        for number, row in enumerate(rows, 1):
+            paper = self.volume.findall('paper')[number-1]
+            self.assertEqual(row['external_id'], f'T78-1{number:03d}')
+            self.assertEqual(row['title'], ' '.join(''.join(paper.find('title').itertext()).split()))
+            self.assertEqual(row['metadata']['venue_codes'], ['tinlap'])
+            self.assertEqual(row['metadata']['historical_event_scope']['original_venue'], 'TINLAP')
+            self.assertEqual(row['metadata']['metadata_commit'], COMMIT)
+            self.assertEqual((row['status'], row['track'], row['abstract']), ('accepted', 'proceedings_unspecified', None))
+
+    def test_old_coling_scope_is_unchanged_by_calendar_replacement_evidence(self):
+        meta = ET.fromstring('<meta><venue>coling</venue><year>1965</year><booktitle>COLING 1965</booktitle></meta>')
+        self.assertEqual(volume_scope(meta, '1', 'C65'), ('COLING', ['COLING'], 'main'))
+        self.assertIsNone(event_scope(meta, '1', 'C65'))
+
+    def test_native_ingestion_does_not_alias_other_tinlap_years_or_infer_negative_status(self):
+        with tempfile.TemporaryDirectory() as temporary:
+            root = Path(temporary)
+            manifest, = collect_xml(FIXTURE, root/'source', COMMIT)
+            db = root/'sample.sqlite'
+            store = Store(db)
+            pid, rid = store.record('test_control', 'tinlap1975', 'https://example.org/tinlap1975',
+                                    'An earlier TINLAP contribution', None, ['Jane Doe'])
+            store.decision(pid, rid, 'TINLAP', 1975, 'main', 'tinlap1975', 'https://example.org/tinlap1975', 'accepted', 'test control')
+            store.conn.commit()
+            store.conn.close()
+            ingest_file(db, manifest['file'])
+            ingest_file(db, manifest['file'])
+            with sqlite3.connect(db) as c:
+                self.assertEqual(c.execute('SELECT count(*) FROM papers').fetchone()[0], 36)
+                self.assertEqual(c.execute('SELECT count(*) FROM submissions').fetchone()[0], 36)
+                self.assertEqual(c.execute('SELECT count(*) FROM decisions').fetchone()[0], 36)
+                self.assertEqual(c.execute("SELECT count(*) FROM decisions WHERE status!='accepted'").fetchone()[0], 0)
+                self.assertIsNone(c.execute("SELECT 1 FROM source_records WHERE external_id='T78-1036'").fetchone())
+                aliases = c.execute('SELECT v.acronym,a.alias FROM venue_aliases a JOIN venues v ON v.id=a.venue_id ORDER BY a.alias').fetchall()
+                self.assertEqual(aliases, [('ACL+TINLAP', 'ACL'), ('ACL+TINLAP', 'TINLAP')])
+                metadata = json.loads(c.execute("SELECT metadata_json FROM source_records WHERE external_id='T78-1001'").fetchone()[0])
+                self.assertEqual(metadata['historical_event_scope']['event_year'], 1978)
+                self.assertEqual(c.execute('PRAGMA foreign_key_check').fetchall(), [])

tests/test_springer_selected.py

@@ -0,0 +1,160 @@
+"""Real 49-chapter snapshots compared with a separately frozen metadata audit."""
+import copy
+import gzip
+import hashlib
+import json
+from pathlib import Path
+import sqlite3
+import tempfile
+import unittest
+
+from paper_atlas.collectors.springer_selected import (
+    BOOK, SOURCE, collect, parse_chapter, parse_toc, read_page, snapshot_index,
+)
+from paper_atlas.db.store import Store
+from paper_atlas.ingestion.records import ingest_file
+
+FIXTURE = Path(__file__).parent/'fixtures/springer-aistats1993-fixture.json.gz'
+
+
+class SpringerSelectedTests(unittest.TestCase):
+    @classmethod
+    def setUpClass(cls):
+        raw = FIXTURE.read_bytes()
+        if hashlib.sha256(raw).hexdigest() != '94028fd37080f9d8027e5790e379cc151ee6eab17ed0d1dcc0f59e6e75f9d4d0':
+            raise AssertionError('Fixed source fixture differs')
+        cls.fixture = json.loads(gzip.decompress(raw))
+
+    def snapshots(self, root):
+        for group in ['toc','chapters']:
+            folder = root/group
+            folder.mkdir()
+            for name, text in self.fixture[group].items():
+                (folder/name).write_text(text)
+        return {'toc_snapshots':root/'toc','chapter_snapshots':root/'chapters'}
+
+    def test_all49_original_fields_against_independent_audit(self):
+        with tempfile.TemporaryDirectory() as tmp:
+            root = Path(tmp)
+            report = collect(root/'out', **self.snapshots(root))
+            manifest, = report['files']
+            rows = [json.loads(s) for s in Path(manifest['file']).read_text().splitlines()]
+            self.assertEqual(len(rows), 49)
+            self.assertEqual(manifest['status'], 'partial')
+            self.assertEqual(manifest['missing_abstract_count'], 0)
+            self.assertTrue(manifest['excluded_materials'])
+            self.assertTrue(all(x['title'] == 'Front Matter' for x in manifest['excluded_materials']))
+            for row, expected in zip(rows, self.fixture['expected']):
+                for field in ['title','abstract']:
+                    self.assertEqual(row[field], expected[field])
+                self.assertEqual(row['identifiers'], {'doi':expected['doi']})
+                self.assertEqual(row['submission_identifiers'], [{'scheme':'publication_doi','value':expected['doi']}])
+                self.assertEqual(row['external_id'], expected['doi'])
+                self.assertEqual(row['metadata']['authors_citation_raw'], expected['authors_citation_raw'])
+                self.assertEqual(row['authors'], [{'family':s.split(',',1)[0].strip(), 'given':s.split(',',1)[1].strip()} for s in expected['authors_citation_raw']])
+                self.assertEqual(row['metadata']['first_page'], expected['first_page'])
+                self.assertEqual(row['metadata']['last_page'], expected['last_page'])
+                self.assertEqual((row['year'],row['metadata']['bibliographic_year']), (1993,1994))
+                self.assertEqual(row['track'], 'selected_volume')
+                self.assertEqual(row['event_key'], 'aistats-1993-selected-volume-1994')
+                self.assertNotIn('decision_date', row)
+                self.assertIn('original 1993 review decision not supplied', row['raw_decision'])
+                for e in [row['metadata']['source_evidence'], *row['metadata']['scope_evidence']]:
+                    self.assertEqual(hashlib.sha256((root/'out'/e['file']).read_bytes()).hexdigest(), e['sha256'])
+            self.assertFalse(report['database_written'])
+            with self.assertRaises(FileExistsError):
+                collect(root/'out', toc_snapshots=root/'toc', chapter_snapshots=root/'chapters')
+
+    def test_native_history_namespaces_and_idempotent_import(self):
+        with tempfile.TemporaryDirectory() as tmp:
+            root = Path(tmp)
+            report = collect(root/'out', **self.snapshots(root))
+            manifest, = report['files']
+            first = json.loads(Path(manifest['file']).read_text().splitlines()[0])
+            db = root/'sample.sqlite'
+            store = Store(db)
+            pid, rid = store.record('prior_public','earlier','https://example.org/earlier',first['title'],first['abstract'],first['authors'])
+            store.decision(pid,rid,'AISTATS',1993,'main','earlier','https://example.org/earlier','rejected','original public rejection')
+            # Explicitly verified work identity; the short title alone must not
+            # force a merge or attach this publication DOI to the old attempt.
+            store.conn.execute('INSERT INTO identifiers VALUES(?,?,?)', ('doi',first['identifiers']['doi'],pid))
+            store.conn.commit()
+            old = store.conn.execute('SELECT * FROM decisions').fetchall()
+            store.conn.close()
+            ingest_file(db, manifest['file'])
+            ingest_file(db, manifest['file'])
+            with sqlite3.connect(db) as c:
+                self.assertEqual(c.execute('SELECT * FROM decisions WHERE status=\'rejected\'').fetchall(), [tuple(r) for r in old])
+                self.assertEqual(c.execute('SELECT count(*) FROM papers').fetchone()[0], 49)
+                self.assertEqual(c.execute('SELECT count(*) FROM submissions').fetchone()[0], 50)
+                self.assertEqual(c.execute('SELECT count(*) FROM decisions').fetchone()[0], 50)
+                self.assertEqual(c.execute('SELECT e.year,e.track,e.event_key FROM editions e ORDER BY e.id').fetchall(), [(1993,'main',''),(1993,'selected_volume','aistats-1993-selected-volume-1994')])
+                self.assertEqual(c.execute('SELECT count(*) FROM paper_tags pt JOIN tags t ON t.id=pt.tag_id WHERE t.namespace=?', (SOURCE+':publication_format',)).fetchone()[0], 49)
+                self.assertEqual(c.execute('SELECT count(*) FROM submission_identifiers WHERE scheme=\'publication_doi\'').fetchone()[0], 49)
+                self.assertIsNone(c.execute("SELECT 1 FROM submission_identifiers si JOIN submissions s ON s.id=si.submission_id JOIN editions e ON e.id=s.edition_id WHERE e.track='main'").fetchone())
+
+    def test_short_unanchored_title_keeps_identity_unconfirmed(self):
+        with tempfile.TemporaryDirectory() as tmp:
+            store = Store(Path(tmp)/'identity.sqlite')
+            title = 'Statistical strategy: step 1'
+            authors = [{'given':'D. J.','family':'Hand'}]
+            old, _ = store.record('prior_public','earlier','https://example.org/old',title,'Same abstract',authors)
+            new, _ = store.record(SOURCE,BOOK+'_1','https://link.springer.com/chapter/'+BOOK+'_1',title,'Same abstract',authors,{'doi':BOOK+'_1'})
+            self.assertNotEqual(old, new)
+            self.assertEqual(store.conn.execute('SELECT count(*) FROM match_candidates WHERE method=\'exact_title_unconfirmed\'').fetchone()[0], 1)
+            store.conn.close()
+
+    def test_receipt_hash_path_redirect_and_content_type_guards(self):
+        with tempfile.TemporaryDirectory() as tmp:
+            root = Path(tmp)
+            self.snapshots(root)
+            index = snapshot_index(root/'chapters')
+            url = 'https://link.springer.com/chapter/'+BOOK+'_1'
+            self.assertTrue(read_page(index,url)[0])
+            for key, value in [('sha256','0'*64),('file','../escape.html'),('final_url','https://example.org/chapter'),('http_status',403),('headers',{'Content-Type':'application/pdf'})]:
+                changed = copy.deepcopy(index)
+                changed[url][1][key] = value
+                with self.subTest(key=key), self.assertRaises((ValueError,KeyError)):
+                    read_page(changed,url)
+            changed = copy.deepcopy(index)
+            changed[url][1]['final_url'] = url+'?page=2'
+            with self.assertRaises(ValueError):
+                read_page(changed,url)
+
+    def test_missing_or_duplicate_snapshot_stops_collection(self):
+        with tempfile.TemporaryDirectory() as tmp:
+            root = Path(tmp)
+            args = self.snapshots(root)
+            path = root/'chapters/receipts.json'
+            d = json.loads(path.read_bytes())
+            original = copy.deepcopy(d)
+            d['responses'].pop()
+            path.write_text(json.dumps(d))
+            with self.assertRaises(ValueError):
+                collect(root/'out', **args)
+            self.assertFalse((root/'out').exists())
+            original['responses'].append(original['responses'][0])
+            path.write_text(json.dumps(original))
+            with self.assertRaises(ValueError):
+                snapshot_index(root/'chapters')
+
+    def test_book_doi_year_and_duplicate_citation_fields_reject_drift(self):
+        html = self.fixture['chapters']['chapter-01.html']
+        for key, value in [('citation_doi',BOOK+'_2'),('citation_inbook_title','Another Book'),('citation_publication_date','1993')]:
+            import re
+            changed, count = re.subn(r'(<meta[^>]*name="'+key+r'"[^>]*content=")[^"]*', lambda m:m[1]+value, html)
+            self.assertEqual(count, 1)
+            with self.subTest(key=key), self.assertRaises(ValueError):
+                parse_chapter(changed, BOOK+'_1')
+        with self.assertRaises(ValueError):
+            parse_chapter(html+'<meta name="citation_doi" content="'+BOOK+'_1">', BOOK+'_1')
+
+    def test_missing_abstract_is_explicit_and_does_not_use_other_page_text(self):
+        html = self.fixture['chapters']['chapter-01.html'].replace('id="Abs1-content"','id="not-an-abstract"')
+        self.assertIsNone(parse_chapter(html, BOOK+'_1')['abstract'])
+
+    def test_toc_ignores_frontmatter_but_rejects_duplicate_publications(self):
+        html = self.fixture['toc']['springer-toc1.html']
+        self.assertEqual(len(parse_toc(html)), 17)
+        with self.assertRaises(ValueError):
+            parse_toc(html+html)