2021-11-11 15:18:04 +01:00
|
|
|
import logging.config
|
2021-05-20 01:57:40 +02:00
|
|
|
|
2022-07-12 07:39:56 +02:00
|
|
|
from mobilizon_reshare.config.command import CommandConfig
|
2022-05-17 23:14:52 +02:00
|
|
|
from mobilizon_reshare.main.publish import select_and_publish
|
2022-03-22 21:16:34 +01:00
|
|
|
from mobilizon_reshare.main.pull import pull
|
2022-09-24 16:46:03 +02:00
|
|
|
from mobilizon_reshare.publishers.coordinators.event_publishing.publish import (
|
|
|
|
PublisherCoordinatorReport,
|
|
|
|
)
|
2021-05-13 13:32:44 +02:00
|
|
|
|
2021-05-20 01:57:40 +02:00
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
2021-05-13 13:32:44 +02:00
|
|
|
|
2022-07-12 07:39:56 +02:00
|
|
|
async def start(command_config: CommandConfig) -> PublisherCoordinatorReport:
|
2021-11-11 15:18:04 +01:00
|
|
|
"""
|
|
|
|
STUB
|
|
|
|
:return:
|
|
|
|
"""
|
2022-03-22 21:16:34 +01:00
|
|
|
events = await pull()
|
2022-07-12 07:39:56 +02:00
|
|
|
return await select_and_publish(command_config, events,)
|