) dZddlmZddlmZddlmZddlmZddlmZddlmZ ddl m Z ddl mZ ddlmZdd lmZdd lmZdd lmZGd d ej&ZdZdZeedZdZdZdZdZdZdZdZdZdZ y)z*'functions deploy' utilities for triggers.)absolute_import)division)unicode_literals) exceptions)triggers)util) storage_util)log) properties) resourcesceZdZdZy)TriggerCompatibilityErrorzARaised when deploy trigger is incompatible with existing trigger.N)__name__ __module__ __qualname____doc__Blib/googlecloudsdk/command_lib/functions/v1/deploy/trigger_util.pyrr sIrra2The `--trigger-bucket` flag corresponds to the `google.storage.object.finalize` event on file creation. You are trying to update a function that is using the legacy `providers/cloud.storage/eventTypes/object.change` event type. To get the legacy behavior, use the `--trigger-event` and `--trigger-resource` flags e.g. `gcloud functions deploy --trigger-event providers/cloud.storage/eventTypes/object.change --trigger-resource [your_bucket_name]`.Please see https://cloud.google.com/storage/docs/pubsub-notifications for more information on storage event types.aThe format of the Pub/Sub event source has changed. You are trying to update a function that is using the legacy `providers/cloud.pubsub/eventTypes/topic.publish` event type. To get the legacy behavior, use the `--trigger-event` and `--trigger-resource` flags e.g. `gcloud functions deploy --trigger-event providers/cloud.pubsub/eventTypes/topic.publish --trigger-resource [your_topic_name]`.)z0providers/cloud.storage/eventTypes/object.changez/providers/cloud.pubsub/eventTypes/topic.publishc|jdsN|jds<|jds*|jdstjgddyyyy)N trigger_topictrigger_bucket trigger_http trigger_event)z--trigger-topicz--trigger-bucket--trigger-httpz--trigger-eventz9You must specify a trigger when deploying a new function.) IsSpecifiedcalliope_exceptionsOneOfArgumentsRequiredException)argss rCheckTriggerSpecifiedr Dsm '  * +  . )  / *  = = D  + * ,(rctjj|}|j}|tjk7rmtjj ||j }|A|tjjk7r$tjdj||r|rtjddyy)a3Check if args related function triggers are valid. Args: trigger_event: The trigger event trigger_resource: The trigger resource retry_specified: Whether or not `--retry` was specified trigger_http_specified: Whether or not `--trigger-http` was specified Raises: FunctionsError. NzAYou must provide --trigger-resource when using --trigger-event={}rz--retry)rTRIGGER_PROVIDER_REGISTRYProviderForEventlabelUNADVERTISED_PROVIDER_LABELEvent resource_type ResourcesPROJECTrFunctionsErrorformatrConflictingArgumentsException)rtrigger_resourceretry_specifiedtrigger_http_specifiedtrigger_providertrigger_provider_labelr's rValidateTriggerArgsr2Vs77HH,11xCCC66<< mMX5G5G5O5O$O  % % %vm4 /  ; ;) 0_rc|dd}dd|dS)Nz cloud.storagezgoogle.storage.object.finalizer0rr-r)r bucket_names r_GetBucketTriggerEventParamsr8xs!q$+)7% rcdd|dS)Nz cloud.pubsubzgoogle.pubsub.topic.publishr6r)rs r_GetTopicTriggerEventParamsr:s(4' rcRtjj|}|j}|||d}|tjk(r|Stjj ||j }|tjjk(rtj|}n|tjjk(r*tjj|j}n|tjj tjj"tjj$fvrng|tjj&k(r6|rHt(j*j,j.j1|nt3j4||d<|S)zGet the args for creating an event trigger. Args: trigger_event: The trigger event trigger_resource: The trigger resource Returns: A dictionary containing trigger_provider, trigger_event, and trigger_resource. r6r-)rr"r#r$r%r&r'r(TOPICapi_utilValidatePubsubTopicNameOrRaiseBUCKETr BucketReferenceFromUrlbucketFIREBASE_ANALYTICS_EVENT FIREBASE_DB FIRESTORE_DOCr)r VALUEScoreprojectValidatecore_exceptions InternalError)rr-r0r1resultr's r_GetEventTriggerEventParamsrMsk77HH,110$* & xCCC M44::mMh((...>>?OP**111#33;; f11$$&&  **222$$--.>?  ' ' ))/&  -rc|ry|r t|S|r t|S|r t||S|rtjdyy)aCheck --trigger-* arguments and deduce if possible. 0. if --trigger-http is return None. 1. if --trigger-bucket return bucket trigger args (_GetBucketTriggerArgs) 2. if --trigger-topic return pub-sub trigger args (_GetTopicTriggerArgs) 3. if --trigger-event, deduce provider and resource from registry and return Args: trigger_http: The trigger http trigger_bucket: The trigger bucket trigger_topic: The trigger topic trigger_event: The trigger event trigger_resource: The trigger resource Returns: None, when using HTTPS trigger. Otherwise a dictionary containing trigger_provider, trigger_event, and trigger_resource. NzIgnoring the flag --trigger-resource. The flag --trigger-resource is provided but --trigger-event is not. If you intend to change trigger-resource you need to provide trigger-event as well.)r8r:rMr warning)rrrrr-s rGetTriggerEventParamsrPsQ*  ' 77 &} 55 &}6F GGKK Frcztjj||j}i}|jj dvr|S|jj dk(r2t jjjj|d<ne|jj dk(r2t jjjj|d<n|jj dk(r tjj|||jj }|jS)a~Prepares resource field for Function EventTrigger to use in API call. API uses relative resource name in EventTrigger message field. The structure of that identifier depends on the resource type which depends on combination of --trigger-provider and --trigger-event arguments' values. This function chooses the appropriate form, fills it with required data and returns as a string. Args: trigger_provider: The --trigger-provider flag value. trigger_event: The --trigger-event flag value. trigger_resource: The --trigger-resource flag value. Returns: Relative resource name to use in EventTrigger field. >google.firestore.documentgoogle.firebase.database.refgoogle.firebase.analytics.eventzcloudresourcemanager.projects projectIdzpubsub.projects.topics projectsIdzcloudfunctions.projects.buckets) collection)rr"r&r'value collection_idr rFrGrH GetOrFailr REGISTRYParse RelativeName)r0rr-r'paramsrefs r ConvertTriggerArgsToRelativeNamer`s&44:: M &&&+ ((,KK$++0088BBF;((,DD%,,1199CCF<((,MM   $$22 ! #   rctj}|j}||_|tj k(r ||_|St||||_|S)zCreate event trigger message. Args: trigger_provider: str, trigger provider label. trigger_event: str, trigger event label. trigger_resource: str, trigger resource name. Returns: A EventTrigger protobuf message. )r=GetApiMessagesModule EventTrigger eventTyperr%resourcer`)r0rr-messages event_triggers rCreateEventTriggerrh se * * ,('')-)-===-M >-)9M rcf|r/|j}|tvr||k7rt|}t|yyy)N)rdLEGACY_TRIGGER_EVENTSr)function_triggernew_trigger_eventfunction_event_typeerrors rCheckLegacyTriggerUpdatero$sH*4444 #4 4#$78e %e ,, 5 5rN)!r __future__rrr#googlecloudsdk.api_lib.functions.v1rrrr=googlecloudsdk.api_lib.storager googlecloudsdk.calliopergooglecloudsdk.corerJr r r ErrorrGCS_COMPATIBILITY_ERRORPUBSUB_COMPATIBILITY_ERRORrjr r2r8r:rMrPr`rhrorrrrxs1&':8@7E=#*)J 5 5J /-9P"$D0f"J)X.-r