&+ SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r SSK J r SSK Jr SSK Jr SSK Jr SS KJr SS KJr SSKJ r SSKJ r SS KJr SS KJr SS KJr SSKJr SSKJ r SSKJ!r" "SS\#\RHS9r%"SS\%5r&"SS\%5r'\&"/5\&"S/5\&"/5\&"S/5\&"SS/5\'"5\&"SS/5S.r(S)Sjr)S*S+S jjr*S,S!jr+S*S-S"jjr,S.S#jr-S/S0S$jjr.S1S%jr/S2S&jr0S3S'jr1S*S4S(jjr2g)5z4Version-agnostic utilities for function source code.) annotationsN)Dict) exceptions) http_wrapper)transfer)util) storage_api) storage_util) gcloudignore)log) resources) transports)archive)filesc@\rSrSrSr\R SSj5rSrg)RequiredFilesStrategy2z;Abstract base class for required files validation strategy.c[5eN)NotImplementedErrorselffiles_in_source_dirruntimes 7lib/googlecloudsdk/command_lib/functions/source_util.pyValidateRequiredFilesStrategy.Validate5s  Nr list[str]rstrreturnNone) __name__ __module__ __qualname____firstlineno____doc__abcabstractmethodr__static_attributes__rrrrr2sC  rr) metaclassc:^\rSrSrSrSU4SjjrSSjrSrU=r$)AllFilesPresentStrategy:z9Strategy that requires all specified files to be present.c6>[[U] 5 Xlgr)superr/__init___required_files)rrequired_files __class__s rr3 AllFilesPresentStrategy.__init__=s !413)rcnURH%nX1;dM [R"SUSUS35e g)Nz.Provided source directory does not have file [z] which is required for [$]. Did you specify the right source?)r4rSourceArgumentError)rrrfs rr AllFilesPresentStrategy.ValidateAsF  ! ! %,,rr?zgo.modz package.jsonz index.phpz composer.jsonzapp.rbGemfile)dotnetgojavanodejsphppythonrubycT[R"U[RS/-5$)N node_modules)r AnyFileOrDirExists GIT_FILES directorys r_GcloudIgnoreCreationPredicaterQis(  ( (''>*:: rc^[RS-n[R"UU[US9$)Nz node_modules )default_ignore_file gcloud_ignore_creation_predicate ignore_file)r DEFAULT_IGNORE_FILEGetFileChooserForDirrQ)pathrUrSs r _GetChooserrYos5%88;MM  * * -'E  rc[RRU5(d[R"S5e[RR U5(d[R"S5eg)zValidates that the given directory exists. Args: directory: a local path to the directory provided by user. Returns: The argument provided, if found valid. Raises: SourceArgumentError: If the user provided an invalid directory. z!Provided directory does not existz+Provided path does not point to a directoryN)osrXexistsrr:isdirrOs r_ValidateDirectoryExistsOrRaiser^|sW  " "  ( ()L MM y ! !  ( (5  "rc<[X5nURn[R"XS9nSnUS-nXG:a/[ R"[U5S-[U5S-5eg![a(n[ R "SRXS95eSnAff=f)z'Validate size of unpacked source files. predicatezError building source archive from path [{path}]. Could not validate source files: [{error}]. Please ensure that path [{path}] contains function code or specify another directory with --source)rXerrorNiiB) rY IsIncluded file_utilsGetTreeSizeBytesOSErrorrFunctionsErrorformatOversizedDeploymentErrorr")rXrUchooserrasize_be size_limit_mb size_limit_bs r_ValidateUnpackedSourceSizerps  *'  )  ( ( CF-&,   - - F c3|,s2    # # 239&d&2L  sA)) B3#BBc[U5 [R"SSU5n[R"U5n[ R U5nU(aURX15 gg)zDValidates the given source directory has the required runtime files.z[0-9]N)r^resubr[listdir_REQUIRED_SOURCE_STRATEGIESgetr)sourcerversionless_runtimerstrategys r(ValidateDirectoryHasRequiredRuntimeFilesr{sT!&)xW5 6* ( , ,-@ A(  )3rc 6[U5 U(af[RR[RR X55(d%[ R "SRU55eU(a [X5 [RR US5n[X5nURn[R"XAUS9 U$![a4n[ R"SRU[U555eSnAff=f)aPrepare zip file with source of the function to upload. Args: zip_dir: str, directory in which zip file will be located. Name of the file will be `fun.zip`. source_path: str, directory containing the sources to be zipped. ignore_file: custom ignore_file name. Override .gcloudignore file to customize files to be skipped. enforce_size_limit: if set, enforces that the unpacked source size is less than or equal to 512 MB. Returns: Path to the zip file. Raises: FunctionsError z4File {0} referenced by --ignore-file does not exist.zfun.zipr`zHError creating a ZIP archive with the source code for directory {0}: {1}N)r^r[rXr\joinrIgnoreFileNotFoundErrorrirprYrdrMakeZipFromDir ValueErrorrhr")zip_dir source_pathrUenforce_size_limit zip_file_namerkrarms rCreateSourcesZipFilers,"+. [(NOO  , ,>EE     9'',,w 2-+3G""I =K    # # !!' SV!< s,,C D$/DDcURnURnSRS[S555nSR XU5$)Nrrc3j# UH)n[R"[R5v M+ g7fr)randomchoicestringascii_lowercase).0_s r -_GenerateRemoteZipFileName..s"L)Q6==!7!788)s13 z{0}-{1}-{2}.zip) locationsId functionsIdr}rangeri) function_refregionnamesuffixs r_GenerateRemoteZipFileNamersC  # #&  ! !$ 77L%)L L&  ! !& 77rc\[U5n[RRU5n[RR XC5n[ R"5RX5 U$![Ra& [R"SRU55ef=f)a0Uploads the given source ZIP file to the provided staging bucket. Args: source_zip: the source ZIP file to upload. function_ref: the function resource reference. stage_bucket: the name of GCS bucket to stage the files to. Returns: dest_object: a reference to the uploaded Cloud Storage object. z;Failed to upload the function source code to the bucket {0})rr BucketReference FromArgumentObjectReference FromBucketRefr StorageClient CopyFileToGCScalliope_exceptionsBadFileExceptionrSourceUploadErrorri) source_zipr stage_bucketzip_file bucket_ref dest_objects rUploadToStageBucketrs( 5(++88F*,,:::P+--jF   - -  & &ELL   s $A11:B+cUR[RR:Xa[R R U5e[R"U5$r) status_codehttp HTTPStatus FORBIDDENhttp_exceptionsHttpForbiddenError FromResponser CheckResponse)responses r&_UploadFileToGeneratedUrlCheckResponsersDT__666  , , 9 9( CC  # #H --rcV^U=(d 0n[RRUSS9mS U4Sjjn[R"USSS0UES9nTR R 5Ul[R"[R"5UU[TRS9nTR R5 URS-S :wa8[R "S R#XRUR$S 95eg !TR R5 f=f)zUpload the given source ZIP file to provided generated URL. Args: source_zip: the source ZIP file to upload. url: the signed Cloud Storage URL to upload to. extra_headers: extra headers to attach to the request. zapplication/zip) mime_typecb>[UR[R5(at[R "S5 [ R"UR5 [R"[R"URURS95 gTRU5 g)Nz5Caught delayed permission propagation error, retrying)max_wait) isinstanceexcrrr debugrRebuildHttpConnectionsrtimesleep http_utilCalculateWaitForRetry num_retriesmax_retry_wait retry_func) retry_argsuploads r_UploadRetryFunc.UploadToGeneratedUrl.._UploadRetryFuncst*../"D"DEE iiGH))*//: jj  ) )$$z/H/H    #rPUTz content-type) http_methodheaders)rcheck_response_funcretriesdzYFailed to upload the function source code to signed url: {url}. Status: [{code}:{detail}])urlcodedetailN)rzhttp_wrapper.ExceptionRetryArgsr#r$)rUploadFromFilerRequeststreamreadbody MakeRequestrGetApitoolsTransportrrcloserrrricontent)rr extra_headersrupload_requestrrs @rUploadToGeneratedUrlrs %2- ?? # #J:K # L& $!)) !2DmDN !--,,.N'''')#B"" H MM S A%  & & $$*F..x7G7G%+%  & MMs A2D D()rPr"r#boolr)rXr"rU str | Noner#zgcloudignore.FileChooser)rPr"r#r$)rXr"rUrr#r$)rxr"rr"r#r$)NF)rr"rr"rUrr#r")rresources.Resourcer#r")rr"rrrr"r#zstorage_util.ObjectReference)rzhttp_wrapper.Responser#zhttp_wrapper.CheckResponse)rr"rr"rzDict[str, str] | Noner#r$)3r) __future__rr*rr[rrsrrtypingrapitools.base.pyrrrrrrgooglecloudsdk.api_lib.storager r googlecloudsdk.callioper$googlecloudsdk.command_lib.functionsgooglecloudsdk.command_lib.utilr googlecloudsdk.corer r rgooglecloudsdk.core.utilrrreobjectABCMetarr/r?rvrQrYr^rpr{rrrrrrrrrs;" :)%.67E;8#)*,8 Fckk   3  "7*&b) !8* - #B '%~&67 "K#A B)+ #Xy$9 :*.   &  (*. & .4# ) )))  )X8#5EH!6.#..GK000.C0 0r