import redis
import json

REDIS = redis.Redis(host="localhost", port=6379, decode_responses=True)

ACTIVE_KEY = "echoweather:active_alerts"


def get(alert_id: str):
    data = REDIS.hget(ACTIVE_KEY, alert_id)
    return json.loads(data) if data else None


def set(alert: dict):
    REDIS.hset(ACTIVE_KEY, alert["id"], json.dumps(alert))


def is_new(alert_id: str) -> bool:
    return not REDIS.hexists(ACTIVE_KEY, alert_id)