SrSSKJr SSKJr SSKJr "SS\R5r"SS\R5r SS jr SS jr "S S \ 5r g )z3Utilities for Cloud Pub/Sub Message Transforms API.)utils)apis) exceptionsc\rSrSrSrSrg)EmptyMessageExceptionz9Error when no message was specified for a Test operation.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r 7lib/googlecloudsdk/api_lib/pubsub/message_transforms.pyrrsArrc\rSrSrSrSrg)EmptyFilePathExceptionzMError when no message transforms file was specified for a Validate operation.r Nr r rrrrsUrrc.[R"SSUS9$)Npubsubv1no_http)rGetClientInstancers rrrs  $ @@rNc@U=(d [5nUR$N)rMESSAGES_MODULE)clients rGetMessagesModuler "s  (&(&   rc@\rSrSrSrSSjrS SjrS SjrSrg) MessageTransformsClient'z?Client for message transforms service in the Cloud Pub/Sub API.NcU=(d [5UlU=(d [U5UlURRUlgr)rrr messagesprojects_service)selfrr%s r__init__ MessageTransformsClient.__init__*s5/-/DK9 1& 9DMKK((DMrcU(d [S5e[R"URRU5nURRUR5URRUS9S9nURRU5$![R [R [R4a"n[R"U54Ul eSnAff=f)aValidates a message transform. Args: project_ref (Resource): Resource reference for the project. message_transform_file (str): The file path to the JSON or YAML file containing the message transform. Returns: ValidateMessageTransformResponse (success) if the message transform is valid, otherwise an error. Raises: EmptyFilePathException: If no message transform file was specified. z]You need to specify a path to JSON or YAML file containing the message transform to validate.N)messageTransform)projectvalidateMessageTransformRequest)rr(GetMessageTransformFromFileForValidationr%MessageTransform#MessageTransformsInvalidFormatErrorMessageTransformsEmptyFileError!MessageTransformsMissingFileErrorGetErrorMessageargs-PubsubProjectsValidateMessageTransformRequest RelativeNameValidateMessageTransformRequestr'ValidateMessageTransform)r( project_refmessage_transform_filemessage_transformevalidate_requests rValidate MessageTransformsClient.Validate/s " " ,   HH -- ( (*@}}RR((*(, (U(U.)V) S == 1 12B CC 11 -- //  %%a(*af  s+B3C. C))C.c U(dU(d [S5eURRUURRRUS9S9nSnU(a+[R "URR USS9nU(aURRUS9OSn URRUR5URRUU U(aUR5OSU(aUR5OSS9S 9n UR R#U 5$![R[R[R4a"n [R"U 54U l eSn A ff=f) a;Tests applying message transforms to a message. Args: project_ref (Resource): Resource reference for the project. message_body (bytes): The message to test. attributes (list[AdditionalProperty]): List of attributes to attach to the message. message_transforms_file (str): The file path to the JSON or YAML file containing the message transforms. topic_ref (Resource): The topic containing the message transforms to test against. subscription_ref (Resource): The subscription containing the message transforms to test against. Returns: TestMessageTransformsResponse which contains a list of TransformedMessage. Raises: EmptyMessageException: If no message body or attributes were specified. EmptyMessageTransformsException: If no message transforms file/topic/subscription were specified. zdYou cannot send an empty message. You must specify either a MESSAGE, one or more ATTRIBUTE, or both.)additionalProperties)data attributesNF)enable_vertex_ai_smt)messageTransforms)messagerFtopic subscription)r-testMessageTransformsRequest)rr% PubsubMessageAttributesValuerGetMessageTransformsFromFiler0r1r2r3r4r5MessageTransforms*PubsubProjectsTestMessageTransformsRequestr7TestMessageTransformsRequestr'TestMessageTransforms) r(r: message_bodyrDmessage_transforms_file topic_refsubscription_refrGmessage_transformsr=message_transforms_msg test_requests rTestMessageTransformsClient.TestWs|>  ! 5  mm)) ==..>>!+? *G  "?? MM * * #!&   '':L'M  ==KK((*%)]]%O%O4.7)((*T*668 &P& L L == . .| <<1  3 3  / /  1 1 ''*, s*D663F )FF )r'rr%)NNr)NNNNN) r r r rrr)r?rYrr rrr"r"'s(G) &DV"L=rr")Fr)rgooglecloudsdk.api_lib.pubsubrgooglecloudsdk.api_lib.utilrgooglecloudsdk.corerErrorrrrr objectr"r rrr`sT:/,*BJ,,BVZ--VA |=f|=r