#SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKJ r SSK J r SS K J r SS K Jr SS KJr SS KJr SS KJr SSKJr "SS\5rSrSr"SS5rg)z=Helper functions for working with Apigee archive deployments.)absolute_import)division)print_function)unicode_literalsN)apigee)errors)log)requests)resource_projector)archive)files)urllibc\rSrSrSrSr/SQr\RRSSS5r Sr S r S r S rS rS rSrSrSrg)LocalDirectoryArchive#zManages 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__<sZG$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 r!r(LocalDirectoryArchive._CheckIfPathExistsDsA 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._ZipFileFilterJs    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_NAMEr MakeZipFromDirrr8)rdst_files r!ZipLocalDirectoryArchive.ZipasEww||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 r!ValidateZipFilePath)LocalDirectoryArchive.ValidateZipFilePathgs7H%   h ' '  * *8 44 (r$c6URR5$)z&Deletes the local temporary directory.)rClosers r!rHLocalDirectoryArchive.Closems ==    r$cU$rrIs r! __enter__LocalDirectoryArchive.__enter__qs Kr$c`UR5 g! [R"S5 g=f)Nz1Temporary directory was not successfully deleted.T)rHr warning)rexc_typevaltbs r!__exit__LocalDirectoryArchive.__exit__ts' jjl kkEF s-)rrN)__name__ __module__ __qualname____firstlineno____doc__r;r3rrr/r-r"rr8r>rErHrMrT__static_attributes__rLr$r!rr#sV$7%!$'',,ufh7-/H . 5 !r$rc[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. /)rparseurlparsersplit) upload_urlurl split_paths r!GetUploadFileIdre|s4  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)rbzip_filesessrhrgresponses r! UploadArchiveros]    $(%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 r!r"ListArchives.__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 createdAtrL)ks r!/ListArchives.ExtendedArchives..s+r$T)keyreverseFoperationStatus operationnameuuid)organizationsId operationsIdstatuserror)sorted enumerater MakeSerializablerrOperationsClient SplitNameDescriberx_StatusFromOperationr{rEntityNotFoundErrorr~r) rarchivesextended_archivescascade_unknownidxaserilized_archiveroprs r!ExtendedArchivesListArchives.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)rzIsDoner{r|r RequestErrorr})rrris_dones r!r!ListArchives._StatusFromOperationsF/  ''+g  00x M 22x M   /,,fX7 I.fWo M /s1A A .A;:A;)r{r}r|rzrr~rxrN) rVrWrXrYrZr"rrr[rLr$r!rqrqs=%0dr$rq)rZ __future__rrrrrrAgooglecloudsdk.api_libr!googlecloudsdk.command_lib.apigeergooglecloudsdk.corer r googlecloudsdk.core.resourcer googlecloudsdk.core.utilr r six.movesrobjectrrerorqrLr$r!rsZD&%' )4#(;,*VFVr$,YYr$