]hmdZddlmZddlmZmZmZmZmZm Z ddl Z ddl Z ddl Z ddlZddlZddlZddlZddlmZddlmZddlZddlmZmZmZmZmZmZmZej:eZdZ gd Z!ejDZ"ejFZ#ejHZ$ejJZ%ejLZ&ejNZ'ejPZ(ejRZ)ejTZ*ejVZ+ejXZ,ejZZ-ej\Z.ej^Z/ej`Z0ejbZ1ejdZ2ejfZ3ejhZ4ejjZ5ejlZ6ejnZ7dd Z8dd d Z9 d d!dZ: d d!dZ; d d"dZddZ?d#dZ@d#dZAGddZBGddZCGdd ZDGddZEGdd ZFy)$z Firebase Cloud Messaging module.) annotations)AnyCallableDictListOptionalcastN)http)_auth) _http_client_messaging_encoder_messaging_utils _gapic_utils_utils exceptionsApp _messaging)# AndroidConfigAndroidFCMOptionsAndroidNotification APNSConfigAPNSFCMOptions APNSPayloadApsApsAlert BatchResponse CriticalSound ErrorInfo FCMOptions LightSettingsMessageMulticastMessage NotificationQuotaExceededErrorSenderIdMismatchError SendResponseThirdPartyAuthErrorTopicManagementResponseUnregisteredError WebpushConfigWebpushFCMOptionsWebpushNotificationWebpushNotificationActionsendsend_allsend_multicast send_eachsend_each_asyncsend_each_for_multicastsend_each_for_multicast_asyncsubscribe_to_topicunsubscribe_from_topic_MessagingServicec@tj|ttSN)rget_app_service_MESSAGING_ATTRIBUTEr7)apps ^/var/www/html/Kila-kolis-project/venv/lib/python3.12/site-packages/firebase_admin/messaging.py_get_messaging_servicer>os  ! !#';=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. )r>r.)messagedry_runr<s r=r.r.rs$ "# & + +GW ==r?rc8t|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. )r>r1messagesrBr<s r=r1r1s, "# & 0 07 CCr?cTKt|j||d{S7w)aSends each message in the given list asynchronously 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. N)r>r2rDs r=r2r2s&,(,<r2multicast_messagerBr<rPrEs r=r4r4s. ')9 :[\\%++-,%  # #&33!))!))  # #%11, -(,<r1rTs r=r3r3s$ ')9 :[\\%++-,%  # #&33!))!))  # #%11, - "# & 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.)warningswarnDeprecationWarningr>r/rDs r=r/r/s,( MMFHZ[ !# & / /' BBr?c 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.rHrI)rXrYrZrQr"rRrSr!rJrKrLrMrNrOr>r/rTs r=r0r0s( MMZ$& ')9 :[\\%++-,%  # #&33!))!))  # #%11, - "# & / /' 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:batchAddr>make_topic_management_requestrStopicr<s r=r5r53s$ "# & D D( **r?c: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:batchRemover]r_s r=r6r6Fs$ "# & D D+ --r?c6eZdZdZdZedZedZy)rzBAn error encountered when performing a topic management operation.c ||_||_yr9)_index_reason)selfindexreasons r=__init__zErrorInfo.__init__]s  r?c|jS)zBIndex of the registration token to which this error is related to.)rdrfs r=rgzErrorInfo.indexas{{r?c|jS)z*String describing the nature of the error.)rerks r=rhzErrorInfo.reasonf||r?N)__name__ __module__ __qualname____doc__ripropertyrgrhr?r=rrZs2Lr?rcFeZdZdZdZedZedZedZy)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) rQdictrRformat_success_count_failure_count_errors enumerateappendr)rfresprgresults r=riz TopicManagementResponse.__init__os$%$)>IPPQUVW W &tI7ME6& ##q(# ##IeVG_$EF##q(# 8r?c|jS)zCNumber of tokens that were successfully subscribed or unsubscribed.r{rks r= success_countz%TopicManagementResponse.success_count|"""r?c|jS)zLNumber of tokens that could not be subscribed or unsubscribed due to errors.)r|rks r= failure_countz%TopicManagementResponse.failure_countrr?c|jS)z;A list of ``messaging.ErrorInfo`` objects (possibly empty).)r}rks r=errorszTopicManagementResponse.errorsrmr?N) rnrorprqrirrrrrrsr?r=r(r(lsFB )####r?r(cNeZdZdZddZeddZed dZed dZy) rz:The response received from a batch request to the FCM API.c@||_td|D|_y)Nc3:K|]}|jsdyw)rxN)success).0rs r= z)BatchResponse.__init__..s!J T\\! s) _responsessumr{)rf responsess r=rizBatchResponse.__init__s#!!J !JJr?c|jS)z>A list of ``messaging.SendResponse`` objects (possibly empty).)rrks r=rzBatchResponse.responsesr?c|jSr9rrks r=rzBatchResponse.success_counts"""r?cFt|j|jz Sr9)lenrrrks r=rzBatchResponse.failure_counts4>>"T%7%777r?N)rList[SendResponse]returnNone)rr)rint) rnrorprqrirrrrrrsr?r=rrsGDK##88r?cFeZdZdZdZedZedZedZy)r&zHThe response received from an individual batched request to the FCM API.cT||_d|_|r|jdd|_yy)Nname) _exception _message_idget)rfr exceptions r=rizSendResponse.__init__s,# #xx5D  r?c|jS)z9A message ID string that uniquely identifies the message.)rrks r= message_idzSendResponse.message_idsr?c<|jduxr |j S)z3A boolean indicating if the request was successful.N)rrrks r=rzSendResponse.successs!t+CDOO0CCr?c|jS)zTA ``FirebaseError`` if an error occurs while sending the message to the FCM service.)rrks r=rzSendResponse.exceptionrr?N) rnrorprqrirrrrrrsr?r=r&r&sHR6   DDr?r&c$eZdZdZdZdZdZddiZejZ e e e e edZddZed Zddd Zddd Zddd Zdd ZdZdZdZdZd dZdZdZd!dZedZe d"dZ edZ!e d#dZ"y)$r7zKService 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||_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_idrRr7FCM_URLrz_fcm_urlfirebase_admin __version__ _fcm_headersoptionsrr DEFAULT_TIMEOUT_SECONDSrget_credential _credentialJsonHttpClient_clientHttpxAsyncClient _async_clientr authorized_http_build_transport)rfr<rrs r=riz_MessagingService.__init__s^^ => >*1188D ),!8!?!?@Z@Z![ ++//-1U1UV>>88:#22d>N>NX_` )::'': % 5 5r?cnt|ts td|jj |S)Nz7Message must be an instance of messaging.Message class.)rQr!rR JSON_ENCODERdefault)clsrAs r=encode_messagez _MessagingService.encode_messages/'7+VW W''00r?c |j||} |jjd|j|j|}t t |dS#tjj$r}|j|d}~wwxYw)z2Sends the given message to FCM via the FCM v1 API.posturlheadersjsonrN) _message_datarbodyrrr strrequestsrRequestException_handle_fcm_error)rfrArBrJrrws r=r.z_MessagingService.sends!!'73 +<<$$MM)) %DT&\* *""33 0((/ / 0s3AB 7BB c t|ts tdt|dkDr tdfd}|Dcgc]}j ||}} t j jt|5}|j||Dcgc]}|}}t|cdddScc}wcc}w#1swYyxYw#t$r+} tjdj| | d} ~ wwxYw) 3Sends 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}~wwxYwNrr)r)rr) rrrrr&rrrrrJrrrfs r= send_dataz._MessagingService.send_each..send_datas :||((  -- )$DD99&&77 \#9O9OPY9Z[[ \s3AB B;BB) max_workersN4Unknown error while making remote service calls: {0}rAcause)rQlistrRrr concurrentfuturesThreadPoolExecutormapr Exceptionr UnknownErrorrz) rfrErBrrA message_dataexecutorrrrws ` r=r1z_MessagingService.send_eachs(D)VW W x=3 PQ Q :MUUH**7G.send_datas A!//77  -- 8$DIIK4@@ ?? b#9U9UV_9`aa&&77 \#9O9OPY9Z[[ \s\C6AAACAC0B C C C1C C CCCNrr) rQrrRrrasynciogatherrrrrrz)rfrErBrrArrrws` r=r2z!_MessagingService.send_each_asyncs(D)VW W x=3 PQ Q AMUUH**7GCBCB"0B?B"B B"CB"" C+&CCCc 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|yr9)_handle_batch_errorr&r)_responserwr send_responserrfs r=batch_callbackz2_MessagingService.send_all..batch_callback8s5I 44U; (9=M   ] +r?)callback batch_uriPOST)r postprocurimethodrrN)rQrrRrr BatchHttpRequestr7 FCM_BATCH_URLrrrdumpsr HttpRequest _postprocrraddexecuterrr) rfrErBrbatch transportrArreqrwrs ` @r=r/z_MessagingService.send_all/s(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)rQrrrR startswithrzr7IID_URLrr IID_HEADERSr(rrr_handle_iid_error) rfrSr` operationt invalid_strrJrrrws r=r^z/_MessagingService.make_topic_management_requestUs) fc "XF&$'vVW W"(L&Q 1c0B!q& 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)NrAT validate_only)r7r)rfrArBrJs r=rz_MessagingService._message_datats*,;;GDE $(D ! r?cHtj|jS)z'Handle response from batch API request.)rloadsdecode)rfrrs r=rz_MessagingService._postproczszz$++-((r?cJtj|tjSz)Handles errors received from the FCM API.)r#handle_platform_error_from_requestsr7_build_fcm_error_requestsrfrws r=rz#_MessagingService._handle_fcm_errors#99 $>>@ @r?cJtj|tjSr)r handle_platform_error_from_httpxr7_build_fcm_error_httpxrs r=rz)_MessagingService._handle_fcm_httpx_errors!66 $;;= =r?c|jtj|i} |jj}t |t r|}|jd}d}|rdj|}nHdj|jj|jjj}tj||S#t $rYwxYw)z1Handles errors received from the Instance ID API.Nrwz(Error while calling the IID service: {0}z4Unexpected HTTP response with status: {0}; body: {1}) rrhandle_requests_errorrrQryrRrrz status_codecontentr)rfrwrJ parsed_bodycodemsgs r=rz#_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_googleapiclientr7 _build_fcm_error_googleapiclientrs r=rz%_MessagingService._handle_batch_errors#FF $EEG Gr?c^tj|jjyr9)rrunracloserks r=closez_MessagingService.closes D&&--/0r?cV|j|}|r||||jSdSzfParses an error response from the FCM API and creates a FCM-specific exception if appropriate.r http_responseN)_build_fcm_errorrrrwrA error_dictexc_types r=rz+_MessagingService._build_fcm_error_requestss/'' 3OWxuENNKa]aar?c|j|}t|tjr|r||||jSdS|r |||SdS)zkParses a httpx error response from the FCM API and creates a FCM-specific exception if appropriate.r1N)r)r3rQrHTTPStatusErrorrr4s r=r z(_MessagingService._build_fcm_error_httpxs`'' 3 eU22 3GOuENND ZUY Z19xu-CtCr?cB|j|}|r ||||SdSr0)r3)rrwrAr5r2r6s r=r*z2_MessagingService._build_fcm_error_googleapiclients+'' 3NVxuMJ`\``r?c|syd}|jdgD])}|jddk(s|jd}n|rtjj|SdS)zNParses an error response to determine the appropriate FCM-specific error type.Ndetailsz@typez3type.googleapis.com/google.firebase.fcm.v1.FcmError errorCode)rr7FCM_ERROR_TYPES)rr5fcm_codedetails r=r3z"_MessagingService._build_fcm_errorsk  nnY3Fzz'"&[[!::k24CK 0044X>TPTTr?N)r<rrr)F)rAr!rBboolrr)rE List[Message]rBr@rr)T)rwhttpx.HTTPErrorrzexceptions.FirebaseError)rr)rwrBrArr5Optional[Dict[str, Any]]rz"Optional[exceptions.FirebaseError])r5rCrz1Optional[Callable[..., exceptions.FirebaseError]])#rnrorprqrrrrr MessageEncoderrr'r$r%r)r=ri classmethodrr.r1r2r/r^rrrrrrr.rr r*r3rsr?r=r7r7s6UHG6M*G&/K4%446L/,3"5) O6&11 +:@$,L1> ) @ = 80G 1bb  D" D D1 D 0 D Daa  U0 U? U Ur?)r< Optional[App]rr7)FN)rAr!rBr@r<rFrr)rErArBr@r<rFrr)rUr"rBr@r<rFrrr9)Grq __future__rtypingrrrrrr concurrent.futuresrrrXrloggingrrgoogleapiclientr r rr r rrrrr getLoggerrnloggerr;__all__rrrrrrrrrrr r!r"r#r*r+r,r-r$r%r'r)r>r.r1r2r4r3r/r0r5r6rr(rr&r7rsr?r=rOsb'"<<  !   8 $#% P!.. $66&::  ( ( !00**   $ $ ..  ( (  ..  $ $%66,,  .. $66&::,FF%88(>>&::$66P>,!DDDD  D4!PPPP  P4!"P+"P"P"P  "PHD>C.!CF*&-($@88*0[U[Ur?