From cc57addcc71424830ccb7852d8f1e2f8e6e351c3 Mon Sep 17 00:00:00 2001
From: Frostebite <jas.f.ukcmti@gmail.com>
Date: Mon, 18 Sep 2023 23:55:33 +0100
Subject: [PATCH] hashed logging k8s

---
 dist/index.js                                 | Bin 19481287 -> 19481376 bytes
 dist/index.js.map                             | Bin 13784689 -> 13784802 bytes
 .../providers/k8s/kubernetes-task-runner.ts   |   5 ++++-
 3 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/dist/index.js b/dist/index.js
index c2228c0bef2af27444f44ae2f20c5f63df78f9d4..9e30fcc78711a7100f921834d13431bdd2fdaf99 100644
GIT binary patch
delta 1293
zcmWmEWmi-I7)9YVmmIpgQ?R=gRP4fTvAeqw2@xqry|x$_*n))tCI%*UccFqEsIcD;
z&tB&joV=KHZCY%)HZoe1rG%-v;&@Bdr%(x2b5$is%`H%j)uPNKLp3qV)J|9Iudjxw
zO1PRGqGzK<gu2@5yh_b=DXIE#C8`2F$Tol>j9?5cOkfH#n8N~=u!1#gU<*6g!vT(P
zf-_v;3OBgJ1D^1LH+<j=Klmd6fhdO{1fx7Epdu=vGOC~|s-Ze+peAaeHtL`*>Y+Xw
zpdlKeF+vcECTNOg2t#wUKufejYqUXIv_pGzKu3h56FQ>{x}qDpqX&AT7kZ-)`l28D
zBLV|35Q8unLogJ>FdQQ=5~DC0V=xxuFdh>y5tA?(Q!o|NFdZ{66SFWIb1)b45Q+JS
z!U9Ai2C<04Ld0Vc60jJFNJ27FkcuVHVJVhjIaI8`O02?atif8W!+NA)12$q4HX|Kd
zuoc^|9U0hxo!Eul*n_>;hyBPz77pMb4&gA4AR9+<499T-ImpFHoWg0G!C9O`9?s(e
zF5(jMaT!-|71wYbH&B3^xP{xegS)tg`*?tdc!bAzf~R<f=Ximac!k$^gSU8x_b9{%
ze8eXdp%|a>1z+(E-|+)K@e9B42POE6fB28mgc4Pg42dGqljutfB!&_riLpd0F_D-`
z%p~R#3yGz~N@6Xsk=RP?B=!;qiKE0x;w*8IxJuk4?h+4)r^HL*E%A}~O8g}Lk^o7d
LCWo8Q<Y$xtyb%rO

delta 1252
zcmWmEXPgfN9LMq3{mrxY9_MV8hL8}YtE`X{4N?)J6rm8Oth!1H|5GZXD~V)Ogrud6
z21QA<P{}I0jQ8)s`}6So@H=~AZtD68xv5#>Q<f((lF7}<M3-b{GSM}el|8l8q|BTI
zdB{sX@>76<q*92&6rm`^C{77V5*wu{Ls`mEo(fc?5|yb!RjN^)G-{AeO=?k_I@F~e
z^=ZHbT*yT<<YF%2QZAzrm(!RgH027KaV5=ZK})Wp6|K3NYiPr@WN;nVa|3N@M|(QZ
zksIkmXS#3`UCE>yH`ARS+`_Hg#_jZ^7kAK`JGqOy=|f-cp&$Jjz`YD)5chFEgL!}l
z8NyH=Vi?02!NWYlNJcT5M;XIdvKYr>JkEF~Fp)`2<_Vr8o2Pi1XPCmXOyxPAXByL)
zL6RJ1@&Ye1i<fwrSD4Kl<}#00$>lX(XFhMRfHzslBHm&#Z?lA@EMqzE@GkGMf|b0_
zDps?G4_M2Gtm7j-<`X{UGuHDtU$B9VY+^HC@)ck64O`gCw|vJow(~tdu!A4j$xrNJ
zH$U?Wzw#TuvxmLx;}8DiFZS~{2RO(f4s(Qm_?M#`<2WZc$th0rAOCZPvz*J$%t@I-
zBoWCI$s5TR$sZ{YDHutO6p9p%6p0j#6pIv(l!%m!l!}y&l!=s$l#7&)RESiJREkuN
jREboLREt!Pq(y2((jzq^wIa16bs}|B*1Cz5O$*Kg9aTO#

diff --git a/dist/index.js.map b/dist/index.js.map
index a63185771fea8d43af37d9cbe0acd6719b3614b2..0ef0fb494841be3b9d90df3e37e02c8d46889848 100644
GIT binary patch
delta 966
zcmWO1`CH3z0KoBQHfwFEP0F^ur5wY`ef4Ea%DIRPxpL%Yj&dK7qJ?5aA0qb^O>=%J
zM{YwJe}Tv22fy$<{pNZ0cpmQ`UVp%=qcN!c;SXv9xh@fsW8y_?p-H23NYNRpnq;$H
zX=snKsl<1`(V*1XO?tHm6`2g8?WfwK_&ln5wJ^GjhVro68+NPE32JE28Cpa@he+sQ
zKoq(l8Zj`!gszB1H^d<x-C>3WRwe9CDElQ!!+xCz{7Z}w#VrYT@z)`x315>%C+ucx
ziYReNdE(D+DNfAr$~KXiWYu_Or-Vc#p$C$Yf}ZGw-sl4x`l28D!;Vy>VE_hV5C&ri
zhGH0oV+2NG6w)DMG{(RICo(V=nHYyGWMe!gU?L`AGN!<V98ASD<YGFwIrA_RZp^}L
z%t1cpVjkvW0T!YFi?A3=uoQ(@hUHj+l~{$<ScA1#2M^X`12$q4icpNr*n+LthV9sa
zo!Eul*n<-6#Xgi`Kgv*!12~8Zcu|Q%IE*8xLN$)!7<@R66R5#SoI))GPU8&fa2DrK
zkMp>Ii@1c#xPq&=hU>V2n`po-+(sk(xPvAHa2NM*9}n;lkD%Z&o}d{mc#3Cuju&Xf
iOT5Bsyun+%!+U%{5FhagpV5XdXh#TN71{YM-SQu*@^3!?

delta 902
zcmWN@=T;5?007XF5h`Rv60%A59*Jxc*?aH3_l~kf`0PEBBJ)$Sg>0Un;{_aV;QqMh
z+&}rHq5twqLkm)eXU9c{1y>bCCWU0jWrPO{e?&C5=&<y%l+3b}5Xw=W3REPNN>ru_
zVT2PwRjN^)NNP}%TGS?rI@Beadc*|FQtIdZ4a6kIrUjCV>&FL5`oty#vT|agGIJAS
zX+T375l3U1(3EC0rv)u(MQh?|LjrASM|(QZkxq1`3tj0(cY4s1Ui799iS#9je)K1q
z0SsgigBik5hB2HGq%e|HMlqT+#xRy~jAsH9nZ#tKFqLUcX9hEw#cbv<mwC)*0Sj5g
zVwSL!Wh`d}D_O;A*07d!tY-ro*~DhHu$66WX9qjk#cuYH&R+JBK_>e-z(Edim?IqJ
z7+D<W1lgSA6sHMrhO?aGJQujgB`$M?t6bwcH@L|yZj-|ua=A+$`P}0^1w7y(k9f=z
wo)Y94g%t6eVqWl)SG?v8Z+XXiO8CG>K2geNzVMZAeCG#0`4!Af{N1D8e-pl<&Hw-a

diff --git a/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts b/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts
index b1e1c3f5..970671a1 100644
--- a/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts
+++ b/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts
@@ -66,7 +66,10 @@ class KubernetesTaskRunner {
           shouldCleanup,
           output,
         ));
-        FollowLogStreamService.DidReceiveEndOfTransmission = RemoteClientLogger.HandleLogChunkLine(message);
+        const result = RemoteClientLogger.HandleLogChunkLine(message);
+        if (result) {
+          FollowLogStreamService.DidReceiveEndOfTransmission = true;
+        }
       }
       if (FollowLogStreamService.DidReceiveEndOfTransmission) {
         CloudRunnerLogger.log('end of log stream');