# Path: firebase_admin/messaging.py
# _MESSAGING_ATTRIBUTE = '_messaging'
#     FCM_URL = 'https://fcm.googleapis.com/v1/projects/{0}/messages:send'
#     FCM_BATCH_URL = 'https://fcm.googleapis.com/batch'
#     IID_URL = 'https://iid.googleapis.com'
#     IID_HEADERS = {'access_token_auth': 'true'}
#     JSON_ENCODER = _messaging_encoder.MessageEncoder()
#     FCM_ERROR_TYPES = {
#         'APNS_AUTH_ERROR': ThirdPartyAuthError,
#         'QUOTA_EXCEEDED': QuotaExceededError,
#         'SENDER_ID_MISMATCH': SenderIdMismatchError,
#         'THIRD_PARTY_AUTH_ERROR': ThirdPartyAuthError,
#         'UNREGISTERED': UnregisteredError,
#     }
# def _get_messaging_service(app):
# def send(message, dry_run=False, app=None):
# def send_all(messages, dry_run=False, app=None):
# def send_multicast(multicast_message, dry_run=False, app=None):
# def subscribe_to_topic(tokens, topic, app=None):
# def unsubscribe_from_topic(tokens, topic, app=None):
#     def __init__(self, index, reason):
#     def index(self):
#     def reason(self):
#     def __init__(self, resp):
#     def success_count(self):
#     def failure_count(self):
#     def errors(self):
#     def __init__(self, responses):
#     def responses(self):
#     def success_count(self):
#     def failure_count(self):
#     def __init__(self, resp, exception):
#     def message_id(self):
#     def success(self):
#     def exception(self):
#     def __init__(self, app):
#     def encode_message(cls, message):
#     def send(self, message, dry_run=False):
#     def send_all(self, messages, dry_run=False):
#         def batch_callback(_, response, error):
#     def make_topic_management_request(self, tokens, topic, operation):
#     def _message_data(self, message, dry_run):
#     def _postproc(self, _, body):
#     def _handle_fcm_error(self, error):
#     def _handle_iid_error(self, error):
#     def _handle_batch_error(self, error):
#     def _build_fcm_error_requests(cls, error, message, error_dict):
#     def _build_fcm_error_googleapiclient(cls, error, message, error_dict, http_response):
#     def _build_fcm_error(cls, error_dict):
# class ErrorInfo:
# class TopicManagementResponse:
# class BatchResponse:
# class SendResponse:
# class _MessagingService:


import datetime
from firebase_admin import messaging
                        body='$GOOG gained 11.80 points to close at 835.67, up 1.43% on the day.',
                    ),
                    badge=42,
                ),
            ),
        ),
        topic='industry-tech',
    )
    # [END apns_message]
    return message


def webpush_message():
    # [START webpush_message]
    message = messaging.Message(
        webpush=messaging.WebpushConfig(
            notification=messaging.WebpushNotification(
                title='$GOOG up 1.43% on the day',
                body='$GOOG gained 11.80 points to close at 835.67, up 1.43% on the day.',
                icon='https://my-server/icon.png',
            ),
        ),
        topic='industry-tech',
    )
    # [END webpush_message]
    return message


def all_platforms_message():
    # [START multi_platforms_message]

# Path: firebase_admin/messaging.py
# _MESSAGING_ATTRIBUTE = '_messaging'
#     FCM_URL = 'https://fcm.googleapis.com/v1/projects/{0}/messages:send'
#     FCM_BATCH_URL = 'https://fcm.googleapis.com/batch'
#     IID_URL = 'https://iid.googleapis.com'
#     IID_HEADERS = {'access_token_auth': 'true'}
#     JSON_ENCODER = _messaging_encoder.MessageEncoder()
#     FCM_ERROR_TYPES = {
#         'APNS_AUTH_ERROR': ThirdPartyAuthError,
#         'QUOTA_EXCEEDED': QuotaExceededError,
#         'SENDER_ID_MISMATCH': SenderIdMismatchError,
#         'THIRD_PARTY_AUTH_ERROR': ThirdPartyAuthError,
#         'UNREGISTERED': UnregisteredError,
#     }
# def _get_messaging_service(app):
# def send(message, dry_run=False, app=None):
# def send_all(messages, dry_run=False, app=None):
# def send_multicast(multicast_message, dry_run=False, app=None):
# def subscribe_to_topic(tokens, topic, app=None):
# def unsubscribe_from_topic(tokens, topic, app=None):
#     def __init__(self, index, reason):
#     def index(self):
#     def reason(self):
#     def __init__(self, resp):
#     def success_count(self):
#     def failure_count(self):
#     def errors(self):
#     def __init__(self, responses):
#     def responses(self):
#     def success_count(self):
#     def failure_count(self):
#     def __init__(self, resp, exception):
#     def message_id(self):
#     def success(self):
#     def exception(self):
#     def __init__(self, app):
#     def encode_message(cls, message):
#     def send(self, message, dry_run=False):
#     def send_all(self, messages, dry_run=False):
#         def batch_callback(_, response, error):
#     def make_topic_management_request(self, tokens, topic, operation):
#     def _message_data(self, message, dry_run):
#     def _postproc(self, _, body):
#     def _handle_fcm_error(self, error):
#     def _handle_iid_error(self, error):
#     def _handle_batch_error(self, error):
#     def _build_fcm_error_requests(cls, error, message, error_dict):
#     def _build_fcm_error_googleapiclient(cls, error, message, error_dict, http_response):
#     def _build_fcm_error(cls, error_dict):
# class ErrorInfo:
# class TopicManagementResponse:
# class BatchResponse:
# class SendResponse:
# class _MessagingService:


# Path: snippets/messaging/cloud_messaging.py
import datetime
from firebase_admin import messaging

                        body='$GOOG gained 11.80 points to close at 835.67, up 1.43% on the day.',
                    ),
                    badge=42,
                ),
            ),
        ),
        topic='industry-tech',
    )
    # [END apns_message]
    return message


def webpush_message():
    # [START webpush_message]
    message = messaging.Message(
        webpush=messaging.WebpushConfig(
            notification=messaging.WebpushNotification(
                title='$GOOG up 1.43% on the day',
                body='$GOOG gained 11.80 points to close at 835.67, up 1.43% on the day.',
                icon='https://my-server/icon.png',
            ),
        ),
        topic='industry-tech',
    )
    # [END webpush_message]
    return message


def all_platforms_message():
    # [START multi_platforms_message]

    message = messaging.Message(