import time
import json

from janny.utils import parse_delta
from janny.auth import SESSION as s
from janny.config import API_HOST, logger


def clean_up(
    url: str, kube_resource: str, resource_name: str, kill_time: str, namespace: str
):
    delta = parse_delta(kill_time)
    secs = delta.total_seconds()
    time.sleep(secs)
    logger.info(f"Slept for {kill_time}. Cleaning resource {resource_name} now.")
    send_delete_event(url, kube_resource, resource_name, namespace)


def send_delete_event(url: str, kube_resource: str, resource_name: str, namespace: str):
    api_url = f"{API_HOST}{url}/namespaces/{namespace}/{kube_resource}/{resource_name}"
    response = s.delete(api_url, params={"propagationPolicy": "Background"})
    logger.info(f"Sent delete event to {kube_resource}/{resource_name}")
    if "Success" not in json.loads(response.content):
        logger.error(f"Deletion did not succeed. Recieved: {response.content}")