dUh*ddlZddlZddlZddlZddlmZddlmZddlm Z ddl m Z ddl Z ddlmZmZmZmZmZGddeZy) N) HTTPAdapter)Retry)service_account) Credentials)AuthenticationErrorInvalidDataErrorFCMSenderIdMismatchErrorFCMServerErrorFCMNotRegisteredErrorceZdZdZ ddededefdZedZddZ d Z d Z d Z d Z d Z ddZy)BaseAPIz&https://fcm.googleapis.com/v1/projectsNservice_account_file project_id credentialscD|s |s td|||_n'tjj |dg|_t |jddxs|}|s td|j d|dz|_||_tj|_ |r=t|tr-d |vsd |vr%|jjj!||d k(r d d lm}|j'||_y||_y#t($r Y||_ywxYw)a Override existing init function to give ability to use v1 endpoints of Firebase Cloud Messaging API Attributes: service_account_file (str): path to service account JSON file project_id (str): project ID of Google account credentials (Credentials): Google oauth2 credentials instance, such as ADC proxy_dict (dict): proxy settings dictionary, use proxy (keys: `http`, `https`) env (dict): environment settings dictionary, for example "app_engine" json_encoder (BaseJSONEncoder): JSON encoder adapter (BaseAdapter): adapter instance zLPlease provide a service account file path or credentials in the constructorNz2https://www.googleapis.com/auth/firebase.messaging)scopesrzLPlease provide a project_id either explicitly or through Google credentials./z/messages:sendhttphttps app_enginer) appengine)rrrrfrom_service_account_filegetattrFCM_END_POINT_BASE fcm_end_pointcustom_adapter threadinglocal thread_local isinstancedictrequests_sessionproxiesupdaterequests_toolbelt.adaptersr monkeypatchModuleNotFoundError json_encoder) selfrrr proxy_dictenvr(adapterrs M/var/www/html/Ryun_Seer/newvenv/lib/python3.12/site-packages/pyfcm/baseapi.py__init__zBaseAPI.__init__s5*% %^   "*D .::TT$LM U D T--|TBPj %^ "44:,n7UU%%OO- :t,J&Gz,A  ! ! ) ) 0 0 < ,  @%%')L' ( s&D DDct|jddtdddgtjt dgz}|j xs t |}tj|j_ |jjjd||jjjd |d |j_ tj}|jj|krQ|jjjj|j|d z|j_ |jjS) Nr"iiPOST)backoff_factorstatus_forcelistallowed_methods) max_retrieszhttp://zhttps://ri)rrrDEFAULT_ALLOWED_METHODS frozensetrrrequestsSessionr"mount token_expirytimeheadersr$request_headers)r)retriesr,current_timestamps r-r"zBaseAPI.requests_session^s$ 4$$&8$ ? G "%s!&!>!>F8AT!TG ))M[W-MG191A1A1CD   .    . . 4 4Y H    . . 4 4Z I-.D   * IIK    ) ),= =    . . 6 6 = =d>R>R>T U->-ED   *  111c&|jj|j||}d|jvrZt |jddkDr?t |jd}t j ||j||S|S)N)datatimeoutz Retry-Afterr)r"postrr=intr<sleep send_request)r)payloadrDresponse sleep_times r-rHzBaseAPI.send_requestrs((--   Wg.  X-- -H$$]34q8X--m<=J JJz "$$Wg6 6rAcddl}ddlm}|Dcgc]}|jdi|}}|j j ||j |j||}|Scc}w)Nrr0) fetch_tasks) end_pointr=payloadsrD)asyncio async_fcmrM parse_payloadnew_event_looprun_until_completerr>)r) params_listrDrQrMparamsrO responsess r-send_async_requestzBaseAPI.send_async_requestsw*?JK{V&D&&00{K**,?? ,,,,.!   LsA-c tjjjj }|j j ||j jS#t$r}t|d}~wwxYw)z Generates access token from credentials. If token expires then new access token is generated. Returns: str: Access token N) googleauth transportr8Requestrrefreshtoken Exceptionr)r)requestes r-_get_access_tokenzBaseAPI._get_access_tokensf &kk++44<<>G    $ $W -##)) ) &"1% % &sA"A%% A>. A99A>c.dd|jzdS)z Generates request headers including Content-Type and Authorization of Bearer token Returns: dict: request headers zapplication/jsonzBearer )z Content-Type Authorization)rd)r)s r-r>zBaseAPI.request_headerss"/&)?)?)AA  rAchtj|dd|jdjdS)z Standardized json.dumps function with separators and sorted keys set Args: data (dict or list): data to be dumped Returns: string: json ),:TF) separators sort_keyscls ensure_asciiutf8)jsondumpsr(encode)r)rCs r- json_dumpszBaseAPI.json_dumpss5zz !!!  &.  rAc|jdk(rDd|jvr&t|jddkr td|j S|jdk(r t d|jdk(rt |j|jdk(r td |jd k(r td td |jd )a Parses the json response sent back by the server and tries to get out the important return variables Returns: dict: name (str) - The identifier of the message sent, in the format of projects/*/messages/{message_id} Raises: FCMServerError: FCM is temporary not available AuthenticationError: error authenticating the sender account InvalidDataError: data passed to FCM was incorrecly structured FCMSenderIdMismatchError: the authenticated sender is different from the sender registered to the token FCMNotRegisteredError: device token is missing, not registered, or invalid zcontent-lengthrz2FCM server connection error, the response is emptyiz4There was an error authenticating the sender accountiizWThe authenticated sender ID is different from the sender ID for the registration token.izToken not registeredz)FCM server error: Unexpected status code z.. The server might be temporarily unavailable.) status_coder=rFr rorrtextr r )r)rJs r-parse_responsezBaseAPI.parse_responses   3 & H$4$44(()9:;q@$H }}&  ! !S (%F  ! !S ("8==1 1  ! !S (*i  ! !S ('(>? ? ;HrrrwrSrPrAr-r r sA%)#' ?)!?)?)! ?)B22&  &  $(XLSrAr )ror<rr8requests.adaptersrurllib3r google.oauth2rgoogle.oauth2.credentialsrgoogle.auth.transport.requestsr[ pyfcm.errorsrrr r r objectr rPrAr-rs< ))1%XSfXSrA