from typing import Optional

from .lenenergo import LenenergoParser
from .building_id import concurrent_fetch_builing_ids
from .preprocess import preprocess_df
from .address import split_addresses


def pipeline(parser: Optional[LenenergoParser] = None) -> LenenergoParser:
    if parser is None:
        parser = LenenergoParser()

    print(parser)

    parser.df = split_addresses(parser.df)

    parser.df = concurrent_fetch_builing_ids(parser.df)

    parser.df = preprocess_df(parser.df)

    return parser