from fansifter_common.utils.functional import lazy_proxy

from resonance_engine.config import settings

from .base import DataSink
from .dummy import DummySink
from .kafka import KafkaSink


def get_data_sink() -> DataSink:
    if settings.fandata_sink_backend == "kafka":
        return KafkaSink()
    return DummySink()


data_sink = lazy_proxy(get_data_sink)