From d581ecadc297577dc7c7394422014f36959895b6 Mon Sep 17 00:00:00 2001
From: Denis <87643305+love-apples@users.noreply.github.com>
Date: Sat, 14 Sep 2024 23:27:11 +0300
Subject: [PATCH] 1

---
 .DS_Store                                     | Bin 0 -> 6148 bytes
 .env                                          |   2 +
 Dockerfile                                    |  13 +++
 bot/__init__.py                               |   0
 bot/__pycache__/__init__.cpython-310.pyc      | Bin 0 -> 146 bytes
 bot/__pycache__/album_handler.cpython-310.pyc | Bin 0 -> 2509 bytes
 bot/__pycache__/config.cpython-310.pyc        | Bin 0 -> 523 bytes
 bot/__pycache__/handlers.cpython-310.pyc      | Bin 0 -> 3106 bytes
 bot/__pycache__/loader.cpython-310.pyc        | Bin 0 -> 465 bytes
 bot/__pycache__/scheduler.cpython-310.pyc     | Bin 0 -> 1924 bytes
 bot/__pycache__/sending.cpython-310.pyc       | Bin 0 -> 3906 bytes
 bot/album_handler.py                          |  72 ++++++++++++
 bot/config.py                                 |  26 +++++
 bot/cyprus_off.session                        | Bin 0 -> 45056 bytes
 bot/cyprus_off.session-journal                | Bin 0 -> 29240 bytes
 bot/handlers.py                               |  74 ++++++++++++
 bot/loader.py                                 |  14 +++
 bot/loader.py.save                            |  11 ++
 bot/scheduler.py                              |  37 ++++++
 bot/sending.py                                | 108 ++++++++++++++++++
 bot/test.py                                   |  11 ++
 main.py                                       |  22 ++++
 requirements.txt                              |  11 ++
 23 files changed, 401 insertions(+)
 create mode 100644 .DS_Store
 create mode 100644 .env
 create mode 100644 Dockerfile
 create mode 100644 bot/__init__.py
 create mode 100644 bot/__pycache__/__init__.cpython-310.pyc
 create mode 100644 bot/__pycache__/album_handler.cpython-310.pyc
 create mode 100644 bot/__pycache__/config.cpython-310.pyc
 create mode 100644 bot/__pycache__/handlers.cpython-310.pyc
 create mode 100644 bot/__pycache__/loader.cpython-310.pyc
 create mode 100644 bot/__pycache__/scheduler.cpython-310.pyc
 create mode 100644 bot/__pycache__/sending.cpython-310.pyc
 create mode 100644 bot/album_handler.py
 create mode 100644 bot/config.py
 create mode 100644 bot/cyprus_off.session
 create mode 100644 bot/cyprus_off.session-journal
 create mode 100644 bot/handlers.py
 create mode 100644 bot/loader.py
 create mode 100644 bot/loader.py.save
 create mode 100644 bot/scheduler.py
 create mode 100644 bot/sending.py
 create mode 100644 bot/test.py
 create mode 100644 main.py
 create mode 100644 requirements.txt

