import os
import ecflow

defs = ecflow.Defs()
suite = defs.add_suite("data_acquisition")
suite.add_repeat(ecflow.RepeatDay(1))
suite.add_variable("ECF_HOME", os.getenv("HOME") + "/course")
suite.add_variable("ECF_INCLUDE", os.getenv("HOME") + "/course")
suite.add_variable("ECF_FILES", os.getenv("HOME") + "/course/data")
suite.add_variable("SLEEP", "2")
for city in (
    "Exeter",
    "Toulouse",
    "Offenbach",
    "Washington",
    "Tokyo",
    "Melbourne",
    "Montreal",
):
    fcity = suite.add_family(city)
    fcity.add_task("archive")
    for obs_type in ("observations", "fields", "images"):
        type_fam = fcity.add_family(obs_type)
        if city in ("Exeter", "Toulouse", "Offenbach"):
            type_fam.add_time("00:00 23:00 01:00")
        if city in ("Washington"):
            type_fam.add_time("00:00 23:00 03:00")
        if city in ("Tokyo"):
            type_fam.add_time("12:00")
        if city in ("Melbourne"):
            type_fam.add_day("monday")
        if city in ("Montreal"):
            type_fam.add_date(1, 0, 0)

        type_fam.add_task("get")
        type_fam.add_task("process").add_trigger("get eq complete")
        type_fam.add_task("store").add_trigger("get eq complete")