ɪWc"@sddkZeeeidddklZlZddkZddkZddklZddk Z ddk Z ddk Z ddk Z ddk Z ddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddkZddklZddk l Z ddk!l!Z!l"Z"ddk#Td e$fd YZ%dS( iNsutf-8(t copy_treet remove_tree(t BaseClass(t InstallHelper(tHttpRequestDecorator(tCMSVersionDeploymentPolicytPrepackDeploymentPolicy(t*tCommoncBseZdZdZdddddddd d d d d g ZdZdZdZhhddddgd6dgd6dd6d6hgd6gd6dd6dd6e d6d6hdddddd d!d"d#d$d%g d6dgd6d&d6d'6hdd(gd6dgd6d%d6d'd6d)6hd*d+gd6d*d+gd6d,d6d-6hdd.d/d0d1d2d3d4gd6dgd6d5d6d66hd7d8d9d:gd6d7d8gd6d;d6d<6hdd=d>d?d7d@dAgd6dgd6d:d6d<d6e d6dB6hdCdDdEgd6dCgd6dFd6dG6hdHdIdJdKdLdMdNgd6dHgd6dEd6dGd6dO6hddPdQgd6dgd6dRd6dS6hdTgd6dTgd6dQd6dSd6e d6dQ6hddPdQgd6dgd6dUd6dV6hdTgd6dTgd6dQd6dVd6e d6dW6hdd(gd6dgd6dXd6dY6hdZd[d\d]d^d_d`dadbdcdddeg d6dZd[gd6dfd6dg6hddhgd6dgd6did6dj6hdkdldmgd6dkgd6dnd6do6hdd(gd6dgd6dpd6dq6hdrdsgd6drgd6dtd6du6hdvdwdxgd6dvgd6dsd6dud6e d6dy6hdrdsgd6drgd6dzd6d{6hdvdwdxgd6dvgd6dsd6d{d6e d6d|6hdd}d~ddgd6dgd6dd6d6hddddddgd6dgd6d~d6dd6e d6d~6hddddgd6dgd6dd6dd6e d6d6hdd(gd6dgd6dd6dd6e d6d6Z dZ dZ e e dZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZe dZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2dZ3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZ<dZ=dZ>dZ?dZ@dZAeBdZCeBdZDeBdZEdZFdZGddZHe ddZIe ddZJdZKe dZLdZMdZNdZOdZPdZQdZRdZSRS(ts/data/backupFiless//opt/tandbergtv/cms/workflow/plugins/subsystemss+/opt/tandbergtv/cms/workflow/plugins/groupss /opt/tandbergtv/cms/workflow/libs(/opt/tandbergtv/cms/workflow/preferencess0/opt/tandbergtv/watchpoint/tomcat/webapps/ffmpegs/opt/tandbergtv/cms/conf/ffmpegs5/opt/tandbergtv/watchpoint/tomcat/webapps/filemanagers$/opt/tandbergtv/cms/conf/filemanagers5/opt/tandbergtv/watchpoint/tomcat/webapps/imagemagicks$/opt/tandbergtv/cms/conf/imagemagicks5/opt/tandbergtv/watchpoint/tomcat/webapps/watchfolders$/opt/tandbergtv/cms/conf/watchfolders rollback.jsons base.jsont PROVIDERIDtNAMEt PARTNERTYPEtCONTENTCLASSNAMEtkeyst uniqueKeystpartnerstjsonKeytPARTNERtparentt mergeNeededtPARTNER_CONTENTCLASSt EXTERNALIDtACTIVEtDISTRIBUTION_OPTIONtMETADATA_FORMATtFILE_LOOKUP_KEYStDIST_TEMPLATE_NAMEtALERT_DELAY_PERIODtTYPEtASSOCIATE_RESOURCEt PARAMETERStsitestSITEtVALUEtSITE_PARAMETERt SELECTIONKEYtTEMPLATEt selectorKeyst SELECOTRKEYtRESOURCETYPENAMEtRESOURCEGROUPNAMEtCONNECTIONSTRINGtMAXCONCURRENTUSERStHEARTBEATCONNECTIONSTRINGtHEARTBEATFREQUENCYtUSERNAMEt resourcestRESOURCEt DISPLAY_NAMEt ASSET_PATHtUUIDtFIELDSt customFieldstCUSTOMFIELDGROUPt DATA_TYPEt JOB_PARAMETERtJOB_SCHEDULE_PARAMETERt MULTIVALUEt FIELD_TYPEt CUSTOMFIELDt ALERT_NAMEtPATTERNtALERTStalertst ALERTNAMEt IDENTIFIERt THRESH_COUNTt THRESH_SECSt FREQ_COUNTt FREQ_SECSt SNMP_TRAPtEMAILtALERTt DESCRIPTIONtCONTENTCLASSFILEStcontentClassestCONTENTCLASSEStFILENAMEtcontentClassesToDeletetCONTENTCLASSESTODELETEtCONTENTCLASSFILESTODELETEt resourceHostst RESOURCEHOSTStpathtfiltert frequencyt processClasst messageUIDtcommandParametertmessageParametert routingDirt failureDirtlooseFileNamePatternteventstthreadst watchfolderst WATCHFOLDERtGROUPSt distTemplatest DISTTEMPLATEtHOSTtUSERtPASSWORDt ftpConfigt FTPCONFIGtparamstPARAMStCATEGORYtREPORTSs 3.0_reportss3.0_REPORTCONFIG_CATEGORYtTITLEt CATALOGNAMEt REPORTNAMEs3.0_REPORTCONFIGsabove_3.0_reportssABOVE_3.0_REPORTCONFIG_CATEGORYsABOVE_3.0_REPORTCONFIGt PLUGIN_NAMEtCRITERIAt ENHANCEDFIELDt PARAMETERt meprofilest MESUBSPROFILEtMAPPINGtDATATYPEtPATHt ASSET_TYPEtVALUE_FIELD_PATHcCs=d|_d|_d|_d|_h|_t|_dS(NR (tconfigtnametinstallerVersiont backupVersionthandleItemObjectsRthelper(tself((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyt__init__gs      cCs|ii|p|djoti|i|}|i|i|d}|i|p dG|GHq6q6WndS(NR@RRRNsFailed to delete rule set: (RBR|tgetUuidsFromXmltgetItemConfigValuetdeleteRulSetsByUuid(Rt ruleSetFilesRFt ruleSetFileRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytdeleteRuleSetss(cCsN|djpt| odSti}x|D]}|i|q3WdS(N(RRtProcessDefinitionstdisable(Rt templatestpdsttpl((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytdisableProcessDefinitionss  cCs|djpt| odStii}x|D]}y`|dGH|ii|d|ddj o+t|didjo|i nWq9t j o}|GH|i q9Xq9Wt i ddS(NtQUERYtCOMMITRg?(RRRRtgetDatabaseConnectiontcursortexecutetstrRtcommitRtrollbackRtsleep(Rtqueriest connectiontqueryte((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytconfigureDatabases .cCsBd}|o1x.|D]"}||}|GHti|qWntS(Nsrpm -ev (RtsystemR(Rtrpmst CMD_UNINSTALLtrpmtCMD((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyt unstallRpmss cCsKg}|ii|o|i|}nx\|D]T}d|GHtii|ot|q1tii|oti|q1q1Wtii|oxti |D]}ti |}||}tii|o_d|d|GHy-d|ti f}d|GHti |Wq;t j o} | GHq;XqqWyxti tii|ti dD]\} } }xU| D]M} dtii| | iddd | d} |id d | tqWxU|D]M}dtii| | iddd |d}|id d |tqWqiWWqGt j oqGXnd S( s7 roll back files (including directory) sDeleting file or directory: sCopying s --> srsync -K -a -I "%s" "%s"s command: topts"iitnobodyN(R|RRRTtisdirRtisfiletremoveRtlistdirtsepRRtwalktabspathtjointindexRR(RtfileOrDirToDeleteConfigNamettargetBackupDirtfilestfiletftdesttsrctcp_cmdRlRTtdirstdirtabsDirtabsFile((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyt_rollbackFilessJ     '11"cCs |i}|id|dS(NtfileOrDirToDelete(RR(Rt fileBackupDir((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyt rollbackFiless cCsP|djpt| odSx)|D]!}tid|diGHq'WdS(Nssh R(RRRRtread(Rtscriptstscript((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytexecuteScriptss cCs |GHdS(s3Writes print statements to log as well as to screenN((Rt outputstr((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyR#scCs ti|S(N(tsockett gethostbyname(Rthostname((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytip)scCs#|ii|o |i|SdS(N(R|R(RR}((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyR,scCs>x7|i|dD]$}|i|pd|| /dev/null 2>&1'tcluster_service_nodessrestarting logstash on RRRt rootPasswdisfailed to restart logstash on ( RRRRRRRRtexecute_interactiveRtlogout(RRtcmdstrtcsnodestndtclienttstatusR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyt restartAlerts]s(    cCs|i|}g}|djo|Sx|D]w}d}|ido|d}nd}|djo%t|d|d|d|}n|djo%t|d|d|d|}n|djo%t|d|d|d|}n|djo8tid jo%t|d|d|d|}nO|djotid jo d}n%t ||d|d|d|}|dj o|i |q.q.W|S( NRR@RRRttomcattvsftpdtworkflowg@( RRRt CMSServicet TomcatServicet FTPServiceRRtWorkflowServicetGenericServiceR(Rt serviceNametnodes_conf_namet arr_nodestclusterServicestnodet rootPasswordtservice((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytbuildServiceObjectsByNamews0  % % % %  $ tcluster_app_nodescCsBx;|D]3}|i||}x|D]}|iq&WqWdS(N(Rtstop(RtservicesRRtclusterServiceObjectsR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytstopServiceInClusterNodess cCsx|D]}}|i||}x)|D]!}|dj o|iq&q&W|o2x/|D]#}|iptdqYqYWqqWdS(NsFailed to startup a service.(RRtstarttwaitforServiceUpR(RRt waitForUpRRRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytstartServiceInClusterNodess  cCsx|D]}}|i||}x)|D]!}|dj o|iq&q&W|o2x/|D]#}|iptdqYqYWqqWdS(NsFailed to startup a service.(RRtrestartRR(RRRRRRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytrestartServiceInClusterNodess  cCsKxD|D]<}|i|}|djoqnd|GH|iqWdS(Ns stopping %s service on localhost(t_getLocalServiceObjectRR(RRRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytstopLocalServicess  cCsaxZ|D]R}|i|}|djoqnd|GH|i|ptS|iqWdS(Ns?restarting %s service on localhost, this can take a few minutes(RRRRR(RRRRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytrestartLocalServicess   cCsd}|djotdt}n|djotdt}n|djotdt}ns|djo&tidjotdt}n@|djotidjo d}ntd|dt}|S(NR@tisNativeRRRg@tsvcname( RRRRRRRRR(RRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyRs      cCs-tiiotiio tiiS(N(tReportPublishert!checkAndWaitReportServerAvailableRBt checkAndWaitRullServiceAvailableRt checkAndWaitSiteServiceAvailable(R((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytwaitForOtherServersAvailablescCstiddii}|dj o2t|djo|ido d}n|Stiddii}|SdS(Ns9rpm -qi watchpoint-cms | grep Version | awk '{print $3}'Ris5.1.100s5.2.0sBconary q | grep watchpoint-cms | awk '{print $1}' | cut -d '=' -f2(RRRtstripRRt startswith(Rt versionString((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyRs  cCsg}ti|D]}|tii|q~}g}|D]=}tii|d|jo|tii||qAqA~}|S(Ni(RRyRTtnormcasetsplitextR}(RRt fileExtListRQRtfileListt_[2]((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyt listDirectorys / @cCs!|i|pdS||SdS(N(RR(RRR}((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyRUscCs5|i|d}|dj ot|idjS(NRR(RURReR(RRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyRscCs|i|d}|S(NtRENAME(RU(RRtrename((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyt getRanamesN(Tt__name__t __module__tCOMPONENTS_PATH_PREFIXtCOMMON_SHARED_FOLDERtBACKUP_FULL_DIRSt ROLLBACK_JSONRRRRRRRRRRRRRRRRRRRRRRRRRRRRRR RR RRR R&R!R"R#R6R>R:RHRSRYR_RmRsRRRRRRRRRRRRt staticmethodRRRRRRRRRRRRRRRURR(((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pyR3s +*@,(7.B(;(0(0%F%(%%6%6.?96                            .                  (&tsystreloadtsetdefaultencodingtdistutils.dir_utilRRRRRRRRRZRRRtMeFieldDefinitionRRR7RRRBRRRRRRRRRRRRt APPServicetobjectR(((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Common.pytsB