ZThW'ddlZddlZddlmZmZddlmZddlmZmZ dZ e dk(reje yy)N)datetimetimezone) SiftClient)CalculatedChannelUpdateChannelReferencec Ktjdd}tjdd}tjdd}t|||}|jj d }|j }t d |jd |d d }tjtjjd}t d|d|dg}t|D]} |jjd|d| d| ddt!ddt!ddgd|gd| } |j#| t d | jd | j d |jj%d!|"} t d#t'| d$| D cgc]} | jc} t d%t d&|d'} | j)t+d(t!ddt!ddg)}t d*|jd+|j,t d,|d-}|j)t+d./}t d*|jd0|j.t d1|d2}|j)t+d34}t d*|jd5|j0t d6|d7}d8|d9}|j)t+| }t d*|jd:|jt d;|d<}|j)t+d=d>?d@A}t d*|jdBt dC|j.t dD|j0t dE|j2t dF|dG}|j)t+dHt!ddt!ddt!dIdJg)}t d*|jdK|j,t dL|dM}|j)t+gN}t d*|jdO|j4t dP |j)t+dQt!ddg)}t dR|j,t dTd'}|D]/} | j9t dU| j|d-z }1t dVt dWt'|dXt dU|dXt'||k(sJdY|dZt'|||k(s JdY|d[|t d\|j,d(k(sJd]|j,d^|j.vsJd_|j.|j0d3k(sJd`|j0|j|k(sJda|j|j.d=k(sJd_|j.|j0d>k(sJd`|j0|j2d@k(sJdb|j2|j,dHk(sJdc|j,t'|j:d7k(sJddt'|j:|j4gk(sJde|j4|jj=| j dfg}t d#t'|dh|d'jt dit djycc} w#t6$r}t dS|Yd}~d}~wwxYww)kN SIFT_GRPC_URIzlocalhost:50051 SIFT_API_KEY SIFT_REST_URIzlocalhost:8080)grpc_urlapi_keyrest_url NostromoLV426)namez Using asset: z (ID: ))tzz %Y%m%d%H%M%Sz === Creating z) calculated channels with unique suffix: z === test_channel__zTest calculated channel z - initial descriptionz$1 / $2z$1zmainmotor.velocity)channel_referencechannel_identifierz$2voltagezvelocity/voltagez,Created for testing update fields - channel )r description expressionchannel_referencesunits asset_ids user_noteszCreated calculated channel: ztest_channel.*) name_regexasset_idzFound z calculated channels: z/ === Testing comprehensive update scenarios ===z9 --- Test 1: Update expression and channel references ---rz $1 / $2 * 100)rexpression_channel_referenceszUpdated z: expression = z# --- Test 2: Update description ---zQUpdated description with more details about velocity-to-voltage ratio calculation)rz: description = z --- Test 3: Update units --- percentage)rz : units = z --- Test 4: Update name ---renamed_channel__5z -> z6 --- Test 5: Update multiple fields simultaneously ---zMulti-field update testratio)rrzUpdated via multi-field update)r:z - description: z - units: z - user_notes: z/ --- Test 6: Update with complex expression ---z($1 / $2) * 100 + ($3 * 0.1)z$3 temperaturez: complex expression = z --- Test 7: Update tag_ids ---)tag_idsz : tag_ids = z5 --- Test 7b: Edge case - Invalid expression test ---invalid_expressionz2Invalid expression update succeeded (unexpected): z.Invalid expression update failed as expected: z! --- Test 8: Archive channels ---z Archived: z === Test Summary ===z Created: z channelsz Expected z created channels, got z archived channels, got z === Validation Checks ===zExpression update failed: z more detailszDescription update failed: zUnits update failed: zName update failed: zUser notes update failed: z"Complex expression update failed: z1Complex expression should have 3 references, got zTag IDs update failed: )calculated_channel_idlimitz versions for zAll validation checks passed!z$ === Test completed successfully ===)osgetenvrassetsfindid_printrrnowrutcstrftimerangecalculated_channelscreaterappendlistlenupdaterrrrrr/ Exceptionarchiver list_versions) r rrclientassetr! num_channelsunique_name_suffixcreated_channelsicalculated_channelsearch_resultscc channel_1updated_channel_1 channel_2updated_channel_2 channel_3updated_channel_3 channel_4new_nameupdated_channel_4 channel_5updated_channel_5 channel_6updated_channel_6 channel_7updated_channel_7invalid_updateearchived_countversionss v/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_client/_tests/integrated/calculated_channels.pymainrd&syy*;> !3 4AaS921#5KL  4L`a 4IV %jEaSI?    23 *+=+B+B*C6J\J`J`Iaab c  &//44#5N F3~&''=Q_>`2rww>`=a bc <= FG #I!((& 4L`a 4IV+  H&++,O K)//0 12 .99: ;< <= #I!((5 4L`a 4IV 4MZ+   H&++,,CDUD`D`Ca bc ,- #I"((   H&++,L9J9R9R8S TU BCD")) #/$*.CW/    B>C\C\B]^_  ./N  277)$%!  "# Ic*+,I 67 J~&i 01  L 0 L>!8=M9N8OP 0 \ ) L>!9.9IJ )  '(  ' '? : $%6%A%A$BC : .:: : %&7&C&C%DE :  " "l 2  1 7 789 2  ! !X -^1EFWF\F\E]/^^ -  ( (,E E %&7&C&C%DE E  " "g -`1FGXG^G^F_/`` -  ' '+K K $%6%A%A$BC K  ' '+I I ,->-I-I,JK I  33 4 9 ;C@Q@d@dqcBCCDs?F ]:"]5K]:A]J ]: ]7]2,]:2]77]:__main__) asyncior4rrsift_client.clientrsift_client.sift_typesrrrd__name__runrcrmsA ') 2O3d zGKKrl