openpectus.aggregator.webpush_publisher

Attributes

logger

Classes

WebPushPublisher

Module Contents

openpectus.aggregator.webpush_publisher.logger

class openpectus.aggregator.webpush_publisher.WebPushPublisher(webpush_keys_path)

Parameters:

webpush_keys_path (str)

webpush_keys_path

wp = None

setup_webpush()

async publish_test_message(user_id)

Parameters:

user_id (None | str)

async publish_message(notification, topic, process_unit)

Parameters:

• notification (openpectus.aggregator.models.WebPushNotification)

• topic (openpectus.aggregator.models.NotificationTopic)

• process_unit (openpectus.aggregator.models.EngineData)

_get_subscriptions_for_topic(topic, process_unit, webpush_repo)

Parameters:

• topic (openpectus.aggregator.models.NotificationTopic)

• process_unit (openpectus.aggregator.models.EngineData)

• webpush_repo (openpectus.aggregator.data.repository.WebPushRepository)

Return type:

Sequence[openpectus.aggregator.data.models.WebPushSubscription]

async _post_webpush(subscription, web_push_repository, notification)

Parameters:

• subscription (openpectus.aggregator.data.models.WebPushSubscription)

• web_push_repository (openpectus.aggregator.data.repository.WebPushRepository)

• notification (openpectus.aggregator.models.WebPushNotification)