diff --git a/.DS_Store b/.DS_Store
new file mode 100644
index 0000000000000000000000000000000000000000..e2dfabb391dc8a7c2f0f1fe59d1d58755e0acd94
GIT binary patch
literal 6148
zcmeHK!H&}~5FNLHG`m8|0i?YkMdG?D1y!IGmu%@CIB?k@H~=ciCP1`lT$*$Xsw(9S
zzrqLbCHxB~cw>8|HoHii5Mn)&{l=adJM)~_F%gN;BE3iC6HyO^(b++DiLjl^1?iX`
zHVPi&Ng+>?LMCYQfL1I6mVtkp0seL!>QhD~owdH-L)iL1m8c}Tl#rx)+e_TO+$&jD
zGqV?bOJ+r0)q}xz(djzZuDh=1?z*p|_i`E4alNQU@%$yXo=I6G=X#tx&$H#kzxh~}
zb)1*kTm|H52A5Ya@-mgnkzAB%rD7v(@VuTk@%L7%;b6EQ3?Ck>_k-2J{Q>j`!}Z$h
z-MVx4(edQ8n3nRh%8CT`E+sb%p2HU?Cg-zgUKX-^haUFcp)r^^p;PcSr?-?-L0O9z
zj^1R?r76YmEW!4SKDE4mw7fk!rXxDUJWqjr#HQO39e$S0@qIi=MjvQ_Iar&jHLa;a
zbWI=I>xQw3zHY28npUn91LnQ&?Ov&@ZL*dD%fO#7!23gh!WbHCG^(uwmAV1|9ds*!
zu73T20e1jHgN;V?K!gqj>QG^>7{c5fgbs&2H2#f79Zo{cjB(7&!rV}Vxp;^`xswPr
z+S)Q;8Q5l^tD8Qb|3|;S|8ED`mSw;)@Lw??oN+WBAtiIRUPzA5+5qJZ3Jd!+8dV4?
ia~vy$kK#QPC9nmo07HX~M)W}JkAR}VR+fRk%D^v`PnQA!

literal 0
HcmV?d00001

diff --git a/.env b/.env
new file mode 100644
index 0000000..ceff82b
--- /dev/null
+++ b/.env
@@ -0,0 +1,2 @@
+API_ID_1 = 24012189
+API_HASH_1 = 5a04d4beafc73f2b3a9d5a64ccb53ae5
\ No newline at end of file
diff --git a/Dockerfile b/Dockerfile
new file mode 100644
index 0000000..4fd654c
--- /dev/null
+++ b/Dockerfile
@@ -0,0 +1,13 @@
+FROM python:3.11
+
+WORKDIR /forwardspam_nedvizhka_Ciprus
+COPY ./ ./
+
+RUN rm -rf /etc/localtime
+RUN ln -s /usr/share/zoneinfo/Europe/Moscow /etc/localtime
+RUN echo "Europe/Moscow" > /etc/timezone
+
+RUN pip install --upgrade pip
+RUN pip install --no-cache-dir -r requirements.txt
+
+CMD ["python","-u", "main.py"]
\ No newline at end of file
diff --git a/bot/__init__.py b/bot/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/bot/__pycache__/__init__.cpython-310.pyc b/bot/__pycache__/__init__.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..f173ed1e62b06faff7358153cdd81ec9992e5577
GIT binary patch
literal 146
zcmd1j<>g`kg044D(?IlN5P=LBfgA@QE@lA|DGb33nv8xc8Hzx{2;!HivsFxJacWU<
zOj2rbNlr{!eo=X1QA%+^Vs3nLWkFGCaeRJST1--YNlbivW?p7Ve7s&k<t+}I-29Z%
PoK!oIam7qPf`tJ9NB$!6

literal 0
HcmV?d00001

diff --git a/bot/__pycache__/album_handler.cpython-310.pyc b/bot/__pycache__/album_handler.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..e960c07eba4b18f43305b2e9148d36a3dfaab01c
GIT binary patch
literal 2509
zcmaJ@OK%*<5$^7pot=G<T#{>AE6WNaCpH!ch&WF`AOssikmL|vD8<Nvz+gDtOYLf2
z>7JEMVGT&808wys$~_>D%E>n1QxaeD2bR~q200iA@&l5C^Hnc5CS}00sGjQT>YD1R
zud26LT52*p&;Rw$;bzF#KWK9CsbTUC$aFYkcbR08r))5P^8v?Pq$2YM9w(WX`dMvI
zbG)AhS$$B?!a?ZfwX~5n2hFTCXt{ZiwzH+dlH=>?a<(#9aeSC|vem(=;~VK(wmw+r
zOm&ag;1w0h<`Exk$d;;0F1gwmdOarFij7}Y8$CAk<&s=};t#GU@0U!j$j%ccJ4XV0
zda9<b;{6)l*VI+@y6O!Dc7W7%xw_5N>dALhYrJ{N<(g{Bb+rU*UHQrrAG^NmWE<Gy
z%U9(UeBp-VyR6^)l47;f=e8l^Do)ba7))AH4dY2#$x%}Eg>Bp}bTO$$xw7>;ho$;$
ztRW3<rz4eDwmuxCmD04Y{u^aXe4xMvNs$jn2jKj;EZ@evJuLM5v6fL;n9A}y)=yy8
z23l1UohL}o{~r$=(QT0V0fvg5@Kg37pYjtiWvBc@QF$l+RGf0orsAYldE;Qt@3I$s
zr(d`A*c|4`sIbcis*2PDcp9ZeQQB6bRa~j4ip_l+xR<eBETvt=5XmA}Q4*)=ew<)k
ztE_mS`kr2b7uI(ceA@bg=^jM?xq18M-d%&^@9is7rF-XxG-aGc$ziD{CMt%*z5Sxv
zi_`r{7Tt?;nJT?i9@-{-;{c(}<r<xokR0+Rer@h^{TikT=+Z-Bc?V=}U{H(@JP>!8
z@{}(*P*76=5aCO)4KyRezOB7W-?ht`lA}1H&y~?g+Ay2v%22ezD9YnZMUibrQC7%F
zN_;ztem{xR^A*oj+O9-VoaaRqSEC{~(DBm|<fy!PJX}!b!&Q=9!$6D)Ff>^xI^4-@
zJ#yhN0LnRx&izRQG#3w@mTVt^%%3ql<_~wKe9XrD8Ne_W&%9$#vI*1O_ZYz8oieJs
zU3TnM{xR>d2VDQGs!jO;haP_}p0Q&#Upe-+*;DqEKNU|sRE3b<lMt{9rs9Yl0ap3?
zLa)bY*SLNXPC0?>@|P~p7CyX>$nW%pz7C)D>lnU~NIKRZLFOKY$D9x@VgA=}|5rFf
zCCL2~cf3=<*~2be@W(ahD3ktkI8p`2;+P$Y#h&-v(S26c4}Z*I0~+B;gF^B<w*seX
zJ6}?vU8*(`5bc6oo~CS!iC)1Rbt^^^BhOw+tqr%+INO);t)I|7%38o4ZWVcS0ccy>
zX@O!gx3;KezMd_%!mxK=9rl~LgZ;K<Ql(1$ed4{cC|&rhZwg)65SATeY~vRnB&s9;
z+D4`0M7dIJlzN03S05zK(H8*zT)m#$iz^^rzX`K07Z>n(1+pK43>Bbw)Zra2_!{3p
z1uk>()x&GwcAkC%Jq*Tme_`2n(e}_NCn_p+QN{<ZPTYYU>|IUIPZgjos$8PAIKSQ^
z6Xea@If|*K!m-PjJ@_7EuJ*+vAwnMT5DvGy?SC)B<u%c6v;{aJ{<~4rH_6CPF<h!C
z%9IcKJID+%Jf=#*z1TxljnP=g{(YgZplVQ2b2+uwBM&eW1kHu?T)PhKw_nl@zt)yw
z7yHnOyva5`*4)H1`_t^xvq!T}W}nVJIs54B<Jo86KR^3ubN08{7qibG_<R$RznuL6
z8eh!*diJr~rU|7x{l>hievZjJ@(plyMN^AMI`Ukll<t<3x_)OOwB?8t?21uodO^*u
zT+pC36s=1L#qA}?YeLGqAk)Sm9(Dbzyvwh1|0}oBf5V|z{|Jk?LKpX`GMYk;i>F9a
zmAJ;Ksj=ChIxI)|fu?L|`lDjQ@=zBCI?i-JvO39@7qTs=!x%LV>)}Gt?%YjqTWJwX
zr8Qk3wnYL1Xpw0b1kb2SuaiOY+xmA<i*qDWd$vAZ^XEl}64EzF^9@>QI_$YC-L@{2
z^&D9gjSCT?>u?U)aC?4*+@gFLiY7Wg;MqoXbp+l-JOF%ecp~iZ&7kRZ`Np;X0XYR|
AuK)l5

literal 0
HcmV?d00001

