# services/collector.py
from models.water_usage import WaterUsageModel
from models.ammeter_usage import AmmeterUsageModel


async def handle_water_response(resp: dict):
    if resp.get("statusCode") == "200":
        await WaterUsageModel.insert(resp["resultObject"])


async def handle_ammeter_response(resp: dict):
    if resp.get("statusCode") == "200":
        await AmmeterUsageModel.insert(resp["resultObject"])