o FhV@sdZddlZddlZddlZddlZddlmZddlmZddl Z ddl m Z ddl m Z ddl m Z ddl m Z dd l mZdd l mZd Zgd Ze jZe jZe jZe jZe jZe jZe jZe jZe jZe jZe jZe jZe jZe jZe j Z e j!Z!e j"Z"e j#Z#e j$Z$e j%Z%e j&Z&e j'Z'd dZ(d(ddZ)d(ddZ*d(ddZ+d(ddZ,d(ddZ-d)ddZ.d)ddZ/GdddZ0Gd d!d!Z1Gd"d#d#Z2Gd$d%d%Z3Gd&d'd'Z4dS)*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_topiccCst|ttSN)rget_app_service_MESSAGING_ATTRIBUTE_MessagingService)appr1Q/var/www/html/loop/nvenv/lib/python3.10/site-packages/firebase_admin/messaging.py_get_messaging_servicedsr3FcCt|||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. )r3r%)messagedry_runr0r1r1r2r%gr%cCr4)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. )r3r(messagesr6r0r1r1r2r({r7r(cs6tts tdfddjD}t|||S)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.c .g|]}tjjjjjj|dqS)data notificationandroidwebpushapns fcm_optionstokenrr=r>r?r@rArB.0rCmulticast_messager1r2  z+send_each_for_multicast..) isinstancer ValueErrortokensr3r(rHr6r0r9r1rGr2r)s   r)cCstdtt|||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.)warningswarnDeprecationWarningr3r&r8r1r1r2r&s r&csBtdtttstdfddjD}t|||S)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:c r;r<rDrErGr1r2rIrJz"send_multicast..) rOrPrQrKrrLrMr3r&rNr1rGr2r's   r'cCt|||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:batchAddr3make_topic_management_requestrMtopicr0r1r1r2r*r*cCrR)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:batchRemoverSrUr1r1r2r+rWr+c@s0eZdZdZddZeddZeddZdS) rzBAn error encountered when performing a topic management operation.cCs||_||_dSr,)_index_reason)selfindexreasonr1r1r2__init__s zErrorInfo.__init__cC|jS)zBIndex of the registration token to which this error is related to.)rXrZr1r1r2r[zErrorInfo.indexcCr^)z*String describing the nature of the error.)rYr_r1r1r2r\r`zErrorInfo.reasonN)__name__ __module__ __qualname____doc__r]propertyr[r\r1r1r1r2rs rc@<eZdZdZddZeddZeddZedd Zd S) rz8The response received from a topic management operation.cCst|tr d|vrtd|d|_d|_g|_t|dD]"\}}d|vr:|jd7_|jt ||dq|jd7_qdS)Nresultsz*Unexpected topic management response: {0}.rerror) rKdictrLformat_success_count_failure_count_errors enumerateappendr)rZrespr[resultr1r1r2r]$sz TopicManagementResponse.__init__cCr^)zCNumber of tokens that were successfully subscribed or unsubscribed.rlr_r1r1r2 success_count1r`z%TopicManagementResponse.success_countcCr^)zLNumber of tokens that could not be subscribed or unsubscribed due to errors.)rmr_r1r1r2 failure_count6r`z%TopicManagementResponse.failure_countcCr^)z;A list of ``messaging.ErrorInfo`` objects (possibly empty).)rnr_r1r1r2errors;r`zTopicManagementResponse.errorsN) rarbrcrdr]rertrurvr1r1r1r2r!s  rc@rf) rz:The response received from a batch request to the FCM API.cCs||_tdd|D|_dS)NcSsg|]}|jr|qSr1)successrFrqr1r1r2rIFsz*BatchResponse.__init__..) _responseslenrl)rZ responsesr1r1r2r]DszBatchResponse.__init__cCr^)z>A list of ``messaging.SendResponse`` objects (possibly empty).)ryr_r1r1r2r{Hr`zBatchResponse.responsescCr^r,rsr_r1r1r2rtMszBatchResponse.success_countcCst|j|jSr,)rzr{rtr_r1r1r2ruQszBatchResponse.failure_countN) rarbrcrdr]rer{rtrur1r1r1r2rAs  rc@rf) rzHThe response received from an individual batched request to the FCM API.cCs&||_d|_|r|dd|_dSdS)Nname) _exception _message_idget)rZrq exceptionr1r1r2r]Ys zSendResponse.__init__cCr^)z9A message ID string that uniquely identifies the message.)r~r_r1r1r2 message_id_r`zSendResponse.message_idcCs|jduo|j S)z3A boolean indicating if the request was successful.N)r~r}r_r1r1r2rwdszSendResponse.successcCr^)zTA ``FirebaseError`` if an error occurs while sending the message to the FCM service.)r}r_r1r1r2rir`zSendResponse.exceptionN) rarbrcrdr]rerrwrr1r1r1r2rVs  rc@seZdZdZdZdZdZddiZe Z e e e e edZdd Zed d Zd&d dZd&ddZd&ddZddZddZddZddZddZddZedd Zed!d"Zed#d$Zd%S)'r/zKService 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 UNREGISTEREDcCsn|j}|s tdtj||_ddtjd|_|j dt j }|j |_t j|j|d|_tj|_dS)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_idrLr/FCM_URLrk_fcm_urlfirebase_admin __version__ _fcm_headersoptionsrrDEFAULT_TIMEOUT_SECONDSrget_credential _credentialJsonHttpClient_clientrauthorized_http_build_transport)rZr0rrr1r1r2r]s   z_MessagingService.__init__cCst|ts td|j|S)Nz7Message must be an instance of messaging.Message class.)rKrrL JSON_ENCODERdefault)clsr5r1r1r2encode_messages  z _MessagingService.encode_messageFc CsV|||}z|jjd|j|j|d}W|dStjjy*}z||d}~ww)z2Sends the given message to FCM via the FCM v1 API.posturlheadersjsonNr|) _message_datarbodyrrrequestsr RequestException_handle_fcm_error)rZr5r6r=rqrhr1r1r2r%s   z_MessagingService.sendc st|ts tdt|dkrtdfdd}fdd|D}z,tjjt|d}d d|||D}t|Wd WS1sHwYWd St ye}z t j d ||d d }~ww) 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 sdzjjdjj|d}Wntjjy+}ztd|dWYd}~Sd}~wwt|ddS)Nrr)rqr)r) rrrrrr rrr)r=rqrr_r1r2 send_datas  z._MessagingService.send_each..send_datacsg|]}|qSr1)r)rFr5r6rZr1r2rIsz/_MessagingService.send_each..) max_workerscSsg|]}|qSr1r1rxr1r1r2rIsNz4Unknown error while making remote service calls: {0})r5cause) rKlistrLrz concurrentfuturesThreadPoolExecutormapr Exceptionr UnknownErrorrk)rZr9r6r message_dataexecutorr{rhr1rr2r(s$    (z_MessagingService.send_eachc st|ts tdt|dkrtdgfdd}tj|tjd}j }|D]}t  ||}tj |jjd|jd}||q,z |WtStye} z| d } ~ ww) z2Sends the given messages to FCM via the batch API.rrrcs*d}|r |}t||}|dSr,)_handle_batch_errorrrp)_responserhr send_responser{rZr1r2batch_callbacks   z2_MessagingService.send_all..batch_callback)callback batch_uriPOST)rpostprocurimethodrrN)rKrrLrzrBatchHttpRequestr/ FCM_BATCH_URLrrrdumpsr HttpRequest _postprocrraddexecuterrr) rZr9r6rbatch transportr5rreqrhr1rr2r&s8      z_MessagingService.send_allc Cst|tr|g}t|tr|stddd|D}|r tdt|tr'|s+td|ds5d|}||d}d tj|}z|jj d ||tj d }Wt|St j j yd}z||d }~ww) z;Invokes the IID service for topic management functionality.z7Tokens must be a string or a non-empty list of strings.cSsg|] }t|tr |s|qSr1)rKstr)rFtr1r1r2rIszC_MessagingService.make_topic_management_request..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)rKrrrL startswithrkr/IID_URLrr IID_HEADERSrr r_handle_iid_errorr) rZrMrV operation invalid_strr=rrqrhr1r1r2rTs6     z/_MessagingService.make_topic_management_requestcCsdt|i}|r d|d<|S)Nr5T validate_only)r/r)rZr5r6r=r1r1r2rsz_MessagingService._message_datacCst|S)z'Handle response from batch API request.)rloadsdecode)rZrrr1r1r2rsz_MessagingService._postproccCt|tjS)z)Handles errors received from the FCM API.)r#handle_platform_error_from_requestsr/_build_fcm_error_requestsrZrhr1r1r2rz#_MessagingService._handle_fcm_errorcCs|jdur t|i}z|j}t|tr|}Wn ty#Ynw|d}d}|r3d|}n d|jj |jj }t||S)z1Handles errors received from the Instance ID API.Nrhz(Error while calling the IID service: {0}z4Unexpected HTTP response with status: {0}; body: {1}) rrhandle_requests_errorrrKrjrLrrk status_codecontentr)rZrhr= parsed_bodycodemsgr1r1r2rs&        z#_MessagingService._handle_iid_errorcCr)zMHandles errors received from the googleapiclient while making batch requests.)r*handle_platform_error_from_googleapiclientr/ _build_fcm_error_googleapiclientrr1r1r2r0rz%_MessagingService._handle_batch_errorcCs"||}|r||||jdSdSzfParses an error response from the FCM API and creates a FCM-specific exception if appropriate.)r http_responseN)_build_fcm_errorr)rrhr5 error_dictexc_typer1r1r2r5s z+_MessagingService._build_fcm_error_requestscCs ||}|r||||dSdSr)r)rrhr5rrrr1r1r2r<s z2_MessagingService._build_fcm_error_googleapiclientcCsF|sdSd}|dgD]}|ddkr|d}nq tj|S)Ndetailsz@typez3type.googleapis.com/google.firebase.fcm.v1.FcmError errorCode)rr/FCM_ERROR_TYPES)rrfcm_codedetailr1r1r2rCs  z"_MessagingService._build_fcm_errorN)F)rarbrcrdrrrrrMessageEncoderrrrrr rr] classmethodrr%r(r&rTrrrrrrrrr1r1r1r2r/os>    &  r/)FNr,)5rdconcurrent.futuresrrrOrgoogleapiclientrrrrrrrrr r.__all__r r r rrrrrrrrrrrr!r"r#r$rrrr r3r%r(r)r&r'r*r+rrrrr/r1r1r1r2sf        &      #