o }l~iV@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_multicastsubscribe_to_topicunsubscribe_from_topiccCst|ttSN)rget_app_service_MESSAGING_ATTRIBUTE_MessagingService)appr/_/var/www/newdalilibackend/backend/venv/lib/python3.10/site-packages/firebase_admin/messaging.py_get_messaging_servicebsr1FcCt|||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. )r1r%)messagedry_runr.r/r/r0r%er%cCr2)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. )r1 send_eachmessagesr4r.r/r/r0r6yr5r6cs6tts 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?r@rA.0rBmulticast_messager/r0  z+send_each_for_multicast..) isinstancer ValueErrortokensr1r6rGr4r.r8r/rFr0send_each_for_multicasts   rNcCstdtt|||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.)warningswarnDeprecationWarningr1r&r7r/r/r0r&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.r9c r:r;rCrDrFr/r0rHrIz"send_multicast..) rOrPrQrJrrKrLr1r&rMr/rFr0r'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:batchAddr1make_topic_management_requestrLtopicr.r/r/r0r(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:batchRemoverSrUr/r/r0r)rWr)c@s0eZdZdZddZeddZeddZdS) rzBAn error encountered when performing a topic management operation.cCs||_||_dSr*)_index_reason)selfindexreasonr/r/r0__init__s zErrorInfo.__init__cC|jS)zBIndex of the registration token to which this error is related to.)rXrZr/r/r0r[zErrorInfo.indexcCr^)z*String describing the nature of the error.)rYr_r/r/r0r\r`zErrorInfo.reasonN)__name__ __module__ __qualname____doc__r]propertyr[r\r/r/r/r0r s 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) rJdictrKformat_success_count_failure_count_errors enumerateappendr)rZrespr[resultr/r/r0r]"sz TopicManagementResponse.__init__cCr^)zCNumber of tokens that were successfully subscribed or unsubscribed.rlr_r/r/r0 success_count/r`z%TopicManagementResponse.success_countcCr^)zLNumber of tokens that could not be subscribed or unsubscribed due to errors.)rmr_r/r/r0 failure_count4r`z%TopicManagementResponse.failure_countcCr^)z;A list of ``messaging.ErrorInfo`` objects (possibly empty).)rnr_r/r/r0errors9r`zTopicManagementResponse.errorsN) rarbrcrdr]rertrurvr/r/r/r0rs  rc@rf) rz:The response received from a batch request to the FCM API.cCs||_tdd|D|_dS)NcSsg|]}|jr|qSr/)successrErqr/r/r0rHDsz*BatchResponse.__init__..) _responseslenrl)rZ responsesr/r/r0r]BszBatchResponse.__init__cCr^)z>A list of ``messaging.SendResponse`` objects (possibly empty).)ryr_r/r/r0r{Fr`zBatchResponse.responsescCr^r*rsr_r/r/r0rtKszBatchResponse.success_countcCst|j|jSr*)rzr{rtr_r/r/r0ruOszBatchResponse.failure_countN) rarbrcrdr]rer{rtrur/r/r/r0r?s  rc@rf) rzHThe response received from an individual batched request to the FCM API.cCs&||_d|_|r|dd|_dSdS)Nname) _exception _message_idget)rZrq exceptionr/r/r0r]Ws zSendResponse.__init__cCr^)z9A message ID string that uniquely identifies the message.)r~r_r/r/r0 message_id]r`zSendResponse.message_idcCs|jduo|j S)z3A boolean indicating if the request was successful.N)r~r}r_r/r/r0rwbszSendResponse.successcCr^)zTA ``FirebaseError`` if an error occurs while sending the message to the FCM service.)r}r_r/r/r0rgr`zSendResponse.exceptionN) rarbrcrdr]rerrwrr/r/r/r0rTs  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_idrKr-FCM_URLrk_fcm_urlfirebase_admin __version__ _fcm_headersoptionsrrDEFAULT_TIMEOUT_SECONDSrget_credential _credentialJsonHttpClient_clientrauthorized_http_build_transport)rZr.rrr/r/r0r]~s   z_MessagingService.__init__cCst|ts td|j|S)Nz7Message must be an instance of messaging.Message class.)rJrrK JSON_ENCODERdefault)clsr3r/r/r0encode_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)rZr3r4r<rqrhr/r/r0r%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_r/r0 send_datas  z._MessagingService.send_each..send_datacsg|]}|qSr/)r)rEr3r4rZr/r0rHsz/_MessagingService.send_each..) max_workerscSsg|]}|qSr/r/rxr/r/r0rHsNz4Unknown error while making remote service calls: {0})r3cause) rJlistrKrz concurrentfuturesThreadPoolExecutormapr Exceptionr UnknownErrorrk)rZr8r4r message_dataexecutorr{rhr/rr0r6s$    (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{rZr/r0batch_callbacks   z2_MessagingService.send_all..batch_callback)callback batch_uriPOST)rpostprocurimethodrrN)rJrrKrzrBatchHttpRequestr- FCM_BATCH_URLrrrdumpsr HttpRequest _postprocrraddexecuterrr) rZr8r4rbatch transportr3rreqrhr/rr0r&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|qSr/)rJstr)rEtr/r/r0rHszC_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)rJrrrK startswithrkr-IID_URLrr IID_HEADERSrr r_handle_iid_errorr) rZrLrV operation invalid_strr<rrqrhr/r/r0rTs6     z/_MessagingService.make_topic_management_requestcCsdt|i}|r d|d<|S)Nr3T validate_only)r-r)rZr3r4r<r/r/r0rsz_MessagingService._message_datacCst|S)z'Handle response from batch API request.)rloadsdecode)rZrrr/r/r0r sz_MessagingService._postproccCt|tjS)z)Handles errors received from the FCM API.)r#handle_platform_error_from_requestsr-_build_fcm_error_requestsrZrhr/r/r0rz#_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_errorrrJrjrKrrk status_codecontentr)rZrhr< parsed_bodycodemsgr/r/r0rs&        z#_MessagingService._handle_iid_errorcCr)zMHandles errors received from the googleapiclient while making batch requests.)r*handle_platform_error_from_googleapiclientr- _build_fcm_error_googleapiclientrr/r/r0r.rz%_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)rrhr3 error_dictexc_typer/r/r0r3s z+_MessagingService._build_fcm_error_requestscCs ||}|r||||dSdSr)r)rrhr3rrrr/r/r0r: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_codedetailr/r/r0rAs  z"_MessagingService._build_fcm_errorN)F)rarbrcrdrrrrrMessageEncoderrrrrr rr] classmethodrr%r6r&rTrrrrrrrrr/r/r/r0r-ms>    &  r-)FNr*)5rdconcurrent.futuresrrrOrgoogleapiclientrrrrrrrrr r,__all__r r r rrrrrrrrrrrr!r"r#r$rrrr r1r%r6rNr&r'r(r)rrrrr-r/r/r/r0sf        $      #