ija vSrSSKJr SSKrSSKrSSKrSSKrSSKJrJrJ r SSK J r S Sjr S Sjr S S Sjjrg) uНакопление истории просмотров постов личного канала. TGStat отдаёт только текущие цифры, а архив в волте перезаписывается — «сколько пост набрал в первые сутки» нигде не хранится и задним числом не восстановимо. Этот модуль — единственный механизм, который копит такую историю: ежедневный снапшот просмотров/пересылок по свежим постам в JSONL-лог, который растёт только вперёд. ) annotationsN)datedatetime timedelta)PathcUSnURS5(aUSSS-n[R"U5R5$)N posted_atZz+00:00)endswithr fromisoformatr)postr s %/home/rasp/tgstat-puller/snapshots.py _posted_datersG[!I#crNX-  ! !) , 1 1 33c0n/nUH:nUSUS4nXA;a/X'URU5 XRU5 M< /nUHnXn[USS9n[U5n[U5S:a*[ SU55US'[ SU55US '[ [U5[ S U555US 'URU5 M U$) uСхлопнуть альбом в одну строку на пост. Телеграм отдаёт альбом (медиагруппу) несколькими сообщениями с разными `msg_id` и одной и той же секундой публикации, и TGStat считает просмотры по каждому. В снапшотах это давало 3–5 почти одинаковых строк на один пост: 2037–2041 от 2026-07-28 с `posted_at` до секунды одинаковым и просмотрами 361/373/373/381/381. Пока сравнения по темпу набора нет, это просто шум; как только оно заработает, один пост весил бы как пять и перекосил бы и медиану темпа, и любой порог по рубрике. Группируем по (`snapshot_date`, `posted_at`): двум разным постам совпасть до секунды практически невозможно, а у альбома совпадение гарантировано. Представитель группы — минимальный `msg_id`: это голова альбома, на неё указывает ссылка на пост, по ней он и опознаётся в архиве. Просмотры и пересылки берём максимальные по группе — ближайшая снизу оценка охвата поста целиком (человек, посмотревший любой слайд, посмотрел пост). `album_size` оставляем в строке: иначе схлопывание — молчаливая правка данных, а его видно в git-диффе и понятно тому, кто читает файл. Применяется к уже слитому набору строк, а не только к свежим, — поэтому чинит и то, что записано в файл раньше. snapshot_dater c US$)Nmsg_idrs r"_collapse_albums..=s( rkeyc3T# UHoRS5=(d Sv M g7f)viewsrNget.0rs r #_collapse_albums..@s!GA55>#6Q#6&(rc3T# UHoRS5=(d Sv M g7f)forwardsrNr r"s rr$r%As$Mu!eeJ&7&<1&!!G!GGF7O!$$Mu$M!MF:  # JFFF | 6 Jrc &[U5n[R"U5[US9- nUVs/sHn[ U5U:dMUPM nn0nUR 5(aj[ URSS9R5SS9HAupU R5(dM[R"U 5n U SU S4n XU 'MC UH8n U SU4n U SU SUU R#S5U R#S5S.X{'M: [%UR'5SS9n[)U5nUR*R-SSS9 [.R0"[3UR*5SSS9unn[4R6"USSS9nUH*n UR9[R:"U SS9S-5 M, S S S 5 [4R<"U[3U55 [CUVs1sHoUSiM sn5$s snf![R[4a.n [SUS US U S 3[R S 9 S n A GMS n A ff=f!,(df  N=f![>a [U5RASS9 ef=fs snf)uДописать в `path` снапшот просмотров по постам не старше `window_days`. Повторный вызов в тот же `today` обновляет строку `msg_id`+`snapshot_date`, а не дублирует её. Файл — единственная копия истории, поэтому он читается целиком, дополняется и перезаписывается атомарно (временный файл рядом + `os.replace`), а не дописывается построчно. Строки альбома (несколько `msg_id` с одной секундой публикации) схлопываются в одну — см. `_collapse_albums`. Возвращает число постов, отобранных в этом прогоне (попавших в окно, после схлопывания альбомов), а не итоговый размер файла. )dayszutf-8)encodingr)startrru#snapshots: битая строка u в u пропущена (u7); остальная история сохранена)fileNr rr()rr rrr(cUSUS4$)Nrrrrs rrwrite_rows..sAo4F( 3TrrT)parentsexist_okz .snapshots-z.tmp)dirprefixsuffixwF) ensure_ascii ) missing_ok)"rrr rrexists enumerate read_text splitlinesstripjsonloadsJSONDecodeErrorKeyErrorprintsysstderrr!sortedvaluesr8parentmkdirtempfilemkstempstrosfdopenwritedumpsreplace Exceptionunlinkr.)pathpoststoday window_dayscutoffpfreshexistinglinenoliner3rerr0fdtmpfhs r write_rowsrqLse :D    & )D DF ;1aF!:QE ;,.H {{}}%dnngn&F&Q&Q&S[\]LF::<< jj&8}c/&:; SM'^*H~u%8nk*"XXg&,    (//#)T UD D !DKKdT23t{{#3MRXYGB YYr3 1RCerys5# ..4/dE0r