D#SrSSKrSSKrSSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r SS K Jr SS KJr "S S \5rS rSr"SS5rg)z=Helper functions for working with Apigee archive deployments.N)apigee)errors)log)requests)resource_projector)archive)files)urllibc\rSrSrSrSr/SQr\RRSSS5r Sr S r S r S rS rS rSrSrSrg)LocalDirectoryArchivezManages a local zip archive.zapigee_archive_deployment.zip)z.graphqlz.jarz.javaz.jsz.jscz.jsonz.oasz .propertiesz.pyz.securityPolicyz.wsdlz.xmlz.xsdz.xslz.yamlz.ymlsrcmainrcURU5 U(a:[RRU5(d[R "U5eUbUO[ R"5Ul[ R"5Ul gN) _CheckIfPathExistsospathisdirrSourcePathIsNotDirectoryErrorr GetCWD_src_dirTemporaryDirectory_tmp_dir)selfsrc_dirs 1lib/googlecloudsdk/command_lib/apigee/archives.py__init__LocalDirectoryArchive.__init__8sZG$rww}}W--  0 0 99&2G DM,,.DMcU(aJ[RRU5(d%[R"SR U55egg)z'Checks that the given file path exists.z-Path to archive deployment does not exist: {}N)rrexistsr MissingFileErrorformat)rrs rr(LocalDirectoryArchive._CheckIfPathExists@sA BGGNN4((  " " 9 @ @ F HH)tr cURUR5(dg[RR U5up#[RR UR U5n[RRU5RS5(ag[RRU5(ag[RRU5(aUR5UR;agg)zEFilter all files in the archive directory to only allow Apigee files.F.T) startswith _ARCHIVE_ROOTrrsplitextjoinrbasenamerisfilelower_APIGEE_ARCHIVE_FILE_EXTENSIONS)r file_name_ext full_paths r_ZipFileFilter$LocalDirectoryArchive._ZipFileFilterFs    2 2 3 3  WW  i (FA T]]I6I  ww "--c22  ww}}Y  y!! t;;;  r c[RRURRUR5n[ R "XRUR5 U$)z1Creates a zip archive of the specified directory.) rrr+r_ARCHIVE_FILE_NAMErMakeZipFromDirrr4)rdst_files rZipLocalDirectoryArchive.Zip]sEww||DMM..0G0GHH 8]]D4G4GH Or cURU5 [R"U5(d[R"U5eg)zCChecks that the zip file path exists and the file is a zip archvie.N)rzipfile is_zipfilerBundleFileNotValidError)rzip_paths rValidateZipFilePath)LocalDirectoryArchive.ValidateZipFilePathcs7H%   h ' '  * *8 44 (r c6URR5$)z&Deletes the local temporary directory.)rClosers rrDLocalDirectoryArchive.Closeis ==    r cU$rrEs r __enter__LocalDirectoryArchive.__enter__ms Kr c`UR5 g! [R"S5 g=f)Nz1Temporary directory was not successfully deleted.T)rDrwarning)rexc_typevaltbs r__exit__LocalDirectoryArchive.__exit__ps' jjl kkEF s-)rrN)__name__ __module__ __qualname____firstlineno____doc__r7r/rrr+r)rrr4r:rArDrIrP__static_attributes__rHr rr r sV$7%!$'',,ufh7-/H . 5 !r r c[RRU5nURR S5nUS$)a}Helper function to extract the upload file id from the signed URL. Archive deployments must be uploaded to a provided signed URL in the form of: https://storage.googleapis.com//.zip? This function extracts the file id from the URL (e.g., .zip). Args: upload_url: A string of the signed URL. Returns: A string of the file id. /)r parseurlparsersplit) upload_urlurl split_paths rGetUploadFileIdraxs4  j)#xx~~c"* Br c[R"5nSSS.n[R"U5nUR XUS9nSSS5 U$!,(df  W$=f)aUploads the specified zip file with a PUT request to the provided URL. Args: upload_url: A string of the URL to send the PUT request to. Required to be a signed URL from GCS. zip_file: A string of the file path to the zip file to upload. Returns: A requests.Response object. zapplication/zipz 0,1073741824)z content-typezx-goog-content-length-range)dataheadersN)r GetSessionr BinaryFileReaderput)r^zip_filesessrdrcresponses r UploadArchiverks]    $(%3 ' h'4xx wx?H( /(' /s A  Ac*\rSrSrSrSrSrSrSrg) ListArchivesz5Adds additional helpful fields to a list of archives.cXl[R"U5UlSUlSUlSUlSUlSUlSUl g)NDeployedz In ProgressFailedz Not FoundUnknownMissing) _orgr LROPoller _lro_helper_deployed_status_inprogress_status_failed_status_not_found_status_unknown_status_missing_status)rorgs rrListArchives.__init__sJI'',D&D+D"D(D$D$Dr c|[USSS9nSn[U5HupE[R"U5nU(aURUS'OSU;a[ R RSUS05Sn[ R RURUS .5nURU5n U S US'U S UR:XaXbU'Us $S U ;aU S US 'OURUS'XbU'M U$![Ra URUS'N/ SnURUS'NC=f) zGiven a list of archives, extends them with a status and error field where needed. Args: archives: A list of archives to extend with a status and potential error. Returns: A list of archives with their associated status. c US$)N createdAtrH)ks r/ListArchives.ExtendedArchives..s+r T)keyreverseFoperationStatus operationnameuuid)organizationsId operationsIdstatuserror)sorted enumeraterMakeSerializabler{rOperationsClient SplitNameDescribert_StatusFromOperationrwrEntityNotFoundErrorrzr|) rarchivesextended_archivescascade_unknownidxaserilized_archiveroprs rExtendedArchivesListArchives.ExtendedArchivessv.>O-.,==a@ /3/C/C+, ! &&00&!K.2344:< F&&//!%"1  ",,R0&171A - . H !6!6 6%6c "$ $& )/ g &04/C/C+,07/8 )) H151G1G - . F /151E1E - .s:ADD#D;'D;c0nURRU5nU(aURUS'U$URUS'U$![R a UR US'USSUS'U$f=f)zGathers given an LRO, determines the associated archive status. Args: op: An Apigee LRO Returns: A dict in the format of {"status": "{status}", "error": "{error if present on LRO}"}. rrmessage)rvIsDonerwrxr RequestErrorry)rrris_dones rr!ListArchives._StatusFromOperationsF/  ''+g  00x M 22x M   /,,fX7 I.fWo M /s1A A .A;:A;)rwryrxrvr|rzrtr{N) rRrSrTrUrVrrrrWrHr rrmrms=%0dr rm)rVrr=googlecloudsdk.api_libr!googlecloudsdk.command_lib.apigeergooglecloudsdk.corerrgooglecloudsdk.core.resourcergooglecloudsdk.core.utilrr six.movesr objectr rarkrmrHr rrsPD )4#(;,*VFVr$,YYr