Obsidian Sync — разбор кода (2026-06-21)

1. Локальный слой: мёртвый mtime/hash-кэш

classify.ts:91-109 читает кэш и пропускает хэширование, если mtime не изменился:

const cachedMtimes = syncState.mtimes || {};
const cachedLocalHashes = syncState.localHashes || {};
...
if (cachedMtime === file.mtime && cachedHash) {
  localHashes.set(file.path, cachedHash);
} else {
  const content = await env.readFileContent(file.path);
  const hash = await env.computeHash(content);   // ← всегда сюда
}

Но запись в .mtimes/.localHashes не существует нигде в продакшене — grep по src/ находит только эти два чтения, объявления типов (src/types.ts:34,36, src/sync/types.ts:39,40) и фикстуры тестов. executePlan/saveSyncState пишут только syncState.files[...] (execute.ts:269). Значит cachedMtime/cachedHash всегда undefined, if всегда ложь, и else-ветка читает+хэширует каждый файл, каждый sync, последовательно (await внутри for).

Это и есть боль №1: и при ручном sync, и при фоновом обновлении badge (main.ts:317).

2. Сетевой слой: full-vault payloads даже при no-op

• env.fetchNoteAssets(paths) игнорирует paths: делает PushNotes({ updates: [] }), что на сервере возвращает ассеты ВСЕХ заметок (pushnotes/resolve.go:53-58 → buildPushedNotes по nvs.List + все layouts), и фильтрует клиентски (env.ts:255-282). Вызывается до 3× за sync (execute.ts:60,72,126) — самый тяжёлый payload.
• Восстановление ассетов (execute.ts:120-129) строит unchangedPaths из всех unchanged && remoteHash !== null и безусловно зовёт uploadMissingAssetsForNotes — то есть на любом синхронизированном вотлте проходит все 2000 заметок.
• Badge-poll тянет полный FetchServerHashes (~180 кБ на 2000 строк) каждые 60с и на каждый focus, на syncDir (main.ts:134-143 → classify.ts:80-83 → env.ts:102-110). На сервере нет since/incremental-фильтра (NotePathsFilter — только like/search/paths, schema.graphqls:1408-1424).
• При старте — ещё два full-table запроса: FetchPublishedUrls (main.ts:146,200-220) и (по кнопке) FetchAllWarnings.

Важно: сам latestContentHash дешёвый — это сохранённая колонка, не пересчитывается per-request (generated.go:30044, IsResolver:false; пишется один раз в insertnote/resolve.go:34,43,79). Страх «82 кБ × 3 пересчёт хэша» из плана не подтверждается — стоит только payload и частота.

3. Серверный слой: полный reload на каждый push

PushNotes зовёт PrepareLatestNotes независимо от числа изменений (pushnotes/resolve.go:83). PrepareLatestNotes → latestNoteLoader.Load перечитывает всё: RawNotes (full content+embedding всех строк, loader.go:147), RawAssets (:152), loadChunks (:324), generateSitemap (:331). NoteCache экономит парсинг, но DB-чтения, карта ассетов, sitemap и search-hash-цикл — безусловны. Плагин шлёт батчами по 100 (execute.ts:252-257), поэтому 2000 заметок = ~20 reload + 1 commit reload.

Таблица: проблема → причина → фикс → effort

Что уже готово (backend, не трогать)

Подписка noteChanges реализована end-to-end и богаче плана:

• internal/notebus/notebus.go — Bus с glob-фильтрацией на подписчика и drop-on-full-buffer, 7 unit-тестов.
• Union NoteChangeItem = NoteUpsertEvent | NoteHideEvent (schema.graphqls:1954-1981); событие несёт versionId, title, noteView, changedHtmlSelectors.
• Резолвер schema.resolvers.go:3231-3272 (gate по API-ключу), buildNoteChangeItems (note_changes.go:8-35).
• Publish из HandleLatestNotesAfterSave (main.go:1286-1302) и hidenotes/resolve.go:73-83; updateNotes покрыт транзитивно.

Чего не хватает в плагине

Плагина-потребителя нет вообще: grep по EventSource|noteChanges|getReader|text/event-stream|lastSyncedVersion|autoPull в obsidian-sync/src — пусто. Сгенерированный graphql.ts:2995-2997 знает только тестовый currentTime, в operations.graphql нет ни одной подписки. SyncState — только хэши (sync/types.ts:35-41). Смена контента — только через 60с-poll или ручной sync.

Минимальный путь включить (реюз 100% backend)

