%9jVNdZddlZddlZddlZddlZddlmZddlmZddl Z ddl m Z ddl m Z ddl m Z ddl m Z dd l mZdd l mZd Zgd Ze j$Ze j&Ze j(Ze j*Ze j,Ze j.Ze j0Ze j2Ze j4Ze j6Ze j8Ze j:Ze j<Ze j>Ze j@Z e jBZ!e jDZ"e jFZ#e jHZ$e jJZ%e jLZ&e jNZ'd Z(ddZ)ddZ*ddZ+ddZ,ddZ-d dZ.d dZ/GddZ0GddZ1GddZ2GddZ3GddZ4y)!z Firebase Cloud Messaging module.N)http)_auth) _http_client)_messaging_encoder)_messaging_utils) _gapic_utils)_utils) exceptions _messaging)! AndroidConfigAndroidFCMOptionsAndroidNotification APNSConfigAPNSFCMOptions APNSPayloadApsApsAlert BatchResponse CriticalSound ErrorInfo FCMOptions LightSettingsMessageMulticastMessage NotificationQuotaExceededErrorSenderIdMismatchError SendResponseThirdPartyAuthErrorTopicManagementResponseUnregisteredError WebpushConfigWebpushFCMOptionsWebpushNotificationWebpushNotificationActionsendsend_allsend_multicast send_eachsend_each_for_multicastsubscribe_to_topicunsubscribe_from_topicc@tj|ttSN)r get_app_service_MESSAGING_ATTRIBUTE_MessagingService)apps T/var/www/html/truck-me/venv/lib/python3.12/site-packages/firebase_admin/messaging.py_get_messaging_servicer4ds  ! !#';=N OOc8t|j||S)aSends the given message via Firebase Cloud Messaging (FCM). If the ``dry_run`` mode is enabled, the message will not be actually delivered to the recipients. Instead FCM performs all the usual validations, and emulates the send operation. Args: message: An instance of ``messaging.Message``. dry_run: A boolean indicating whether to run the operation in dry run mode (optional). app: An App instance (optional). Returns: string: A message ID string that uniquely identifies the sent message. Raises: FirebaseError: If an error occurs while sending the message to the FCM service. ValueError: If the input arguments are invalid. )r4r&)messagedry_runr2s r3r&r&gs$ "# & + +GW ==r5c8t|j||S)aSends each message in the given list via Firebase Cloud Messaging. If the ``dry_run`` mode is enabled, the message will not be actually delivered to the recipients. Instead FCM performs all the usual validations, and emulates the send operation. Args: messages: A list of ``messaging.Message`` instances. dry_run: A boolean indicating whether to run the operation in dry run mode (optional). app: An App instance (optional). Returns: BatchResponse: A ``messaging.BatchResponse`` instance. Raises: FirebaseError: If an error occurs while sending the message to the FCM service. ValueError: If the input arguments are invalid. )r4r)messagesr8r2s r3r)r){s$ "# & 0 07 CCr5c Bt|ts td|jDcgc]P}t |j |j |j|j|j|j|R}}t|j||Scc}w)aSends the given mutlicast message to each token via Firebase Cloud Messaging (FCM). If the ``dry_run`` mode is enabled, the message will not be actually delivered to the recipients. Instead FCM performs all the usual validations, and emulates the send operation. Args: multicast_message: An instance of ``messaging.MulticastMessage``. dry_run: A boolean indicating whether to run the operation in dry run mode (optional). app: An App instance (optional). Returns: BatchResponse: A ``messaging.BatchResponse`` instance. Raises: FirebaseError: If an error occurs while sending the message to the FCM service. ValueError: If the input arguments are invalid. @Message must be an instance of messaging.MulticastMessage class.data notificationandroidwebpushapns fcm_optionstoken) isinstancer ValueErrortokensrr?r@rArBrCrDr4r)multicast_messager8r2rEr;s r3r*r*s$ ')9 :[\\%++-   # #&33!))!))  # #%11-H- "# & 0 07 CC-sABcltjdtt|j ||S)aSends the given list of messages via Firebase Cloud Messaging as a single batch. If the ``dry_run`` mode is enabled, the message will not be actually delivered to the recipients. Instead FCM performs all the usual validations, and emulates the send operation. Args: messages: A list of ``messaging.Message`` instances. dry_run: A boolean indicating whether to run the operation in dry run mode (optional). app: An App instance (optional). Returns: BatchResponse: A ``messaging.BatchResponse`` instance. Raises: FirebaseError: If an error occurs while sending the message to the FCM service. ValueError: If the input arguments are invalid. send_all() is deprecated. Use send_each() instead. z2send_all() is deprecated. Use send_each() instead.)warningswarnDeprecationWarningr4r'r:s r3r'r's,( MMFHZ[ !# & / /' BBr5c vtjdtt|ts t d|j Dcgc]P}t|j|j|j|j|j|j|R}}t|j||Scc}w)a'Sends the given mutlicast message to all tokens via Firebase Cloud Messaging (FCM). If the ``dry_run`` mode is enabled, the message will not be actually delivered to the recipients. Instead FCM performs all the usual validations, and emulates the send operation. Args: multicast_message: An instance of ``messaging.MulticastMessage``. dry_run: A boolean indicating whether to run the operation in dry run mode (optional). app: An App instance (optional). Returns: BatchResponse: A ``messaging.BatchResponse`` instance. Raises: FirebaseError: If an error occurs while sending the message to the FCM service. ValueError: If the input arguments are invalid. send_multicast() is deprecated. Use send_each_for_multicast() instead. zFsend_multicast() is deprecated. Use send_each_for_multicast() instead.r=r>)rLrMrNrFrrGrHrr?r@rArBrCrDr4r'rIs r3r(r(s( MMZ$& ')9 :[\\%++-   # #&33!))!))  # #%11-H- "# & / /' BB-sAB6c:t|j||dS)a4Subscribes a list of registration tokens to an FCM topic. Args: tokens: A non-empty list of device registration tokens. List may not have more than 1000 elements. topic: Name of the topic to subscribe to. May contain the ``/topics/`` prefix. app: An App instance (optional). Returns: TopicManagementResponse: A ``TopicManagementResponse`` instance. Raises: FirebaseError: If an error occurs while communicating with instance ID service. ValueError: If the input arguments are invalid. ziid/v1:batchAddr4make_topic_management_requestrHtopicr2s r3r+r+s$ "# & D D( **r5c:t|j||dS)a<Unsubscribes a list of registration tokens from an FCM topic. Args: tokens: A non-empty list of device registration tokens. List may not have more than 1000 elements. topic: Name of the topic to unsubscribe from. May contain the ``/topics/`` prefix. app: An App instance (optional). Returns: TopicManagementResponse: A ``TopicManagementResponse`` instance. Raises: FirebaseError: If an error occurs while communicating with instance ID service. ValueError: If the input arguments are invalid. ziid/v1:batchRemoverQrSs r3r,r,s$ "# & D D+ --r5c6eZdZdZdZedZedZy)rzBAn error encountered when performing a topic management operation.c ||_||_yr.)_index_reason)selfindexreasons r3__init__zErrorInfo.__init__s  r5c|jS)zBIndex of the registration token to which this error is related to.)rXrZs r3r[zErrorInfo.indexs{{r5c|jS)z*String describing the nature of the error.)rYr_s r3r\zErrorInfo.reason||r5N)__name__ __module__ __qualname____doc__r]propertyr[r\r5r3rrs2Lr5rcFeZdZdZdZedZedZedZy)r z8The response received from a topic management operation.cdt|trd|vrtdj|d|_d|_g|_t|dD]\\}}d|vr>|xj dz c_|j jt||dH|xjdz c_^y)Nresultsz*Unexpected topic management response: {0}.rerror) rFdictrGformat_success_count_failure_count_errors enumerateappendr)rZrespr[results r3r]z TopicManagementResponse.__init__$s$%$)>IPPQUVW W &tI7 )ME6& ##q(# ##IeVG_$EF##q(#  )r5c|jS)zCNumber of tokens that were successfully subscribed or unsubscribed.ror_s r3 success_countz%TopicManagementResponse.success_count1"""r5c|jS)zLNumber of tokens that could not be subscribed or unsubscribed due to errors.)rpr_s r3 failure_countz%TopicManagementResponse.failure_count6ryr5c|jS)z;A list of ``messaging.ErrorInfo`` objects (possibly empty).)rqr_s r3errorszTopicManagementResponse.errors;rar5N) rbrcrdrer]rfrxr{r}rgr5r3r r !sFB )####r5r cFeZdZdZdZedZedZedZy)rz:The response received from a batch request to the FCM API.cr||_t|Dcgc]}|js|c}|_ycc}wr.) _responseslensuccessro)rZ responsesrts r3r]zBatchResponse.__init__Ds*#!I"ND4"NO"Ns44c|jS)z>A list of ``messaging.SendResponse`` objects (possibly empty).)rr_s r3rzBatchResponse.responsesHr5c|jSr.rwr_s r3rxzBatchResponse.success_countMs"""r5cFt|j|jz Sr.)rrrxr_s r3r{zBatchResponse.failure_countQs4>>"T%7%777r5N) rbrcrdrer]rfrrxr{rgr5r3rrAsGDP##88r5rcFeZdZdZdZedZedZedZy)rzHThe response received from an individual batched request to the FCM API.cT||_d|_|r|jdd|_yy)Nname) _exception _message_idget)rZrt exceptions r3r]zSendResponse.__init__Ys,# #xx5D  r5c|jS)z9A message ID string that uniquely identifies the message.)rr_s r3 message_idzSendResponse.message_id_sr5c<|jduxr |j S)z3A boolean indicating if the request was successful.N)rrr_s r3rzSendResponse.successds!t+CDOO0CCr5c|jS)zTA ``FirebaseError`` if an error occurs while sending the message to the FCM service.)rr_s r3rzSendResponse.exceptionirr5N) rbrcrdrer]rfrrrrgr5r3rrVsHR6   DDr5rceZdZdZdZdZdZddiZejZ e e e e edZdZed Zdd Zdd Zdd Zd ZdZdZdZdZdZedZedZedZy)r1zKService class that implements Firebase Cloud Messaging (FCM) functionality.z8https://fcm.googleapis.com/v1/projects/{0}/messages:sendz https://fcm.googleapis.com/batchzhttps://iid.googleapis.comaccess_token_authtrue)APNS_AUTH_ERRORQUOTA_EXCEEDEDSENDER_ID_MISMATCHTHIRD_PARTY_AUTH_ERROR UNREGISTEREDc|j}|s tdtjj ||_ddj t jd|_|jjdtj}|jj|_tj |j||_t$j&|_y)NzProject ID is required to access Cloud Messaging service. Either set the projectId option, or use service account credentials. Alternatively, set the GOOGLE_CLOUD_PROJECT environment variable.2zfire-admin-python/{0})zX-GOOG-API-FORMAT-VERSIONzX-FIREBASE-CLIENT httpTimeout) credentialtimeout) project_idrGr1FCM_URLrn_fcm_urlfirebase_admin __version__ _fcm_headersoptionsrrDEFAULT_TIMEOUT_SECONDSrget_credential _credentialJsonHttpClient_clientrauthorized_http_build_transport)rZr2rrs r3r]z_MessagingService.__init__s^^ => >*1188D ),!8!?!?@Z@Z![ ++//-1U1UV>>88:#22d>N>NX_` % 5 5r5cnt|ts td|jj |S)Nz7Message must be an instance of messaging.Message class.)rFrrG JSON_ENCODERdefault)clsr7s r3encode_messagez _MessagingService.encode_messages/'7+VW W''00r5c|j||} |jjd|j|j|}|dS#t j j$r}|j|d}~wwxYw)z2Sends the given message to FCM via the FCM v1 API.posturlheadersjsonrN) _message_datarbodyrrrequestsr RequestException_handle_fcm_error)rZr7r8r?rtrks r3r&z_MessagingService.sends!!'73 <<$$MM)) %D< ""33 0((/ / 0s3A A?)A::A?c t|ts tdt|dkDr tdfd}|Dcgc]}j ||}} t j jt|5}|j||Dcgc]}|}}t|cdddScc}wcc}w#1swYyxYw#t$r+} tjdj| | d} ~ wwxYw) z3Sends the given messages to FCM via the FCM v1 API.7messages must be a list of messaging.Message instances.1messages must not contain more than 500 elements.c jjdjj|}t |dS#t j j$r&}t dj|cYd}~Sd}~wwxYw)Nrr)r)rtr) rrrrrrr rr)r?rtrrZs r3 send_dataz._MessagingService.send_each..send_datas :||((  -- )$DD99&&77 \#9O9OPY9Z[[ \s3AB B;BB) max_workersNz4Unknown error while making remote service calls: {0})r7cause)rFlistrGrr concurrentfuturesThreadPoolExecutormapr Exceptionr UnknownErrorrn) rZr;r8rr7 message_dataexecutorrtrrks ` r3r)z_MessagingService.send_eachs(D)VW W x=3 PQ Q :MUU**7G<U U ##663|CT6U 0Ya.6ll9l.STdTT T$Y/ 0 0VU 0 0 ))NUUV[\  sMB8)CC B=" C. C=CC C C D&C==Dc f t|ts tdt|dkDr tdg fd}t j |t j}jj}|D]q}tjj||}t j|jjd|j }|j#|s |j%t' S#t($r} j+| d} ~ wwxYw) z2Sends the given messages to FCM via the batch API.rrrcjd}|rj|}t||}j|yr.)_handle_batch_errorrrs)_responserkr send_responserrZs r3batch_callbackz2_MessagingService.send_all..batch_callbacks5I 44U; (9=M   ] +r5)callback batch_uriPOST)rpostprocurimethodrrN)rFrrGrrBatchHttpRequestr1 FCM_BATCH_URLrrrdumpsr HttpRequest _postprocrraddexecuterrr) rZr;r8rbatch transportr7rreqrkrs ` @r3r'z_MessagingService.send_alls(D)VW W x=3 PQ Q  ,%%#/@/N/NP))$*:*:;  G::d00'BCD""MM)) C IIcN  , MMO!+ + 2**51 1 2s6D D0D++D0cpt|tr|g}t|tr|s td|Dcgc]}t|tr|r|}}|r tdt|tr|s td|j dsdj |}||d}dj t j|} |jjd||t j }t|Scc}w#tjj$r} |j| d } ~ wwxYw) z;Invokes the IID service for topic management functionality.z7Tokens must be a string or a non-empty list of strings.z!Tokens must be non-empty strings.z!Topic must be a non-empty string.z/topics/z /topics/{0})toregistration_tokensz{0}/{1}r)rrrN)rFstrrrG startswithrnr1IID_URLrr IID_HEADERSr rr r_handle_iid_error) rZrHrT operationt invalid_strr?rrtrks r3rRz/_MessagingService.make_topic_management_requests( fc "XF&$'vVW W"(LQ 1c0B!qL L @A A%%U@A A +!((/E#) 088)D 1<<$$)55 %D+40 0/M(""33 0((/ / 0s#C= C=-DD5D00D5cBdtj|i}|rd|d<|S)Nr7T validate_only)r1r)rZr7r8r?s r3rz_MessagingService._message_datas*,;;GDE $(D ! r5cHtj|jS)z'Handle response from batch API request.)rloadsdecode)rZrrs r3rz_MessagingService._postprocszz$++-((r5cJtj|tjS)z)Handles errors received from the FCM API.)r #handle_platform_error_from_requestsr1_build_fcm_error_requestsrZrks r3rz#_MessagingService._handle_fcm_errors#99 $>>@ @r5c|jtj|i} |jj}t |t r|}|jd}d}|rdj|}nHdj|jj|jjj}tj||S#t $rYwxYw)z1Handles errors received from the Instance ID API.Nrkz(Error while calling the IID service: {0}z4Unexpected HTTP response with status: {0}; body: {1}) rr handle_requests_errorrrFrmrGrrn status_codecontentr)rZrkr? parsed_bodycodemsgs r3rz#_MessagingService._handle_iid_errors >> !..u5 5 ..--/K+t," xx  <CCDICHOO**ENN,B,B,I,I,KMC++E377   s,C C"!C"cJtj|tjS)zMHandles errors received from the googleapiclient while making batch requests.)r*handle_platform_error_from_googleapiclientr1 _build_fcm_error_googleapiclientrs r3rz%_MessagingService._handle_batch_error0s#FF $EEG Gr5cV|j|}|r||||jSdSzfParses an error response from the FCM API and creates a FCM-specific exception if appropriate.)r http_responseN)_build_fcm_errorr)rrkr7 error_dictexc_types r3rz+_MessagingService._build_fcm_error_requests5s/'' 3OWxuENNKa]aar5cB|j|}|r ||||SdSr)r)rrkr7rrr s r3rz2_MessagingService._build_fcm_error_googleapiclient<s+'' 3NVxuMJ`\``r5c|syd}|jdgD])}|jddk(s|jd}ntjj|S)Ndetailsz@typez3type.googleapis.com/google.firebase.fcm.v1.FcmError errorCode)rr1FCM_ERROR_TYPES)rrfcm_codedetails r3rz"_MessagingService._build_fcm_errorCsc nnY3 Fzz'"&[[!::k2 !0044X>>r5N)F)rbrcrdrerrrrrMessageEncoderrrrrr!rr] classmethodrr&r)r'rRrrrrrrrrrgr5r3r1r1osUHG6M*G&/K4%446L/,3"5) O6"11  :$,L1> ) @ 80G bb aa ??r5r1)FNr.)5reconcurrent.futuresrrrLrgoogleapiclientrrrrrrrr r r0__all__r r rrrrrrrrrrrrr"r#r$r%rrrr!r4r&r)r*r'r(r+r,rr rrr1rgr5r3rs'  !'-+'!%$# L!.. $66&::  ( ( !00**   $ $ ..  ( (  ..  $ $%66,,  .. $66&::,FF%88(>>&::$66P>(D(D>C.!CF*&-($@88*2]?]?r5