from web.core.celery import app


@app.task()
def create_raw_logs(logs):
    from infrastructure.persistence.repositories.raw_session_repository import (
        get_raw_session_repository,
    )

    raw_session_repository = get_raw_session_repository()

    raw_session_repository.bulk_create_logs(logs)


@app.task()
def create_user_activity_logs(logs):
    from infrastructure.persistence.repositories.user_session_repository import (
        get_user_session_repository,
    )

    user_session_repository = get_user_session_repository()

    user_session_repository.bulk_create_user_session_logs(logs)


@app.task()
def detect_single_page_sessions(*args, **kwargs):
    import application.sessions.detetc_single_page_session
    from infrastructure.persistence.repositories.raw_session_repository import (
        get_raw_session_repository,
    )
    from infrastructure.persistence.repositories.user_session_repository import (
        get_user_session_repository,
    )

    detect_single_page_session = application.sessions.detetc_single_page_session.DetectSinglePageSession(
        get_user_session_repository(), get_raw_session_repository()
    )
    detect_single_page_session()