a $j@sddlmZddlZddlZddlmZddlmZmZddl m Z ddl m Z Gdd d ej Z eGd d d ZeGd d d Zd ddddZd ddddZdd ddddZd ddddZedeGdddZedeGdddZdS) ) annotationsN) dataclass) event_class T_JSON_DICT)network)service_workerc@sJeZdZdZdZdZdZdZdZdZ dd d d Z e ddd d dZ dS) ServiceNamez The Background Service that will be associated with the commands/events. Every Background Service operates independently, but share the same API. ZbackgroundFetchZbackgroundSyncZ pushMessagingZ notificationsZpaymentHandlerZperiodicBackgroundSyncstrreturncCs|jSN)value)selfr>E:\soccer\ml_env\Lib\site-packages\mycdp/background_service.pyto_jsonszServiceName.to_jsonjsonr cCs||Sr rclsrrrr from_json szServiceName.from_jsonN) __name__ __module__ __qualname____doc__ZBACKGROUND_FETCHZBACKGROUND_SYNCZPUSH_MESSAGINGZ NOTIFICATIONSZPAYMENT_HANDLERZPERIODIC_BACKGROUND_SYNCr classmethodrrrrrr sr c@sDeZdZUdZded<ded<ddddZeddd d d Zd S) EventMetadataz@A key-value pair for additional event information to pass along.r keyrrr cCst}|j|d<|j|d<|S)Nrr)dictrrrrrrrr+s  zEventMetadata.to_jsonrcCs|t|dt|ddS)Nrr)rr)r rrrrr1s  zEventMetadata.from_jsonN)rrrr__annotations__rrrrrrrr%s rc@speZdZUded<ded<ded<ded<ded <ded <d ed <ded <ddddZedddddZdS)BackgroundServiceEventznetwork.TimeSinceEpoch timestampr originzservice_worker.RegistrationIDservice_worker_registration_idr service event_name instance_idztyping.List[EventMetadata]event_metadata storage_keyrr cCspt}|j|d<|j|d<|j|d<|j|d<|j|d<|j|d<dd|jD|d <|j |d <|S) Nr#r$serviceWorkerRegistrationIdr& eventName instanceIdcSsg|] }|qSr)r.0irrr Vz2BackgroundServiceEvent.to_json.. eventMetadata storageKey) rr#rr$r%r&r'r(r)r*r rrrrLs    zBackgroundServiceEvent.to_jsonrc Csh|tj|dt|dtj|dt|dt|dt|ddd|d Dt|d d S) Nr#r$r+r&r,r-cSsg|]}t|qSr)rrr.rrrr1esz4BackgroundServiceEvent.from_json..r3r4)r#r$r%r&r'r(r)r*)rZTimeSinceEpochrr rZRegistrationIDr rrrrrZs     z BackgroundServiceEvent.from_jsonN)rrrr!rrrrrrrr"9s r"z0typing.Generator[T_JSON_DICT, T_JSON_DICT, None])r&r ccs&t}||d<d|d}|V}dS)zD Enables event updates for the service. :param service: r&z BackgroundService.startObservingmethodparamsNrrr&r7cmd_dictrrrrstart_observingls  r;ccs&t}||d<d|d}|V}dS)zE Disables event updates for the service. :param service: r&zBackgroundService.stopObservingr5Nr8r9rrrstop_observing|s  r<bool) should_recordr&r ccs.t}||d<||d<d|d}|V}dS)z` Set the recording state for the service. :param should_record: :param service: Z shouldRecordr&zBackgroundService.setRecordingr5Nr8)r>r&r7r:rrrr set_recordings r?ccs&t}||d<d|d}|V}dS)zE Clears all stored data for the service. :param service: r&zBackgroundService.clearEventsr5Nr8r9rrr clear_eventss  r@z'BackgroundService.recordingStateChangedc@s6eZdZUdZded<ded<eddddd Zd S) RecordingStateChangedzACalled when the recording state for the service has been updated.r= is_recordingr r&rrcCs|t|dt|ddS)NZ isRecordingr&)rBr&)r=r rrrrrrs  zRecordingStateChanged.from_jsonNrrrrr!rrrrrrrAs rAz0BackgroundService.backgroundServiceEventReceivedc@s.eZdZUdZded<edddddZdS) BackgroundServiceEventReceivedz Called with all existing backgroundServiceEvents when enabled, and all new events afterwards if enabled and recording. r"background_service_eventrrcCs|t|ddS)NZbackgroundServiceEvent)rE)r"rrrrrrs z(BackgroundServiceEventReceived.from_jsonNrCrrrrrDs rD) __future__renumtyping dataclassesrutilrrrrEnumr rr"r;r<r?r@rArDrrrrs*    2