RDSrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK r SSK J r SSK J r SS K Jr SSKJ r SS KJr SS KJr SS KJr SS KJr SSKJr SSKJ r SSKJr SSKJr SSKJ r SSK J!r! SSK"J r# SSK"J$r$ SSK"J%r% SSK"J&r& SSK'J(r( SSK)J*r* SSK+r,Sr-\ R\"S5r/Sr0\ R\"S5r1Sr2\ R\"S5r3Sr4Sr5SS /r6/S!Qr7\*RpRrRtr;\RxRz4S"jr>\RxRz4S#jr?S$r@\RxRz4S%jrAS&rBS'rCS(rDS)\C-S*-rES+\C-S,-\D-S--rFS.\F-S,-\E-S/-rGS0\F-S,-\E-S1-\G-S2-rHS3rIS4rJS5rKS6rLS7rMS8rNS9rOS:rPS;rQS<rRS=rS\SS>5rT\SS?5rU\SSLS@j5rV\SSA5rW\SSB5rX\SSC5rY\SSMSDj5rZ\SSMSEj5r[\SSF5r\SGr]SHr^SIr_SJr`SKrag)Nz5A library that is used to support Functions commands.)absolute_import)division)print_function)unicode_literalsN)base_api) exceptions) list_pager) operations)util) storage_api) storage_util)apis) arg_parsers)base)iam_util)log) properties) resources)encoding)cloudfunctions_v1_messagesz7Deploying function (may take a while - up to 2 minutes)z3^(.*/)?[A-Za-z](?:[-_A-Za-z0-9]{0,61}[A-Za-z0-9])?$zFunction name must contain only Latin letters, digits and a hyphen (-). It must start with letter, must not end with a hyphen, and must be at most 63 characters long.z%^[a-zA-Z][\-\._~%\+a-zA-Z0-9]{2,254}$zTopic must contain only Latin letters (lower- or upper-case), digits and the characters - + . _ ~ %. It must start with a letter and be from 3 to 255 characters long.z^projects/_/buckets/.{3,222}$cloudfunctionsv1z asia-east1z europe-west6)zsouthamerica-east1z us-central1zus-east1zus-east4zus-west1c[$)aiReturns the current cloudfunctions Api Version configured in the sdk. NOTE: Currently the value is hard-coded to v1, and surface/functions/deploy.py assumes this to parse OperationMetadataV1 from the response. Please change the parsing if more versions should be supported. Args: track: The gcloud track. Returns: The current cloudfunctions Api Version. ) _API_VERSIONtracks /lib/googlecloudsdk/api_lib/functions/v1/util.py_GetApiVersionrWs  c[R"5nU(aSU;a$[R"[[ U55$[ R"S5 [RRRS5RS5 [R"[[ U55n[RRRS5RS5 U$)z"Returns the GCFv1 client instance.zautopush-cloudfunctionszTemporarily overriding cloudfunctions endpoint to staging-cloudfunctions.sandbox.googleapis.com so that GCFv1 autopush resources can be accessed.rz6https://staging-cloudfunctions.sandbox.googleapis.com/z7https://autopush-cloudfunctions.sandbox.googleapis.com/) v2_utilGetApiEndpointOverriderGetClientInstance _API_NAMErrinforVALUESapi_endpoint_overridesPropertySet)rendpoint_overrideclients rGetApiClientInstancer,gs446  "*; ;  ! !)^E-B CC(($  **334DEII>  ! !)^E-B C& **334DEII? -rc0[R"SS5$)Ncloudresourcemanagerr)rr#rr#GetResourceManagerApiClientInstancer0s   6 ==rcJ[R"[[U55$N)rGetMessagesModuler$rrs rGetApiMessagesModuler4s   >%+@ AArc[RRU[RR R RSS9[RRRR5S.SS9$)NTrequired) projectsId locationsIdz+cloudfunctions.projects.locations.functions)params collection) rREGISTRYParserr&coreprojectGet functionsregionnames rGetFunctionRefrEsn    ! ! "))..66::D:I#**44;;??A? " rz [a-zA-Z0-9_]z[][~@#$%&.,?:;+*='()-]z(\{z (=\*\*?)?})z((|z)+)z(/(z))z(/?()z*)zgPath must be a slash-separated list of segments and captures. For example, [users/{userId}/profilePic].cURRnURRnSn[R"UR 5nSU;aJUSnSU;aUSn[ U5nU(aUSU-- nUS:Xa[U5nU(aUSU-- nSRX[R"U55$![[4a UR nNDf=f)zReturns a human readable string representation from the http response. Args: error: HttpException representing the error response. Returns: A human readable string representation of the error. errormessagez Problems: iz Permission Details: z6ResponseError: status=[{0}], code=[{1}], message=[{2}]) responsestatusreasonjsonloadscontent_GetViolationsFromError_GetPermissionErrorDetails ValueError TypeErrorformatrDecode)rJrMcoderKdata error_info violationspermission_issuess rGetHttpErrorMessager]s >> &   $ ' ::emm $D$=j j Y'*51j ?Z// 36zB  .1BB B' B H H HOOG,  i mmGsA0CC%$C%c[U[5(a[R"X5nOURU5nU(d%[R "SR X55eU$)NzInvalid value '{0}': {1}) isinstancestrrematchrArgumentTypeErrorrV)argumentregex error_messagerbs r_ValidateArgumentByRegexOrRaisergsVs HHU %E KK !E   ' '"))(B  /rc,[U[[5$)zChecks if a function name provided by user is valid. Args: name: Function name provided by user. Returns: Function name. Raises: ArgumentTypeError: If the name provided by user is not valid. )rg_FUNCTION_NAME_RE_FUNCTION_NAME_ERRORrCs rValidateFunctionNameOrRaiserks ) 3 rc~[RU5(a [RR U5nO[RR USS9nUR5RS5S-nU$![ Ra*n[R"SRX55eSnAff=f)aChecks if a bucket uri provided by user is valid. If the Bucket uri is valid, converts it to a standard form. Args: bucket: Bucket uri provided by user. Returns: Sanitized bucket uri. Raises: ArgumentTypeError: If the name provided by user is not valid. F)require_prefixzInvalid value '{}': {}N/) _BUCKET_RESOURCE_URI_RErbr BucketReferenceFromUrl FromArgumentargparsercrrVToUrlrstrip)bucket bucket_refes r%ValidateAndStandarizeBucketUriOrRaiserys""6**--55f=J//<< =j     $ $S )C /& -  % %  ) ) " ) )& 4 sA>>B<%B77B<c0[U[[5nU$)zChecks if a Pub/Sub topic name provided by user is valid. Args: topic: Pub/Sub topic name provided by user. Returns: Topic name. Raises: ArgumentTypeError: If the name provided by user is not valid. )rg_TOPIC_NAME_RE_TOPIC_NAME_ERROR)topics rValidatePubsubTopicNameOrRaiser~ s * ^. % ,rcURUSRXRRRR 5S9nU(a UR cg[UR 5S:a%[R"SRU55eUR SnU(a UR(aURS$S$)aChecks if runtime is supported. Does not raise if the runtime list cannot be retrieved Args: client: v2 GCF client that supports ListRuntimes() runtime: str, the runtime. region: str, region code. Returns: warning: None|str, the warning if deprecated zname={} AND environment={}) query_filterNzargument `--runtime`: {} is not a supported runtime on GCF 1st gen. Use `gcloud functions runtimes list` to get a list of available runtimesr) ListRuntimesrVmessagesRuntimeEnvironmentValueValuesEnumGEN_1runtimeslenrFunctionsErrorwarnings)r+runtimerBrL runtime_infos rValidateRuntimeOrRaisers  /66 ??**EEKK!( X&&.   a  # # !!'  ""1%, ,//A rc0[U[[5nU$)zCheck if path provided by user is valid. Args: path: A string: resource path Returns: The argument provided, if found valid. Raises: ArgumentTypeError: If the user provided a path which is not valid )rg_PATH_PATH_RE_ERROR)paths rValidatePathOrRaiserAs )un E$ +rc [R"U5n/nURURR 5VVs/sHup4SR X45PM snn5 URUR R 5VVs/sHup4SR X45PM snn5 U(aSRU5S-$gs snnfs snnf)zLooks for violations descriptions in error message. Args: error: HttpError containing error information. Returns: String of newline-separated violations descriptions. z{}: {} rI)exceptions_utilHttpErrorPayloadextendr[itemsrVfield_violationsjoin)rJ error_payloaderrorskvs rrRrRPs"2259- &--*7*B*B*H*H*JK*J$!y*JK --$44::<T"U0UD6$![Ra=n[R"[R "[ U555 SnAgSnAff=fr2)apitools_exceptions HttpErrorcore_exceptionsreraisebase_exceptions HttpExceptionr])argskwargsrJfuncs r"CatchHTTPErrorRaiseHTTPExceptionFnLCatchHTTPErrorRaiseHTTPException..CatchHTTPErrorRaiseHTTPExceptionFnsU 4 "6 ""  ( (  ' '(;E(B Cs A3AA) functoolswraps)rrs` r CatchHTTPErrorRaiseHTTPExceptionr}s( ??4 ,+rc([5nURnURRUR US95$![ R a=nUR[RRR:XaSnAgeSnAff=f)zFReturns the Get method on function response, None if it doesn't exist.rCN) r,MESSAGES_MODULEprojects_locations_functionsr@2CloudfunctionsProjectsLocationsFunctionsGetRequestrr status_codesixmoves http_client NOT_FOUND) function_namer+rrJs r GetFunctionrs !&  # #(   . . 2 2CC D    & &  CII11;;;   s'AB2B  B  Bc [5nURn[R"URUR S[ RRRRSS9-S9SSS9n[R"5[RRLa>[R "S5 UVs/sHo3R"[$;dMUPM sn$[R"5[RR&La>[R "S 5 UVs/sHo3R"[(;dMUPM sn$U$s snfs snf) z;Returns the list of regions where GCF 1st Gen is supported.z projects/Tr6rC locationspageSize)servicerequestfieldbatch_size_attributezFListRegions: Autopush env detected. Filtering for v1 autopush regions.zDListRegions: Staging env detected. Filtering for v1 staging regions.)r,rr YieldFromListprojects_locations*CloudfunctionsProjectsLocationsListRequestrr&r>r?r@r!GetCloudFunctionsApiEnvApiEnvAUTOPUSHrr% locationId_V1_AUTOPUSH_REGIONSSTAGING_V1_STAGING_REGIONS)r+rresultsrs r ListRegionsrs !&  # #(  $ $''AAZ..33;;???NNB %  ' $$&'..*A*AAHHP Gw!,,2F"FAw GG&&(GNN,B,BBHHN Fw!,,2E"EAw FF N H GsEE/E Ec f[5n[R"UURU[UUS9 g)aWait for the specied function update to complete. Args: op: Cloud operation to wait on. try_set_invoker: function to try setting invoker, see above TODO. on_every_poll: list of functions to execute every time we poll. Functions should take in Operation as an argument. )try_set_invoker on_every_pollN)r,r Waitr_DEPLOY_WAIT_NOTICE)oprrr+s rWaitForFunctionUpdateOperationrs0 !& //  %! rc[5nURnSR[U55nURR UR UURUS95$)zCall the api to patch a function based on updated fields. Args: function: the function to patch fields_to_patch: the fields to patch on the function Returns: The cloud operation for the Patch. ,) cloudFunctionrD updateMask)r,rrsortedrPatch4CloudfunctionsProjectsLocationsFunctionsPatchRequestrD)functionfields_to_patchr+rfields_to_patch_strs r PatchFunctionrse !&  # #(!89  , , 2 2CC }}(D rc~[5nURnURRUR XS95$)zCall the api to create a function. Args: function: the function to create location: location for function Returns: Cloud operation for the create. )locationr)r,rrCreate5CloudfunctionsProjectsLocationsFunctionsCreateRequest)rrr+rs rCreateFunctionrsG !&  # #(  , , 3 3DDE rc~[5nURnURRUR US95$)N)resource)r,rr GetIamPolicy;CloudfunctionsProjectsLocationsFunctionsGetIamPolicyRequest)function_resource_namer+rs rGetFunctionIamPolicyrsE  !&  # #(  , , 9 9JJ)K rc [5nURn[U5n[R"UR XQU5 UR RURUURUS9S95$)NpolicyrsetIamPolicyRequest) r,rrrAddBindingToIamPolicyBindingr SetIamPolicy;CloudfunctionsProjectsLocationsFunctionsSetIamPolicyRequestSetIamPolicyRequestrmemberroler+rrs rAddFunctionIamPolicyBindingr s{ !&  # #(  6 7&   !1!164H  , , 9 9JJ)&::&:IK rc [5nURn[U5n[R"XQU5(dU$[R "XQU5 UR RURUURUS9S95$)z4Removes the specified policy binding if it is found.rr) r,rrrBindingInPolicyRemoveBindingFromIamPolicyrrrrrs r%RemoveFunctionIamPolicyBindingIfFoundrs !&  # #(  6 7&  ! !&$ 7 7 M %%fd;  , , 9 9JJ)&::&:IK rc[5nURnSS/nURUURUS9S9nURR U5nSnUHnXuR ;dMSnM U$)z@Returns True iff the caller can add policy bindings for project.z%resourcemanager.projects.getIamPolicyz%resourcemanager.projects.setIamPolicy) permissions)rtestIamPermissionsRequestTF)r0r5CloudresourcemanagerProjectsTestIamPermissionsRequestTestIamPermissionsRequestprojectsTestIamPermissionsr)r?r+rneeded_permissions iam_request iam_responsecan_addneeded_permissions rCanAddFunctionIamPolicyBindingr 2s / 0&  # #(--NN ( B B(!C!O+ 33K@, '- 8 88g. .rc[5 [X5n[R"5R [ R RU55nU(a5[R"USS5(a[R"S5 ggg![Ra [R"S5 gf=f)zValidates image repository. Yields security and deprecation warnings. Args: region_name: String name of the region to which the function is deployed. project_id: String ID of the Cloud project. allUserszroles/storage.objectVieweraThe Container Registry repository that stores this function's image is public. This could pose the risk of disclosing sensitive data. To mitigate this, either use Artifact Registry ('--docker-registry=artifact-registry' flag) or change this setting in Google Container Registry. aSecuirty check for Container Registry repository that stores this function's image has not succeeded. To mitigate risks of disclosing sensitive data, it is recommended to keep your repositories private. This setting can be verified in Google Container Registry. N)_AddGcrDeprecationWarning GetStorageBucketForGcrRepositorygcs_api StorageClientrr rprqrrrwarningrr) region_name project_idgcr_bucket_urlgcr_host_policys r#ValidateSecureImageRepositoryOrWarnrIs3KL.++-::$$,,^<O833%A kk 4  & &KK PsA;B*CCc4SR[U5US9$)a Retrieves the GCS bucket that backs the GCR repository in specified region. Args: region_name: String name of the region to which the function is deployed. project_id: String ID of the Cloud project. Returns: String representing the URL of the GCS bucket that backs the GCR repo. z5gs://{multiregion}.artifacts.{project_id}.appspot.com) multiregionr)rV_GetGcrMultiregion)rrs rrris) A G G$[1 H rcURS5(agURS5(dURS5(agg)z@Returns String name of the GCR multiregion for the given region.europeeuasia australiaus) startswith)rs rrrys?H%% f%%)?)? )L)L  rc(UR[:H$r2)dockerRegistry_DOCKER_REGISTRY_GCR)rs rIsGcrRepositoryr&s  $8 88rc0[R"S5 g)z2Adds warning on deprecation of Container Registry.aDue to the general transition from Container Registry to Artifact Registry, `--docker-registry=container-registry` will no longer be available as an option when deploying a function. All container image storage and management will automatically transition to Artifact Registry. For more information, please visit: https://cloud.google.com/artifact-registry/docs/transition/transition-from-gcrN)rrr/rrrrs++Xr)NN)rzroles/cloudfunctions.invoker)b__doc__ __future__rrrrrsrrOraapitools.base.pyrrrr #googlecloudsdk.api_lib.functions.v1r #googlecloudsdk.api_lib.functions.v2r r!googlecloudsdk.api_lib.storager rr googlecloudsdk.api_lib.utilrrgooglecloudsdk.callioperr calliope_basergooglecloudsdk.command_lib.iamrgooglecloudsdk.corerrrrgooglecloudsdk.core.utilr7googlecloudsdk.generated_clients.apis.cloudfunctions.v1rsix.moves.http_clientrrcompilerirjr{r|ror$rrr CloudFunctionDockerRegistryValueValuesEnumCONTAINER_REGISTRYr% ReleaseTrackGArr,r0r4rE_ID_CHAR_P_CHAR_CAPTURE_SEGMENT_PARTrrr]rgrkryr~rrrRrSrrrrrrrrrr rrrr&rr/rrrAs <&%' %>'::?A7,E/9A3=#*)-^OJJ:. DE **%EF   $n5,,JJ]] '3366  -99<<B> -99<<B  " H ~ - (?S 7 *U 2 3)D0C(*S0584?: B   <"#L  2( ," " $""<",0","",""&"""  '"""  '"("",@  9 r