im2 ddlmZmZddlmZddlmZmZmZm Z ddl m Z m Z m Z mZmZddlmZddlmZmZmZmZmZddlmZmZeZded ed ed ed ef d Zej?ddZ ej?ddefdZ!ej?ddefdZ"ejGdde fdZ$ejKddedefdZ&ejOddefdZ(ejGddedefdZ)ejGddedefdZ*ej?ddefd Z+y!)") APIRouter HTTPException)Any)WorkflowCopyRequestWorkflowRenameRequestWorkflowUpdateContentRequestWorkflowUploadContentRequest) copy_workflowpersist_workflowrename_workflowvalidate_workflow_contentvalidate_workflow_filename)YAML_DIR)ResourceConflictErrorResourceNotFoundError SecurityErrorValidationErrorWorkflowExecutionError)get_server_loggerLogTypefilenamecontentallow_overwriteactionsuccess_messagec t|j|\}}t|z }|jr|s t dd|js|r t ddt ||||td||j |d S#t$rt$rt$r5}t} | j|d |td |d |d}~wwxYw) Niz8Workflow already exists; use the update API to overwrite status_codedetailWorkflow file not found)r directorysuccess)rstatusrmessagez!Unexpected error during workflow z Failed to z workflow: ) r striprexistsrr formatr Exceptionr log_exceptionr) rrrrr safe_filename yaml_content save_pathexcloggers D/Users/bowang/.openclaw/workspace/ChatDev/server/routes/workflows.py_persist_workflow_from_contentr2sL&?@PRY&Z# |},    oC8rs s!oC8QR RfX`a%&--}-E    L"$S$EfX"NO$z&SE%JKKLsB BC +0CC z/api/workflowscKtjsdgiSdtjdDcgc]}|jc}iScc}ww)N workflowsz*.yaml)rr(globname)files r1list_workflowsr8@sG ?? R   h0GH0G$))0GH IIHs1AA  Az/api/workflows/{filename}/argsc*Ktt t|d}t|t|z }|j r|j st dd||jd}t||\}}g}t|tr|jdxsi}t|tr|jd xsg}t|trt|d k(rt d d||D]} t| trt| d k7r"| j\\} } t| tsHd | i} t| tr>| D]9} t| ts| jD]\}}|| t|<;|j| t!}|j#dt$j&|t|d |iS#t($r}t+ddt|id}~wt,$r}t+ddt|id}~wt $r}t+ddt|id}~wt.$r6}t!}|j1|d|t+ddd|id}~wwxYww)NTrequire_yaml_extensionr!workflow resource_type resource_idutf-8encodinggraphargsr Workflow file does not have argsr6zWorkflow args retrieved)log_typer args_countr&rr +Unexpected error retrieving workflow args: "Failed to retrieve workflow args: )printstrrrr(is_filer read_textr isinstancedictgetlistlenitemsappendrinforWORKFLOWrrrr*r+)rr, file_path raw_content_r-rDrCraw_argsitemarg_name spec_listarg_infospeckeyvaluer0r/s r1get_workflow_argsreGs #JO 28TXY  m}, !):):)<')()  ))7); 3M;O<%' lD ) $$W-3E%& 99V,2h-8})3>*4(5 !))$5Ta$15.-9)(C8$4:H3E%i6(1#-dD#96:jjl U=BS(:7C)2  H-!)"#$ %%%"4y  ~  s3x(    s3x(   ! s3x(    "$S$OPXz"Z[!CC5IJ   sTJEG%0A4G%$J% J.H JH** J6I J1J  JJz/api/workflows/{filename}/desccbK t|d}t|z }|jr|jst dd||j d}t ||\}}d}t|trV|jd xsi}t|tr1|jd xsd}t|d k(rt d d|t}|jd tj|d |iS#t$r} t!ddt#| id} ~ wt$$r} t!ddt#| id} ~ wt$r} t!ddt#| id} ~ wt&$r6} t}|j)| d|t!ddd| id} ~ wwxYww)NTr:r!r<r=r@rArC descriptionrrEzWorkflow description retrievedrGrrIr&rr rJrKrL)rrr(rOrrPr rQrRrSrUrrXrrYrrrNrr*r+) rr,rZr[r\r-descrCr0r/s r1get_workflow_descrks: 28TXY }, !):):)<')()  ))7); 3M;O< lD ) $$W-3E%&yy/52t9>3>*4(5 #$ ,%%"  t$$  s3x(    s3x(   ! s3x(    "$S$OPXz"Z[!CC5IJ   sMF/CKt||jdddSw)NTupdatez(Workflow {filename} updated successfullyro)r2r)rrls r1update_workflow_contentrss& )B  sz /api/workflows/{filename}/deletecRK t|d}t|z }|jr|jst dd| |j t}|jd tj| d |d |ddS#t $r3}t}|j|d|tdd|i d}~wwxYw#t$rt$rt$rt $r2}t}|j|d|td|d}~wwxYww)NTr:r!r<r=z Failed to delete workflow file: zFailed to delete workflow filer)detailszWorkflow file deletedrideletedz Workflow 'z' deleted successfullyr$z$Unexpected error deleting workflow: zFailed to delete workflow: )rrr(rOrunlinkr*rr+rrXrrYrr)rr,rZr/r0s r1delete_workflowrxsZ&J28TXY }, !):):)<')()   p     #$ #%%"   %#M?2HI   p&(F  (H&X Y()IT^`mSno o p"    J"$S$H "ST$'B3%%HIIJsMD'AC B5CD' C .CC  C$D$2-DD$$D'z /api/workflows/{filename}/renamecrK t||jtdt|dt|jdd|jddS#t$rt $rt $rt$rt$r2}t}|j|d|td |d}~wwxYww) Nr"r#Tr:zWorkflow renamed to '' successfullyr%sourcetargetr&z$Unexpected error renaming workflow: zFailed to rename workflow: ) r new_filenamerrrrrrr*rr+rrrlr/r0s r1rename_workflow_filersJ'"6"6(K0RVW01E1E^bc.w/C/C.DNS       J"$S$H "ST$'B3%%HIIJ)B7AAB7-B4-B//B44B7z/api/workflows/{filename}/copycrK t||jtdt|dt|jdd|jddS#t$rt $rt $rt$rt$r2}t}|j|d|td |d}~wwxYww) Nrzr#Tr:zWorkflow copied to 'r{r|z#Unexpected error copying workflow: zFailed to copy workflow: ) r rrrrrrrr*rr+rrs r1copy_workflow_filer4sHh 4 4I0RVW01E1E^bc-g.B.B-C>R       H"$S$Gz"RS$'@%FGGHrz/api/workflows/{filename}/getc K t|d}t|z }|jr|jst dd|t |dd5}|j }dddt}|jd tj| d iS#1swY9xYw#t$rt$rt$rt$r2}t}|j|d |td |d}~wwxYww)NTr:r!r<r=rr@rAzWorkflow file content retrievedrirz&Unexpected error retrieving workflow: zFailed to retrieve workflow: )rrr(rOropenreadrrXrrYrrr*r+r)rr,rZhandler[r0r/s r1get_workflow_raw_contentrLsL28TXY }, !):):)<')()  )S7 3v ++-K4#$ 5@P@P[h i;'' 4 3    L"$S$J8*"UV$'DSE%JKKLsADAB+B'7B+DB($B++$D-C<<DDN),fastapirrtypingr server.modelsrrrr server.services.workflow_storager r r r rserver.settingsrutils.exceptionsrrrrrutils.structured_loggerrrrouterrNboolr2rSr8rerkpostrpputrsdeleterxrrrr1rs, %? LL L L  L  LD JJ  ,-Q cQ .Q h ,-; c; .; | ,-+G. ./C:V012'JC'J3'JT /0JJ7LJ1J. -.HsH5HH/H. +,LSL-Lr