from hetdesrun.component.registration import register
from hetdesrun.datatypes import DataType

import pandas as pd
import numpy as np

# ***** DO NOT EDIT LINES BELOW *****
# These lines may be overwritten if input/output changes.
@register(
    inputs={"data": DataType.Any, "t": DataType.String},
    outputs={"movmin": DataType.Any},
)
def main(*, data, t):
    """entrypoint function for this component

    Usage example:
    >>> main(
    ...     data = pd.Series(
    ...        {
    ...            "2019-08-01T15:20:00": 4.0,
    ...            "2019-08-01T15:20:01": 5.0,
    ...            "2019-08-01T15:20:05": 1.0,
    ...            "2019-08-01T15:20:09": 9.0,
    ...        }
    ...     ),
    ...     t = "4s"
    ... )["movmin"]
    2019-08-01 15:20:00    4.0
    2019-08-01 15:20:01    4.0
    2019-08-01 15:20:05    1.0
    2019-08-01 15:20:09    9.0
    dtype: float64
    """
    # ***** DO NOT EDIT LINES ABOVE *****
    # write your code here.

    try:
        data.index = pd.to_datetime(data.index)
    except (ValueError, TypeError):
        raise TypeError("indices of data must be datetime")

    data_sort = data.sort_index().dropna()
    try:
        return {"movmin": data_sort.rolling(t).min()}
    except (ValueError):
        raise ValueError(f"t could not be parsed as frequency: {t}")

[(9, 'hetdesrun.component.registration.register', 'register', False, 'from hetdesrun.component.registration import register\n'), (38, 'pandas.to_datetime', 'pd.to_datetime', True, 'import pandas as pd\n')]