1. Добавить subscription NoteChanges в operations.graphql, перегенерировать SDK.
2. Маленький pure-JS SSE-клиент (obsidian-sync/src/sync/livepull.ts): POST на graphql с Accept: text/event-stream + X-Api-Key, getReader()-цикл, reconnect с backoff (graphql-request стримить не умеет).
3. На каждый NoteUpsertEvent брать только path и тянуть его через существующий FetchNoteContents({filter:{paths}}) + FetchNoteAssets({filter:{paths}}), прогонять существующий classifyFile, auto-pull только безопасных (localHash === lastSyncedHash), конфликты — в badge.
4. Когда SSE подключён — отключить 60с-poll (оставить как fallback при разрыве). Это убирает большинство FetchServerHashes, потому что badge/auto-pull реагируют на события, а не диффят 2000 хэшей.

Важно для надёжности live-pull (две серверные правки):

• При skip_webhooks=true (нормальный режим sync) HandleLatestNotesAfterSave возвращается ДО PublishNoteChanges (main.go:1274-1276 vs 1311-1312) — подписчики не узнают о пушах своего же издателя. Поднять конструкцию busBatch+publish выше гейта skipWebhooks.
• updateNotes hide-only батч не публикует remove (updatenotes/resolve.go:97-130) — добавить PublishNoteChanges по аналогии с hidenotes.

Delta-sync для cold-start/reconnect

Plan предлагает новую таблицу sync_version + колонку last_changed_version — это лишнее. Глобальная монотонная последовательность уже есть: note_versions.id integer primary key autoincrement (migration 20250515071315), и она уже отдаётся как NoteUpsertEvent.versionId (note_changes.go:20). Достаточно notePathsDelta(sinceVersion: Int64!) (или changedSinceVersion в NotePathsFilter), который выбирает note_paths с max(note_versions.id) > sinceVersion + скрытые, и возвращает currentVersion = max(id). Без новой таблицы, колонки и миграции.

Быстрые победы (small/trivial, высокий impact)

1. Оживить mtime/hash-кэш — classify.ts:91-109 + saveSyncState. Убирает почти весь локальный re-hash на idle. Чинит сразу все три фронтенда. (perf #1)
2. skipCommit:true в CLI/browser — cli/env.ts:404-411, browser/index.ts:574-581. Один полный reload вместо N. (trivial)
3. Publish выше гейта skipWebhooks — main.go:1274-1276. Без этого live-pull не заработает вообще. (trivial)
4. Re-entrancy guard в checkForPendingChanges — main.ts:272-275. Убирает удвоение нагрузки на slow path. (trivial)
5. Починить browser latestContent → content — browser/index.ts:479. (trivial)
6. Гонка notebus — notebus.go:85-104: не закрывать канал / держать RLock на fan-out. Критично перед включением live-pull. (small)
7. publish:false → hide — filter.ts:72-78. Приватность. (small)
8. Lazy старт-запросы — main.ts:146,200-220: не тянуть FetchPublishedUrls/FetchAllWarnings по всему вотлту. (small)

Крупнее (medium/large, фундамент)

9. Live-pull клиент — новый livepull.ts + operations.graphql + codegen + wiring в main.ts. Реюз 100% backend. Снимает большинство FetchServerHashes и даёт реальные live-обновления. (medium, наивысший impact для цели №2)
10. fetchNoteAssets на FetchNoteAssets({filter:{paths}}) — env.ts:255-282 и оба клона. Убирает самый тяжёлый payload. (medium)
11. Восстановление ассетов только по changed — execute.ts:120-129. (small, но завязано на #1)
12. Delta-sync на note_versions.id — notePathsDelta(sinceVersion), без новой таблицы/миграции. Для cold-start/reconnect/manual. (medium)
13. Инкрементальный reload на push — pushnotes/resolve.go:83, loader.go. Самый дорогой, но снимает «21 reload на sync». (large)
14. Лок только вокруг записи / RWMutex + materialize только на receive-pack — schema.resolvers.go:2628-2631, gitapi/api.go:279-281. (medium)
15. Per-change auth подписки — schema.resolvers.go:3231-3242. Перед публичным использованием live-pull. (medium)
16. Indexed GetByPathID + batch NotePathByID — note.go:1295-1303, main.go:1279-1295. (small каждое)

DRY-рефактор (когда дойдут руки)

17. Общий RemoteApi + единые hasPublishFieldInContent/isSyncableNote/withRetry в sync/utils.ts — закрывает целый класс drift-багов (#latestContent, retry, расширения, publish-field). (medium)