. 0hVdZddlZddlZddlZddlZddlmZddlmZddl 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 Z(d dZ)d dZ*d dZ+d dZ,d dZ-d!dZ.d!dZ/GddZ0GddZ1GddZ2GddZ3GddZ4dS)"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_topiccBtj|ttSN)r get_app_service_MESSAGING_ATTRIBUTE_MessagingService)apps S/var/www/html/nourish/venv/lib/python3.11/site-packages/firebase_admin/messaging.py_get_messaging_servicer4ds  !#';=N O OOFcHt|||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 = ==r5cHt|||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 C CCr5cttstdfdjD}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 xg|]6}tjjjjjj|7S)data notificationandroidwebpushapns fcm_optionstokenrr@rArBrCrDrE.0rFmulticast_messages r3 z+send_each_for_multicast..a---   #&3!)!)  #%1---r5) isinstancer ValueErrortokensr4r)rJr8r2r;s` r3r*r*sv$ ')9 : :][\\\----%+---H "# & & 0 07 C CCr5c|tjdtt|||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's6( MFHZ[[[ !# & & / /' B BBr5ctjdtttst dfdjD}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 xg|]6}tjjjjjj|7Sr?rGrHs r3rKz"send_multicast..rLr5) rRrSrTrMrrNrOr4r'rPs` r3r(r(s( MZ$&&& ')9 : :][\\\----%+---H "# & & / /' B BBr5cJt|||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_requestrOtopicr2s r3r+r+s, "# & & D D( * **r5cJt|||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:batchRemoverXrZs r3r,r,s, "# & & D D+ - --r5cDeZdZdZdZedZedZdS)rzBAn error encountered when performing a topic management operation.c"||_||_dSr.)_index_reason)selfindexreasons r3__init__zErrorInfo.__init__s  r5c|jS)zBIndex of the registration token to which this error is related to.)r_ras r3rbzErrorInfo.indexs {r5c|jS)z*String describing the nature of the error.)r`rfs r3rczErrorInfo.reason |r5N)__name__ __module__ __qualname____doc__rdpropertyrbrcr5r3rrs_LLXXr5rcZeZdZdZdZedZedZedZdS)r z8The response received from a topic management operation.ct|trd|vr"td|d|_d|_g|_t|dD]X\}}d|vr?|xjdz c_|jt||dH|xjdz c_YdS)Nresultsz*Unexpected topic management response: {0}.rerror) rMdictrNformat_success_count_failure_count_errors enumerateappendr)raresprbresults r3rdz TopicManagementResponse.__init__$s$%% X$)>)>IPPQUVVWW W &tI77 ) )ME6&  ##q(## ##IeVG_$E$EFFFF##q(###  ) )r5c|jS)zCNumber of tokens that were successfully subscribed or unsubscribed.rvrfs r3 success_countz%TopicManagementResponse.success_count1 ""r5c|jS)zLNumber of tokens that could not be subscribed or unsubscribed due to errors.)rwrfs r3 failure_countz%TopicManagementResponse.failure_count6rr5c|jS)z;A list of ``messaging.ErrorInfo`` objects (possibly empty).)rxrfs r3errorszTopicManagementResponse.errors;rhr5N) rirjrkrlrdrmrrrrnr5r3r r !szBB ) ) )##X###X#Xr5r cZeZdZdZdZedZedZedZdS)rz:The response received from a batch request to the FCM API.cP||_td|D|_dS)Nc g|] }|j | Srn)successrIr{s r3rKz*BatchResponse.__init__..Fs"N"N"ND"N4"N"N"Nr5) _responseslenrv)ra responsess r3rdzBatchResponse.__init__Ds.#!"N"NI"N"N"NOOr5c|jS)z>A list of ``messaging.SendResponse`` objects (possibly empty).)rrfs r3rzBatchResponse.responsesH r5c|jSr.r~rfs r3rzBatchResponse.success_countMs ""r5c:t|j|jz Sr.)rrrrfs r3rzBatchResponse.failure_countQs4>""T%777r5N) rirjrkrlrdrmrrrrnr5r3rrAs}DDPPPX##X#88X888r5rcZeZdZdZdZedZedZedZdS)rzHThe response received from an individual batched request to the FCM API.c`||_d|_|r|dd|_dSdS)Nname) _exception _message_idget)rar{ exceptions r3rdzSendResponse.__init__Ys?#  6#xx55D    6 6r5c|jS)z9A message ID string that uniquely identifies the message.)rrfs r3 message_idzSendResponse.message_id_s r5c$|jduo|j S)z3A boolean indicating if the request was successful.N)rrrfs r3rzSendResponse.successdst+CDO0CCr5c|jS)zTA ``FirebaseError`` if an error occurs while sending the message to the FCM service.)rrfs r3rzSendResponse.exceptionirr5N) rirjrkrlrdrmrrrrnr5r3rrVs}RR666   X DDXDXr5rceZdZdZdZdZdZddiZej Z e e e e edZdZed Zdd Zdd Zdd ZdZdZdZdZdZdZedZedZedZdS)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}|stdtj||_ddt jd|_|j dtj }|j |_tj|j||_t$j|_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_idrNr1FCM_URLru_fcm_urlfirebase_admin __version__ _fcm_headersoptionsrrDEFAULT_TIMEOUT_SECONDSrget_credential _credentialJsonHttpClient_clientrauthorized_http_build_transport)rar2rrs r3rdz_MessagingService.__init__s^  >=>> >*188DD ),!8!?!?@Z![![  +//-1UVV>88::#2d>NX_``` % 5r5c~t|tstd|j|S)Nz7Message must be an instance of messaging.Message class.)rMrrN JSON_ENCODERdefault)clsr7s r3encode_messagez _MessagingService.encode_messages;'7++ XVWW W''000r5Fc|||} |jd|j|j|}|dS#t jj$r}||d}~wwxYw)z2Sends the given message to FCM via the FCM v1 API.posturlheadersjsonrN) _message_datarbodyrrrequestsr RequestException_handle_fcm_error)rar7r8r@r{rrs r3r&z_MessagingService.sends!!'733 <$$M) %D< "3 0 0 0((// / 0s(AA6A11A6ct|tstdt|dkrtdfd}fd|D} tjt|5}d|||D}t|cdddS#1swxYwYdS#t$r.}tj d || 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 jdjj|}t |dS#t jj$r.}t d|cYd}~Sd}~wwxYw)Nrr)r)r{r) rrrrrrr rr)r@r{rras r3 send_dataz._MessagingService.send_each..send_datas :|((  - )$DD9999&7 \ \ \#9O9OPY9Z9Z[[[[[[[[[ \s(<A>#A93A>9A>c<g|]}|Srn)r)rIr7r8ras r3rKz/_MessagingService.send_each..s)UUU**7G<<UUUr5) max_workerscg|]}|Srnrnrs r3rKz/_MessagingService.send_each..sTTTdTTTTr5Nz4Unknown error while making remote service calls: {0})r7cause) rMlistrNr concurrentfuturesThreadPoolExecutormapr Exceptionr UnknownErrorru)rar;r8r message_dataexecutorrrrs` ` r3r)z_MessagingService.send_eachs(D)) XVWW W x==3  PQQ Q : : : : :VUUUUHUUU  #663|CTCT6UU 0YaTThll9l.S.STTT $Y// 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0   )NUUV[\\  s<-C /C: CC  CC C D )DD c  t|tstdt|dkrtdg fd}t j|t j}j }|D]h}tj ||}t j |jjd|j}||i |t' S#t($r} | d} ~ wwxYw) z2Sends the given messages to FCM via the batch API.rrrcd}|r|}t||}|dSr.)_handle_batch_errorrrz)_responserrr send_responserras r3batch_callbackz2_MessagingService.send_all..batch_callbacksLI < 44U;; (9==M   ] + + + + +r5)callback batch_uriPOST)rpostprocurimethodrrN)rMrrNrrBatchHttpRequestr1 FCM_BATCH_URLrrrdumpsr HttpRequest _postprocrraddexecuterrr) rar;r8rbatch transportr7rreqrrrs ` @r3r'z_MessagingService.send_allsl(D)) XVWW W x==3  PQQ Q  , , , , , ,%#/@/NPPP))$*:;;   G:d00'BBCCD"M) C IIcNNNN , MMOOO!++ + 2 2 2**511 1 2s7D D>$D99D>ctt|tr|g}t|tr|stdd|D}|rtdt|tr|std|dsd|}||d}dt j|} |j d ||t j }t|S#tj j$r}||d }~wwxYw) z;Invokes the IID service for topic management functionality.z7Tokens must be a string or a non-empty list of strings.c@g|]}t|tr||Srn)rMstr)rIts r3rKzC_MessagingService.make_topic_management_request..s,LLLQ 1c0B0BL!LqLLLr5z!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)rMrrrN startswithrur1IID_URLrr IID_HEADERSr rr r_handle_iid_error) rarOr[ operation invalid_strr@rr{rrs r3rYz/_MessagingService.make_topic_management_requestsk fc " " XF&$'' Xv XVWW WLL&LLL  B@AA A%%% BU B@AA A ++ 0!((//E#)  08)DD 1<$$)5 %D+400 0"3 0 0 0((// / 0s(D D7D22D7cLdt|i}|rd|d<|S)Nr7T validate_only)r1r)rar7r8r@s r3rz_MessagingService._message_datas2,;;GDDE  )$(D ! r5cNtj|S)z'Handle response from batch API request.)rloadsdecode)rarrs r3rz_MessagingService._postprocsz$++--(((r5c@tj|tjS)z)Handles errors received from the FCM API.)r #handle_platform_error_from_requestsr1_build_fcm_error_requestsrarrs r3rz#_MessagingService._handle_fcm_errors#9 $>@@ @r5c|jtj|i} |j}t |t r|}n#t $rYnwxYw|d}d}|rd|}n !.u55 5 .--//K+t,, #"    D xx    M<CCDIICCHOO*EN,B,I,I,K,KMMC+E3777s0A AAc@tj|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#F $EGG Gr5cZ||}|r||||jndSzfParses an error response from the FCM API and creates a FCM-specific exception if appropriate.)r http_responseN)_build_fcm_errorr)rrrr7 error_dictexc_types r3rz+_MessagingService._build_fcm_error_requests5s;'' 33OWaxxuENKKKK]aar5cP||}|r||||ndSr)r)rrrr7rrrs r3rz2_MessagingService._build_fcm_error_googleapiclient<s9'' 33NV`xxuMJJJJ\``r5c|sdSd}|dgD]2}|ddkr|d}n3tj|S)Ndetailsz@typez3type.googleapis.com/google.firebase.fcm.v1.FcmError errorCode)rr1FCM_ERROR_TYPES)rrfcm_codedetails r3rz"_MessagingService._build_fcm_errorCs~ 4 nnY33  Fzz'""&[[[!::k22\!044X>>>r5N)F)rirjrkrlrrrrrMessageEncoderrrrrr!rrd classmethodrr&r)r'rYrrrrrrrrrnr5r3r1r1osUUHG6M*G&/K4%466L/,3"5) O666"11[1     :$,$,$,$,L111> ))) @@@ 8880GGG bb[b aa[a ??[???r5r1)FNr.)5rlconcurrent.futuresrrrRrgoogleapiclientrrrrrrrr r r0__all__r r rrrrrrrrrrrrr"r#r$r%rrrr!r4r&r)r*r'r(r+r,rr rrr1rnr5r3r"s2'&  !!!!!!''''''------++++++''''''!!!!!!%%%%%%$# # # L!. $6&:  ( !0*   $ .  (  .  $%6,  . $6&:,F%8(>&:$6PPP>>>>(DDDD(DDDD>CCCC.!C!C!C!CF****&----($@88888888*2]?]?]?]?]?]?]?]?]?]?r5