(phV\SrSSKrSSKrSSKrSSKrSSKJr SSKJr SSK r SSK J r SSK J r SSK J r SSK J r SS K Jr SS K Jr S r/S Qr\ R$r\ R&r\ R(r\ R*r\ R,r\ R.r\ R0r\ R2r\ R4r\ R6r\ R8r\ R:r\ R<r\ R>r\ R@r \ RBr!\ RDr"\ RFr#\ RHr$\ RJr%\ RLr&\ RNr'S r(SSjr)SSjr*SSjr+SSjr,SSjr-S Sjr.S Sjr/"SS5r0"SS5r1"SS5r2"SS5r3"SS5r4g)!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_topiccB[R"U[[5$N)r get_app_service_MESSAGING_ATTRIBUTE_MessagingService)apps K/var/www/html/venv/lib/python3.13/site-packages/firebase_admin/messaging.py_get_messaging_servicer4ds  ! !#';=N OOc6[U5RX5$)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$ "# & + +G ==r5c6[U5RX5$)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 0 CCr5c J[U[5(d [S5eURVs/sHNn[ UR UR URURURURUS9PMP nn[U5RXA5$s snf)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, - "# & 0 0 CC-sAB cl[R"S[5 [U5R X5$)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 [R"S[5 [U[5(d [ S5eUR Vs/sHNn[URURURURURURUS9PMP nn[U5RXA5$s snf)aSends 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, - "# & / / BB-s AB;c8[U5RXS5$)aSubscribes 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( **r5c8[U5RXS5$)aUnsubscribes 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+ --r5c>\rSrSrSrSr\S5r\S5rSr g)rizBAn error encountered when performing a topic management operation.cXlX lgr._index_reason)selfindexreasons r3__init__ErrorInfo.__init__s   r5cUR$)zBIndex of the registration token to which this error is related to.)rYr[s r3r\ErrorInfo.indexs{{r5cUR$)z*String describing the nature of the error.)rZras r3r]ErrorInfo.reason||r5rXN) __name__ __module__ __qualname____firstlineno____doc__r^propertyr\r]__static_attributes__r5r3rrs2Lr5rcN\rSrSrSrSr\S5r\S5r\S5r Sr g) r i!z8The response received from a topic management operation.cx[U[5(aSU;a[SRU55eSUlSUl/Ul[US5H^up#SU;a>U=R S- slUR R[X#S55 MIU=RS- slM` g)Nresultsz*Unexpected topic management response: {0}.rerror) rFdictrGformat_success_count_failure_count_errors enumerateappendr)r[respr\results r3r^ TopicManagementResponse.__init__$s$%%$)>IPPQUVW W &tI7ME& ##q(# ##IeG_$EF##q(# 8r5cUR$)zCNumber of tokens that were successfully subscribed or unsubscribed.ruras r3 success_count%TopicManagementResponse.success_count1"""r5cUR$)zLNumber of tokens that could not be subscribed or unsubscribed due to errors.)rvras r3 failure_count%TopicManagementResponse.failure_count6rr5cUR$)z;A list of ``messaging.ErrorInfo`` objects (possibly empty).)rwras r3errorsTopicManagementResponse.errors;rer5)rwrvruN) rfrgrhrirjr^rkrrrrlrmr5r3r r !sFB )####r5r cN\rSrSrSrSr\S5r\S5r\S5r Sr g) riAz:The response received from a batch request to the FCM API.cXl[UVs/sHo"R(dMUPM sn5Ulgs snfr.) _responseslensuccessru)r[ responsesrzs r3r^BatchResponse.__init__Ds*#!I"NID4I"NO"Ns;;cUR$)z>A list of ``messaging.SendResponse`` objects (possibly empty).)rras r3rBatchResponse.responsesHr5cUR$r.r~ras r3rBatchResponse.success_countMs"""r5cF[UR5UR- $r.)rrrras r3rBatchResponse.failure_countQs4>>"T%7%777r5)rruN) rfrgrhrirjr^rkrrrrlrmr5r3rrAsGDP##88r5rcN\rSrSrSrSr\S5r\S5r\S5r Sr g) riVzHThe response received from an individual batched request to the FCM API.c\X lSUlU(aURSS5Ulgg)Nname) _exception _message_idget)r[rz exceptions r3r^SendResponse.__init__Ys*# #xx5D  r5cUR$)z9A message ID string that uniquely identifies the message.)rras r3 message_idSendResponse.message_id_sr5cNURSL=(a UR(+$)z3A boolean indicating if the request was successful.N)rrras r3rSendResponse.successds!t+CDOO0CCr5cUR$)zTA ``FirebaseError`` if an error occurs while sending the message to the FCM service.)rras r3rSendResponse.exceptionirr5)rrN) rfrgrhrirjr^rkrrrrlrmr5r3rrVsHR6   DDr5rc\rSrSrSrSrSrSrSS0r\ R"5r \ \ \\ \S.rS r\S 5rSS jrSS jrSS jrSrSrSrSrSrSr\S5r\S5r\S5rSr g)r1iozKService 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 UNREGISTEREDcURnU(d [S5e[RR U5UlSSR [ R5S.UlURRS[R5nURR5Ul[R "URUS9Ul[$R&Ulg)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_URLrt_fcm_urlfirebase_admin __version__ _fcm_headersoptionsrrDEFAULT_TIMEOUT_SECONDSrget_credential _credentialJsonHttpClient_clientrauthorized_http_build_transport)r[r2rrs r3r^_MessagingService.__init__s^^ => >*1188D ),!8!?!?@Z@Z![ ++//-1U1UV>>88:#22d>N>NX_` % 5 5r5cx[U[5(d [S5eURR U5$)Nz7Message must be an instance of messaging.Message class.)rFrrG JSON_ENCODERdefault)clsr7s r3encode_message _MessagingService.encode_messages2'7++VW W''00r5cURX5nURRSURURUS9nUS$![ R RanURU5eSnAff=f)z2Sends the given message to FCM via the FCM v1 API.posturlheadersjsonrN) _message_datarbodyrrrequestsr RequestException_handle_fcm_error)r[r7r8r?rzrqs r3r&_MessagingService.sends!!'3 <<$$MM)) %D< ""33 0((/ / 0s0AA<&A77A<c ^[U[5(d [S5e[U5S:a [S5eU4SjnUVs/sHnTR XB5PM nn[ R R[U5S9nURX55Vs/sHowPM nn[U5sSSS5 $s snfs snf!,(df  g=f![a)n [R"SRU 5U S9eSn A ff=f) 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>TRRSTRTRUS9n[ USS9$![ R Ra#n[ STRU5S9sSnA$SnAff=f)Nrr)r)rzr) rrrrrrr rr)r?rzrr[s r3 send_data._MessagingService.send_each..send_datas :||((  -- )$DD99&&77 \#9O9OPY9Z[[ \s0=A>A93A>9A>) max_workersNz4Unknown error while making remote service calls: {0})r7cause)rFlistrGrr concurrentfuturesThreadPoolExecutormapr Exceptionr UnknownErrorrt) r[r;r8rr7 message_dataexecutorrzrrqs ` r3r)_MessagingService.send_eachs(D))VW W x=3 PQ Q :MUUH**7SnU(aTRU5n[X5nTRU5 gr.)_handle_batch_errorrry)_responserqr send_responserr[s r3batch_callback2_MessagingService.send_all..batch_callbacks3I 44U; (=M   ] +r5)callback batch_uriPOST)rpostprocurimethodrrN)rFrrGrrBatchHttpRequestr1 FCM_BATCH_URLrrrdumpsr HttpRequest _postprocrraddexecuterrr) r[r;r8rbatch transportr7rreqrqrs ` @r3r'_MessagingService.send_alls(D))VW W x=3 PQ Q  ,%%#/@/N/NP))$*:*:; G::d00BCD""MM)) C IIcN  , MMO!+ + 2**51 1 2s;D D6 D11D6c[U[5(aU/n[U[5(aU(d [S5eUVs/sH#n[U[5(a U(aM!UPM% nnU(a [S5e[U[5(aU(d [S5eUR S5(dSR U5nUUS.nSR [ RU5nURRSUU[ RS 9n[U5$s snf![RRan URU 5eS n A ff=f) 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 startswithrtr1IID_URLrr IID_HEADERSr rr r_handle_iid_error) r[rHrT operationt invalid_strr?rrzrqs r3rR/_MessagingService.make_topic_management_requests8 fc " "XF&$''vVW W"(L&Q 1c0B0B!q& L @A A%%%U@A A ++!((/E#) 088)D 1<<$$)55 %D+40 0/M(""33 0((/ / 0s$ D+(D+6*D00E$EE$cLS[RU50nU(aSUS'U$)Nr7T validate_only)r1r)r[r7r8r?s r3r_MessagingService._message_datas*,;;GDE $(D ! r5cJ[R"UR55$)z'Handle response from batch API request.)rloadsdecode)r[rrs r3r_MessagingService._postprocszz$++-((r5cL[R"U[R5$)z)Handles errors received from the FCM API.)r #handle_platform_error_from_requestsr1_build_fcm_error_requestsr[rqs r3r#_MessagingService._handle_fcm_errors#99 $>>@ @r5cURc[R"U5e0nURR5n[ U[ 5(aUnURS5nSnU(aSRU5nOHSRURRURRR55n[R"X5$![ a Nf=f)z1Handles errors received from the Instance ID API.Nrqz(Error while calling the IID service: {0}z4Unexpected HTTP response with status: {0}; body: {1}) rr handle_requests_errorrrFrsrGrrt status_codecontentr)r[rqr? parsed_bodycodemsgs r3r#_MessagingService._handle_iid_errors >> !..u5 5 ..--/K+t,," xx  <CCDICHOO**ENN,B,B,I,I,KMC++E77   s1C"" C/.C/cL[R"U[R5$)zMHandles errors received from the googleapiclient while making batch requests.)r*handle_platform_error_from_googleapiclientr1 _build_fcm_error_googleapiclientrs r3r%_MessagingService._handle_batch_error0s#FF $EEG Gr5cXURU5nU(aU"X!URS9$S$z^Parses an error response from the FCM API and creates a FCM-specific exception if appropriate.)r http_responseN)_build_fcm_errorr)rrqr7 error_dictexc_types r3r+_MessagingService._build_fcm_error_requests5s-'' 3OWxENNKa]aar5cDURU5nU(aU"X!US9$S$r$)r&)rrqr7r'r%r(s r3r!2_MessagingService._build_fcm_error_googleapiclient<s)'' 3NVxMJ`\``r5cU(dgSnURS/5H+nURS5S:XdMURS5n O [RRU5$)Ndetailsz@typez3type.googleapis.com/google.firebase.fcm.v1.FcmError errorCode)rr1FCM_ERROR_TYPES)rr'fcm_codedetails r3r&"_MessagingService._build_fcm_errorCs^ nnY3Fzz'"&[[!::k24!0044X>>r5)rrrrrN)F)!rfrgrhrirjrrrrrMessageEncoderrrrrr!r/r^ classmethodrr&r)r'rRrrrrrrr!r&rlrmr5r3r1r1osUHG6M*G&/K%446L/,3"5) O6"11  :$,L1> ) @ 80G bb aa ??r5r1)FNr.)5rjconcurrent.futuresrrrLrgoogleapiclientrrrrrrrr r r0__all__r r rrrrrrrrrrrrr"r#r$r%rrrr!r4r&r)r*r'r(r+r,rr rrr1rmr5r3r8s'  !'-+'!%$# L!.. $66&::  ( ( !00**   $ $ ..  ( (  ..  $ $%66,,  .. $66&::,FF%88(>>&::$66P>(D(D>C.!CF*&-($@88*2]?]?r5