From 2b9d37cc2f602605081f66484bbd884a15526cad Mon Sep 17 00:00:00 2001
From: Kristjan Komlosi <kristjan@piskot.si>
Date: Sat, 17 May 2025 23:35:13 +0200
Subject: [PATCH] async fetch to limit load

---
 __pycache__/main.cpython-313.pyc | Bin 10873 -> 10987 bytes
 main.py                          |   2 +-
 wall_messages.db                 | Bin 28672 -> 28672 bytes
 webroot/index.html               |  30 ++++++++++++++++++++++++++----
 4 files changed, 27 insertions(+), 5 deletions(-)

diff --git a/__pycache__/main.cpython-313.pyc b/__pycache__/main.cpython-313.pyc
index 987dcb2cab1093f606da7cab6b9fa53e6df42d33..1046649e58b3eadd69051f129127cb17fabda385 100644
GIT binary patch
delta 1529
zcmZ`&TWlLe6rEYWQYY&;yLP+}XZ^^!_9iZkt2n7cKu}1KXlRQkCY8LRic*uh#p`I-
z65=aCh=)M54O2D!tPn!{A>j}H_^1HE2U46MoLW38R0SbENEK88st_}FlDeW9&78gW
z+<WKTo!R|+`u7~W&9ZJlhWu~h-1agn!n@1yRk;fQ<TgdUBMNj8b)v2zh}aBcN+$!$
z_k=|UDcFssAuT7qq{Apkw;W)~x`)(C$diF)Q15Pw^a&seP`3n-SMN*PS_P)kWP1q9
zwXvZl%M;e8JNI%OVZASV49~iFG_j-C_GpQQfi7pCX`^>c<lk)=^-A~KRZ&0!W=!wR
zPGPU$bL%lAATh&aPvV*^;Yp@HkZATIkzVAsUNpSK_!kF=Sn45SimsthhC$&rslk16
zBl<uyH`<n)B)R#A>>Js8iGF=xm`Ng40_W{}hyTbv5;6U-9>!1D{F$MBGU9r;*+fE5
z4Kql4VAmt0W*%R(g`T3Zfd^v4BzEEdjp{raJPgTEQlu-HaWrqHgtu%m6mXaQm+Bw(
zzdD`cq*x2$%RxVGD4wdf=Q{>YS8wxQG0dk7z9e7AQ-R}<!#}c0C$b|)1{$_J2k<>s
z#xF8%d^_Ot7<R(!jI2cN(Qk96A^s^Kc??IsZ#R@za8d{|*$BN_hIr=$#hYW0D+3Ra
ze<5ef*>ev3p>S;RbSkUvR^5M&4FGWZ$$cZw?-xNG8Moog5AN=iBh9t!FvvMopdC2z
z+ZDq6<DDv&iWMu2(_&aMpCdWu2@0nOXt3e33Ug)StcA;B8upSS3*j%sUIEdRX$m<C
zFHo2vfNzSjpT33}qi~QymVoBMDM`#XOB$W#Z0XEG!JI1?l}6XuqIF@<<E&S$N}+V7
zXuMQ5OS6??*|1!sKHM6nM(jq%e4*0Hc!Rial4bQkycrzFpG&=ub3&a{*Esd#xf*w5
z>G%)SkFRm@bxx~usT!9e952>+b&XfAqjg@Z^Qju2TAKRP2_yx7FGUY*bOq>SMVypn
zb;B2`_m9@d^o?%tN<BJKBa<K5@P+H@(Hfb)qt#RLyU_6#Y2}0Jt)QQQZ{xd4#_<jz
zKB*3eeuj?sh<T$bM81XaBHoN9-B$?l4O!L<F2^3N&h%e`@G|~Y9f8YOiN)ai_~}^0
zu|hJ|s^?=2grm50@Jr6@CQQRwFy@O!p<$a{SimSgH$+dur1}l}LfNXARJmb)xkyZ^
zY(7STN}5+Gtl-V~u=_J&(yzjr!fIk-oF2kWR=PI6I{NI_6RRWH8jD_=yv6%h#+Jvf
w88!aUPJEqBEKT0&04~q##U<MvC-4UGM~NHVB2>0*fQfH0#M&CEzM?VkKZL$IMF0Q*

delta 1359
zcmZuxU5Fc16rMYoY&XeF(#`)&l1V0Mnq-q~yFXE)7C}_X%5G(DgOv=FwHv#U-6YNg
zQ4me3)`f~~y%t4K`dEA`LEn54UHVc?wh!5c1-pWXy5g4gK|#cGlO|2U%iNFi^PO+b
zJ@fNh;qQ~ez93i`Snu3Rt~`B35YgV1M9bn}7;M!h)G4wPbiHj!06{}hCP$gDbP?Nh
z33dQ>5L@+-HXdcP5azLP6k&Uw)n&~N5g9x3NDpg{k=lr#i8A=0#NY`nk~7^`RC-Y-
zL|r4%D2*P+ZU}p{u^~C8MbzW{!ckP88}<5jzl8{+iRuD9jN;9qeg^xb2M0=Ezr^TC
z&8w=U<#SuLB(`BO&#DD-E*K<>tb)>{#(DyoUY|i|C^XVg7UZX?yeMlK9L}>iG9o@T
z%qm*8myM2Ok3e>b))JeE_hsi;d`Mzm;fAxG9#n_p+Kd)6L-#$6!y_8A1CEl=V!doq
zn**iPLrOVdt<gK3NDPP2=S@DudlY!D{?8~~IDG`cTqx3=$(wtFHK?W~t9jtLPGK8y
zazCPz%|E%nY{=UD{op@r^H<jfi(Vr)yt_8nK)C28pZkKW>VpYOEO-&S>@BdE%cCs3
zl0|7iRD<-9jAJt%%cG)17X3l;uV5qlb{7lox?kq-fgB>cc8Mz>^$=<KJ>+|T>WSjy
zK%$r#T2liHkLRrwQ*nCW7fgepM3{n!EQ_;J3Uv<{r8CvavY{^kPhX_)JOH^N=8#B!
z7IWe%jm=P)1?XDp<+ajsX|=vY0+K{-ilI}w3W*e_&r_0@l7t@N^nLBF(|E(Em)1^~
zD=$~|wWWHwS}{1_MPTVES}=aLRPU$HgL?tC@e@O~B$X9IWF-(iwaq&_yu8WF*G+9c
z)AN)~Ub)T3I()j#r?&-HN02uK`4i)|5bFr(wvgWP20Px#ws-P@;R|(qnYJ&p?F!M$
z9d2$0E+X^0aKq1<FNHiTx<FnJ=gsR7_@en$_y=UZ2<F$#PnBB;y-!wR8S94-_!hSD
z0=XA|ym=>f384>2IsOQ`M6Si-=rY-eE9R@fxYgW^vj{y#{y6-d(lssBYI+sIdW`~o
z19kWjG2O9J<!rf9A{&V_N9pl(+D@0NRgJn%8|iYZWiV+Y`Y{T$1N|ckSILXXIqR2T
z(y!iFARi~6Ii@_>c<R0RbMxzOwK;ibOgLX|nC=P_4eM49?9PVmt|QyvcP!q^Z?<Ni
my=iXEEVeBt8e?}H0pd@6<8UK+-^8$qJr=CJO!Jo%i~a-kO*0Mv

diff --git a/main.py b/main.py
index 34dcd1e..d775a54 100644
--- a/main.py
+++ b/main.py
@@ -107,7 +107,7 @@ def check_and_log_overages():
             db.add(event)
             db.commit()
         db.close()
-        time.sleep(10)
+        time.sleep(60)
 
 threading.Thread(target=check_and_log_overages, daemon=True).start()
 
diff --git a/wall_messages.db b/wall_messages.db
index 6b74bc45d44b9a250e61c54fa531788202b7ac3d..30e7fd9b6c7e2cfe7f1984193bab564712b5f030 100644
GIT binary patch
delta 193
zcmZp8z}WDBae_2s%|sbz#+r=@bM2W^Qc^ZKum~_S^UvDM9+1elae@(Jy#g~E11Bek
zqmhA;sjh*kuA#Ytk+GGriIs_oo~40_g|Vpu6B`2urV3+_3KIhZb2B3aMxY7~PBb%&
zEUb)-^vq2y3=NIB7#J9s`9Co5|Kb0}|AGG%{}cXu{5SY7@o$z)Sjazdf|&p-Gb1B2
NGl*njVrJ&#1OP=|D!Bjv

delta 501
zcmZvYJyHTe5QTSKV1L*Ga|yagEykXn>E4-1#PR}$gqWFm1UP~gv4>DH4`XozkKm35
z6tc;SzWUzl-X7HUpkA)j>UDOnR`2V#+x&Vt`&bSx^Jen2FCHEz8)!yZSyp$1#0%tw
zX@Mx(5YcP0&N&O?j;Q_<Mj{!F$RV^)_c;tl^4bOVC{Xn|(8moM9X#3KpzM=i8=cod
zf){~elvQU_Q6h_W+*(I4>aCH8tcjdMgyCt+=I>s_$f(6oHx>rHHJGlk;#peAPbJA=
zB8TXtBTy*7#rcqq@R6<djK(miU&s9Tcm`t=Vw|?vy~Nj9mNnDQeX-t8ci+zgXqsWJ
V)Oeh-u2WW3%CbyZ6uYmR`40-PS2q9v

diff --git a/webroot/index.html b/webroot/index.html
index cd0f6b5..fbe4d42 100644
--- a/webroot/index.html
+++ b/webroot/index.html
@@ -236,27 +236,49 @@
                 const cpu = parseInt(document.getElementById('cpuLimit').value, 10);
                 const ram = parseInt(document.getElementById('ramLimit').value, 10);
                 const disk = parseInt(document.getElementById('diskLimit').value, 10);
-                console.log(cpu, ram, disk);
                 const requestBody = JSON.stringify({
                     cpu_threshold: cpu,
                     ram_threshold: ram,
                     disk_threshold: disk
                 });
                 console.log(requestBody);
-
                 await fetch('/limits', {
                     method: 'POST',
                     headers: {'Content-Type': 'application/json'},
                     body: requestBody
+                }).then(async (response) => {
+                    if (response.ok) {
+                            try {
+                                const limits = await response.json();
+                                document.getElementById('cpuLimit').value = limits.cpu;
+                                document.getElementById('ramLimit').value = limits.ram;
+                                document.getElementById('diskLimit').value = limits.disk;
+                                document.getElementById('cpuLimitValue').textContent = limits.cpu + '%';
+                                document.getElementById('ramLimitValue').textContent = limits.ram + '%';
+                                document.getElementById('diskLimitValue').textContent = limits.disk + '%';
+                                } catch (e) {
+                                console.error('Error fetching limits:', e);
+                                // fallback: set to 50 if error
+                                document.getElementById('cpuLimit').value = 50;
+                                document.getElementById('ramLimit').value = 50;
+                                document.getElementById('diskLimit').value = 50;
+                                document.getElementById('cpuLimitValue').textContent = '50%';
+                                document.getElementById('ramLimitValue').textContent = '50%';
+                                document.getElementById('diskLimitValue').textContent = '50%';
+                    }
+                    } else {
+                        console.error('Error updating limits:', response.statusText);
+                    }
+                }).catch(error => {
+                    console.error('Error updating limits:', error);
                 });
             };
 
         window.onload = function() {
             fetchStats();
-            setInterval(fetchStats, 5000); // Fetch every 5 seconds
+            setInterval(fetchStats, 15000); // Fetch every 5 seconds
             fetchLimits();
             setupLimitSliders();
-            setInterval(fetchLimits, 5000); // Fetch limits every 5 seconds
         };
     </script>
 </body>