avandClaude Fable 5
37f2f6481a
Все сущности переехали с INTEGER AUTOINCREMENT на TEXT ULID (lowercase, internal/ident — единая точка генерации и разбора; oklog/ulid). Инфохэши загрузки — множество (download_infohash, v1/v2 гибридных торрентов): дедуп и сопоставление в поллинге по любому из хешей, magnet-парсер отдаёт оба хеша гибридной ссылки, усечённый v2-хеш v2-only раздач не хранится. Инвариант «не более одной активной загрузки на infohash» вместо снятого unique-индекса держат guarded-методы store в одной write-транзакции (_txlock=immediate): CreateDownloadIfNoActive (приём/adopt, с доносом недостающих хешей), ActivateIfNoOtherActive (retry/recovery/relink, отказ до побочных эффектов), guarded AddInfohashes; SetDownloadState отклоняет терминал→активное как механический бэкстоп. Миграция 0006 — первая Go-миграция goose: пересоздание таблиц при включённых FK, backfill ULID с timestamp из created_at (хронология id сохранена), разнос infohash, удаление idempotency_key. BREAKING: формат id в URL/логах/Telegram, REST-поля id (string) и infohashes (список). Новая конвенция docs/conventions/database.md (без числовых PK), корреляция в логах grep'ом по голому ULID, ER-схема обновлена. Спеки: новая capability identity, MODIFIED в state-reconciliation; change заархивирован. Пройдены ревью дизайна и кода (по 8 углов), все находки исправлены с регрессионными тестами. Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
63 lines
2.2 KiB
Go
63 lines
2.2 KiB
Go
package worker
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"git.vakhrushev.me/av/jellybit/internal/qbt"
|
|
"git.vakhrushev.me/av/jellybit/internal/store"
|
|
)
|
|
|
|
// TestPollBuildsLiveSnapshot: после Poll снимок несёт телеметрию качающейся и
|
|
// сидирующей задач (с верным Seeding), доступную по любому из трёх хэшей;
|
|
// неизвестный/пустой infohash → ok=false.
|
|
func TestPollBuildsLiveSnapshot(t *testing.T) {
|
|
qb := &fakeQbt{torrents: []qbt.Torrent{
|
|
// Качается (Category пуст → discover не усыновляет, store не мешает).
|
|
{Hash: "aaa", State: "downloading", Progress: 0.5, Dlspeed: 1000, Eta: 120},
|
|
// Сидирует, торрент v2 (три ключа).
|
|
{
|
|
Hash: "bbb", InfohashV1: "bbb1", InfohashV2: "BBB2",
|
|
State: "uploading", Progress: 1.0,
|
|
Ratio: 2.5, NumSeeds: 3, NumLeechs: 1, Uploaded: 999, Upspeed: 50,
|
|
},
|
|
}}
|
|
w := newTestWorker(&fakeStore{downloads: map[string]*store.Download{}}, qb)
|
|
|
|
if err := w.Poll(context.Background()); err != nil {
|
|
t.Fatalf("Poll: %v", err)
|
|
}
|
|
|
|
dl, ok := w.Live("aaa")
|
|
if !ok {
|
|
t.Fatal("нет телеметрии качающейся задачи")
|
|
}
|
|
if dl.Seeding {
|
|
t.Error("качающаяся задача помечена Seeding")
|
|
}
|
|
if dl.Progress != 0.5 || dl.DlSpeed != 1000 || dl.ETA != 120 {
|
|
t.Errorf("телеметрия качания неверна: %+v", dl)
|
|
}
|
|
|
|
// Сидирующая задача находится по любому из трёх хэшей (lowercase).
|
|
for _, h := range []string{"bbb", "bbb1", "BBB2", "bbb2"} {
|
|
sd, ok := w.Live(h)
|
|
if !ok {
|
|
t.Fatalf("нет телеметрии раздачи по ключу %q", h)
|
|
}
|
|
if !sd.Seeding {
|
|
t.Errorf("ключ %q: Seeding=false для uploading", h)
|
|
}
|
|
if sd.Ratio != 2.5 || sd.Seeds != 3 || sd.Peers != 1 || sd.Uploaded != 999 || sd.UpSpeed != 50 {
|
|
t.Errorf("ключ %q: статистика раздачи неверна: %+v", h, sd)
|
|
}
|
|
}
|
|
|
|
if _, ok := w.Live("unknownhash"); ok {
|
|
t.Error("неизвестный infohash вернул ok=true")
|
|
}
|
|
if _, ok := w.Live(""); ok {
|
|
t.Error("пустой infohash вернул ok=true")
|
|
}
|
|
}
|