From 3acd3fafc56c3d49627774dea02e2d054797404e Mon Sep 17 00:00:00 2001 From: Lyncoln Date: Wed, 14 Oct 2026 18:28:06 -0400 Subject: [PATCH] Added recursive action behavior to recursively go over selected messages --- .../__pycache__/execute.cpython-314.pyc | Bin 793 -> 755 bytes core/apirequest/execute.py | 2 +- .../action/__pycache__/action.cpython-314.pyc | Bin 600 -> 999 bytes core/execution/action/action.py | 16 ++++++++--- .../__pycache__/operation.cpython-314.pyc | Bin 934 -> 924 bytes core/execution/operation/operation.py | 4 +-- core/manager/__init__.py | 1 - .../__pycache__/__init__.cpython-314.pyc | Bin 180 -> 0 bytes .../__pycache__/manager.cpython-314.pyc | Bin 1309 -> 0 bytes core/manager/manager.py | 25 ------------------ .../__pycache__/recursive.cpython-314.pyc | Bin 0 -> 1216 bytes .../recursiveactions.cpython-314.pyc | Bin 834 -> 1223 bytes .../{recursiveactions.py => recursive.py} | 16 ++++++++++- .../synapseassignspace.cpython-314.pyc | Bin 945 -> 875 bytes .../synapseassignusername.cpython-314.pyc | Bin 895 -> 895 bytes .../synapsecreatedmroom.cpython-314.pyc | Bin 1156 -> 1086 bytes .../synapsepushmessages.cpython-314.pyc | Bin 947 -> 1066 bytes .../synapseregister.cpython-314.pyc | Bin 924 -> 854 bytes plugins/rmass/actions/synapseassignspace.py | 10 ------- .../rmass/actions/synapseassignusername.py | 14 ---------- plugins/rmass/actions/synapsecreatedmroom.py | 5 +--- plugins/rmass/actions/synapsepushmessages.py | 18 ++++++++----- plugins/rmass/actions/synapseregister.py | 4 --- plugins/rmass/manager.py | 24 ----------------- plugins/rmass/operations/manageoperation.py | 7 ----- tokens.json | 2 +- 26 files changed, 44 insertions(+), 104 deletions(-) delete mode 100644 core/manager/__init__.py delete mode 100644 core/manager/__pycache__/__init__.cpython-314.pyc delete mode 100644 core/manager/__pycache__/manager.cpython-314.pyc delete mode 100644 core/manager/manager.py create mode 100644 core/runtime/__pycache__/recursive.cpython-314.pyc rename core/runtime/{recursiveactions.py => recursive.py} (50%) delete mode 100644 plugins/rmass/manager.py delete mode 100644 plugins/rmass/operations/manageoperation.py diff --git a/core/apirequest/__pycache__/execute.cpython-314.pyc b/core/apirequest/__pycache__/execute.cpython-314.pyc index 1bb37566f6102400c30c3132807e5e831ece3495..9c200e980f42e1784c285caba17387ad8f694e81 100644 GIT binary patch delta 100 zcmbQq_L-Gen~#@^0SNxRJ)gCGB5yC_x{0$_PmW=$AnBD1MWR5eNEk@m;;_lhPbtkwwJVaGe1u7x1tbFiIU6YZ diff --git a/core/apirequest/execute.py b/core/apirequest/execute.py index 90fb841..a2a0df4 100644 --- a/core/apirequest/execute.py +++ b/core/apirequest/execute.py @@ -22,7 +22,7 @@ def executeRequest(action, outputs, resolved): # session.cookies.set( # sessioncookies[cookie_name] = response[cookie_key], - print(request) + #print(request) #print(response.status_code) #print(response.text) return response, outputs diff --git a/core/execution/action/__pycache__/action.cpython-314.pyc b/core/execution/action/__pycache__/action.cpython-314.pyc index c67c1c39e3aff9a83f33a6033084232408e6e041..bb2910e7ec0d993c1399aeb9791e7fd6f113f11c 100644 GIT binary patch literal 999 zcmcIj%}*0S6o32CZ7T>BR*bsnni8alEru@-##lvYLqfoJ}!h2cCf;z;U?F`yqJ@Sl#_{k6AbAJkcc5CAr<+-(^3K*La&kK5oDm3 z9&$-aq=_xhu9OY0M(ire5`yWd@7chp&uR7QavX(ytS>lwEbtymj0aQz1Lng&Z->6J z1)xDOvC)qZ#tdQRTBtJ7uP0z73s4t}w+isjOtJs(NtRuT^pJ`|uZLHxCLS$C|3nJX zJnx*5AIp~Ffdx<$3i4kub?pg29Bx2C*p%nQ6+|ZFdqZ+DKQ@b%Z#zGVp_y@YBcJ2r0x-y$~Hk&8pFtSDh*WjwYpPt zk;`)@Cv{z?3z==FiZW%hVV5(wS~Y9tbA&UNgHa~9Aq+ATAcrDde?tfSo00Vk;!6yT zBf1|M+ktZhV#CeG?%Pf@`8k?AQLlHjnU*%Qw|T5BcGRUKb*Z_0a&KXGrK3)?)QR`S zWA$!pFx}PX_E*~aa%*tBx!Tp!dyT_bThDVd*VSkD#}233`kEhoxA`*;m+zmB!Qkj_ z?r1^K;5lQ^2f({Ji4SVvu4rwaE!g?p8cNCdiaxGa%8xa7RLW zh1+Ebn~N->4en1Q)E1QO;J7T|2;zD?k rZgJS;=BJeAq}mk;0=Xd17YhK156p~=jCUEd?lbs(VPj{M1?vC+Kea*T diff --git a/core/execution/action/action.py b/core/execution/action/action.py index bbbd704..524f051 100644 --- a/core/execution/action/action.py +++ b/core/execution/action/action.py @@ -3,10 +3,18 @@ from core.runtime.runtimecontract import buildRuntimeAttr, buildPreRuntimeAttr def buildAction (action, outputs): - outputs, resolved = buildPreRuntimeAttr(action, outputs) + #outputs, resolved = buildPreRuntimeAttr(action, outputs) - response, outputs = executeRequest(action, outputs, resolved) - - outputs, response = buildRuntimeAttr(action, outputs, response) + if hasattr(action, "recursive"): + for item in outputs[action.recursive["source"]]: + outputs[action.recursive["label"]] = item + outputs, resolved = buildPreRuntimeAttr(action, outputs) + response, outputs = executeRequest(action, outputs, resolved) + outputs, response = buildRuntimeAttr(action, outputs, response) + + else: + outputs, resolved = buildPreRuntimeAttr(action, outputs) + response, outputs = executeRequest(action, outputs, resolved) + outputs, response = buildRuntimeAttr(action, outputs, response) return outputs, response diff --git a/core/execution/operation/__pycache__/operation.cpython-314.pyc b/core/execution/operation/__pycache__/operation.cpython-314.pyc index d5c874aaf0a5f66ab51f8d0f56089a776b126e37..0823dbe5d3edff61af7ed8294467f0b48a60c24c 100644 GIT binary patch delta 91 zcmZ3+K8Kx8n~#@^0SLDKKA-iAX(HcrUY?@VAx7v&4Y(V-N=hn4pZ$LO@0XLmXoeqbGw0V+o@?LlBcPgC_G!MxcZy z<1O~w#Jt4x)FMAkrdtd}%s|1F44*-oZ|Ui0SwHoLP3Of*21v$;`Yr@0)Mtz4>Oi{ZtF!_Tk<8 z`4t9WpE!1-Eu($`8#TBOd1?a2K>T~$88WbQ$R*y89nzpY3Irc~pyXPThE#@4@ zqjpTD3zP@Oz5&S0w9Cd7m^{QR_KVgcF9P&IfytSrv5|*!o=V&W;Bm(Y$hG|%CEguc zrEk%Rn;6w$q1un5%=k4D&*BnhM|$Dk^AbxuPO2V5J%@ zykOf?VVBV&*=nsKB2R;wOUHuHyN4^aqL9>^uC8+fR}j<;9$hBR-emOk+HK20tsS4MSTNb`j@eV1yP z{Z9X5*KTXa(v4>`dh6gu>)=}Wb!0vAHoY}8w&Omdy91g#u$tL+r{1LXSW1hfba!f} z>+EiD_*L?G^2MkgjBCO8W-zgo+3ml)c5k!)`f}=^!MN36%xn*hn~VdRdtkLh80YnP zN{bW5jlUqRcSBd8j<|@oGsJMLpOh ZAEfHR!xx64s69Bh2Uowc9x7q(_zpyB`}P0; diff --git a/core/manager/manager.py b/core/manager/manager.py deleted file mode 100644 index 4b124f8..0000000 --- a/core/manager/manager.py +++ /dev/null @@ -1,25 +0,0 @@ -from datetime import datetime -from core.operation.operation import buildOperation - -def buildManager(definition): - operations = definition.operations - - current_time = datetime.now().time() - - for operation in operations: - if hasattr(operation, "role") and operation.role == "activate": - if definition.uptime <= current_time <= definition.downtime: - while True: - current_time = datetime.now().time() - outputs = buildOperation(operation) - - if hasattr(operation, "role") and operation.role == "deactivate": - if definition.downtime <= current_time <= definition.uptime: - while True: - current_time = datetime.now().time() - outputs = buildOperation(operation) - -# if hasattr(operation, "role") and role == offline: -# outputs = buildOperation(operation) - - diff --git a/core/runtime/__pycache__/recursive.cpython-314.pyc b/core/runtime/__pycache__/recursive.cpython-314.pyc new file mode 100644 index 0000000000000000000000000000000000000000..2826d94aebf30a82d4964efe0b466170b14caa57 GIT binary patch literal 1216 zcmeHGUr!T35TET`%h8s4P_UJN6iG@7hKmVksD^})_$L@*4pV#}CZ%2QNZY&Y-J!mi zKK2p6Mf>JA(MD>U4L%tkd;^OwJ~?}Bu^5bBz)5y?c6R1Bb2q=8j|>F?Mi7CQEJFZd4ujU-XEaiG= z;x2#-t3f+R1abzR2=5=F!_D#EF3Y#2UK&OEqxx+X?&|=Sv~}w*_`d$=B$mqfFh|84 zd0TYn$=2#(xAT{{v$6FNfI+wp+x}iehUij1(jtD7kg1C?^5rq>Pdj)SG6OX~AIN%t z%jN;wbXkt_km)*>>lCs(w7>@}X6_mV%9SFu?d%@4YZ4DLnsb?L98jA&Of=5@7Bfmt zEx?0$x@(jSF#tZ$L9$s`gvf?Ni(J|_ceui+ZJ8yT+F~xrWCDe2+6%KtwS4x#$ZM=v z%$Bem({d)G8gomIftTln7p&KPZERv2V~FHU_zfCmXhkQR(YbnbuDaZaE|nj*)L1jF z)#KVbr4e6ls_74Ex+1sID~G|RI$Kv~t3wU-c3rvC4!~%lvUZ%9udaPeEZ4)6l?QL1 zol59E3&3EcvUg}SB8ekq`dAsl!+s+&{YklTIt;^iPevddEpN231NcwBf76c%O0$qq z5mbF_V54~ESI+0%dD83}dhs~`yDC%+)kaF@6M`cP^cAvF@NS{Q=n~#@^0SKP{I-hlgc_N>LffkV0z!1j}#OTT3!C1m5&k)2U&QQXHBEk$5 zVGd$ZX3%8a=wiXhxN>qWqY;qYz$h)blI<2(N@`kWUS>&Ve%>wi{L+$w(vspLp2<%b zW5juiQj<%IiZjbngHub2M1htu1M%m{QB3U{BUBjOidcc%B5n}D2PBHwfP|Ww0uU65 z0GYS=;rbnuLFN}p0!4*@xJV2{hyw{fO_s?|m{dGLhJ&S7Lc}2kaM$vDrU=5`GXzW#BnC!nt+f)}LM!hTj(rJRU&1DZ z4`7p4M9@yG{03%z3`{XE_S5)dUlxMpzusGUl9&|JB@cACgRx|NSdL;gqX`)7`CMMUqyt?Z!IE8F5I RJ9UxzYEC9ys}p^|tA9MwG3NjP delta 276 zcmaFOwvnArn~#@^0SF#GKc6*^c_N=g{X8JAfgz3|h|!awgdvEjgfWP@gei!nggKTW zfCHo!6$G*BNFhW@ScBN~7=onz8H3n^*!38LID$BXIP{o;xPrL#81-37*n)V1c!T(Y z_<=koJ;oCDAb}E&Ai*G^Aa;GmAmJc+p&%|GLqw0YgfmDqNGymoNIXbFpD9Q(NJ^in zglpnF9Zn9%;P?=KZ&$yGCx1>p!|21zT_iYJnn_k5HLonQC_nEOdtz}(es*f!WHY8} vE+wGr7=gHW+vMF$QhX1%c>1+EwI)Pe diff --git a/plugins/rmass/actions/__pycache__/synapseassignusername.cpython-314.pyc b/plugins/rmass/actions/__pycache__/synapseassignusername.cpython-314.pyc index 910c14bba21498bf916b4de072829aa508c0ba0c..1ea7691f505aea53c0c72b68f5190e6896c7a27d 100644 GIT binary patch delta 67 zcmey*_MeSUn~#@^0SIi~ozL3Ow2|*Ulkg1|z6p{uyelW2e!%P%pL%mbrNL& delta 67 zcmey*_MeSUn~#@^0SN5Yp3hQY*~s^vN%#Q^-vr4SUKa$^Kd`fMGc~Y(keDpMEWyvs W&B4^b@!{1L+d diff --git a/plugins/rmass/actions/__pycache__/synapsecreatedmroom.cpython-314.pyc b/plugins/rmass/actions/__pycache__/synapsecreatedmroom.cpython-314.pyc index d5313b14f84c0bcd3e69f13b883b3496fdaa2fa7..361085a634565d5c96e2064acd35067f4fade297 100644 GIT binary patch delta 306 zcmW-cJxc>Y5Qca6cK7x!?j`XfF@BweC=%KI31VSkgalr#EVQ?b+k2otAmJMSf>wgP ze?hVFs|ohPRn`tSFvIf>^Ug50$+NNj%%+Uu=lA7uFtxqw2NDH4XW&OHFo?hr1pyf% zD95ll;?Rhpo$w+^7$iv1fcD%AQggLZu*f`3P^U?qR!wc9`I;7pWKD}iOOCuw2Zc`P zYjkOy@*K-93NdkjxQHBc&xaOIvfuXa{C+oUJHirJ-HO!7NxfZVuD)uz*Vi&7;8m+UkO13lj>$ZzmY&IJ~Ef(Q<>pIj`eHq5Q9$Yortsv&r zP`8@(AbMhVVj05}PneFRkt+^F@}YEJ>K=WFLWd7+VtMa=abWu0?BjMnwKU{bg5g6d LIx{}aMQr>5qzX^~ diff --git a/plugins/rmass/actions/__pycache__/synapsepushmessages.cpython-314.pyc b/plugins/rmass/actions/__pycache__/synapsepushmessages.cpython-314.pyc index a648b28163863ecf09468acf60cbdb8e39415281..cca4eafc19809029bcc52a4e79b61b5976def873 100644 GIT binary patch delta 519 zcmXxgziZn-6bEqK>16ANWyf~Z)^^gg`E5cZ&xH(KN<9_cQc6jSV;!lC9Tn*kQfP=r zF98J+=u|vs?UsL{8pW;MItfbG(pTy{cznL^-EhZ!E8psudsW+1u)hBJK603%{P;KA zm$eALZZS-icM6ccA{3y4fGQ|3p@Ie_D1+`%!N33=OqYU%R!|$QqBU4@3Dj|FxYW~x z22EH72OfB@DaMBwAA#)=kGfQppe4%C#!by5&_OM91vSuBw2nS@4WYvtJb|aM4jUeY zP1wRm7(h0Z?)LTF?wjy58gi*mcpMLoc`UW@;E0cj$?=bPsCvIQ5wUD4+Qt0i_{@Et>&|FcrHHhaS)!k!*H@K z;sdGndcE|Hyi(1mo%ZR9X+(T@8pXjGPks8??BWj-?D%*3ldip-jdEtq4hv1S>C`AH zie}F)zKpVJH)l)9!F)4o?BuMG9L`^4%X>Mq6Ki&nvs$u0?_~A;!YWyGS}q#tuKLz# bQytJ(+F1W?b^OiN7U`v#>? z_6X1xkp!5ephyN>Dv+`W)Y=r%$R(tTTt*7WSk&f{g9bWeA!jqRJX!%%o7&7`G6ma) zOv4OD!lqC}rjaFN3R$*PsX_&+Fbi`qj|&!H(PmNrT_tAy?tOjJ?K*A{Yn~g12gmMy z$BDC3KlGjRSPgvN8^;;Pn`ktk4@P0@%;;`Ht@!YL` feVOR0&iZOnj_#FRt&$XkV11rcBhDLq1*d-ioUvsb diff --git a/plugins/rmass/actions/__pycache__/synapseregister.cpython-314.pyc b/plugins/rmass/actions/__pycache__/synapseregister.cpython-314.pyc index 9f06ac302803d3143b60e1b14d8f8b51ab7c0d94..7696ee527bb6c771f858425a44cfad82dd7fa122 100644 GIT binary patch delta 236 zcmbQkevOS!n~#@^0SI=!J)iZ1X(FFQeGQP;z!1j}#OTRT!Vtt%!WhI{!W6_(!W_h^ z#}Fjx<oO#2&<^$E43x!V<(0#2LgD#I4T+WU&ERJVC5Myg_{WKv|#&KTw24pGl9o zgf&Q@ge^$0ggrVldXt$Mk8<7Oa14$Q z@%MK1n|y-NkD04TV6r5W>|_t7dM-tv3mJj9cyUt delta 346 zcmY*TJxc>Y5Z&F|yS>}wHi@4}Dm8@|C8s~Z!a~JFMk_%jV8AF|AUA612{u+Hq_Ieq zzam(w1hhDt`w968j+OXehBt5CJm$+8Dzj>Q%?Rb;`$gO8o8sMwrkI^D;M)ut2;^X) z0EyNy+joDx{{i+|`ARy2C{)5ril6AfPq{