§ ¥‹j1ãó<—ddlZddlmZmZddlmZddlmZd„ZdS)éN)ÚascÚ nulls_lasté)Ú SessionLocal)ÚStreamcó(— t¦«} | t¦« t t tj¦«¦«t tj¦«¦« ¦«}t|d¬¦«D] \}}||_ Œ |  ¦«tj  dt|¦«›d¦«tj  ¦«| ¦«dS#| ¦«wxYw#t$$rL}tj  d|›d¦«tj  ¦«Yd}~dSd}~wwxYw)zµReassign stream numbers based on chronological order (oldest = #1). Sorts by stream_date (or created_at as fallback), then assigns consecutive numbers starting from 1. é)Ústartz'[NUMBERING] Reassigned stream numbers: z streams (#1 = oldest) z.[NUMBERING ERROR] Failed to renumber streams: Ú N)rÚqueryrÚorder_byrrÚ stream_dateÚ created_atÚallÚ enumerateÚ stream_numberÚcommitÚsysÚstderrÚwriteÚlenÚflushÚcloseÚ Exception)ÚdbÚstreamsÚidxÚstreamÚes ú-/app/app/services/stream_numbering_service.pyÚrenumber_all_streamsr!sh€ð Ý ‰^Œ^ˆð à—h’hvÑ&Ô&×/Ò/Ý3vÔ1Ñ2Ô2Ñ3Ô3Ý•FÔ%Ñ&Ô&ñô÷Šc‰eŒeð õ )¨¸Ð:Ñ:Ô:ð +ð +‘ VØ'*Ô$Ð$à IŠI‰KŒKˆKå ŒJ× Ò ÐmÅsÈ7Á|Ä|ÐmÐmÐmÑ nÔ nÐ nÝ ŒJ× Ò Ñ Ô Ð à HŠH‰JŒJˆJˆJˆJøˆBHŠH‰JŒJˆJˆJøøøøÝ ðððÝ Œ ×ÒÐOÈ!ÐOÐOÐOÑPÔPÐPÝ Œ ×ÒÑÔÐÐÐÐÐÐÐøøøøðøøøs0‚D;‘C;D"Ä D;Ä"D8Ä8D;Ä; FÅAF Æ F) rÚ sqlalchemyrrÚdatabaserÚ models.streamrr!©ór úr'scðØ € € € Ø&Ð&Ð&Ð&Ð&Ð&Ð&Ð&Ø#Ð#Ð#Ð#Ð#Ð#Ø"Ð"Ð"Ð"Ð"Ð"ðððððr&