dj! JSrSSKrSSKrSSKJrJrJr SSKJr \"\5R5Rr \ S- r \ S- r \ S- r\ S- rSSS S S S S S SSSSS. rS$SjrSrS$SjrSrSrSrSrS\-rS$SjrSrS$SjrS%SjrSrS$S jrS!rS&S"jr S'S#jr!g)(uRОбщие утилиты feedwatch: .env, конфиг, база, медианы.N)datetime timedeltatimezone)Pathdata feedwatch.dbz config.jsonz.env@ sunz18:00z10:00) instagramtelegrampulse_multipliermedian_window_daysmedian_min_postsmedian_min_age_dayspulse_max_age_daysfetch_limit_pulsefetch_limit_weekly weekly_day weekly_time pulse_timec[U=(d [5n0nUR5(dU$URSS9R 5HnUR 5nU(aUR S5(dSU;aM8URS5up4nUR 5R S5R S5nU(dMXQUR 5'M U$)Nutf-8encoding#="')rENV_PATHexists read_text splitlinesstrip startswith partition)pathenvlinekey_values /home/rasp/feedwatch/common.pyload_envr2s   !D C ;;== 0;;=zz|ts++s$ s+  ##C(..s3 5$ > JcBURS5(ddURS5(dURS5(a8URS5=(d SURS5=(d /S.US'URSS5 URSS5 U$)uПлоский legacy-формат (source/accounts в корне) → секция instagram. Корневые legacy-ключи не удаляем — их никто больше не читает.raccountssourceapify)r6r5Nr)get setdefault)cfgs r1normalize_configr;-s 77;  SWWZ%8%8CGGH?@ C  r3cZ/nURS5=(d 0nURS/5H$nURSUR545 M& URS5=(d 0nURS/5H$nURSUR545 M& U$)uJ[(platform, account), ...] по конфигу, аккаунты в lower.rr5rchannels)r8appendlower)r:outigatgcs r1active_accountsrMAs C   #B VVJ # K+,$   "B VVJ # J *+$ Jr3cJ[R"[R5$N)rnowrutcr3r1now_utcrSMs << %%r3cURSS5nURS5(aUSSS-n[R"U5$)uTISO-таймстамп → aware datetime. Терпит 'Z' и '+0000' (Python 3.9).Zz+00:00z+0000N)replaceendswithr fromisoformat)r0s r1parse_tsrZQsB MM#x (E ~~gcr X%  ! !% ((r3z CREATE TABLE IF NOT EXISTS account_status ( platform TEXT NOT NULL DEFAULT 'instagram', account TEXT NOT NULL, last_ok TEXT, last_error TEXT, subscribers INTEGER, PRIMARY KEY (platform, account) ); a CREATE TABLE IF NOT EXISTS posts ( post_id TEXT PRIMARY KEY, account TEXT NOT NULL, platform TEXT NOT NULL DEFAULT 'instagram', caption TEXT, posted_at TEXT NOT NULL, permalink TEXT NOT NULL ); CREATE TABLE IF NOT EXISTS snapshots ( id INTEGER PRIMARY KEY AUTOINCREMENT, post_id TEXT NOT NULL, fetched_at TEXT NOT NULL, likes INTEGER, comments INTEGER, views INTEGER ); CREATE TABLE IF NOT EXISTS alerted ( post_id TEXT PRIMARY KEY, alerted_at TEXT NOT NULL ); c[U=(d [5nURRSSS9 URS- nURS:Xa;UR 5(d&UR 5(aUR U5 [R"U5n[RUl UR[5 [U5 U$)NT)parentsexist_okz instawatch.dbr)rDB_PATHparentmkdirnamer%renamesqlite3connectRow row_factory executescriptSCHEMA_migrate)db_pathr+legacycons r1rdrd|s "7 #DKKdT2 [[? *F yyN"4;;==V]]__ d //$ CkkCOf SM Jr3cURS5Vs1sHoSiM nnSU;aURS5 URS5Vs1sHoSiM nnSU;aHURS5 UR[5 URS5 URS5 UR5 gs snfs snf) NzPRAGMA table_info(posts)raplatformzGALTER TABLE posts ADD COLUMN platform TEXT NOT NULL DEFAULT 'instagram'z!PRAGMA table_info(account_status)z:ALTER TABLE account_status RENAME TO account_status_legacyzINSERT INTO account_status (platform, account, last_ok, last_error) SELECT 'instagram', account, last_ok, last_error FROM account_status_legacyz DROP TABLE account_status_legacy)executergACCOUNT_STATUS_SCHEMAcommit)rlrcolss r1riris"{{+EF GF!fIFD G ]^"{{+NO PO!fIOD P PQ /0 b c 67JJL H Qs B=Cc p[U[5(d!U=(d [5R5OUnUHhnUR SUSUSUR SS5USUSUS45 UR S USX4S US UR S 545 Mj UR 5 g) NzINSERT INTO posts (post_id, account, platform, caption, posted_at, permalink) VALUES (?,?,?,?,?,?) ON CONFLICT(post_id) DO UPDATE SET caption=excluded.captionpost_idaccountrnrcaption posted_at permalinkzVINSERT INTO snapshots (post_id, fetched_at, likes, comments, views) VALUES (?,?,?,?,?)likescommentsviews) isinstancestrrS isoformatror8rq)rlrecords fetched_atfetchedrrs r1 save_postsrs;EjRU;V;Vz&WY113\fG   Jy\1Y<z;)G9 {^Q{^ -    ! y\7gJ* quuW~ N JJLr3cURSX45R5nUVs/sHn[U5PM sn$s snf)uuПоследний снапшот каждого поста аккаунта, свежие посты первыми.a| SELECT p.post_id, p.account, p.platform, p.caption, p.posted_at, p.permalink, s.likes, s.comments, s.views FROM posts p JOIN snapshots s ON s.post_id = p.post_id WHERE p.account = ? AND p.platform = ? AND s.id = (SELECT MAX(id) FROM snapshots WHERE post_id = p.post_id) ORDER BY p.posted_at DESC )rofetchallr>)rlrvrnrowsrrs r1latest_metricsrsG ;;   hj " "TDGT "" "s>cHURSU45R5SL$)Nz'SELECT 1 FROM alerted WHERE post_id = ?)rofetchone)rlrus r1 was_alertedrs( ;;1G: hj r3cU=(d [5R5nURSUVs/sHoDU4PM sn5 UR5 gs snf)Nz@INSERT OR IGNORE INTO alerted (post_id, alerted_at) VALUES (?,?))rSr executemanyrq)rlpost_idsatstamppids r1 mark_alertedrsI _79 ' ' )EOOJ!)*#u*JJL +s A c[U5n[U5nUS:XagUS-nUS-(a [X5$XS- X-S- $)Nrr r )sortedlenfloat)valuesnmids r1_medianrsS F^F F AAv q&C1uV[!! 7Ofk )S 00r3cpU=(d [5nU[USS9- nU[USS9- n[XUS9Vs/sHn[US5U::dMUPM nnUVs/sHn[US5U:dMUPM n n[ U 5US:aUSUSn U Vs/sHowScM USPM n nU Vs/sHowS cM US PM n nU Vs/sHowS cM US PM n n[ U 5[ U 5[ U 5[ U 5S .$s snfs snfs snfs snfs snf) uwМедианы лайков/комментов/просмотров аккаунта по окну из конфига.r)daysr)rnrxrNrzr{r|)rzr{r|n_posts)rSrrrZrr) rlrvr:rPrnmin_age window_startpsettled in_windowrzr{r|s r1account_mediansrsK CI3'<#=>>G,@(ABBL(I7IQ1[>*g5IG7#PGqx+'?<'OGIP 9~.//4S!345 !* EAjZQwZE E'0Ny!jM * yHN!* EAjZQwZE EU^1BU^I @@7P FN Es;DD$D$>D$$ D)1 D) D. D. D3) D3cU=(d [5R5nUcURSXAXe45 OURSXAU45 UR5 g)NaINSERT INTO account_status (platform, account, last_ok, last_error, subscribers) VALUES (?,?,?,NULL,?) ON CONFLICT(platform, account) DO UPDATE SET last_ok=excluded.last_ok, last_error=NULL, subscribers=COALESCE(excluded.subscribers, account_status.subscribers)zINSERT INTO account_status (platform, account, last_error) VALUES (?,?,?) ON CONFLICT(platform, account) DO UPDATE SET last_error=excluded.last_error)rSrrorq)rlrverrorrrn subscribersrs r1set_account_statusrs^ _79 ' ' )E }  U  3    Z  & JJLr3rO)r)Nr)NNrN)"__doc__rArcrrrpathlibr__file__resolver_ROOTDATA_DIRr^r=r$r?r2r;rCrMrSrZrprhrdrirrrrrrrrRr3r1rsX 22 H~&& &= ^ #]" &=   ! &)  *+ 0  $#$ 1@"DO#'r3