From 6bd6fddf40f51c4cbdfee28bc32a4603edb2674a Mon Sep 17 00:00:00 2001 From: Frostebite Date: Wed, 20 Sep 2023 21:11:36 +0100 Subject: [PATCH] hashed logging k8s --- dist/index.js | Bin 19481616 -> 19481773 bytes dist/index.js.map | Bin 13785032 -> 13785214 bytes .../providers/k8s/kubernetes-task-runner.ts | 25 ++++++++++-------- 3 files changed, 14 insertions(+), 11 deletions(-) diff --git a/dist/index.js b/dist/index.js index 7509a921288c9e727389c9b0d12a2941830c19cb..c9d2ab79172d8343c968fc469e61bd34c18536c1 100644 GIT binary patch delta 1484 zcmZY9X;f5Y7{Ku}cLo?37?9l=mJ6~4MUj=Z34~d;S=vTY4Y3G9!vsuZX`x|&q{3Y6 z7Ad|2g+Q@AH0qn;SZOyBa%uYwHX> zN>58tm8-n8TCH$byWG`kL5bU0rsg{f)e=%(q`HbK)$&qjk>2exN5vc&R}>#To+GEz zCoV{F?0k7Cn@RinS&-=bvdwS5_8LxJw&QKso?yTwZz9FN!YJxZE3mT1x)U1l58 zPLGl?@ok-MOw~=A62i|IO|c(a$nyxSg43YJfr^ zcn9xd2=C#2e1Kt$U^BL0E4E=fM)4tb;3MqBE_{qnup4{uDL%vJ_yT*e4`1Rde2s7L zExyC|_yIrSC;W_GFos|88}{ROjN=ddiNA0F2XP30;~)Hs|C)wd4XYthBu0rz;wABx z_(;qWUx}Z@BJr05NUV}TNswfcBv=w636+FN!X*)sNXcZ0O=6csNunh&l30l@cm5`Awki&vceqG5#~{Yf(Z~ z!yX%Z)zDRIr*^R@mHu0?T9j&u4h~LgYO=SZ+Nhno`?QDz1zPA}16$a^9(v?}19Bo4 z9N~oA$OC7%z!h$gn;ysuPvk>>c)=S!@Pz?J_`x3m2t*JHpdbn%7$GQ(A_zrM6hm>8 zKuMHBX_P@2%Ay>~qXH_T5-Ot#s-haIBOEnQ6SYtqbx;@eP#+D@5RK3nP0$q0&>St$ z60Oi0ZO|6&&>kJo5uMN(UCcO{6TQ$Ieb5&X=!gCofPol8F$}{o z0wXaBqcH|!F%IJqg9(_3Ntlc&n2Kqbjv1JVSj@s~%)wm5As!}}VL<{Cp<*89BMA$z z5R0%FORyBlScc_TffTI7Dy+sDti?L4#|CUfDmGy=wqPsLunpU>13R$`yRip*u@C!k z00(ghhj9c)aSX?C0w-|_r*Q^naSrEk0qMAiOSp_HxQYy9;u@~w25#aOZsQKJV8vbB z!+ku!Lp;J`Ji${u!*jgAOT5Bsyg@eJ;vL@O13uytKI03%;v2r>2Y%vLY(#=)E+mRX zE73`8B(@SeiM>QG$suu&F7c4$m3T_>N%Bj)B;FDq ciLb;UF-rU-{*nMmpd?6AKy!d^LKB|)8$Fta4*&oF diff --git a/dist/index.js.map b/dist/index.js.map index 2e6986657826b65beaa79945b0371c454c6b83c5..c5cdd42a90d64902e5b71e38431deb5e493fc6af 100644 GIT binary patch delta 1216 zcmZwASyaqn7{~FG>dzRH`54N_H6f^dIR`H8}J9UOK; zh0xeEYEj*+o@X~SmMH%1o%h3h)SfLr@%fYIN~bl`!_hjHR9Yi%)FdzR5KTrOb%8sn z*q!8oHt>WOydj}2+Chc(P@@Anq7ynp10QsO7QW~TKXijX0?^&*PSSn-7?Nww&ax;u zc@}e?MKNaPnN}!irgSBfCp$wiXRKDTvrHMn{w2UyL<~~YK|gnLmj23&ZHa`pwuGjp zq?m-cT-R0D^nq&OaLFp+ij>EQ^7qr)c^E~2UXBq>)?hE8vCF+glTGI>^7V39X=<`0 z4BK_u--}Q5@~|>Pnj{u~ltV@TXj$vsdR8Rv>mK+g>?N#Ga?gLlwNdim)+=SXI!TzT zgH+#$T+G9KEI=|+un>!|7^z6Z5*U$=3@pVmWFia8u>#px2@`T) z#wx5vE-c8y8mz@StVcdJU?VnRGq%8rt=NVF6ru>*QH&kfiCx%@J=lwV*bf`*IDiry zL@CN3a0rKS1V?cU4jjh`l;b2$;WW;m0%vg!=WziSQHe{qj4QZ`DqO>L+`vuT!fiNl v2X}D~)wqubc!)=+K`rX=7*FsN&+r`eXuu1+gbR&$h1YQ7jZ=zwTi4?URgR$I delta 1065 zcmZY0*;mYA7{Ku}W}2v!DMM4gv@oG;DViA-ijeHaHX&=aG&I?%RK_lbUc2mxG}fPG zs*$ZR2)8cAMgM^dcOBny)p7AT=Xsy!{dPJ%>b6FY+F6w&%Kn4~%9&b4hQbjO9w7g0 z4~qXcc@s2&%C4R0>`)fU)ydjArJR-<>`-(!6+W}wXI7vWlu*GBYWSl!`XB&-2tr>3 zBLw}RK`6q|A6g8+K!ihw2-#$^sjRz`*jcT0rM?lMV;!XQK=2C<04U<`pC@feC>7>)!aVgyEF6h>nVk}wv@NWnOa zM=A_3!h{J(Lpm}r5tA?(naIKvOhq=PVLE0Y2Q!h2S(uGEn2ULsj|Er=GZtYnmS8EC z!Gb(2#|o@OK2~8h)?h8xVLb}40UNOio3RCj*oq=pu?^c%3>!+Y13R$`yRip*u@C!k z0Hr8HIS!%%m8ilY*l`#~a1_UI94BxRr%;X4I0FaH;v8xqa2^+M5tncoS8x^AP>buh zft$F6+qi?fsKY(f<31js0T0m#Cm!K3p5Q5-;W=cyz)QTsYq-#aX0*VKH)zFMyu*8Z az(=&fgHQ0{Grr&}+VKtFWtZtkYt&!W`{%O& 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 7b70d72d..45d91424 100644 --- a/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts +++ b/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts @@ -36,17 +36,20 @@ class KubernetesTaskRunner { const callback = (outputChunk: string) => { output += outputChunk; - // check if log start included in logs if so log a message - if (outputChunk.includes(`Collected Logs`)) { - CloudRunnerLogger.log(`Log Start found in logs`); - } - if (outputChunk.includes(`LOGHASH:`)) { - RemoteClientLogger.HandleLogChunkLine(outputChunk); - CloudRunnerLogger.log(`Loghash found`); - } - if (outputChunk.includes(`LOGS:`)) { - const result = RemoteClientLogger.HandleLogChunkLine(outputChunk); - CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}`); + // split output chunk and handle per line + for (const chunk of outputChunk.split(`\n`)) { + // check if log start included in logs if so log a message + if (chunk.includes(`Collected Logs`)) { + CloudRunnerLogger.log(`Log Start found in logs`); + } + if (chunk.includes(`LOGHASH:`)) { + RemoteClientLogger.HandleLogChunkLine(chunk); + CloudRunnerLogger.log(`Loghash found`); + } + if (chunk.includes(`LOGS:`)) { + const result = RemoteClientLogger.HandleLogChunkLine(chunk); + CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}`); + } } }; try {