+ SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK Jr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ!r! SSK"J#r# SSK"J$r% "SS\&\RNS9r("SS\(5r)"SS\(5r*\)"/5\)"S/5\)"/5\)"S/5\)"SS/5\*"5\)"SS /5S!.r+S,S"jr,S-S.S#jjr-S/S$jr.S-S0S%jjr/S1S&jr0S2S3S'jjr1S4S(jr2S5S)jr3S6S*jr4S-S7S+jjr5g)8z4Version-agnostic utilities for function source code.)absolute_import) annotations)division)unicode_literalsN)Dict) exceptions) http_wrapper)transfer)util) storage_api) storage_util) gcloudignore)log) resources) transports)archive)filesc@\rSrSrSr\R SSj5rSrg)RequiredFilesStrategy5z;Abstract base class for required files validation strategy.c[5eN)NotImplementedErrorselffiles_in_source_dirruntimes 7lib/googlecloudsdk/command_lib/functions/source_util.pyValidateRequiredFilesStrategy.Validate8s  Nr list[str]rstrreturnNone) __name__ __module__ __qualname____firstlineno____doc__abcabstractmethodr__static_attributes__r"r!rrr5sC  r!r) metaclassc:^\rSrSrSrSU4SjjrSSjrSrU=r$)AllFilesPresentStrategy=z9Strategy that requires all specified files to be present.c6>[[U] 5 Xlgr)superr2__init___required_files)rrequired_files __class__s rr6 AllFilesPresentStrategy.__init__@s !413)r!cnURH%nX1;dM [R"SUSUS35e g)Nz.Provided source directory does not have file [z] which is required for [$]. Did you specify the right source?)r7rSourceArgumentError)rrrfs rr AllFilesPresentStrategy.ValidateDsF  ! ! %,,r!rBzgo.modz package.jsonz index.phpz composer.jsonzapp.rbGemfile)dotnetgojavanodejsphppythonrubycT[R"U[RS/-5$)N node_modules)rAnyFileOrDirExists GIT_FILES directorys r_GcloudIgnoreCreationPredicaterTls(  ( (''>*:: r!c^[RS-n[R"UU[US9$)Nz node_modules )default_ignore_file gcloud_ignore_creation_predicate ignore_file)rDEFAULT_IGNORE_FILEGetFileChooserForDirrT)pathrXrVs r _GetChooserr\rs5%88;MM  * * -'E  r!c[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)osr[existsrr=isdirrRs r_ValidateDirectoryExistsOrRaiserasW  " "  ( ()L MM y ! !  ( (5  "r!c<[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)r[errorNiiB) r\ IsIncluded file_utilsGetTreeSizeBytesOSErrorrFunctionsErrorformatOversizedDeploymentErrorr%)r[rXchooserrdsize_be size_limit_mb size_limit_bs r_ValidateUnpackedSourceSizerss  *'  )  ( ( 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)raresubr^listdir_REQUIRED_SOURCE_STRATEGIESgetr)sourcerversionless_runtimerstrategys r(ValidateDirectoryHasRequiredRuntimeFilesr~sT!&)xW5 6* ( , ,-@ A(  )3r!c 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.ziprczHError creating a ZIP archive with the source code for directory {0}: {1}N)rar^r[r_joinrIgnoreFileNotFoundErrorrlrsr\rgrMakeZipFromDir ValueErrorrkr%)zip_dir source_pathrXenforce_size_limit zip_file_namernrdrps rCreateSourcesZipFilers,"+. [(NOO  , ,>EE     9'',,w 2-+3G""I =K    # # !!' SV!< s,,C D$/DDcURnURnSRS[S555nSR XU5$)Nruc3j# UH)n[R"[R5v M+ g7fr)randomchoicestringascii_lowercase).0_s r -_GenerateRemoteZipFileName..s"L)Q6==!7!788)s13 z{0}-{1}-{2}.zip) locationsId functionsIdrrangerl) function_refregionnamesuffixs r_GenerateRemoteZipFileNamersC  # #&  ! !$ 77L%)L L&  ! !& 77r!c\[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_exceptionsBadFileExceptionrSourceUploadErrorrl) 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 --r!cV^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) isinstanceexcrrrdebugr RebuildHttpConnectionsrtimesleep http_utilCalculateWaitForRetry num_retriesmax_retry_wait retry_func) retry_argsuploads r_UploadRetryFunc.UploadToGeneratedUrl.._UploadRetryFuncst*../"D"DEE iiGH))*//: jj  ) )$$z/H/H    #r!PUTz 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')r UploadFromFiler Requeststreamreadbody MakeRequestrGetApitoolsTransportrrcloserrrrlcontent)rr extra_headersrupload_requestrrs @rUploadToGeneratedUrlr s %2- ?? # #J:K # L& $!)) !2DmDN !--,,.N'''')#B"" H MM S A%  & & $$*F..x7G7G%+%  & MMs A2D D()rSr%r&boolr)r[r%rX str | Noner&zgcloudignore.FileChooser)rSr%r&r')r[r%rXrr&r')r{r%rr%r&r')NF)rr%rr%rXrr&r%)rresources.Resourcer&r%)rr%rrrr%r&zstorage_util.ObjectReference)rzhttp_wrapper.Responser&zhttp_wrapper.CheckResponse)rr%rr%rzDict[str, str] | Noner&r')6r, __future__rrrrr-rr^rrvrrtypingrapitools.base.pyrrr r r rgooglecloudsdk.api_lib.storager r googlecloudsdk.callioper$googlecloudsdk.command_lib.functionsgooglecloudsdk.command_lib.utilrgooglecloudsdk.corerrrgooglecloudsdk.core.utilrrrhobjectABCMetarr2rBryrTr\rarsr~rrrrrr"r!rrs;&"' :)%.67E;8#)*,8 Fckk   3  "7*&b) !8* - #B '%~&67 "K#A B)+ #Xy$9 :*.   &  (*. & .4# ) )))  )X8#5EH!6.#..GK000.C0 0r!