diff --git a/bot/__pycache__/config.cpython-310.pyc b/bot/__pycache__/config.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..5604f5a78d91dd8785ac747e88726948db39aba5
GIT binary patch
literal 523
zcmY*V!D<^Z6nv7_YiDhDDTG2VIR<=4YdbA*Lr5FiLvksBG#9a;ZY=F~gS;}*I>kQZ
zQs}YY&=zti^qybHH|QE#2qpP|Kyf7Zl0MLA-n@}UNVVG$xcYqaEBk^0E`4*qh-+TC
zW!^hD1P&ZYpnk^^jWERs1pWjL;Va?f8=}F21&-Bn;I;3FhN3PSk3lT)a0_^yM!Z3r
ze2KPrlq1?+-~)~hpwql^De$&~Y*VU~Gp;I8p4i6D{vO+V!+JLIY<K5im-RYC`p2Da
z4qn!v__=caw8(yE+cr%3s3^_Vg&WGh^ZESxxVv&j7WB`%+3FdYJzVQ`yZwHD<N4sl
zVB;C<t#@LJm7(FkK<$14Y?uq5u6>FQJk-1#$ih^X6lG;&#?rD>RazCQG>p-<8K)!W
zMna#YlEzw;6&rqVCLvkDX>5d){|UKPld)l$(#)G_d{6M^AD~-4+QaSo>&@iQ2yK!h
zVJexpQy){!7oo%HSWgU7S(Y5BDjBLWEAl7fscmeH6rV`3jocOHk%I_YD8vzo&@v84
JP!DkE_#F%%me2qI

literal 0
HcmV?d00001

diff --git a/bot/__pycache__/handlers.cpython-310.pyc b/bot/__pycache__/handlers.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..faaf6f2d20eb49cf5b163fdebd095c5fa0c5640d
GIT binary patch
literal 3106
zcmbtW&2QYs73Yv#?w3B+@=CT`x1ob1?WV2r0VD+s!!Xb^wSig)q7*?01q8iA$t&|?
zGeag(um&WpfwpjpB0)|Kf=cPhH^r$6CAO7A{{iyKYmkF4x#f~me{WWwYXuEZE@t-4
z%zMM(@BQ9;6OWG8G(7pY-z?mL^fe6*KNbd;(Bu-+G_G+LXb%1B0SlSK7|BMUhlXP)
z*$m9E<dl?L3aqf~l$C4+m9Xkmm0S*LVcn^RBhH8#SAx-S%o$U1H5d;YP9r?woCqhJ
ziSVRzGHg1{aMGD%+V3@9<Mmq_ulIFl%0JcDoYQ`NecB&eKjT-IezL(Jo#i7N?2@*@
z_^4lA(D@i2zh(BB^V4HA8%H!x@P^X-*)f_EM>J3J38neiF`CUInv=Y#H0@(Fr;ccz
z;!{fV9A|S{>-0nN!fcBbR<|oUQ39#@iYKIhHRe7Bqp$eBxWcbQZ+k(9W1@W3m(p9L
zHLD#*3!TN5UYK6D`&?0#?dv{I17DEdLMKRkAzN0_>_}IcyGbYX-Gx|$UQ(2$AMsAK
zSd7D}eZ!SW+;wGVF)Bu&@s20B+l^&XG#35DjneR%FVuuA8ggi+O&@Xi0f`25YC!Nc
zhjGo(IdcrI<D-qDJU4jvYqKr0sJL$A;aqM}bKNke4}d)4x^Jaku)AW;{ciT9JDQlp
zeyaQah2Nf^|D(hQ&R_Fo63p+OS$4h9Z7+94D&2TtVg6d2%wP8+4p8JwcUjPZ#?hpS
zuA)_#nkmZdR0ux;D&YX$wvP3^$AC~m`wyCY8Qm)5jO*)&32xrf61Jqjr1jYbJEh&!
z6NAQm#!EMJG2PR-^&8Cg*t*%%H`o=8moICGfii%oq<_F>*+24?Y&&1gZ)f+i&1@@Q
zv-7oVEBi9<=YPqzvn?8KW?y9Y^Hpf<<ZJnDJA06A+SymoUO^k!!XSN~HvIIc^-8u0
z%dhAi*yn-T62l#stz|pe-Sf4A)!O8<y=U)(=P)6s&@E~`?alJMag*KDZ?c~Lf&Lae
zdEgHCRG)daU~XX&#|{<*Sr@enK}RO-IP6}WrY#BFDeb*;yQsT~CvV7^3qjoW0(lX_
zp0=P<rIfpXQh#vZ*;c7Am*P$&Dwr=y%D6BBKPpPX?*_{_jMWZ0aHlv;8fN0Zn+zXm
z^vJvEl#;g7SI!tytf`A9$kOmQe}oCd9K{3<VU;CXk1a9yo88dlcmhu^fg97{gPexf
z4Q?o}o676voYJOsFvVOdB^DS``l}9JD2=3?RC=txKjyG#S?RNQRrV2_^%*>P7cAJ?
z^Wy{ZAlm2Ij-A~lHe~k)s}Bj~hXmkv1bX%%^tQ5pfd*ig{R}?MzI^%o)vL3VKnTR5
zBGO3Zh*nkDFhN+vVTkAv<N<MxI)!-!#>#1;PIH8nD5JY$h{s7L*u`1u_5)TCK|G1M
z$I#>$I(_A=(O@R4u_k_n#r?of{2#{qUD*78c&{tGH+In#&ny3wdiuxOCxh7B^+69_
zdc+66!t1kt0>I55hrf6V2IA+`{Q})=+EN>+P~6J@3<vJmdH>LU2M)~tX16NJ1>%=v
zKLmeW_+k9EKkR{Dlj;!QGnjiCO;X}J0DOXh<bYhh(@EObk3deW*{Aq<3<&ZiCMq2N
zE{l-E=^xPP+)yhgxfvnd?Sp73s#_p#IVEa<m)V!uy=Oqr+ax@ax3X>f<=0Y$?|o2N
z@mJ-%d-?m6=m5uXszdfm>C!UTIwe-_Z9m&GR8kjBOe)ge(GSsb2q22A7tthPtgl!`
zg<1L&sKQj_r~t}G(4qIL1n??^RrcO=f)aqRM}?!X@8i0ph=l;}YagRXd~zrSypBMh
zLjj=QfPM$*;SIHhaCfmWxS{eLWo!y@gl+yl@;)f@Z#A`L1I!(8aXbH$ssU@z0*4M|
zb{p)vcN}`#wjyRq(VG4Jf9;Z<I_5ls9JDj5Ts)jy_QA7pHmW<QTdk6y%3Bz?<_u`9
z5(;Gk@f>wSo}p592~Ccm(^qtJg4xUhaa)fUWlt_g?M^I+t;HA$d%P&TaK^_)MG7ik
z#rVOb5V4SgNPS2(S?>B$P+2bw+!6$NwWvXw31W}?LM61_bho#as6xr9lhW?(X%Lz!
z3(_&gD0S+S=vxPu3j=64lfrMKA_dEC=<|-}E{Ztq%AyuWm{2#m!fap1z0C4>*oou-
zA(dGvX$lHtL1Yz#%OR{3YO2asE(~r@7b)jUiu#H+!bWs7^bPd3K4w_v8D!lv6|@>!
J9j)4A{{=j+v`zp3

literal 0
HcmV?d00001

diff --git a/bot/__pycache__/loader.cpython-310.pyc b/bot/__pycache__/loader.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..927a97b2783bb16f3226d8ab2c7f333a871f4851
GIT binary patch
literal 465
zcmYjO%SyvQ6rIVdN%}zg1>I&7sP06>QWxz;gyLohgfug0N0UsLNhx*Pt$v8VG+S{Y
z_yw-K6R3J&&OP_QoHGwG9EJ$$<?Ew3#|XWf;eUBB+`v)<fFg=ZRAGX#;Z|u?HnBTy
zmrmsp7b9jrdZY*FlYn9BupSGjOTAZzgse|{N7&2yEbO{_L}Wny6^epS@JA8W-n`_j
zZVk&tUGNRC(M%oce3fq*-IYv|Fh4YMr&3WA+Fpw`vbC2rJmpmTrf)N~)xEutPn65&
zao#yjxSH%U-cI5;zKe$1Zw^vyWL8NFlBH|F1|UOljMXVjI-qHPcE3!Qx9OC00i32&
z9U5&hTP;8hPqCmoS<_6l+eluwB=|LYLvmy?418bAFOvtwq)OIIwPjKWxz8k3O;)9U
pmrLLzNhvbQWZWFIe^m+d0N3zQNR0soXkZPnXL<O{@+}{S)(_V_en|iT

literal 0
HcmV?d00001

diff --git a/bot/__pycache__/scheduler.cpython-310.pyc b/bot/__pycache__/scheduler.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..2f31d460e1487ac3e9e74e72b3b7fbfbdbbdc907
GIT binary patch
literal 1924
zcmZux&u<$=6rP#gwbwrqg(#wcROD9b!3g!(gH@qcK@bkfCFNontu{OB;&$zIX4h1S
z9AU?S3I&l164zL8;TEC>LfWK4`~$n!y>LJrD)AQ}4t#GNr>?_D^LA$5n;-jq?|c5t
zOrD|b{{2_|H-oW1X)@U~Ozxluw_qfb++)?zmsdIF!V^ucsx|eh-ZZKPXCE@DNqvV&
zeITkC$yZs~c!9larK~09qV0M1n&&3DyN~QfI2tbc%I}1Ymg`X5WYaOZgC3A^8QoYF
zl2<h;q_)GVy3}1m8g8bp%Z$wK=+&$=Wey%w=G|Of$bu|lH7{rIj@e}PZm`jER-I2>
z+3{S}`5edQOK8z|(LwY)9>o3V1f!#P``uD>7Wd<A%udk{qo>g^Z0ajT2XOVVa2kIR
z_o6d|oW{G+Q7QTb5l`TLjPG$NI=on+5CkIR5Ic^dXYpQov%~R*aig(7UqlaxnER~D
zEZ~jT^OZ7BjL;4q1{mmp>(zf`%0$pVw-zh4j{{c)wKX>gy;|K@k8CA_w%xRxjkf9p
zmS3;e*8H#*jQ{;+dm}L|tI=wNmPJ<uba9?<UU?Oxo8y>7r@IqVby`-~Xu1xi#<&qt
zNFVk)dQgGs^BfD=K9>Sk4B1d@X<e-=9tyS4<pcH+(qxHo7Haz-amdH>bx}4tf8c-=
zod2ih0@L_$JOEE8U}_t^2i*4v-`(grpneKY_J~S~IEa3Zp1|>I3G^Jn^Yt`2sdM~u
z7q?g1wz8Wg`t?f5rkpKBKg0uYc@lpa9iNj(?>vtjpHL}L_N2*y+e_D%mMY83*Dub!
zw`ts1s@zy!d2t&*TQ-0$Fip%LRP}U}^L)ql(qY!7tZn#-5qPfKF6%0bJ*q&a2$K|@
zj#6$bOnFIDVq|jUEYRC6JgeoZ87u^|Frp_ibKK-bKF7tsn{Q2VKC$Hz%^7S@X?_QT
zJ|~j9pt#GsVkm|jG_waFmF8Wot_?Xy)j<A=&MG!U--4N+KnDp5JU~N`1S#VX9qham
z&`3UKkR|DbSR3t_meEStP_N<Wq~Ivm4qc00uNJVP=&eb{Znxc*ybRk+`kReb5ZW!r
zoyN_yrA&`{6NdzJlIYEg*DniX9G7I28+KId6~t)Y1!7B>^num`_CEXMYE9eHw)8Cn
zvfz-#wXUAZ<676)=R-(?;()7$bz_9%2+4I_3gD@CYB(<Xp32PxmdLt6{1wu^4<T%0
z{0+@6Aq#<&;+>a?OvQ=-PqBVBV&>ilsM+TjIs}nNzu5FYbIY0O6y#x5Q&y<1;7!v=
z7Dk&=FyDqhn1d0$IYAjX&of-~bbcuZCpN8=3skFGcGI=2ByU+wpXxWpMax?6*xtD(
zYgy8FEK5;6Q&i6q4T2iw!W%Tz*L>eoSIJG4bHb2T6qPVyD<D~!Oy{OHubIVpBlVQC
wX`U$(P?8BZ+Ktxz^cF>>P*Dv`<0ei`FG*!+-X1;rJ*x2mt((l`3w&Pt51H73jQ{`u

literal 0
HcmV?d00001

diff --git a/bot/__pycache__/sending.cpython-310.pyc b/bot/__pycache__/sending.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..66edcdd7e6f3d618eb67ed3335de4d4be6899743
GIT binary patch
literal 3906
zcmZ`+O^h5z6|SoOnV#O+*&nah|MA4J2_x(!m?RJ@KoZ-;5%LnnL?+FeR(q;<J?oz7
zadnUFUCpAk$3T!3TL>-?LDmu%-%N;walkp`!g1!>#~==tkT`LP5axT;JL}y|(o(&y
zdiA<~-p}`5$HT)e!*l&#|D3&1X6zp{SpPT}yo8qg7eq42Bj)9A?s1GoBpSjKoOniL
zG)&LbeKWEewr4jAUZLT5j^<fWvEh2I?%UB&qvVxzzYq;K%3c|LCm4}M>0V>rs2mE%
zW`!)t;cKQhF3WNR+%2y%IV#7lF*(*1-h><v$K;l9LQX)|mRsc{WVgy~;BH6T5l)8N
zb}&8b$enT*X1B}Tat~J8A)g3stiM-Qz}+dI3{B$bZ^puHvtkFsiu>eKnB67$DOTP8
z5E@|9Rh~IANW-+=2+_BXM)k0nR*kH1GE9<SF3jB5nyq$vGL-co8+qJ+{al>J^hGUh
z&erG9GlN#^Yj_t_(3JIN`fvgp)M%IW569prT4I8v>=e7rr*HGDH2vnuSB}5ozyAGG
zKR9)pDHty&pFVr^$jqBbsFInpVUk8Ov$47qD4Dc^hF@D~sdnPWv$Hd2<8&qoY2&%6
z)<QNq7p8u*-8dU6zZEBGGDdp}5L2j8yfS{dMrRp3)L%Orxk-lw@PboJ4Pl^4AXTnt
zmB(jOBN%3*$)>F)!PQ$iLXD&U868+)eoR99K(6qVrF>qX8E9r|by?SZ4Ze8-2hz3@
z?UN96D|mW;=y!X6>)r4Ftaq<}v(o#Z_aVJL>fP-xqh0A=?|s<2-@8Yw2Nm${^sk_M
z5A+VcyVt)lrPrCR+S%AZm3|ugwR1t5r~>xMMig9t7|muF`E{9%Bw-Y7V9cqw-Aa5c
z;FGY{=sLY<>uKc_R&BD2u1h8t%N0{?L+3MEp}k*1OI`s98O5U~LZiz(Gqfa!H;b?^
zYf3|!*UT>WoX1>gg+=(cEem?al@2_-m<=5Z>e0f>(b;w*fum~I&dLpPWnbR_m#Z1r
zZSc?msU1a2z68?Y^DxeexW!fs$#3zFm^GG+4x2Yutd4PuQ^3Q8#q^?cKu#TKOdWU&
zinW7Q9ZM^6x6Ek9mog_w)hxwWHk`&XSV;UJKa~+kdE3m4T9l|A5LY`vyrQ1<&xZ@^
zl&bYvgna(((-71eofM;daqGIPPOZsgwhGg>YJTx0D_G?VE~&41ks^SMSGCk`y!4&a
z9_l?oWG|5?iL6Cz9u;NaLK@VYt2aFek=4_>d~xUc({2=;t`236?>B=+==+)L`;Az(
zBkGrY|3W*6R%Z-Eo!&hgszpJPG{W>;EEQQZGk`woDe9SL<2X_WHlA<IJJohf>_<x|
zyd7q9AttymcXK_H6(}eu07{Y^X<#!esyFKC2AxtwlmC89i*-P*@Hw_*q->sd5W`Zu
zBM!60XTFZCa)O;^OJ>KM7pe+sfbtbHWyHB9l4{3*YnkL);M)T}XKA5hbm4&KEp-@k
z#wnIMD@6%OU<Fp??1KBe=2xxuH5?(wi}!jD01@5(&k_H3`&TtC04A>XuUC5adVj9a
zME`2<&OyuoE*|vWCn)LP?B6_yIm|q$fC=QNfd7mBFDvNZC32_#Q%rmS$*Wio81#N+
zy_RyAdH8o6q$<=Qywq1grssb98+!ioovNz{W^<(0iau9Q(pW9%5P<H3R$7mn+ISRE
zEr5G&R3i$TSs_RknzeeISxFRzEx4!NV`{LGXKC2aOnPm0&Y{^bt)0sg!(n`pkRym?
z)7;5-a+jBRi3@Iu@kioQv!K37Yf>^(TR}2A2frEt#o#HTvxe%+7+is+5}+2W#JaF|
z3P0$Wu%MA6`;r9?-@vguR>$7PmI|pzjgFC;okEv)MVB9AXC{}N)JpA6q2uge9Whvi
zykf;ki}SAb0-Z4~JiVGT&f*vYA6TCqKHm>EVLqIrvI+Ic!o5GiH@ZkDAN8*f63LJb
z7OkbsLheV+U^MDY^(^+!N~<|W>slLJJqNyeo`}vi!#a~AVncN?h^ocMnpQ865P6Lv
zvt~{sFG&)wIOrYrN&!;SV3_gxCR3{|`0{16gt9W3*yOet=i}TFlYEj-aPxm!W<xPR
zz`d3S$Tw29!U_MEcq$N<fW}+AOJ$VN{syLd?`;U38;CO<V-!#K`&}I_mHxHf1Bm^V
z;;nMx#F3LH7q|WRN6#EOd<Nu&Ge<z5%e(uht7axth#-g?t$GwHg3ruq1n}Cb@Epn{
zKHS<X>0T>Hp}pp&t7jAS#D_}j($`Y31QvJ$D`_BhMVTu~bXj3leH&CjwGe?RNhE~)
z5_Jj^AFh3owT4$m@J`AQRWaSRA@j+*zy9~Vo2VWQ98OVWWo8;)PEk1>!(j6PM{4K7
z+Id_gZuv=luK7dA=)wsA{3^*)M%;k2<S|r_X`KB89jcx>I8!o&EXI>zP>~E%Qtk-E
zjlYDnP0@sNa<!{tNH!~)Ln*4P)Xw=U1u`tf*^F2+m#oFTSi@1@!d;7qPd@L?)7nEF
z3n)%?86&K1y5N;CZ%N}FG2otN%{?YdhZjQ5mTb-z$I`MiJNCOw0@Fe5-&tKC`)T$T
z)>*QDVmGb)eTiRU>B!2cEa*tqdt4ZydsLn2jQdqn;~U~h#i)B%^OC!2Im%I6RM<j}
zLMiu{3B7+0N@`Qa>;1m}HW2@hs1ENOskEsEcHQ2u2JuYH#a*s@=<^@feMmu39m@?v
zrd8i1avUTxBS1HzK4_`0(AY{^Q9aFpe6$v~7I3DuqAN4$_?f_&O`6M!$1m4H4fdJU
zQk1*bAfj5xt0L_^1P7k0;X*^O=M0KC&&e;3C3(2X%hZebYz8g)GKg575T=fOAiyIb
zY(5I8FF%?v%;hrQ$DL*IXk3{8(O*?}=O=jyALhlJ(^^pRoC+Fwp-~<Tr_zO1m?**w
zMR`C`G-L*TN^+2M(VL3mK!z&MdN%ze#SKM?Lk$xlgJ|vPe+FG5KL%DsKLA?S8mx5O
z=9Zw_t-JABZId}K=9Sa8DUy@@AP#eo*h(mIN`l^|;TUDhvC75C@)IM@SlQlZ{vX3+
B0|x*A

literal 0
HcmV?d00001

diff --git a/bot/album_handler.py b/bot/album_handler.py
new file mode 100644
index 0000000..08f45d3
--- /dev/null
+++ b/bot/album_handler.py
@@ -0,0 +1,72 @@
+import asyncio
+import traceback
+from dataclasses import dataclass
+from collections import defaultdict
+from typing import Coroutine, TypeVar
+
+from pyrogram import Client, filters
+from pyrogram.types import Message
+
+from bot import config
+from bot.loader import app1
+from bot.sending import forward_post
+
+_tasks = set()
+T = TypeVar("T")
+
+
+def background(coro: Coroutine[None, None, T]) -> asyncio.Task[T]:
+    loop = asyncio.get_event_loop()
+    task = loop.create_task(coro)
+    _tasks.add(task)
+    task.add_done_callback(_tasks.remove)
+    return task
+
+
+@dataclass
+class Album:
+    media_group_id: str
+    messages: list[Message]
+
+
+# chat_id: group_id: album
+_albums: defaultdict[int, dict[str, Album]] = defaultdict(dict)
+
+
+@app1.on_message(filters.media_group)
+async def on_media_group(client: Client, message: Message):
+    try:
+        chat_id = message.chat.id
+        media_group_id = message.media_group_id
+        if media_group_id is None:
+            return
+
+        if media_group_id not in _albums[chat_id]:
+            album = Album(messages=[message], media_group_id=media_group_id)
+            _albums[chat_id][media_group_id] = album
+
+            async def task():
+                await asyncio.sleep(1)
+                _albums[chat_id].pop(media_group_id, None)
+                try:
+                    album.messages.sort(key=lambda m: m.id)
+                    await on_album(client, album)
+                except Exception:
+                    traceback.print_exc()
+
+            background(task())
+        else:
+            album = _albums[chat_id][media_group_id]
+            album.messages.append(message)
+    finally:
+        message.continue_propagation()
+
+
+async def on_album(client: Client, album: Album):
+    """
+    Обрабатывает новые альбомы
+    """
+    if album.messages[0].chat.id == config.rent_channel_id:
+        await forward_post(client, album.messages[0], config.groups_for_rent)
+    if album.messages[0].chat.id == config.sell_channel_id:
+        await forward_post(client, album.messages[0], config.groups_for_sell)
diff --git a/bot/config.py b/bot/config.py
new file mode 100644
index 0000000..102d10a
--- /dev/null
+++ b/bot/config.py
@@ -0,0 +1,26 @@
+import os
+from dotenv import load_dotenv
+
+load_dotenv()
+
+
+API_ID_1 = os.getenv("API_ID_1")
+API_HASH_1 = os.getenv("API_HASH_1")
+
+admins: list[int] = [5899041406, 800530092, 1046931046]
+
+# Интвервал спама постов (в секундах)
+spam_interval = 200
+
+
+# айди канала/группы берем из веб версии тг
+# или с помощью @username_to_id_bot
+
+# Канал по аренде
+rent_channel_id = -1002054380269
+# Канал по продаже
+sell_channel_id = -1002123908331
+
+# Группы для перессылки
+groups_for_rent = ["-1002227589874_13"]
+groups_for_sell = ["-1002227589874_13"]
\ No newline at end of file
diff --git a/bot/cyprus_off.session b/bot/cyprus_off.session
new file mode 100644
index 0000000000000000000000000000000000000000..529f14260f96b0691d25d71736c1338134a4ceda
GIT binary patch
literal 45056
zcmeI)du&rx90%}ww?4LZ4-oM>=iFg)wlxE@AdE=>yY+4~Y#p?BymYDUdbc&Ow)EaI
z20>ZfUjiXfGeVFc#6W`4s4-%EMM;PVC>TxrL(zZ+9GHkkP$m#h?_+B_XXH=H_onN;
zJCENv=W~B;a+a>XWvyXZB;C<?UqB|anJEm*GLI9&FiaKwvC<#?xQkvG^k3+iO}n1#
zvWl72zPXszS__XbrPGVA6z?ydRunF(ww|zdTW(km(qbGCfB*y_009U<00OrpFc`F&
z%NKA3$xU)R+|wh*<#>-jCW>*%zcwJr{zNPkkVStqqLejxd8fb=!Ru~m;k{(CwiZGU
zXR|<?bS!nz9!f#GhbTcTjeLvSqZFyNT5+nAj~7VhxMTroa{2_jPw+Mi?l#_TtC4KA
z#1@J6+Z@E{BW{nt)5$oLfGZaBUY>+Qw3mlpF)JLJZ{a;I!D8ZOR<ditk&w6{9NOSd
zNMbw^=o2M>I5c)`)mG>BxcHScMrJcYr$5$|*ux=5PobG>sALE8|0S&6Qa?+U{|K%(
z${Ip1c61fcfw=U6)EgA*jYdR&B+(ZX<4Q^4gh3`YObw!x5_@`o$8xiYtK(Q{Y%ywA
zeG<xV1(U?r8>Pk8iySVKiL2q*C$i#(LrO&RBoXNy9G@q(9<&+FTulv|oGJ%`Yeg+9
zC7I@C`n5?5Cpa5hd6HgZu`BsO;}Sh%$WpJn&FNi5mhh`;mD-prjn%3p>n4<>UJiN$
zwT&dM8|!6p3>F#8TqRA59(AUArs*J(F>{W3efk7buLLcv)gkoGMBrBnYEg5$mv^^#
zQj=G*k$CxLn){w6-lyK*REk<0%koWJc{#gDnaq0nvJOWh+R2bH5v@?0hMH9RB+{iU
zj$}oind3Nis7wi}+(+dpKO>-0l)b9d%Es1~9#&mcpsP!iB!6!}>P>5>*2x1gQR%Hd
zX+Ff$E)Y*gYikyi+Gw0BJ=ba7ctzH`O?Ft~;+vfvtpc(Czjq-@KG@5exrz$**=of{
zqAQ~4l77z1P|`~^s8APuM^fglPh>)p24Z2YO-72yB7L{+i-xk2Gmwyb{cFSlLK<7!
z8&xDFg);`3h^P*cF+y1K2cvSTpH^&fr1s`)$$5r8a6kY85P$##AOHafKmY;|fB*z;
zbAcphC}a!;Lq!H-0UHtb%sX7$SN7@h*N1M5Ug+%T7@79_>7P2=&b;u<S!3+ju9y5H
z<%#&#{^3_2PE-cX=N7dbS=e^|#lKfRwC=p`4Y9d@_~_8-ja4faT;23h$0zKy<H7so
z*iEMPwK<)`o42(M_mIbS-b|j`@3NJ>d*<Th(GM>7U);XCZ0@29`~LdO@nhG=Q{I|6
zC$?|V*L=xus}qO2XIy$@q439>TY@`+dxLxDzi;s7{dwi-Q%9>uuUfZ+l4U<XV4t$S
z>R{7%_w9V%Jn;SeBM&AI)!Tl}+aNWp`F7flZOP*szo=V1@A}(yA=`&9zcaY`!pQ?C
zOP(y5dg#FVCA&IZGe%~tUU>YuJr}<`bx-tKqUjfB_Ye10FzkDy;$da~U-~&iA2=WY
z0SG_<0uX=z1Rwwb2tWV=5V#!#X72uG<V3xhF-@<oHY`52^_8_}pZY5G$&;>uSUe&5
zqut$gv**+|G}PDE&3&{k^;ZCO|9_n+y?#3^5Oah81Rwwb2tWV=5P$##AOHafK;Tvd
z@=SS5YX49F=^qCKAOHafKmY;|fB*y_009U<00KEIfc<|C-&`yW0uX=z1Rwwb2tWV=
z5P$##AfO3Y=$S3O%+Lo82tWV=5P$##AOHafKmY;|fB*z?M4&X^XjH%XPkmPR|CgB3
zOF6PYECT`%fB*y_009U<00Izz00ba#XA9h&Uu{hLB0%i_@9cEI>LCCD2tWV=5P$##
zAOHafKp;m2Qv3h3Z~q_P|Kt1ra`cX4SrC8#1Rwwb2tWV=5P$##AOHbPAoclw?EjGt
Z5P$##AOHafKmY;|fB*y_0D;^V_y<l9qxk>;

literal 0
HcmV?d00001

diff --git a/bot/cyprus_off.session-journal b/bot/cyprus_off.session-journal
new file mode 100644
index 0000000000000000000000000000000000000000..fd949cecdc1e5f3122b9953035f7220c6514a724
GIT binary patch
literal 29240
zcmeI)ze>YE90%}=F;*)Q2L%zFIy)5qgua2#;8H=_Nl;ok_zXURtM4HA1fn<zI*OyX
zbapbKm8NUAlh1LG3*q4IbK93+E`(V-eS6w1-_}D|Dj%D(4@Uo4V69p1F3G<`*);+L
z2oNAZfB*pk1PBlyKp=jBt+bUL92K2TQM8W_+aY=Q>D^CrpH(?P{0D3Y1PBlyK!5-N
z0t5&UAV8odP~`yU*H?qluzT6>&*uP*Ne(a$`M5U2kN^P!1PBlyK!5-N0t5&Uh*}^|
zvusicFjo(dZj`%9@|RF{jQ{}x1PBlyK!5-N0t5&Uh(Tcg_WkR*XoQvRR%`j>@#gO0
z^Xzpr><wyV0JT2@`X4)cfA>LD^#HDeh~bc}kpKY#1PBlyK!5-N0t5&wE-=jjnsR`}
z4b3D#fB*pk1PBlyK!5-N0<j28bAYV+FF-v&ET?9j1PBlyK!5-N0t5&UAV6R-fhq_1
E1@2frRR910

literal 0
HcmV?d00001

diff --git a/bot/handlers.py b/bot/handlers.py
new file mode 100644
index 0000000..428e0af
--- /dev/null
+++ b/bot/handlers.py
@@ -0,0 +1,74 @@
+import asyncio
+from pprint import pprint
+
+from pyrogram.enums import ParseMode
+from pyrogram.errors import PeerIdInvalid
+from pyrogram.types import Message
+
+from bot import config
+from bot.loader import app1, scheduler
+from pyrogram import filters
+
+from bot.sending import is_valid_time_format, sending, check_stop_sign, forward_post, get_number_posts, set_number_posts
+
+
+class Sending:
+    SEND = True
+
+
+recently_media_groups = set()
+
+
+@app1.on_message(filters.chat(config.admins) & filters.command('current'))
+async def current_tasks(client, message: Message):
+    """Присылает текущие таймслоты на пересылку"""
+    text = "Текущие расписание постов:\n" + '\n'.join([time for _, time, _ in scheduler.tasks])
+    if len(scheduler.tasks) == 0: text += "Пусто"
+    # print(message.text)
+    await message.reply(text)
+
+
+@app1.on_message(filters.chat(config.admins) & filters.command('add'))
+async def add(client, message: Message):
+    """Добавление нового времени"""
+    if len(message.command) < 2 or not is_valid_time_format(message.command[1]):
+        await message.reply("Введите /add HH:MM")
+        return
+    time = message.command[1]
+    await scheduler.add_task(task=sending, run_time=time)
+    await current_tasks(app1, message)
+
+
+@app1.on_message(filters.chat(config.admins) & filters.command('delete'))
+async def delete(client, message: Message):
+    """Удаление нового времени"""
+    if len(message.command) < 2 or not is_valid_time_format(message.command[1]):
+        await message.reply("Введите /add HH:MM")
+        return
+    time = message.command[1]
+    if await scheduler.remove_task(sending, time):
+        await message.reply(f"Успешно удалено время {time}")
+    await current_tasks(client, message)
+
+
+@app1.on_message(filters.chat(config.admins) & filters.command('switch'))
+async def switch(client, message: Message):
+    """ вкл/выкл пересылки """
+    if Sending.SEND:
+        Sending.SEND = False
+    else:
+        Sending.SEND = True
+    await message.reply(f"моментальная пересылка {'вкл' if Sending.SEND else 'выкл'}")
+
+
+@app1.on_message(filters.chat(config.admins) & filters.command('set_posts'))
+async def set_posts(client, message: Message):
+    """ установить нужное количество постов для пересылки """
+    global g
+    try:
+        set_number_posts(int(message.command[1]))
+        await message.reply(f"Количество постов {get_number_posts()} установлено")
+    except:
+        await message.reply("Введите /set_posts число")
+
+
diff --git a/bot/loader.py b/bot/loader.py
new file mode 100644
index 0000000..3ab7aa3
--- /dev/null
+++ b/bot/loader.py
@@ -0,0 +1,14 @@
+from pyrogram import Client
+
+from bot import config
+from bot.scheduler import AsyncScheduler
+
+api_id_1 = config.API_ID_1
+api_hash_1 = config.API_HASH_1
+
+app1 = Client("cyprus_off", api_id=api_id_1, api_hash=api_hash_1, workdir='bot')
+
+print(f'client is wait ...')
+print(app1)
+
+scheduler = AsyncScheduler()
diff --git a/bot/loader.py.save b/bot/loader.py.save
new file mode 100644
index 0000000..2c487be
--- /dev/null
+++ b/bot/loader.py.save
@@ -0,0 +1,11 @@
+from pyrogram import Client
+
+from bot import config
+from bot.scheduler import AsyncScheduler
+
+api_id_1 = config.API_ID_1
+api_hash_1 = config.API_HASH_1
+
+app1 = Client("cyprus_off", api_id=api_id_1, api_hash=api_hash_1, workdir='bot')
+
+scheduler = AsyncScheduler()
diff --git a/bot/scheduler.py b/bot/scheduler.py
new file mode 100644
index 0000000..32bc00c
--- /dev/null
+++ b/bot/scheduler.py
@@ -0,0 +1,37 @@
+import asyncio
+import time
+from typing import Callable, Awaitable, Coroutine
+
+
+class AsyncScheduler:
+    """
+    Запускает, останавливает ассинхронные задачаи в заданное время
+    """
+    def __init__(self):
+        self.tasks = []
+
+    async def task_runner(self, task: Callable, run_time: str):
+        """
+        Запускает задачу, которая выполняет каждый день в заданный run_time
+        :param task: await Функция
+        :param run_time: строка "HH:MM"
+        """
+        while True:
+            current_time = time.strftime("%H:%M", time.localtime())
+            if current_time == run_time:
+                await task()
+            await asyncio.sleep(60)
+
+    async def add_task(self, task, run_time):
+        """Добавление новой задачи в определенное время"""
+        task_instance = asyncio.create_task(self.task_runner(task, run_time))
+        self.tasks.append((task, run_time, task_instance))
+
+    async def remove_task(self, task, run_time) -> bool:
+        """Удаление сущесвтующей задачи по функции и времени"""
+        for t, r_t, task_instance in self.tasks:
+            if t == task and r_t == run_time:
+                task_instance.cancel()
+                self.tasks.remove((t, r_t, task_instance))
+                return True
+        return False
diff --git a/bot/sending.py b/bot/sending.py
new file mode 100644
index 0000000..df6d0e4
--- /dev/null
+++ b/bot/sending.py
@@ -0,0 +1,108 @@
+import asyncio
+import re
+from datetime import datetime
+
+from pyrogram import Client
+from pyrogram.types import Message, InputMedia, InputMediaPhoto
+
+from bot import config
+from bot.loader import app1
+
+from random import randint
+
+
+NUMBER_POSTS = 20
+
+
+def get_number_posts():
+    global NUMBER_POSTS
+    return NUMBER_POSTS
+
+
+def set_number_posts(x: int):
+    global NUMBER_POSTS
+    NUMBER_POSTS = x
+
+
+async def sending():
+    """
+    Функция для пересылки по расписанию.
+    """
+    await forwards_to_chats(config.rent_channel_id, config.sell_channel_id, config.groups_for_rent, get_number_posts())
+    # await forwards_to_chats(config.sell_channel_id, config.groups_for_sell, get_number_posts())
+
+
+# contains date: client: media groups
+class DailyAlbums:
+    todays_albums = set()
+
+    @classmethod
+    def add_album(cls, client: Client, media_group_id: int):
+        album_key = (client.api_id, datetime.now().strftime('%d.%m.%Y'), media_group_id)
+        cls.todays_albums.add(album_key)
+
+    @classmethod
+    def contains_album(cls, client: Client, media_group_id: int) -> bool:
+        album_key = (client.api_id, datetime.now().strftime('%d.%m.%Y'), media_group_id)
+        return album_key in cls.todays_albums
+
+
+async def fetch_posts(chat_id: int, daily_albums: DailyAlbums, limit: int):
+    """
+    Получает посты из чата, проверяя, что они ещё не находятся в daily_albums.
+    """
+    posts = []
+    async for post in app1.get_chat_history(chat_id=chat_id, limit=200):
+        if post.media_group_id and post.caption and not daily_albums.contains_album(app1, post.media_group_id):
+            posts.append(post)
+            daily_albums.add_album(app1, post.media_group_id)
+        if len(posts) >= limit:
+            break
+        await asyncio.sleep(0.1)
+    return posts
+
+
+async def forwards_to_chats(rent_channel_id: int, sell_channel_id: int, groups: list[str], limit: int):
+    """
+    Пересылает посты из rent_channel_id и sell_channel_id в группы.
+    """
+    if not groups:
+        return
+
+    daily_albums = DailyAlbums()
+    messages = await fetch_posts(rent_channel_id, daily_albums, limit)
+    messages2 = await fetch_posts(sell_channel_id, daily_albums, limit)
+
+    all_messages = messages + messages2
+    for i in range(min(limit, len(all_messages))):
+        await forward_post(app1, all_messages[i], groups)
+        await asyncio.sleep(config.spam_interval)
+
+
+def is_valid_time_format(time_str):
+    """Проверяют строку на формат HH:MM"""
+    time_pattern = re.compile(r'^[0-2][0-9]:[0-5][0-9]$')
+    return bool(time_pattern.match(time_str))
+
+
+def check_stop_sign(message: Message):
+    return "⛔️" in str(message.caption) or "⛔️" in str(message.text)
+
+
+async def forward_post(client: Client, message: Message, groups: list[int, str]):
+    # === СТОП ЗНАК ===
+    if check_stop_sign(message) or not (message.caption or message.text):
+        return
+    # ===============================
+    for spam_group in groups:
+        group_id, reply_id = (spam_group, None) if '_' not in str(spam_group) else list(
+            map(int, str(spam_group).split('_')))
+        try:
+            if message.media_group_id:
+                await client.copy_media_group(chat_id=group_id, from_chat_id=message.chat.id, message_id=message.id,
+                                              reply_to_message_id=reply_id)
+            else:
+                await message.copy(group_id, reply_to_message_id=reply_id)
+        except Exception as e:
+            print(f"Ошибка: {e}\n\nГруппа: {group_id}\n\n-----------------------\n\n")
+        await asyncio.sleep(2)
diff --git a/bot/test.py b/bot/test.py
new file mode 100644
index 0000000..e704b13
--- /dev/null
+++ b/bot/test.py
@@ -0,0 +1,11 @@
+from pyrogram import Client
+
+api_id = 29370778
+api_hash = '9beeb54652c5ce4f323d67f57dc233be'
+
+with Client("my_account", api_id, api_hash) as app:
+    # Идентификатор чата, из которого вы хотите получить сообщения
+    chat_id = "your_chat_id"
+    # Количество сообщений, которые вы хотите получить (максимальное значение - 100)
+    me = app.get_me()
+    print(me)
diff --git a/main.py b/main.py
new file mode 100644
index 0000000..31696fb
--- /dev/null
+++ b/main.py
@@ -0,0 +1,22 @@
+import asyncio
+
+from pyrogram import compose, idle
+
+from bot import config
+from bot.loader import app1
+
+from bot import handlers
+from bot import album_handler
+
+def main():
+    print("Bot started.")
+    # compose([app1])
+
+    print('test')
+
+    app1.run()
+
+
+if __name__ == '__main__':
+    # main()
+    main()
\ No newline at end of file
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..dbc7d52
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,11 @@
+croniter==2.0.1
+pyaes==1.6.1
+https://github.com/KurimuzonAkuma/pyrogram/archive/dev.zip
+PySocks==1.7.1
+python-dateutil==2.8.2
+python-dotenv==1.0.1
+pytz==2024.1
+six==1.16.0
+TgCrypto==1.2.5
+tzdata==2023.4
+tzlocal==5.2