Restructure of ui package is now in working state. And we now support editing old alarms.

.gitignore

@@ -0,0 +1,6 @@
+__pycache*
+*log
+/logs
+/data
+*json
+*~

README.md

@@ -0,0 +1,16 @@
+# EEE PC Alarm Clock!
+
+Runs on Debian 12.
+Requires Python 3 and mpg123.
+
+To use, just run `main.py` from the `clock/` directory.
+
+It includes:
+- A local ncurses UI.
+- A simple HTTP API
+  - for how to use it, check out
+    `alert_clients/alarm_api_client/alarm_api_client.py`.
+
+Put your alarm sounds in `~/alarms/` as MP3 files.
+
+License: MIT

alert_api/alert_api.py

@@ -1,491 +0,0 @@
-#!/usr/bin/python3
-
-from http.server import BaseHTTPRequestHandler, HTTPServer
-import logging
-import os
-import json
-import hashlib
-from dataclasses import dataclass, field, asdict
-from typing import List, Optional, Dict, Any
-from datetime import datetime
-from http import HTTPStatus
-import re
-
-# Set up logging configuration
-logging.basicConfig(
-    level=logging.DEBUG,  # Set to DEBUG to show all log levels
-    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
-    handlers=[
-        logging.StreamHandler(),  # Console handler
-        logging.FileHandler('alert_api.log')  # File handler
-    ]
-)
-
-logger = logging.getLogger('AlertApi')
-
-
-@dataclass
-class RepeatRule:
-    type: str  # "daily" or "weekly" or "once"
-    days_of_week: Optional[List[str]] = field(default_factory=list)
-    at: Optional[str] = None
-
-    def validate(self) -> bool:
-        """Validate repeat rule configuration"""
-        valid_types = {"daily", "weekly", "once"}
-        valid_days = {"monday", "tuesday", "wednesday", "thursday", "friday", "saturday", "sunday"}
-
-        if self.type not in valid_types:
-            logger.error(f"Invalid RepeatRule type: '{self.type}'. Must be one of {valid_types}")
-            return False
-
-        if self.type == "weekly":
-            invalid_days = [day for day in self.days_of_week if day.lower() not in valid_days]
-            if invalid_days:
-                logger.error(f"Invalid RepeatRule weekday names: {invalid_days}. Must be one of {valid_days}")
-                return False
-            if not self.days_of_week:
-                logger.error("Weekly repeat rule must specify at least one day")
-                return False
-
-        if self.type == "once" and self.days_of_week:
-            if self.days_of_week:
-                logger.error("One-time alert does not support days_of_week")
-                return False
-            if not self.at:
-                logger.error("One-time repeat rule must specify a valid 'at' date")
-                return False
-            try:
-                datetime.strptime(self.at, "%d.%m.%Y")
-            except ValueError:
-                logger.error(f"Invalid 'at' date format: '{self.at}'. Expected format: 'dd.mm.yyyy'")
-                return False
-
-        logger.debug(f"RepeatRule validation passed: {self.__dict__}")
-        return True
-
-
-@dataclass
-class Snooze:
-    enabled: bool = True
-    duration: int = 10    # minutes
-    max_count: int = 3
-
-    def validate(self) -> bool:
-        """Validate snooze configuration"""
-        if not isinstance(self.enabled, bool):
-            logger.error(f"Snooze enabled must be boolean, got {type(self.enabled)}")
-            return False
-
-        if not isinstance(self.duration, int):
-            logger.error(f"Snooze duration must be integer, got {type(self.duration)}")
-            return False
-
-        if self.duration <= 0:
-            logger.error(f"Snooze duration must be positive, got {self.duration}")
-            return False
-
-        if not isinstance(self.max_count, int):
-            logger.error(f"Snooze max_count must be integer, got {type(self.max_count)}")
-            return False
-
-        if self.max_count <= 0:
-            logger.error(f"Snooze max_count must be positive, got {self.max_count}")
-            return False
-
-        logger.debug(f"Snooze validation passed: {self.__dict__}")
-        return True
-
-
-@dataclass
-class Metadata:
-    volume: int = 100
-    notes: str = ""
-    md5sum: str = ""
-
-    def validate(self) -> bool:
-        """Validate metadata configuration"""
-        if not isinstance(self.volume, int):
-            logger.error(f"Volume must be integer, got {type(self.volume)}")
-            return False
-
-        if not 0 <= self.volume <= 100:
-            logger.error(f"Volume must be between 0 and 100, got {self.volume}")
-            return False
-
-        logger.debug(f"Metadata validation passed: {self.__dict__}")
-        return True
-
-
-@dataclass
-class Alarm:
-    name: str
-    time: str  # Format: "HH:MM:SS"
-    repeat_rule: RepeatRule
-    file_to_play: str = field(default=os.path.expanduser("~/.alarms/alarm-lofi.mp3"))
-    enabled: bool = field(default=True)
-    snooze: Snooze = field(default_factory=Snooze)
-    metadata: Metadata = field(default_factory=Metadata)
-    id: Optional[int] = field(default=None)
-
-    def validate(self) -> bool:
-        """Validate complete alarm configuration"""
-        logger.debug(f"Starting validation for alarm: {self.name}")
-
-        # Validate name
-        if not isinstance(self.name, str) or len(self.name.strip()) == 0:
-            logger.error(f"Invalid alarm name: '{self.name}'. Must be non-empty string")
-            return False
-
-        # Validate time format
-        time_pattern = re.compile(r'^([0-1]?[0-9]|2[0-3]):[0-5][0-9]:[0-5][0-9]$')
-        if not time_pattern.match(self.time):
-            logger.error(f"Invalid time format: '{self.time}'. Must match HH:MM:SS")
-            return False
-
-        # Validate enabled flag
-        if not isinstance(self.enabled, bool):
-            logger.error(f"Enabled must be boolean, got {type(self.enabled)}")
-            return False
-
-        # Create default alarms directory if it doesn't exist
-        default_alarms_dir = os.path.expanduser("~/.alarms")
-        os.makedirs(default_alarms_dir, exist_ok=True)
-
-        # Validate audio file
-        if self.file_to_play != os.path.expanduser("~/.alarms/alarm-lofi.mp3") and not os.path.exists(self.file_to_play):
-            logger.error(f"Audio file not found: '{self.file_to_play}'")
-            return False
-
-        # Validate repeat rule
-        if not isinstance(self.repeat_rule, RepeatRule):
-            logger.error(f"Invalid repeat_rule type: {type(self.repeat_rule)}")
-            return False
-        if not self.repeat_rule.validate():
-            logger.error("Repeat rule validation failed")
-            return False
-
-        # Validate snooze
-        if not isinstance(self.snooze, Snooze):
-            logger.error(f"Invalid snooze type: {type(self.snooze)}")
-            return False
-        if not self.snooze.validate():
-            logger.error("Snooze validation failed")
-            return False
-
-        # Validate metadata
-        if not isinstance(self.metadata, Metadata):
-            logger.error(f"Invalid metadata type: {type(self.metadata)}")
-            return False
-        if not self.metadata.validate():
-            logger.error("Metadata validation failed")
-            return False
-
-        logger.debug(f"Alarm validation passed: {self.name}")
-        return True
-
-class StorageHandler:
-    def __init__(self, file_path: str):
-        self.file_path = file_path
-        self._ensure_storage_directory()
-
-    def _ensure_storage_directory(self) -> None:
-        """Ensure the directory for the storage file exists"""
-        directory = os.path.dirname(os.path.abspath(self.file_path))
-        if directory:
-            os.makedirs(directory, exist_ok=True)
-
-    @staticmethod
-    def _generate_alarm_hash(alarm: dict) -> str:
-        """Generate an MD5 hash for the given alarm data"""
-        # Convert dataclass instances to dictionaries if needed
-        def to_dict(value):
-            return asdict(value) if hasattr(value, '__dataclass_fields__') else value
-
-        alarm_data = alarm.copy()
-        alarm_data["repeat_rule"] = to_dict(alarm_data.get("repeat_rule"))
-        alarm_data["snooze"] = to_dict(alarm_data.get("snooze"))
-        alarm_data["metadata"] = to_dict(alarm_data.get("metadata"))
-
-        hash_input = json.dumps({
-            "name": alarm_data["name"],
-            "time": alarm_data["time"],
-            "file_to_play": alarm_data.get("file_to_play", os.path.expanduser("~/.alarms/alarm-lofi.mp3")),
-            "repeat_rule": alarm_data["repeat_rule"]
-        }, sort_keys=True)
-        return hashlib.md5(hash_input.encode('utf-8')).hexdigest()
-
-    def load_data(self) -> dict:
-        """Load the JSON data from the file"""
-        try:
-            with open(self.file_path, 'r') as file:
-                data = json.load(file)
-                if not isinstance(data, dict):
-                    raise ValueError("Invalid data format")
-                return data
-        except (FileNotFoundError, json.JSONDecodeError):
-            return {"last_id": 0, "alarms": []}
-
-    def save_data(self, data: dict) -> None:
-        """Save the JSON data back to the file"""
-        def convert_to_dict(obj):
-            """Convert dataclass instances to dictionaries recursively"""
-            if isinstance(obj, list):
-                return [convert_to_dict(item) for item in obj]
-            elif isinstance(obj, dict):
-                return {key: convert_to_dict(value) for key, value in obj.items()}
-            elif hasattr(obj, "__dataclass_fields__"):
-                return asdict(obj)
-            else:
-                return obj
-
-        # Convert data to JSON-serializable format
-        serializable_data = convert_to_dict(data)
-
-        with open(self.file_path, 'w') as file:
-            json.dump(serializable_data, file, indent=4)
-
-    def save_new_alert(self, alarm_data: dict) -> int:
-        """Add a new alarm to the storage"""
-        # Remove id if present in input data
-        alarm_data.pop('id', None)
-
-        # Set default file_to_play if not provided
-        alarm_data['file_to_play'] = alarm_data.get('file_to_play', os.path.expanduser("~/.alarms/alarm-lofi.mp3"))
-
-        # Convert nested dictionaries to dataclass instances
-        try:
-            if 'repeat_rule' in alarm_data:
-                alarm_data['repeat_rule'] = RepeatRule(**alarm_data['repeat_rule'])
-            if 'snooze' in alarm_data:
-                alarm_data['snooze'] = Snooze(**alarm_data['snooze'])
-            if 'metadata' in alarm_data:
-                alarm_data['metadata'] = Metadata(**alarm_data['metadata'])
-        except TypeError as e:
-            raise ValueError(f"Invalid format in one of the nested fields: {str(e)}")
-
-        # Validate input
-        try:
-            alarm = Alarm(**alarm_data)
-            if not alarm.validate():
-                raise ValueError("Invalid alarm configuration")
-        except (TypeError, ValueError) as e:
-            raise ValueError(f"Invalid alarm data: {str(e)}")
-
-        # Generate hash and check for duplicates
-        alarm_hash = self._generate_alarm_hash(alarm_data)
-        data = self.load_data()
-
-        if any(a.get("hash") == alarm_hash for a in data["alarms"]):
-            raise ValueError("Duplicate alarm detected")
-
-        # Add new alarm
-        alarm_data["id"] = data.get("last_id", 0) + 1
-        alarm_data["hash"] = alarm_hash
-        data["last_id"] = alarm_data["id"]
-        data["alarms"].append(alarm_data)
-
-        self.save_data(data)
-        return alarm_data["id"]
-
-    def get_saved_alerts(self) -> list:
-        """Retrieve the list of saved alarms"""
-        return self.load_data().get("alarms", [])
-
-    def remove_saved_alert(self, alarm_id: int) -> bool:
-        """Remove an alarm by its ID"""
-        data = self.load_data()
-        original_length = len(data["alarms"])
-        data["alarms"] = [a for a in data["alarms"] if a["id"] != alarm_id]
-
-        if len(data["alarms"]) == original_length:
-            return False
-
-        self.save_data(data)
-        return True
-
-    def update_alert(self, alarm_id: int, alarm_data: dict) -> bool:
-        """Update an existing alarm"""
-        alarm_data["id"] = alarm_id
-
-        # Set default file_to_play if not provided
-        alarm_data['file_to_play'] = alarm_data.get('file_to_play', os.path.expanduser("~/.alarms/alarm-lofi.mp3"))
-
-        # Convert nested dictionaries to dataclass instances
-        try:
-            if 'repeat_rule' in alarm_data:
-                alarm_data['repeat_rule'] = RepeatRule(**alarm_data['repeat_rule'])
-            if 'snooze' in alarm_data:
-                alarm_data['snooze'] = Snooze(**alarm_data['snooze'])
-            if 'metadata' in alarm_data:
-                alarm_data['metadata'] = Metadata(**alarm_data['metadata'])
-        except TypeError as e:
-            raise ValueError(f"Invalid format in one of the nested fields: {str(e)}")
-
-        # Validate input
-        try:
-            alarm = Alarm(**alarm_data)
-            if not alarm.validate():
-                raise ValueError("Invalid alarm configuration")
-        except (TypeError, ValueError) as e:
-            raise ValueError(f"Invalid alarm data: {str(e)}")
-
-        data = self.load_data()
-        for i, existing_alarm in enumerate(data["alarms"]):
-            if existing_alarm["id"] == alarm_id:
-                alarm_data["hash"] = self._generate_alarm_hash(alarm_data)
-                data["alarms"][i] = alarm_data
-                self.save_data(data)
-                return True
-        return False
-
-
-class AlertApi(BaseHTTPRequestHandler):
-    def __init__(self, *args, **kwargs):
-        self.storage = StorageHandler("data/alerts.json")
-        self.logger = logging.getLogger('AlertApi')
-        super().__init__(*args, **kwargs)
-
-    def _send_response(self, status_code: int, data: Any = None, error: str = None) -> None:
-        """Send a JSON response with the given status code and data/error"""
-        self.send_response(status_code)
-        self.send_header("Content-Type", "application/json")
-        self.send_header("Access-Control-Allow-Origin", "*")
-        self.end_headers()
-
-        response = {}
-        if data is not None:
-            response["data"] = data
-        if error is not None:
-            response["error"] = error
-
-        response_json = json.dumps(response)
-        self.logger.debug(f"Sending response: {response_json}")
-        self.wfile.write(response_json.encode("utf-8"))
-
-    def _handle_request(self, method: str) -> None:
-        """Handle incoming requests with proper error handling"""
-        self.logger.info(f"Received {method} request from {self.client_address[0]}")
-
-        try:
-            if method in ["POST", "PUT", "DELETE"]:
-                content_length = int(self.headers.get("Content-Length", 0))
-                if content_length == 0:
-                    raise ValueError("Missing request body")
-
-                post_data = self.rfile.read(content_length)
-                self.logger.debug(f"Received {method} payload: {post_data.decode('utf-8')}")
-
-                post_data = json.loads(post_data)
-            else:
-                post_data = None
-
-            # Route request to appropriate handler
-            handler = getattr(self, f"_handle_{method.lower()}", None)
-            if handler:
-                self.logger.debug(f"Routing to handler: _handle_{method.lower()}")
-                handler(post_data)
-            else:
-                self.logger.warning(f"Method not allowed: {method}")
-                self._send_response(HTTPStatus.METHOD_NOT_ALLOWED, error="Method not allowed")
-
-        except json.JSONDecodeError as e:
-            self.logger.error(f"JSON decode error: {str(e)}")
-            self._send_response(HTTPStatus.BAD_REQUEST, error="Invalid JSON in request body")
-        except ValueError as e:
-            self.logger.error(f"Validation error: {str(e)}")
-            self._send_response(HTTPStatus.BAD_REQUEST, error=str(e))
-        except Exception as e:
-            self.logger.error(f"Unexpected error: {str(e)}", exc_info=True)
-            self._send_response(HTTPStatus.INTERNAL_SERVER_ERROR, error="Internal server error")
-
-    def _handle_get(self, _) -> None:
-        """Handle GET request"""
-        self.logger.debug("Processing GET request for all alarms")
-        alarms = self.storage.get_saved_alerts()
-        self.logger.debug(f"Retrieved {len(alarms)} alarms")
-        self._send_response(HTTPStatus.OK, data=alarms)
-
-    def _handle_post(self, data: dict) -> None:
-        """Handle POST request"""
-        self.logger.debug(f"Processing POST request with data: {json.dumps(data, indent=2)}")
-        try:
-            alarm_id = self.storage.save_new_alert(data)
-            self.logger.info(f"Successfully created new alarm with ID: {alarm_id}")
-            self._send_response(HTTPStatus.CREATED, data={"id": alarm_id})
-        except ValueError as e:
-            self.logger.error(f"Failed to create alarm: {str(e)}")
-            self._send_response(HTTPStatus.BAD_REQUEST, error=str(e))
-
-    def _handle_put(self, data: dict) -> None:
-        """Handle PUT request"""
-        alarm_id = data.pop("id", None)
-        self.logger.debug(f"Processing PUT request for alarm ID {alarm_id} with data: {json.dumps(data, indent=2)}")
-
-        if alarm_id is None:
-            self.logger.error("PUT request missing alarm ID")
-            self._send_response(HTTPStatus.BAD_REQUEST, error="Missing alarm ID")
-            return
-
-        if self.storage.update_alert(alarm_id, data):
-            self.logger.info(f"Successfully updated alarm ID: {alarm_id}")
-            self._send_response(HTTPStatus.OK, data={"message": "Alarm updated successfully"})
-        else:
-            self.logger.warning(f"Alarm not found for update: {alarm_id}")
-            self._send_response(HTTPStatus.NOT_FOUND, error="Alarm not found")
-
-    def _handle_delete(self, data: dict) -> None:
-        """Handle DELETE request"""
-        alarm_id = data.get("id")
-        self.logger.debug(f"Processing DELETE request for alarm ID: {alarm_id}")
-
-        if not isinstance(alarm_id, int):
-            self.logger.error(f"Invalid alarm ID format: {alarm_id}")
-            self._send_response(HTTPStatus.BAD_REQUEST, error="Invalid alarm ID")
-            return
-
-        if self.storage.remove_saved_alert(alarm_id):
-            self.logger.info(f"Successfully deleted alarm ID: {alarm_id}")
-            self._send_response(HTTPStatus.OK, data={"message": "Alarm removed successfully"})
-        else:
-            self.logger.warning(f"Alarm not found for deletion: {alarm_id}")
-            self._send_response(HTTPStatus.NOT_FOUND, error="Alarm not found")
-
-    def do_GET(self): self._handle_request("GET")
-    def do_POST(self): self._handle_request("POST")
-    def do_PUT(self): self._handle_request("PUT")
-    def do_DELETE(self): self._handle_request("DELETE")
-
-
-def run(server_class=HTTPServer, handler_class=AlertApi, port=8000):
-    # Set up logging configuration
-    logging.basicConfig(
-        level=logging.DEBUG,  # Set to DEBUG to show all log levels
-        format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
-        handlers=[
-            logging.StreamHandler(),  # Console handler
-            logging.FileHandler('alert_api.log')  # File handler
-        ]
-    )
-
-    logger = logging.getLogger('AlertApi')
-    logger.info(f"Starting AlertApi on port {port}")
-
-    server_address = ("", port)
-    httpd = server_class(server_address, handler_class)
-
-    try:
-        logger.info("Server is ready to handle requests")
-        httpd.serve_forever()
-    except KeyboardInterrupt:
-        logger.info("Received shutdown signal")
-    except Exception as e:
-        logger.error(f"Server error: {str(e)}", exc_info=True)
-    finally:
-        httpd.server_close()
-        logger.info("Server stopped")
-
-
-if __name__ == "__main__":
-    from sys import argv
-    run(port=int(argv[1]) if len(argv) == 2 else 8000)

alert_api/tests.sh

@@ -1,173 +0,0 @@
-#!/bin/bash
-
-# Configuration
-API_URL="http://localhost:8000"
-TEST_ALARM_NAME="Test Alarm"
-TEST_ALARM_TIME="08:30:00"
-TEST_AUDIO_FILE="/tmp/test.mp3"
-
-# Color codes for output
-GREEN='\033[0;32m'
-RED='\033[0;31m'
-BLUE='\033[0;34m'
-NC='\033[0m' # No Color
-
-# Helper function to print status messages
-print_status() {
-    echo -e "${BLUE}=== $1 ===${NC}"
-}
-
-# Helper function to check test results
-check_result() {
-    if [ $? -eq 0 ]; then
-        echo -e "${GREEN}✓ $1${NC}"
-    else
-        echo -e "${RED}✗ $1${NC}"
-        exit 1
-    fi
-}
-
-# 1. Test server connectivity
-print_status "Testing server connectivity"
-curl -s "$API_URL" > /dev/null
-check_result "Server connectivity check"
-
-# 2. Get initial state
-print_status "Getting initial state"
-INITIAL_STATE=$(curl -s -X GET "$API_URL")
-echo "$INITIAL_STATE" | jq .
-check_result "Retrieved initial state"
-
-# 3. Add a new alarm (POST)
-print_status "Adding new alarm"
-POST_DATA=$(jq -n \
-    --arg name "$TEST_ALARM_NAME" \
-    --arg time "$TEST_ALARM_TIME" \
-    '{
-        "name": $name,
-        "time": $time,
-        "repeat_rule": {
-            "type": "weekly",
-            "days_of_week": ["monday", "wednesday", "friday"]
-        },
-        "enabled": true,
-        "snooze": {
-            "enabled": true,
-            "duration": 5,
-            "max_count": 3
-        },
-        "metadata": {
-            "volume": 75,
-            "notes": "Test alarm with full configuration"
-        }
-    }'
-)
-
-ADD_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$POST_DATA" "$API_URL")
-NEW_ALARM_ID=$(echo "$ADD_RESPONSE" | jq -r '.data.id')
-
-if [[ "$NEW_ALARM_ID" == "null" || -z "$NEW_ALARM_ID" ]]; then
-    echo -e "${RED}Failed to add alarm${NC}"
-    echo "Response: $ADD_RESPONSE"
-    exit 1
-fi
-
-echo -e "${GREEN}Added alarm with ID: $NEW_ALARM_ID${NC}"
-
-# 4. Test duplicate alarm detection
-print_status "Testing duplicate alarm detection"
-DUPLICATE_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$POST_DATA" "$API_URL")
-if [[ $(echo "$DUPLICATE_RESPONSE" | jq -r '.error') == *"Duplicate alarm detected"* ]]; then
-    echo -e "${GREEN}✓ Duplicate detection working${NC}"
-else
-    echo -e "${RED}✗ Duplicate detection failed${NC}"
-    echo "Response: $DUPLICATE_RESPONSE"
-fi
-
-# 5. Update the alarm (PUT)
-print_status "Updating alarm"
-UPDATE_DATA=$(jq -n \
-    --arg name "$TEST_ALARM_NAME Updated" \
-    --arg time "$TEST_ALARM_TIME" \
-    --argjson id "$NEW_ALARM_ID" \
-    '{
-        "id": $id,
-        "name": $name,
-        "time": $time,
-        "repeat_rule": {
-            "type": "daily"
-        },
-        "enabled": true,
-        "snooze": {
-            "enabled": false,
-            "duration": 10,
-            "max_count": 2
-        },
-        "metadata": {
-            "volume": 90,
-            "notes": "Updated test alarm"
-        }
-    }'
-)
-
-UPDATE_RESPONSE=$(curl -s -X PUT -H "Content-Type: application/json" -d "$UPDATE_DATA" "$API_URL")
-if [[ $(echo "$UPDATE_RESPONSE" | jq -r '.data.message') == "Alarm updated successfully" ]]; then
-    echo -e "${GREEN}✓ Alarm update successful${NC}"
-else
-    echo -e "${RED}✗ Alarm update failed${NC}"
-    echo "Response: $UPDATE_RESPONSE"
-fi
-
-# 6. Verify the update
-print_status "Verifying update"
-UPDATED_STATE=$(curl -s -X GET "$API_URL")
-UPDATED_ALARM=$(echo "$UPDATED_STATE" | jq -r ".data[] | select(.id == $NEW_ALARM_ID)")
-if [[ $(echo "$UPDATED_ALARM" | jq -r '.name') == "$TEST_ALARM_NAME Updated" ]]; then
-    echo -e "${GREEN}✓ Update verification successful${NC}"
-else
-    echo -e "${RED}✗ Update verification failed${NC}"
-    echo "Current alarm state: $UPDATED_ALARM"
-fi
-
-# 7. Test invalid inputs
-print_status "Testing invalid inputs"
-
-# Test invalid time format
-INVALID_TIME_DATA=$(echo "$POST_DATA" | jq '. + {"time": "25:00:00"}')
-INVALID_TIME_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$INVALID_TIME_DATA" "$API_URL")
-if [[ $(echo "$INVALID_TIME_RESPONSE" | jq -r '.error') == *"Invalid alarm configuration"* ]]; then
-    echo -e "${GREEN}✓ Invalid time format detection working${NC}"
-else
-    echo -e "${RED}✗ Invalid time format detection failed${NC}"
-fi
-
-# Test invalid repeat rule
-INVALID_REPEAT_DATA=$(echo "$POST_DATA" | jq '.repeat_rule.type = "monthly"')
-INVALID_REPEAT_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$INVALID_REPEAT_DATA" "$API_URL")
-if [[ $(echo "$INVALID_REPEAT_RESPONSE" | jq -r '.error') == *"Invalid alarm configuration"* ]]; then
-    echo -e "${GREEN}✓ Invalid repeat rule detection working${NC}"
-else
-    echo -e "${RED}✗ Invalid repeat rule detection failed${NC}"
-fi
-
-# 8. Delete the test alarm
-print_status "Deleting test alarm"
-DELETE_RESPONSE=$(curl -s -X DELETE -H "Content-Type: application/json" -d "{\"id\":$NEW_ALARM_ID}" "$API_URL")
-if [[ $(echo "$DELETE_RESPONSE" | jq -r '.data.message') == "Alarm removed successfully" ]]; then
-    echo -e "${GREEN}✓ Alarm deletion successful${NC}"
-else
-    echo -e "${RED}✗ Alarm deletion failed${NC}"
-    echo "Response: $DELETE_RESPONSE"
-fi
-
-# 9. Verify deletion
-print_status "Verifying deletion"
-FINAL_STATE=$(curl -s -X GET "$API_URL")
-if [[ $(echo "$FINAL_STATE" | jq ".data[] | select(.id == $NEW_ALARM_ID)") == "" ]]; then
-    echo -e "${GREEN}✓ Deletion verification successful${NC}"
-else
-    echo -e "${RED}✗ Deletion verification failed${NC}"
-    echo "Current state: $FINAL_STATE"
-fi
-
-print_status "Test suite completed!"

clock/alarm_api.py

@@ -0,0 +1,151 @@
+from http.server import BaseHTTPRequestHandler, HTTPServer
+import logging
+import os
+import json
+import hashlib
+from dataclasses import dataclass, field, asdict
+from typing import List, Optional, Dict, Any
+from datetime import datetime
+from http import HTTPStatus
+import re
+
+from alarm_storage import AlarmStorage
+from data_classes import RepeatRule, Snooze, Metadata, Alarm
+from logging_config import setup_logging
+
+# Set up logging configuration
+logger = setup_logging()
+
+class AlertApi(BaseHTTPRequestHandler):
+    def __init__(self, *args, **kwargs):
+        self.storage = AlarmStorage("data/alerts.json")
+        self.logger = logger
+        super().__init__(*args, **kwargs)
+
+    def _send_response(self, status_code: int, data: Any = None, error: str = None) -> None:
+        """Send a JSON response with the given status code and data/error"""
+        self.send_response(status_code)
+        self.send_header("Content-Type", "application/json")
+        self.send_header("Access-Control-Allow-Origin", "*")
+        self.end_headers()
+
+        response = {}
+        if data is not None:
+            response["data"] = data
+        if error is not None:
+            response["error"] = error
+
+        response_json = json.dumps(response)
+        self.logger.debug(f"Sending response: {response_json}")
+        self.wfile.write(response_json.encode("utf-8"))
+
+    def _handle_request(self, method: str) -> None:
+        """Handle incoming requests with proper error handling"""
+        self.logger.info(f"Received {method} request from {self.client_address[0]}")
+
+        try:
+            if method in ["POST", "PUT", "DELETE"]:
+                content_length = int(self.headers.get("Content-Length", 0))
+                if content_length == 0:
+                    raise ValueError("Missing request body")
+
+                post_data = self.rfile.read(content_length)
+                self.logger.debug(f"Received {method} payload: {post_data.decode('utf-8')}")
+
+                post_data = json.loads(post_data)
+            else:
+                post_data = None
+
+            # Route request to appropriate handler
+            handler = getattr(self, f"_handle_{method.lower()}", None)
+            if handler:
+                self.logger.debug(f"Routing to handler: _handle_{method.lower()}")
+                handler(post_data)
+            else:
+                self.logger.warning(f"Method not allowed: {method}")
+                self._send_response(HTTPStatus.METHOD_NOT_ALLOWED, error="Method not allowed")
+
+        except json.JSONDecodeError as e:
+            self.logger.error(f"JSON decode error: {str(e)}")
+            self._send_response(HTTPStatus.BAD_REQUEST, error="Invalid JSON in request body")
+        except ValueError as e:
+            self.logger.error(f"Validation error: {str(e)}")
+            self._send_response(HTTPStatus.BAD_REQUEST, error=str(e))
+        except Exception as e:
+            self.logger.error(f"Unexpected error: {str(e)}", exc_info=True)
+            self._send_response(HTTPStatus.INTERNAL_SERVER_ERROR, error="Internal server error")
+
+    def _handle_get(self, _) -> None:
+        """Handle GET request"""
+        self.logger.debug("Processing GET request for all alarms")
+        alarms = self.storage.get_saved_alerts()
+        self.logger.debug(f"Retrieved {len(alarms)} alarms")
+        self._send_response(HTTPStatus.OK, data=alarms)
+
+    def _handle_post(self, data: dict) -> None:
+        """Handle POST request"""
+        self.logger.debug(f"Processing POST request with data: {json.dumps(data, indent=2)}")
+        try:
+            alarm_id = self.storage.save_new_alert(data)
+            self.logger.info(f"Successfully created new alarm with ID: {alarm_id}")
+            self._send_response(HTTPStatus.CREATED, data={"id": alarm_id})
+        except ValueError as e:
+            self.logger.error(f"Failed to create alarm: {str(e)}")
+            self._send_response(HTTPStatus.BAD_REQUEST, error=str(e))
+
+    def _handle_put(self, data: dict) -> None:
+        """Handle PUT request"""
+        alarm_id = data.pop("id", None)
+        self.logger.debug(f"Processing PUT request for alarm ID {alarm_id} with data: {json.dumps(data, indent=2)}")
+
+        if alarm_id is None:
+            self.logger.error("PUT request missing alarm ID")
+            self._send_response(HTTPStatus.BAD_REQUEST, error="Missing alarm ID")
+            return
+
+        if self.storage.update_alert(alarm_id, data):
+            self.logger.info(f"Successfully updated alarm ID: {alarm_id}")
+            self._send_response(HTTPStatus.OK, data={"message": "Alarm updated successfully"})
+        else:
+            self.logger.warning(f"Alarm not found for update: {alarm_id}")
+            self._send_response(HTTPStatus.NOT_FOUND, error="Alarm not found")
+
+    def _handle_delete(self, data: dict) -> None:
+        """Handle DELETE request"""
+        alarm_id = data.get("id")
+        self.logger.debug(f"Processing DELETE request for alarm ID: {alarm_id}")
+
+        if not isinstance(alarm_id, int):
+            self.logger.error(f"Invalid alarm ID format: {alarm_id}")
+            self._send_response(HTTPStatus.BAD_REQUEST, error="Invalid alarm ID")
+            return
+
+        if self.storage.remove_saved_alert(alarm_id):
+            self.logger.info(f"Successfully deleted alarm ID: {alarm_id}")
+            self._send_response(HTTPStatus.OK, data={"message": "Alarm removed successfully"})
+        else:
+            self.logger.warning(f"Alarm not found for deletion: {alarm_id}")
+            self._send_response(HTTPStatus.NOT_FOUND, error="Alarm not found")
+
+    def do_GET(self): self._handle_request("GET")
+    def do_POST(self): self._handle_request("POST")
+    def do_PUT(self): self._handle_request("PUT")
+    def do_DELETE(self): self._handle_request("DELETE")
+
+
+def run(server_class=HTTPServer, handler_class=AlertApi, port=8000):
+    logger.info(f"Starting AlertApi on port {port}")
+
+    server_address = ("", port)
+    httpd = server_class(server_address, handler_class)
+
+    try:
+        logger.info("Server is ready to handle requests")
+        httpd.serve_forever()
+    except KeyboardInterrupt:
+        logger.info("Received shutdown signal")
+    except Exception as e:
+        logger.error(f"Server error: {str(e)}", exc_info=True)
+    finally:
+        httpd.server_close()
+        logger.info("Server stopped")

clock/alarm_siren.py

@@ -0,0 +1,260 @@
+import os
+import time
+import threading
+import subprocess
+import queue
+import logging
+from datetime import datetime, timedelta
+from typing import Optional, Dict, Any
+
+from logging_config import setup_logging
+
+# Set up logging
+logger = setup_logging()
+
+class AlarmSiren:
+    def __init__(self):
+        # Communication queues
+        self.alarm_queue = queue.Queue()
+        self.control_queue = queue.Queue()
+
+        # Tracking active alarms
+        self.active_alarms: Dict[int, Dict[str, Any]] = {}
+
+        # Playback thread
+        self.playback_thread = threading.Thread(target=self._playback_worker, daemon=True)
+        self.playback_thread.start()
+
+    def schedule_alarm(self, alarm_config: Dict[str, Any]):
+        """Schedule an alarm based on its configuration"""
+        logger.info(f"Scheduling alarm: {alarm_config}")
+        self.alarm_queue.put(alarm_config)
+
+    def _calculate_next_alarm_time(self, alarm_config: Dict[str, Any]) -> Optional[datetime]:
+        """Calculate the next alarm trigger time based on repeat rule"""
+        now = datetime.now()
+        current_time = now.time()
+
+        # Parse alarm time
+        alarm_time = datetime.strptime(alarm_config['time'], "%H:%M:%S").time()
+
+        # Determine the next trigger
+        repeat_rule = alarm_config['repeat_rule']
+
+        # Determine repeat rule type and details
+        if isinstance(repeat_rule, dict):
+            repeat_type = repeat_rule.get('type')
+            repeat_days = repeat_rule.get('days_of_week', [])
+            repeat_at = repeat_rule.get('at')
+        else:
+            # Assume it's an object-like structure with attributes
+            repeat_type = getattr(repeat_rule, 'type', None)
+            repeat_days = getattr(repeat_rule, 'days_of_week', [])
+            repeat_at = getattr(repeat_rule, 'at', None)
+
+        # Sanity check
+        if repeat_type is None:
+            logger.error(f"Invalid repeat rule configuration: {repeat_rule}")
+            return None
+
+        if repeat_type == 'once':
+            # For one-time alarm, check the specific date
+            try:
+                # If 'at' is None, use current date
+                if repeat_at is None:
+                    specific_date = now.date()
+                else:
+                    specific_date = datetime.strptime(repeat_at, "%d.%m.%Y").date()
+                return datetime.combine(specific_date, alarm_time)
+            except ValueError:
+                logger.error("Invalid one-time alarm configuration")
+                return None
+
+        elif repeat_type == 'daily':
+            # Daily alarm - trigger today or tomorrow
+            next_trigger = datetime.combine(now.date(), alarm_time)
+            if current_time < alarm_time:
+                return next_trigger
+            return next_trigger + timedelta(days=1)
+
+        elif repeat_type == 'weekly':
+            # Weekly alarm - check configured days
+            today = now.strftime("%A").lower()
+            configured_days = [day.lower() for day in repeat_days]
+
+            if today in configured_days and current_time < alarm_time:
+                return datetime.combine(now.date(), alarm_time)
+
+            # Find next configured day
+            days_order = ['monday', 'tuesday', 'wednesday', 'thursday', 'friday', 'saturday', 'sunday']
+            current_index = days_order.index(today)
+
+            for offset in range(1, 8):
+                next_day_index = (current_index + offset) % 7
+                next_day = days_order[next_day_index]
+
+                if next_day in configured_days:
+                    next_date = now.date() + timedelta(days=offset)
+                    return datetime.combine(next_date, alarm_time)
+
+        return None
+
+    def _play_audio(self, file_path: str, volume: int = 100):
+        """Play audio file using mpg123 in the background."""
+        try:
+            if not os.path.exists(file_path):
+                logger.error(f"Audio file not found: {file_path}")
+                return None
+
+            # Construct mpg123 command with volume control
+            volume_adjust = f"-g {volume}"
+            cmd = ["mpg123", volume_adjust, file_path]
+
+            logger.info(f"Playing alarm: {file_path}")
+
+            # Run mpg123 in the background, suppressing stdout/stderr
+            process = subprocess.Popen(cmd, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+            return process
+        except Exception as e:
+            logger.error(f"Error playing audio: {e}")
+            return None
+
+    def _playback_worker(self):
+        """Background thread for managing alarm playback"""
+        while True:
+            try:
+                # Check for new alarms to schedule
+                try:
+                    new_alarm = self.alarm_queue.get(timeout=1)
+                    alarm_time = self._calculate_next_alarm_time(new_alarm)
+                    if alarm_time:
+                        alarm_id = new_alarm.get('id', id(new_alarm))
+                        self.active_alarms[alarm_id] = {
+                            'config': new_alarm,
+                            'trigger_time': alarm_time,
+                            'snooze_count': 0,
+                            'process': None
+                        }
+                except queue.Empty:
+                    pass
+
+                # Check for control signals (snooze/dismiss)
+                try:
+                    control_msg = self.control_queue.get(timeout=0.1)
+                    alarm_id = control_msg.get('alarm_id')
+                    if control_msg['type'] == 'snooze':
+                        self.snooze_alarm(alarm_id)
+                    elif control_msg['type'] == 'dismiss':
+                        self.dismiss_alarm(alarm_id)
+                except queue.Empty:
+                    pass
+
+                # Check for alarms to trigger
+                now = datetime.now()
+                for alarm_id, alarm_info in list(self.active_alarms.items()):
+                    # Check if alarm is more than 1 hour late
+                    if now > alarm_info['trigger_time'] + timedelta(hours=1):
+                        logger.warning(f"Alarm {alarm_id} is over 1 hour late. Disabling.")
+                        del self.active_alarms[alarm_id]
+                        continue
+                    if now >= alarm_info['trigger_time']:
+                        # Trigger alarm if not already active
+                        if alarm_info['process'] is None:
+                            alarm_info['process'] = self._play_audio(
+                                alarm_info['config']['file_to_play'],
+                                alarm_info['config'].get('metadata', {}).get('volume', 100)
+                            )
+                            logger.info(f"Alarm {alarm_id} triggered at {now}.")
+
+                        # Notify UI about the triggered alarm
+                        self.control_queue.put({
+                            'type': 'trigger',
+                            'alarm_id': alarm_id,
+                            'info': alarm_info
+                        })
+
+                    # Handle alarms that have been snoozed or dismissed
+                    if alarm_info['process'] and alarm_info['process'].poll() is not None:
+                            # Process has finished naturally
+                            next_trigger = self._calculate_next_alarm_time(alarm_info['config'])
+                            if next_trigger:
+                                alarm_info['trigger_time'] = next_trigger
+                                alarm_info['process'] = None
+                            else:
+                                logger.info(f"Removing non-repeating alarm {alarm_id}.")
+                                del self.active_alarms[alarm_id]
+
+                    # Actively clean up zombie processes
+                    for alarm_id, alarm_info in list(self.active_alarms.items()):
+                        process = alarm_info.get('process')
+                        if process and process.poll() is not None:
+                            # Remove terminated processes
+                            alarm_info['process'] = None
+
+                time.sleep(0.5)  # Prevent tight loop
+            except Exception as e:
+                logger.error(f"Error in playback worker: {e}")
+                time.sleep(1)
+
+    def snooze_alarm(self, alarm_id: int):
+        """Snooze a specific alarm"""
+        if alarm_id not in self.active_alarms:
+            logger.warning(f"Cannot snooze alarm {alarm_id} - not found in active alarms")
+            return False
+
+        alarm_info = self.active_alarms[alarm_id]
+        alarm_config = alarm_info['config']
+
+        # Default snooze configuration if not provided
+        snooze_config = alarm_config.get('snooze', {
+            'enabled': True,
+            'duration': 5,  # Default 5 minutes
+            'max_count': 3  # Default max 3 snoozes
+        })
+
+        if not snooze_config.get('enabled', True):
+            logger.warning(f"Snooze not enabled for alarm {alarm_id}")
+            return False
+
+        # Check snooze count
+        if alarm_info.get('snooze_count', 0) >= snooze_config['max_count']:
+            logger.warning(f"Maximum snooze count reached for alarm {alarm_id}")
+            return False
+
+        # Increment snooze count and set next trigger time
+        alarm_info['snooze_count'] = alarm_info.get('snooze_count', 0) + 1
+        snooze_duration = snooze_config.get('duration', 5)
+        alarm_info['trigger_time'] = datetime.now() + timedelta(minutes=snooze_duration)
+
+        # Stop any active playback
+        process = alarm_info.get('process')
+        if process:
+            process.terminate()
+            process.wait()
+            alarm_info['process'] = None
+
+        logger.info(f"Snoozed alarm {alarm_id} for {snooze_duration} minutes.")
+        return True
+
+def dismiss_alarm(self, alarm_id: int):
+    """Dismiss a specific alarm."""
+    if alarm_id not in self.active_alarms:
+        logger.warning(f"Cannot dismiss alarm {alarm_id} - not found in active alarms")
+        return False
+
+    # Stop playback and terminate any running process
+    alarm_info = self.active_alarms.pop(alarm_id, None)
+    if alarm_info and alarm_info.get('process'):
+        try:
+            alarm_info['process'].terminate()
+            alarm_info['process'].wait(timeout=2)
+        except Exception as e:
+            logger.error(f"Error terminating alarm process: {e}")
+            # Force kill if terminate fails
+            try:
+                alarm_info['process'].kill()
+            except Exception:
+                pass
+
+    logger.info(f"Dismissed alarm {alarm_id}.")
+    return True

clock/alarm_storage.py

@@ -0,0 +1,263 @@
+import logging
+import os
+import json
+import hashlib
+from typing import List, Optional, Dict, Any
+from datetime import datetime
+import re
+from dataclasses import asdict
+
+from data_classes import RepeatRule, Snooze, Metadata, Alarm
+
+# Set up logging configuration
+logging.basicConfig(
+    level=logging.DEBUG,
+    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+    handlers=[
+        logging.StreamHandler(),  # Console handler
+        logging.FileHandler('alert_api.log')  # File handler
+    ]
+)
+
+logger = logging.getLogger('AlertApi')
+
+class AlarmStorage:
+    def __init__(self, file_path: str, siren=None):
+        """Initialize AlarmStorage with optional Siren integration"""
+        self.file_path = file_path
+        self.siren = siren
+        self._ensure_storage_directory()
+
+    def _ensure_storage_directory(self) -> None:
+        """Ensure the directory for the storage file exists"""
+        directory = os.path.dirname(os.path.abspath(self.file_path))
+        if directory:
+            os.makedirs(directory, exist_ok=True)
+
+    @staticmethod
+    def _generate_alarm_hash(alarm: dict) -> str:
+        """Generate an MD5 hash for the given alarm data"""
+        def to_dict(value):
+            return asdict(value) if hasattr(value, '__dataclass_fields__') else value
+
+        alarm_data = alarm.copy()
+        alarm_data["repeat_rule"] = to_dict(alarm_data.get("repeat_rule"))
+        alarm_data["snooze"] = to_dict(alarm_data.get("snooze"))
+        alarm_data["metadata"] = to_dict(alarm_data.get("metadata"))
+
+        hash_input = json.dumps({
+            "name": alarm_data["name"],
+            "time": alarm_data["time"],
+            "file_to_play": alarm_data.get("file_to_play", os.path.expanduser("~/.alarms/alarm-lofi.mp3")),
+            "repeat_rule": alarm_data["repeat_rule"]
+        }, sort_keys=True)
+        return hashlib.md5(hash_input.encode('utf-8')).hexdigest()
+
+    def load_data(self) -> dict:
+        """Load the JSON data from the file"""
+        try:
+            with open(self.file_path, 'r') as file:
+                data = json.load(file)
+                if not isinstance(data, dict):
+                    raise ValueError("Invalid data format")
+                return data
+        except (FileNotFoundError, json.JSONDecodeError):
+            return {"last_id": 0, "alarms": []}
+
+    def save_data(self, data: dict) -> None:
+        """Save the JSON data back to the file"""
+        def convert_to_dict(obj):
+            """Convert dataclass instances to dictionaries recursively"""
+            if isinstance(obj, list):
+                return [convert_to_dict(item) for item in obj]
+            elif isinstance(obj, dict):
+                return {key: convert_to_dict(value) for key, value in obj.items()}
+            elif hasattr(obj, "__dataclass_fields__"):
+                return asdict(obj)
+            else:
+                return obj
+
+        # Convert data to JSON-serializable format
+        serializable_data = convert_to_dict(data)
+
+        with open(self.file_path, 'w') as file:
+            json.dump(serializable_data, file, indent=4)
+
+    def save_new_alert(self, alarm_data: dict) -> int:
+        """
+        Add a new alarm to the storage and notify Siren if configured
+        """
+        # Check for potential duplicates before saving
+        existing_alarms = self.get_saved_alerts()
+        for alarm in existing_alarms:
+            # Compare key characteristics
+            if (alarm['name'] == alarm_data['name'] and
+                alarm['time'] == alarm_data['time'] and
+                alarm['repeat_rule'] == alarm_data['repeat_rule']):
+                raise ValueError("Duplicate alarm already exists")
+
+
+        # Set default file_to_play if not provided
+        alarm_data['file_to_play'] = alarm_data.get('file_to_play', os.path.expanduser("~/.alarms/alarm-lofi.mp3"))
+
+        # Convert nested dictionaries to dataclass instances
+        try:
+            if 'repeat_rule' in alarm_data:
+                alarm_data['repeat_rule'] = RepeatRule(**alarm_data['repeat_rule'])
+            if 'snooze' in alarm_data:
+                alarm_data['snooze'] = Snooze(**alarm_data['snooze'])
+            if 'metadata' in alarm_data:
+                alarm_data['metadata'] = Metadata(**alarm_data['metadata'])
+        except TypeError as e:
+            raise ValueError(f"Invalid format in one of the nested fields: {str(e)}")
+
+        # Validate input
+        try:
+            alarm = Alarm(**alarm_data)
+            if not alarm.validate():
+                raise ValueError("Invalid alarm configuration")
+        except (TypeError, ValueError) as e:
+            raise ValueError(f"Invalid alarm data: {str(e)}")
+
+        # Load existing data
+        data = self.load_data()
+
+        # Increment last_id and assign to new alarm
+        data['last_id'] += 1
+        alarm_data['id'] = data['last_id']
+
+        # Generate hash for the alarm
+        alarm_data['hash'] = self._generate_alarm_hash(alarm_data)
+
+        # Check for duplicates
+        if any(a.get("hash") == alarm_data['hash'] for a in data["alarms"]):
+            raise ValueError("Duplicate alarm detected")
+
+        # Add new alarm to the list
+        data['alarms'].append(alarm_data)
+
+        # Save updated data
+        self.save_data(data)
+
+        # Notify Siren if available
+        if self.siren and alarm_data.get('enabled', True):
+            try:
+                self.siren.schedule_alarm(alarm_data)
+                logger.info(f"Siren notified of new alarm: {alarm_data['id']}")
+            except Exception as e:
+                logger.error(f"Failed to notify Siren about new alarm: {e}")
+
+        return data['last_id']
+
+    def get_saved_alerts(self) -> list:
+        """Retrieve the list of saved alarms"""
+        return self.load_data().get("alarms", [])
+
+    def remove_saved_alert(self, alarm_id: int) -> bool:
+        """Remove an alarm by its ID"""
+        data = self.load_data()
+        original_length = len(data["alarms"])
+
+        # Filter out the alarm with the given ID
+        data["alarms"] = [a for a in data["alarms"] if a["id"] != alarm_id]
+
+        if len(data["alarms"]) == original_length:
+            return False
+
+        # Save updated data
+        self.save_data(data)
+
+        # Notify Siren if available
+        if self.siren:
+            try:
+                self.siren.dismiss_alarm(alarm_id)
+                logger.info(f"Siren dismissed alarm: {alarm_id}")
+            except Exception as e:
+                logger.error(f"Failed to notify Siren about removed alarm: {e}")
+
+        return True
+
+    def update_alert(self, alarm_id: int, alarm_data: dict) -> bool:
+        """Update an existing alarm"""
+        alarm_data["id"] = alarm_id
+
+        # Set default file_to_play if not provided
+        alarm_data['file_to_play'] = alarm_data.get('file_to_play', os.path.expanduser("~/.alarms/alarm-lofi.mp3"))
+
+        # Convert nested dictionaries to dataclass instances
+        try:
+            if 'repeat_rule' in alarm_data:
+                alarm_data['repeat_rule'] = RepeatRule(**alarm_data['repeat_rule'])
+            if 'snooze' in alarm_data:
+                alarm_data['snooze'] = Snooze(**alarm_data['snooze'])
+            if 'metadata' in alarm_data:
+                alarm_data['metadata'] = Metadata(**alarm_data['metadata'])
+        except TypeError as e:
+            raise ValueError(f"Invalid format in one of the nested fields: {str(e)}")
+
+        # Validate input
+        try:
+            alarm = Alarm(**alarm_data)
+            if not alarm.validate():
+                raise ValueError("Invalid alarm configuration")
+        except (TypeError, ValueError) as e:
+            raise ValueError(f"Invalid alarm data: {str(e)}")
+
+        # Load existing data
+        data = self.load_data()
+
+        # Find and update the alarm
+        for i, existing_alarm in enumerate(data["alarms"]):
+            if existing_alarm["id"] == alarm_id:
+                # Generate new hash
+                alarm_data["hash"] = self._generate_alarm_hash(alarm_data)
+
+                # Replace the existing alarm
+                data["alarms"][i] = alarm_data
+
+                # Save updated data
+                self.save_data(data)
+
+                # Notify Siren if available
+                if self.siren:
+                    try:
+                        # Remove existing alarm and reschedule
+                        self.siren.dismiss_alarm(alarm_id)
+
+                        if alarm_data.get('enabled', True):
+                            self.siren.schedule_alarm(alarm_data)
+                            logger.info(f"Siren updated for alarm: {alarm_id}")
+                        else:
+                            logger.info(f"Siren dismissed disabled alarm: {alarm_id}")
+                    except Exception as e:
+                        logger.error(f"Failed to notify Siren about updated alarm: {e}")
+
+                return True
+
+        # Alarm not found
+        return False
+
+    def _get_alarm_by_id(self, alarm_id: int) -> Optional[dict]:
+        """
+        Retrieve a specific alarm by its ID
+
+        Args:
+            alarm_id (int): ID of the alarm to retrieve
+
+        Returns:
+            dict or None: Alarm configuration or None if not found
+        """
+        data = self.load_data()
+        for alarm in data.get('alarms', []):
+            if alarm.get('id') == alarm_id:
+                return alarm
+        return None
+
+    def set_siren(self, siren):
+        """
+        Set or update the Siren instance for alarm synchronization
+
+        Args:
+            siren (AlarmSiren): Siren instance to use for alarm management
+        """
+        self.siren = siren

clock/data_classes.py

@@ -0,0 +1,179 @@
+import hashlib
+from dataclasses import dataclass, field, asdict
+from typing import List, Optional, Dict, Any
+from datetime import datetime
+import os
+import re
+from logging_config import setup_logging
+
+# Set up logging
+logger = setup_logging()
+
+@dataclass
+class RepeatRule:
+    type: str  # "daily" or "weekly" or "once"
+    days_of_week: Optional[List[str]] = field(default_factory=list)
+    at: Optional[str] = None
+
+    def validate(self) -> bool:
+        """Validate repeat rule configuration"""
+        valid_types = {"daily", "weekly", "once"}
+        valid_days = {"mon", "tue", "wed", "thu", "fri", "sat", "sun"}
+
+
+        if self.type not in valid_types:
+            logger.error(f"Invalid RepeatRule type: '{self.type}'. Must be one of {valid_types}")
+            return False
+
+        if self.type == "weekly":
+            if self.days_of_week is None:
+                logger.error("days_of_week is None")
+                return False
+
+            if not self.days_of_week:
+                logger.error("days_of_week is empty")
+                return False
+
+            invalid_days = [day for day in self.days_of_week if day.lower() not in valid_days]
+            if invalid_days:
+                logger.error(f"Invalid RepeatRule weekday names: {invalid_days}. Must be one of {valid_days}")
+                return False
+            if not self.days_of_week:
+                logger.error("Weekly repeat rule must specify at least one day")
+                return False
+
+        if self.type == "once" and self.days_of_week:
+            if self.days_of_week:
+                logger.error("One-time alert does not support days_of_week")
+                return False
+            if not self.at:
+                logger.error("One-time repeat rule must specify a valid 'at' date")
+                return False
+            try:
+                datetime.strptime(self.at, "%d.%m.%Y")
+            except ValueError:
+                logger.error(f"Invalid 'at' date format: '{self.at}'. Expected format: 'dd.mm.yyyy'")
+                return False
+
+        logger.debug(f"RepeatRule validation passed: {self.__dict__}")
+        return True
+
+
+@dataclass
+class Snooze:
+    enabled: bool = True
+    duration: int = 10    # minutes
+    max_count: int = 3
+
+    def validate(self) -> bool:
+        """Validate snooze configuration"""
+        if not isinstance(self.enabled, bool):
+            logger.error(f"Snooze enabled must be boolean, got {type(self.enabled)}")
+            return False
+
+        if not isinstance(self.duration, int):
+            logger.error(f"Snooze duration must be integer, got {type(self.duration)}")
+            return False
+
+        if self.duration <= 0:
+            logger.error(f"Snooze duration must be positive, got {self.duration}")
+            return False
+
+        if not isinstance(self.max_count, int):
+            logger.error(f"Snooze max_count must be integer, got {type(self.max_count)}")
+            return False
+
+        if self.max_count <= 0:
+            logger.error(f"Snooze max_count must be positive, got {self.max_count}")
+            return False
+
+        logger.debug(f"Snooze validation passed: {self.__dict__}")
+        return True
+
+
+@dataclass
+class Metadata:
+    volume: int = 100
+    notes: str = ""
+    md5sum: str = ""
+
+    def validate(self) -> bool:
+        """Validate metadata configuration"""
+        if not isinstance(self.volume, int):
+            logger.error(f"Volume must be integer, got {type(self.volume)}")
+            return False
+
+        if not 0 <= self.volume <= 100:
+            logger.error(f"Volume must be between 0 and 100, got {self.volume}")
+            return False
+
+        logger.debug(f"Metadata validation passed: {self.__dict__}")
+        return True
+
+
+@dataclass
+class Alarm:
+    name: str
+    time: str  # Format: "HH:MM:SS"
+    repeat_rule: RepeatRule
+    file_to_play: str = field(default=os.path.expanduser("~/.alarms/alarm-lofi.mp3"))
+    enabled: bool = field(default=True)
+    snooze: Snooze = field(default_factory=Snooze)
+    metadata: Metadata = field(default_factory=Metadata)
+    id: Optional[int] = field(default=None)
+
+    def validate(self) -> bool:
+        """Validate complete alarm configuration"""
+        logger.debug(f"Starting validation for alarm: {self.name}")
+
+        # Validate name
+        if not isinstance(self.name, str) or len(self.name.strip()) == 0:
+            logger.error(f"Invalid alarm name: '{self.name}'. Must be non-empty string")
+            return False
+
+        # Validate time format
+        time_pattern = re.compile(r'^([0-1]?[0-9]|2[0-3]):[0-5][0-9]:[0-5][0-9]$')
+        if not time_pattern.match(self.time):
+            logger.error(f"Invalid time format: '{self.time}'. Must match HH:MM:SS")
+            return False
+
+        # Validate enabled flag
+        if not isinstance(self.enabled, bool):
+            logger.error(f"Enabled must be boolean, got {type(self.enabled)}")
+            return False
+
+        # Create default alarms directory if it doesn't exist
+        default_alarms_dir = os.path.expanduser("~/.alarms")
+        os.makedirs(default_alarms_dir, exist_ok=True)
+
+        # Validate audio file
+        if self.file_to_play != os.path.expanduser("~/.alarms/alarm-lofi.mp3") and not os.path.exists(self.file_to_play):
+            logger.error(f"Audio file not found: '{self.file_to_play}'")
+            return False
+
+        # Validate repeat rule
+        if not isinstance(self.repeat_rule, RepeatRule):
+            logger.error(f"Invalid repeat_rule type: {type(self.repeat_rule)}")
+            return False
+        if not self.repeat_rule.validate():
+            logger.error("Repeat rule validation failed")
+            return False
+
+        # Validate snooze
+        if not isinstance(self.snooze, Snooze):
+            logger.error(f"Invalid snooze type: {type(self.snooze)}")
+            return False
+        if not self.snooze.validate():
+            logger.error("Snooze validation failed")
+            return False
+
+        # Validate metadata
+        if not isinstance(self.metadata, Metadata):
+            logger.error(f"Invalid metadata type: {type(self.metadata)}")
+            return False
+        if not self.metadata.validate():
+            logger.error("Metadata validation failed")
+            return False
+
+        logger.debug(f"Alarm validation passed: {self.name}")
+        return True

clock/logging_config.py

@@ -0,0 +1,16 @@
+import logging
+import os
+
+def setup_logging(log_dir="logs", log_file="alarm_system.log", level=logging.DEBUG):
+    os.makedirs(log_dir, exist_ok=True)
+    log_path = os.path.join(log_dir, log_file)
+
+    logging.basicConfig(
+        level=level,
+        format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+        handlers=[
+            logging.FileHandler(log_path, mode='a', encoding='utf-8')
+        ]
+    )
+    logger = logging.getLogger("AlarmSystem")
+    return logger

clock/main.py

@@ -0,0 +1,190 @@
+#!/usr/bin/python3
+
+import os
+import sys
+import signal
+import threading
+import logging
+import curses
+from http.server import HTTPServer
+from multiprocessing import Queue
+import subprocess
+
+# Import our custom modules
+from alarm_api import AlertApi, run as run_api
+from alarm_storage import AlarmStorage
+from alarm_siren import AlarmSiren
+from ui.ncurses_ui import UI
+from logging_config import setup_logging
+
+# Set up logging
+logger = setup_logging()
+
+class AlarmSystemManager:
+    def __init__(self,
+                 api_port: int = 8000,
+                 storage_path: str = "data/alerts.json",
+                 log_level: int = logging.DEBUG):
+        """
+        Initialize and manage the entire alarm system
+
+        Args:
+            api_port (int): Port for the HTTP API server
+            storage_path (str): Path to the JSON storage file
+            log_level (int): Logging level
+        """
+        # Configure logging
+        logging.getLogger().setLevel(log_level)
+
+        # Ensure storage directory exists
+        os.makedirs(os.path.dirname(os.path.abspath(storage_path)), exist_ok=True)
+
+        # Initialize components
+        self.siren = AlarmSiren()
+        self.storage = AlarmStorage(storage_path, siren=self.siren)
+
+        # API server setup
+        self.api_port = api_port
+        self.api_server = None
+        self.api_thread = None
+
+        # Synchronization and lifecycle management
+        self.stop_event = threading.Event()
+
+        # Signal handling setup
+        self._setup_signal_handlers()
+
+        # Alarm synchronization
+        self._sync_alarms()
+
+        # UI..
+        self.ui = UI(self, control_queue=self.siren.control_queue)
+
+    def _setup_signal_handlers(self):
+        """Set up signal handlers for graceful shutdown"""
+        signal.signal(signal.SIGINT, self._handle_shutdown)
+        signal.signal(signal.SIGTERM, self._handle_shutdown)
+
+    def _handle_shutdown(self, signum, frame):
+        """
+        Handle system shutdown signals
+
+        Args:
+            signum (int): Signal number
+            frame (frame): Current stack frame
+        """
+        logger.info(f"Received shutdown signal {signum}. Initiating graceful shutdown...")
+        self.stop_event.set()
+
+    def _sync_alarms(self):
+        """
+        Synchronize stored alarms with the siren
+        This ensures any saved alarms are loaded and scheduled
+        """
+        try:
+            saved_alarms = self.storage.get_saved_alerts()
+            logger.info(f"Synchronizing {len(saved_alarms)} saved alarms")
+
+            for alarm in saved_alarms:
+                if alarm.get('enabled', True):
+                    self.siren.schedule_alarm(alarm)
+        except Exception as e:
+            logger.error(f"Error synchronizing alarms: {e}")
+
+    def _start_api_server(self):
+        """
+        Start the HTTP API server in a separate thread
+        """
+        try:
+            def run_server():
+                server_address = ("", self.api_port)
+                self.api_server = HTTPServer(server_address, AlertApi)
+                logger.info(f"API Server started on port {self.api_port}")
+
+                # Run until stopped
+                while not self.stop_event.is_set():
+                    self.api_server.handle_request()
+
+                self.api_server.server_close()
+                logger.info("API Server stopped")
+
+            # Start API server in a thread
+            self.api_thread = threading.Thread(target=run_server, daemon=True)
+            self.api_thread.start()
+        except Exception as e:
+            logger.error(f"Failed to start API server: {e}")
+            self.stop_event.set()
+
+    def run(self):
+        """
+        Main run method to start all system components
+        """
+        try:
+            # Start API server
+            self._start_api_server()
+
+            # Start UI
+            ui_thread = self.ui.run()
+
+            # Log system startup
+            logger.info("Alarm System started successfully")
+
+            # Wait for shutdown signal
+            while not self.stop_event.is_set():
+                self.stop_event.wait(timeout=1)
+
+            # Graceful shutdown
+            logger.info("Initiating system shutdown...")
+        except Exception as e:
+            logger.error(f"System startup error: {e}")
+        finally:
+            self._cleanup()
+
+    def _cleanup(self):
+        """
+        Perform cleanup operations during shutdown
+        """
+        # Close API server if running
+        if self.api_server:
+            try:
+                self.api_server.server_close()
+            except Exception as e:
+                logger.error(f"Error closing API server: {e}")
+
+        # Stop threads
+        if self.api_thread and self.api_thread.is_alive():
+            self.api_thread.join(timeout=2)
+
+        # Kill any remaining mpg123 processes
+        try:
+            subprocess.run(['pkill', 'mpg123'], check=False)
+        except Exception as e:
+            logger.error(f"Error killing mpg123 processes: {e}")
+
+        logger.info("Alarm System shutdown complete")
+
+def main():
+    """
+    Entry point for the Alarm System
+    Parse command-line arguments and start the system
+    """
+    # Default configurations
+    default_port = 8000
+    default_storage_path = "data/alerts.json"
+
+    # Parse port from command line if provided
+    port = int(sys.argv[1]) if len(sys.argv) > 1 else default_port
+
+    # Create and run the Alarm System
+    try:
+        alarm_system = AlarmSystemManager(
+            api_port=port,
+            storage_path=default_storage_path
+        )
+        alarm_system.run()
+    except Exception as e:
+        logger.error(f"Fatal error starting Alarm System: {e}", exc_info=True)
+        sys.exit(1)
+
+if __name__ == "__main__":
+    main()

clock/tests.sh

@@ -0,0 +1,173 @@
+#!/bin/bash
+
+# Configuration
+API_URL="http://localhost:8000"
+TEST_ALARM_NAME="Test Alarm"
+TEST_ALARM_TIME="08:30:00"
+TEST_AUDIO_FILE="/tmp/test.mp3"
+
+# Color codes for output
+GREEN='\033[0;32m'
+RED='\033[0;31m'
+BLUE='\033[0;34m'
+NC='\033[0m' # No Color
+
+# Helper function to print status messages
+print_status() {
+    echo -e "${BLUE}=== $1 ===${NC}"
+}
+
+# Helper function to check test results
+check_result() {
+    if [ $? -eq 0 ]; then
+        echo -e "${GREEN}✓ $1${NC}"
+    else
+        echo -e "${RED}✗ $1${NC}"
+        exit 1
+    fi
+}
+
+# 1. Test server connectivity
+print_status "Testing server connectivity"
+curl -s "$API_URL" > /dev/null
+check_result "Server connectivity check"
+
+# 2. Get initial state
+print_status "Getting initial state"
+INITIAL_STATE=$(curl -s -X GET "$API_URL")
+echo "$INITIAL_STATE" | jq .
+check_result "Retrieved initial state"
+
+# 3. Add a new alarm (POST)
+print_status "Adding new alarm"
+POST_DATA=$(jq -n \
+    --arg name "$TEST_ALARM_NAME" \
+    --arg time "$TEST_ALARM_TIME" \
+    '{
+        "name": $name,
+        "time": $time,
+        "repeat_rule": {
+            "type": "weekly",
+            "days_of_week": ["monday", "wednesday", "friday"]
+        },
+        "enabled": true,
+        "snooze": {
+            "enabled": true,
+            "duration": 5,
+            "max_count": 3
+        },
+        "metadata": {
+            "volume": 75,
+            "notes": "Test alarm with full configuration"
+        }
+    }'
+)
+
+ADD_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$POST_DATA" "$API_URL")
+NEW_ALARM_ID=$(echo "$ADD_RESPONSE" | jq -r '.data.id')
+
+if [[ "$NEW_ALARM_ID" == "null" || -z "$NEW_ALARM_ID" ]]; then
+    echo -e "${RED}Failed to add alarm${NC}"
+    echo "Response: $ADD_RESPONSE"
+    exit 1
+fi
+
+echo -e "${GREEN}Added alarm with ID: $NEW_ALARM_ID${NC}"
+
+#j# 4. Test duplicate alarm detection
+#jprint_status "Testing duplicate alarm detection"
+#jDUPLICATE_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$POST_DATA" "$API_URL")
+#jif [[ $(echo "$DUPLICATE_RESPONSE" | jq -r '.error') == *"Duplicate alarm detected"* ]]; then
+#j    echo -e "${GREEN}✓ Duplicate detection working${NC}"
+#jelse
+#j    echo -e "${RED}✗ Duplicate detection failed${NC}"
+#j    echo "Response: $DUPLICATE_RESPONSE"
+#jfi
+#j
+#j# 5. Update the alarm (PUT)
+#jprint_status "Updating alarm"
+#jUPDATE_DATA=$(jq -n \
+#j    --arg name "$TEST_ALARM_NAME Updated" \
+#j    --arg time "$TEST_ALARM_TIME" \
+#j    --argjson id "$NEW_ALARM_ID" \
+#j    '{
+#j        "id": $id,
+#j        "name": $name,
+#j        "time": $time,
+#j        "repeat_rule": {
+#j            "type": "daily"
+#j        },
+#j        "enabled": true,
+#j        "snooze": {
+#j            "enabled": false,
+#j            "duration": 10,
+#j            "max_count": 2
+#j        },
+#j        "metadata": {
+#j            "volume": 90,
+#j            "notes": "Updated test alarm"
+#j        }
+#j    }'
+#j)
+#j
+#jUPDATE_RESPONSE=$(curl -s -X PUT -H "Content-Type: application/json" -d "$UPDATE_DATA" "$API_URL")
+#jif [[ $(echo "$UPDATE_RESPONSE" | jq -r '.data.message') == "Alarm updated successfully" ]]; then
+#j    echo -e "${GREEN}✓ Alarm update successful${NC}"
+#jelse
+#j    echo -e "${RED}✗ Alarm update failed${NC}"
+#j    echo "Response: $UPDATE_RESPONSE"
+#jfi
+#j
+#j# 6. Verify the update
+#jprint_status "Verifying update"
+#jUPDATED_STATE=$(curl -s -X GET "$API_URL")
+#jUPDATED_ALARM=$(echo "$UPDATED_STATE" | jq -r ".data[] | select(.id == $NEW_ALARM_ID)")
+#jif [[ $(echo "$UPDATED_ALARM" | jq -r '.name') == "$TEST_ALARM_NAME Updated" ]]; then
+#j    echo -e "${GREEN}✓ Update verification successful${NC}"
+#jelse
+#j    echo -e "${RED}✗ Update verification failed${NC}"
+#j    echo "Current alarm state: $UPDATED_ALARM"
+#jfi
+#j
+#j# 7. Test invalid inputs
+#jprint_status "Testing invalid inputs"
+#j
+#j# Test invalid time format
+#jINVALID_TIME_DATA=$(echo "$POST_DATA" | jq '. + {"time": "25:00:00"}')
+#jINVALID_TIME_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$INVALID_TIME_DATA" "$API_URL")
+#jif [[ $(echo "$INVALID_TIME_RESPONSE" | jq -r '.error') == *"Invalid alarm configuration"* ]]; then
+#j    echo -e "${GREEN}✓ Invalid time format detection working${NC}"
+#jelse
+#j    echo -e "${RED}✗ Invalid time format detection failed${NC}"
+#jfi
+#j
+#j# Test invalid repeat rule
+#jINVALID_REPEAT_DATA=$(echo "$POST_DATA" | jq '.repeat_rule.type = "monthly"')
+#jINVALID_REPEAT_RESPONSE=$(curl -s -X POST -H "Content-Type: application/json" -d "$INVALID_REPEAT_DATA" "$API_URL")
+#jif [[ $(echo "$INVALID_REPEAT_RESPONSE" | jq -r '.error') == *"Invalid alarm configuration"* ]]; then
+#j    echo -e "${GREEN}✓ Invalid repeat rule detection working${NC}"
+#jelse
+#j    echo -e "${RED}✗ Invalid repeat rule detection failed${NC}"
+#jfi
+#j
+#j# 8. Delete the test alarm
+#jprint_status "Deleting test alarm"
+#jDELETE_RESPONSE=$(curl -s -X DELETE -H "Content-Type: application/json" -d "{\"id\":$NEW_ALARM_ID}" "$API_URL")
+#jif [[ $(echo "$DELETE_RESPONSE" | jq -r '.data.message') == "Alarm removed successfully" ]]; then
+#j    echo -e "${GREEN}✓ Alarm deletion successful${NC}"
+#jelse
+#j    echo -e "${RED}✗ Alarm deletion failed${NC}"
+#j    echo "Response: $DELETE_RESPONSE"
+#jfi
+#j
+#j# 9. Verify deletion
+#jprint_status "Verifying deletion"
+#jFINAL_STATE=$(curl -s -X GET "$API_URL")
+#jif [[ $(echo "$FINAL_STATE" | jq ".data[] | select(.id == $NEW_ALARM_ID)") == "" ]]; then
+#j    echo -e "${GREEN}✓ Deletion verification successful${NC}"
+#jelse
+#j    echo -e "${RED}✗ Deletion verification failed${NC}"
+#j    echo "Current state: $FINAL_STATE"
+#jfi
+#j
+#jprint_status "Test suite completed!"

clock/ui/active_alarm.py

@@ -0,0 +1,115 @@
+import curses
+from datetime import datetime
+from .utils import init_colors, draw_big_digit
+
+class ActiveAlarmView:
+    def __init__(self, storage, control_queue):
+        self.storage = storage
+        self.control_queue = control_queue
+        self.active_alarms = {}
+
+    def reset_state(self):
+        """Reset the view state"""
+        self.active_alarms.clear()
+
+    def draw(self, stdscr):
+        """Draw the active alarm screen"""
+        init_colors()
+        height, width = stdscr.getmaxyx()
+        current_time = datetime.now()
+
+        self._draw_main_clock(stdscr, height, width, current_time)
+        self._draw_active_alarm_info(stdscr, height, width)
+        self._draw_instructions(stdscr, height, width)
+
+    def handle_input(self, key):
+        """Handle user input and return the next view name or None to stay"""
+        if not self.active_alarms:
+            return 'CLOCK'
+
+        alarm_id = list(self.active_alarms.keys())[0]
+
+        if key == ord('s'):
+            self._handle_snooze(alarm_id)
+            return None
+        elif key == ord('d'):
+            self._handle_dismiss(alarm_id)
+            return 'CLOCK'
+        
+        return None
+
+    def update_active_alarms(self, active_alarms):
+        """Update the active alarms state"""
+        self.active_alarms = active_alarms
+
+    def _draw_main_clock(self, stdscr, height, width, current_time):
+        """Draw the main clock display"""
+        time_str = current_time.strftime("%H:%M:%S")
+        digit_width = 14
+        total_width = digit_width * len(time_str)
+        start_x = (width - total_width) // 2
+        start_y = (height - 7) // 2 - 4
+
+        # Draw blinking dot
+        if int(current_time.timestamp()) % 2 == 0:
+            stdscr.attron(curses.color_pair(1))
+            stdscr.addstr(start_y - 1, start_x + total_width - 2, "•")
+            stdscr.attroff(curses.color_pair(1))
+
+        # Draw big time digits
+        stdscr.attron(curses.color_pair(1))
+        for i, digit in enumerate(time_str):
+            draw_big_digit(stdscr, start_y, start_x + i * digit_width, digit)
+        stdscr.attroff(curses.color_pair(1))
+
+        # Draw date
+        date_str = current_time.strftime("%Y-%m-%d")
+        date_x = width // 2 - len(date_str) // 2
+        date_y = height // 2 + 4
+        stdscr.attron(curses.color_pair(2))
+        stdscr.addstr(date_y, date_x, date_str)
+        stdscr.attroff(curses.color_pair(2))
+
+    def _draw_active_alarm_info(self, stdscr, height, width):
+        """Draw information about the active alarm"""
+        if not self.active_alarms:
+            return
+
+        alarm_id = list(self.active_alarms.keys())[0]
+        alarm_info = self.active_alarms[alarm_id]
+        alarm_config = alarm_info['config']
+
+        alarm_name = alarm_config.get('name', 'Unnamed Alarm')
+        alarm_time = alarm_config.get('time', 'Unknown Time')
+        alarm_str = f"[ {alarm_name} - {alarm_time} ]"
+
+        # Position alarm info above the date
+        date_y = height // 2 + 4  # Same as in _draw_main_clock
+        alarm_y = date_y - 2
+        alarm_x = max(0, width // 2 - len(alarm_str) // 2)
+
+        stdscr.attron(curses.color_pair(1))
+        stdscr.addstr(alarm_y, alarm_x, alarm_str)
+        stdscr.attroff(curses.color_pair(1))
+
+    def _draw_instructions(self, stdscr, height, width):
+        """Draw the user instructions"""
+        if self.active_alarms:
+            instructions = "S: Snooze  D: Dismiss"
+            stdscr.addstr(height - 2, width // 2 - len(instructions) // 2, instructions)
+
+    def _handle_snooze(self, alarm_id):
+        """Handle snoozing the alarm"""
+        self.control_queue.put({
+            'type': 'snooze',
+            'alarm_id': alarm_id
+        })
+        del self.active_alarms[alarm_id]
+
+    def _handle_dismiss(self, alarm_id):
+        """Handle dismissing the alarm"""
+        self.control_queue.put({
+            'type': 'dismiss',
+            'alarm_id': alarm_id
+        })
+        del self.active_alarms[alarm_id]

clock/ui/add_alarm.py

@@ -0,0 +1,298 @@
+import curses
+from datetime import datetime, date, timedelta
+
+class AddAlarmView:
+    def __init__(self, storage, control_queue):
+        self.storage = storage
+        self.control_queue = control_queue
+        self.weekday_names = ['Mon', 'Tue', 'Wed', 'Thu', 'Fri', 'Sat', 'Sun']
+        self.reset_state()
+
+    def set_alarm_data(self, alarm):
+        """Load existing alarm data for editing."""
+        self.alarm_data = alarm  # Store for pre-filling the form
+
+        # Debug log to inspect the alarm structure
+        import logging
+        logging.getLogger(__name__).debug(f"set_alarm_data received: {alarm}")
+
+        # Ensure alarm is a dictionary
+        if not isinstance(alarm, dict):
+            logging.getLogger(__name__).error(f"Invalid alarm format: {type(alarm)}")
+
+        # Parse time string
+        hour, minute, _ = map(int, alarm['time'].split(':'))  # Extract hour and minute           return
+
+        # Pre-fill the form fields with alarm data
+        self.alarm_draft = {
+            'hour': hour,
+            'minute': minute,
+            'name': alarm.get('name', 'Unnamed Alarm'),
+            'enabled': alarm.get('enabled', True),
+            'date': None,  # Your structure doesn't use date directly
+            'weekdays': alarm.get('repeat_rule', {}).get('days_of_week', []),
+            'current_weekday': 0,
+            'editing_name': False,
+            'temp_name': alarm.get('name', 'Unnamed Alarm'),
+            'selected_item': 0
+        }
+
+    def reset_state(self):
+        """Reset all state variables to their initial values"""
+        self.alarm_draft = {
+            'hour': datetime.now().hour,
+            'minute': datetime.now().minute,
+            'name': 'New Alarm',
+            'enabled': True,
+            'date': None,
+            'weekdays': [],
+            'current_weekday': 0,
+            'editing_name': False,
+            'temp_name': '',
+            'selected_item': 0
+        }
+        self.date_edit_pos = 2  # Default to editing the day
+
+    def draw(self, stdscr):
+        """Draw the add alarm screen"""
+        height, width = stdscr.getmaxyx()
+        form_y = height // 2 - 8
+
+        self._draw_title(stdscr, form_y, width)
+        self._draw_time_field(stdscr, form_y + 2, width)
+        self._draw_date_field(stdscr, form_y + 4, width)
+        self._draw_weekdays(stdscr, form_y + 6, width)
+        self._draw_name_field(stdscr, form_y + 8, width)
+        self._draw_status_field(stdscr, form_y + 10, width)
+        self._draw_instructions(stdscr, height - 2, width)
+
+    def handle_input(self, key):
+        """Handle user input and return the next view name or None to stay"""
+        if key == 27:  # ESC
+            return self._handle_escape()
+        elif key == 10:  # ENTER
+            return self._handle_enter()
+
+        if not self.alarm_draft['editing_name']:
+            if key in [ord('h'), curses.KEY_LEFT]:
+                self.alarm_draft['selected_item'] = (self.alarm_draft['selected_item'] - 1) % 6
+            elif key in [ord('l'), curses.KEY_RIGHT]:
+                self.alarm_draft['selected_item'] = (self.alarm_draft['selected_item'] + 1) % 6
+
+        self._handle_field_input(key)
+        return None
+
+    def _handle_field_input(self, key):
+        """Handle input for the currently selected field"""
+        selected_item = self.alarm_draft['selected_item']
+
+        if key in [ord('k'), curses.KEY_UP, ord('j'), curses.KEY_DOWN]:
+            is_up = key in [ord('k'), curses.KEY_UP]
+            if selected_item == 0:
+                self._adjust_hour(is_up)
+            elif selected_item == 1:
+                self._adjust_minute(is_up)
+            elif selected_item == 2:
+                self._adjust_date(is_up)
+        elif selected_item == 3:
+            self._handle_weekday_input(key)
+        elif selected_item == 4:
+            self._handle_name_input(key)
+        elif selected_item == 5 and key == 32:
+            self.alarm_draft['enabled'] = not self.alarm_draft['enabled']
+
+    def _draw_title(self, stdscr, y, width):
+        """Draw the title of the form"""
+        title = "Add New Alarm"
+        stdscr.attron(curses.color_pair(1) | curses.A_BOLD)
+        stdscr.addstr(y, width // 2 - len(title) // 2, title)
+        stdscr.attroff(curses.color_pair(1) | curses.A_BOLD)
+
+    def _draw_field(self, stdscr, y, label, value, is_selected):
+        """Draw a form field with label and value"""
+        label_str = f"{label}: "
+        x = self._center_text_x(label_str + str(value))
+
+        stdscr.attron(curses.color_pair(1))
+        stdscr.addstr(y, x, label_str)
+        stdscr.attroff(curses.color_pair(1))
+
+        if is_selected:
+            stdscr.attron(curses.color_pair(2))
+        stdscr.addstr(y, x + len(label_str), str(value))
+        if is_selected:
+            stdscr.attroff(curses.color_pair(2))
+
+    def _draw_time_field(self, stdscr, y, width):
+        """Draw the time field"""
+        self._draw_field(stdscr, y, "Time",
+                        f"{self.alarm_draft['hour']:02d}:{self.alarm_draft['minute']:02d}",
+                        self.alarm_draft['selected_item'] in [0, 1])
+
+    def _draw_date_field(self, stdscr, y, width):
+        """Draw the date field"""
+        date_str = "Repeating weekly" if self.alarm_draft['weekdays'] else (
+            self.alarm_draft['date'].strftime("%Y-%m-%d") if self.alarm_draft['date'] else "None"
+        )
+        self._draw_field(stdscr, y, "Date", date_str,
+                        self.alarm_draft['selected_item'] == 2)
+
+    def _draw_weekdays(self, stdscr, y, width):
+        """Draw the weekday selection field"""
+        label_x = width // 2 - 20
+        stdscr.attron(curses.color_pair(1))
+        stdscr.addstr(y, label_x, "Repeat: ")
+        stdscr.attroff(curses.color_pair(1))
+
+        weekday_x = label_x + len("Repeat: ")
+        for i, day in enumerate(self.weekday_names):
+            self._draw_weekday(stdscr, y, weekday_x + i * 4, day, i)
+
+    def _draw_weekday(self, stdscr, y, x, day, index):
+        """Draw a single weekday"""
+        is_selected = (self.alarm_draft['selected_item'] == 3 and
+                      index == self.alarm_draft['current_weekday'])
+        is_active = index in self.alarm_draft['weekdays']
+
+        if is_selected:
+            stdscr.attron(curses.color_pair(2))
+        elif is_active:
+            stdscr.attron(curses.color_pair(1) | curses.A_BOLD)
+        else:
+            stdscr.attron(curses.color_pair(1))
+
+        stdscr.addstr(y, x, day)
+
+        if is_selected:
+            stdscr.attroff(curses.color_pair(2))
+        elif is_active:
+            stdscr.attroff(curses.color_pair(1) | curses.A_BOLD)
+        else:
+            stdscr.attroff(curses.color_pair(1))
+
+    def _draw_name_field(self, stdscr, y, width):
+        """Draw the name field"""
+        self._draw_field(stdscr, y, "Name", self.alarm_draft['name'],
+                        self.alarm_draft['selected_item'] == 4)
+
+    def _draw_status_field(self, stdscr, y, width):
+        """Draw the enabled/disabled status field"""
+        enabled_str = "● Enabled" if self.alarm_draft['enabled'] else "○ Disabled"
+        self._draw_field(stdscr, y, "Status", enabled_str,
+                        self.alarm_draft['selected_item'] == 5)
+
+    def _draw_instructions(self, stdscr, y, width):
+        """Draw the instructions at the bottom of the screen"""
+        instructions = "j/k: Change  h/l: Move  Space: Toggle  Enter: Save  Esc: Cancel"
+        stdscr.attron(curses.color_pair(1))
+        stdscr.addstr(y, width // 2 - len(instructions) // 2, instructions)
+        stdscr.attroff(curses.color_pair(1))
+
+    def _center_text_x(self, text):
+        """Calculate x position to center text"""
+        return curses.COLS // 2 - len(text) // 2
+
+    def _adjust_hour(self, increase):
+        """Adjust the hour value"""
+        delta = 1 if increase else -1
+        self.alarm_draft['hour'] = (self.alarm_draft['hour'] + delta) % 24
+
+    def _adjust_minute(self, increase):
+        """Adjust the minute value"""
+        delta = 1 if increase else -1
+        self.alarm_draft['minute'] = (self.alarm_draft['minute'] + delta) % 60
+
+    def _adjust_date(self, increase):
+        """Adjust the date value"""
+        if not self.alarm_draft['date']:
+            self.alarm_draft['date'] = datetime.now().date()
+            return
+
+        delta = 1 if increase else -1
+        current_date = self.alarm_draft['date']
+
+        try:
+            if self.date_edit_pos == 0:  # Year
+                new_year = max(current_date.year + delta, datetime.now().year)
+                self.alarm_draft['date'] = current_date.replace(year=new_year)
+            elif self.date_edit_pos == 1:  # Month
+                new_month = max(1, min(12, current_date.month + delta))
+                max_day = (datetime(current_date.year, new_month, 1) +
+                          timedelta(days=31)).replace(day=1) - timedelta(days=1)
+                self.alarm_draft['date'] = current_date.replace(
+                    month=new_month,
+                    day=min(current_date.day, max_day.day)
+                )
+            elif self.date_edit_pos == 2:  # Day
+                max_day = (datetime(current_date.year, current_date.month, 1) +
+                          timedelta(days=31)).replace(day=1) - timedelta(days=1)
+                new_day = max(1, min(max_day.day, current_date.day + delta))
+                self.alarm_draft['date'] = current_date.replace(day=new_day)
+        except ValueError as e:
+            # Handle date validation errors
+            pass
+
+    def _handle_weekday_input(self, key):
+        """Handle input for weekday selection"""
+        if key in [ord('h'), curses.KEY_LEFT]:
+            self.alarm_draft['current_weekday'] = (self.alarm_draft['current_weekday'] - 1) % 7
+        elif key in [ord('l'), curses.KEY_RIGHT]:
+            self.alarm_draft['current_weekday'] = (self.alarm_draft['current_weekday'] + 1) % 7
+        elif key == 32:  # SPACE
+            current_day = self.alarm_draft['current_weekday']
+            if current_day in self.alarm_draft['weekdays']:
+                self.alarm_draft['weekdays'].remove(current_day)
+            else:
+                self.alarm_draft['weekdays'].append(current_day)
+                self.alarm_draft['weekdays'].sort()
+
+            if self.alarm_draft['weekdays']:
+                self.alarm_draft['date'] = None
+
+    def _handle_name_input(self, key):
+        """Handle input for name editing"""
+        if key == 32:  # SPACE
+            if not self.alarm_draft['editing_name']:
+                self.alarm_draft['editing_name'] = True
+                self.alarm_draft['temp_name'] = self.alarm_draft['name']
+                self.alarm_draft['name'] = ''
+        elif self.alarm_draft['editing_name']:
+            if key == curses.KEY_BACKSPACE or key == 127:
+                self.alarm_draft['name'] = self.alarm_draft['name'][:-1]
+            elif 32 <= key <= 126:  # Printable ASCII
+                self.alarm_draft['name'] += chr(key)
+
+    def _handle_escape(self):
+        """Handle escape key press"""
+        if self.alarm_draft['editing_name']:
+            self.alarm_draft['name'] = self.alarm_draft['temp_name']
+            self.alarm_draft['editing_name'] = False
+            return None
+        return 'CLOCK'
+
+    def _handle_enter(self):
+        """Handle enter key press"""
+        if self.alarm_draft['editing_name']:
+            self.alarm_draft['editing_name'] = False
+            self.alarm_draft['selected_item'] = 0
+            return None
+
+        try:
+            alarm_data = {
+                "name": self.alarm_draft['name'],
+                "time": f"{self.alarm_draft['hour']:02d}:{self.alarm_draft['minute']:02d}:00",
+                "enabled": self.alarm_draft['enabled'],
+                "repeat_rule": {
+                    "type": "weekly" if self.alarm_draft['weekdays'] else "once",
+                    "days_of_week": [self.weekday_names[day].lower()
+                                   for day in self.alarm_draft['weekdays']],
+                    "at": (self.alarm_draft['date'].strftime("%Y-%m-%d")
+                          if self.alarm_draft['date'] and not self.alarm_draft['weekdays']
+                          else None)
+                }
+            }
+            self.storage.save_new_alert(alarm_data)
+            return 'CLOCK'
+        except Exception as e:
+            # Handle save errors
+            return None

clock/ui/big_digits.py

@@ -0,0 +1,110 @@
+# Big digit patterns (15x7 size)
+BIG_DIGITS = {
+    '0': [
+        "  █████████  ",
+        " ███████████ ",
+        "███     ████",
+        "███     ████",
+        "███     ████",
+        " ███████████ ",
+        "  █████████  "
+    ],
+    '1': [
+        "     ████    ",
+        "   ██████    ",
+        "     ████    ",
+        "     ████    ",
+        "     ████    ",
+        "     ████    ",
+        "  █████████  "
+    ],
+    '2': [
+        " ██████████ ",
+        "████████████",
+        "        ████",
+        " ██████████ ",
+        "████        ",
+        "████████████",
+        " ██████████ "
+    ],
+    '3': [
+        " ██████████ ",
+        "████████████",
+        "        ████",
+        "    ██████  ",
+        "        ████",
+        "████████████",
+        " ██████████ "
+    ],
+    '4': [
+        "███    ████",
+        "███    ████",
+        "███    ████",
+        "████████████",
+        "        ████",
+        "        ████",
+        "        ████"
+    ],
+    '5': [
+        "████████████",
+        "████████████",
+        "████        ",
+        "████████████",
+        "        ████",
+        "████████████",
+        "████████████"
+    ],
+    '6': [
+        " ██████████ ",
+        "████████████",
+        "████        ",
+        "████████████",
+        "████    ████",
+        "████████████",
+        " ██████████ "
+    ],
+    '7': [
+        "████████████",
+        "████████████",
+        "      ████  ",
+        "    ████    ",
+        "  ████      ",
+        "████        ",
+        "████        "
+    ],
+    '8': [
+        " ██████████ ",
+        "████████████",
+        "████    ████",
+        " ██████████ ",
+        "████    ████",
+        "████████████",
+        " ██████████ "
+    ],
+    '9': [
+        " ██████████ ",
+        "████████████",
+        "████    ████",
+        "████████████",
+        "        ████",
+        "████████████",
+        " ██████████ "
+    ],
+    ':': [
+        "            ",
+        "    ████    ",
+        "    ████    ",
+        "            ",
+        "    ████    ",
+        "    ████    ",
+        "            "
+    ],
+    '?': [
+        "  ???  ",
+        " ????? ",
+        "??   ??",
+        "  ???  ",
+        " ?? ?? ",
+        "   ?   "
+    ]
+}

clock/ui/list_alarms.py

@@ -0,0 +1,170 @@
+import curses
+from datetime import datetime
+
+class ListAlarmsView:
+    def __init__(self, storage):
+        """Initialize the list alarms view"""
+        self.storage = storage
+        self.weekday_names = ['Mon', 'Tue', 'Wed', 'Thu', 'Fri', 'Sat', 'Sun']
+        self.selected_index = 0
+        self.alarms = []
+
+    def reset_state(self):
+        """Reset the view state"""
+        self.selected_index = 0
+        self.alarms = self.storage.get_saved_alerts()
+
+    def update_alarms(self, alarms):
+        """Update the list of alarms to display."""
+        self.alarms = alarms
+        self.selected_index = 0
+
+    def get_selected_alarm(self):
+        """Get the currently selected alarm."""
+        if 0 <= self.selected_index < len(self.alarms):
+            return self.alarms[self.selected_index]
+        return None
+
+    def draw(self, stdscr):
+        """Draw the list of alarms screen"""
+        height, width = stdscr.getmaxyx()
+
+        self._draw_header(stdscr, width)
+        visible_range = self._calculate_visible_range(height)
+        self._draw_alarm_list(stdscr, height, width, visible_range)
+        self._draw_instructions(stdscr, height, width)
+
+    def handle_input(self, key):
+        """Handle user input and return the next view name or None to stay"""
+        total_items = len(self.alarms) + 1  # +1 for "Add new alarm" option
+
+        if key == 27:  # ESC
+            return 'CLOCK'
+        elif key in [ord('j'), curses.KEY_DOWN]:
+            self.selected_index = (self.selected_index + 1) % total_items
+        elif key in [ord('k'), curses.KEY_UP]:
+            self.selected_index = (self.selected_index - 1) % total_items
+        elif key == ord('d'):
+            return self._handle_delete()
+        elif key in [ord('a'), 10]:  # 'a' or Enter
+            return self._handle_add_edit()
+
+        return None
+
+    def _calculate_visible_range(self, height):
+        """Calculate the visible range for scrolling"""
+        max_visible_items = height - 8  # Space for header and footer
+        total_items = len(self.alarms) + 1  # +1 for "Add new alarm" option
+
+        # Calculate scroll position
+        start_idx = max(0, min(self.selected_index - max_visible_items // 2,
+                             total_items - max_visible_items))
+        if start_idx < 0:
+            start_idx = 0
+        end_idx = min(start_idx + max_visible_items, total_items)
+
+        return (start_idx, end_idx)
+
+    def _draw_header(self, stdscr, width):
+        """Draw the header text"""
+        header_text = "Alarms"
+        stdscr.attron(curses.color_pair(1) | curses.A_BOLD)
+        stdscr.addstr(2, self._center_x(width, header_text), header_text)
+        stdscr.attroff(curses.color_pair(1) | curses.A_BOLD)
+
+    def _draw_alarm_list(self, stdscr, height, width, visible_range):
+        """Draw the list of alarms"""
+        start_idx, end_idx = visible_range
+
+        for i in range(start_idx, end_idx):
+            y_pos = 4 + (i - start_idx)
+            display_str = self._format_alarm_display(i)
+
+            # Truncate if too long
+            max_length = width - 6
+            if len(display_str) > max_length:
+                display_str = display_str[:max_length-3] + "..."
+
+            x_pos = self._center_x(width, display_str)
+            self._draw_alarm_item(stdscr, y_pos, x_pos, display_str, i == self.selected_index)
+
+    def _format_alarm_display(self, index):
+        """Format the display string for an alarm"""
+        if index == len(self.alarms):
+            return "Add new alarm..."
+
+        alarm = self.alarms[index]
+        time_str = alarm.get('time', 'Unknown')
+        repeat_info = self._format_repeat_info(alarm)
+        status = "✓" if alarm.get('enabled', True) else "✗"
+
+        return f"{status} {time_str} {alarm.get('name', 'Unnamed')}{repeat_info}"
+
+    def _format_repeat_info(self, alarm):
+        """Format the repeat information for an alarm"""
+        repeat_rule = alarm.get('repeat_rule', {})
+        if not repeat_rule:
+            return ""
+
+        if repeat_rule.get('type') == 'weekly':
+            days = repeat_rule.get('days', [])
+            return f" (Every {', '.join(self.weekday_names[d] for d in days)})"
+        elif repeat_rule.get('type') == 'once' and repeat_rule.get('date'):
+            return f" (On {repeat_rule['date']})"
+
+        return ""
+
+    def _draw_alarm_item(self, stdscr, y_pos, x_pos, display_str, is_selected):
+        """Draw a single alarm item"""
+        if is_selected:
+            # Draw selection brackets in green
+            stdscr.attron(curses.color_pair(1))
+            stdscr.addstr(y_pos, x_pos - 2, "[ ")
+            stdscr.addstr(y_pos, x_pos + len(display_str), " ]")
+            stdscr.attroff(curses.color_pair(1))
+
+            # Draw text in yellow (highlighted)
+            stdscr.attron(curses.color_pair(2))
+            stdscr.addstr(y_pos, x_pos, display_str)
+            stdscr.attroff(curses.color_pair(2))
+        else:
+            # Draw normal items in green
+            stdscr.attron(curses.color_pair(1))
+            stdscr.addstr(y_pos, x_pos, display_str)
+            stdscr.attroff(curses.color_pair(1))
+
+    def _draw_instructions(self, stdscr, height, width):
+        """Draw the instructions at the bottom of the screen"""
+        instructions = "j/k: Move  d: Delete  a: Add/Edit  Esc: Back"
+        stdscr.attron(curses.color_pair(1))
+        stdscr.addstr(height - 2, self._center_x(width, instructions), instructions)
+        stdscr.attroff(curses.color_pair(1))
+
+    def _center_x(self, width, text):
+        """Calculate x coordinate to center text"""
+        return width // 2 - len(text) // 2
+
+    def _handle_delete(self):
+        """Handle alarm deletion"""
+        if self.selected_index < len(self.alarms):
+            try:
+                alarm_to_delete = self.alarms[self.selected_index]
+                self.storage.remove_saved_alert(alarm_to_delete['id'])
+                self.alarms = self.storage.get_saved_alerts()
+                # Adjust selected item if needed
+                if self.selected_index >= len(self.alarms):
+                    self.selected_index = len(self.alarms)
+            except Exception as e:
+                # You might want to add error handling here
+                pass
+        return None
+
+    def _handle_add_edit(self):
+        """Handle add/edit action"""
+        if self.selected_index == len(self.alarms):
+            # "Add new alarm" option selected
+            return 'ADD_ALARM'
+        else:
+            # Edit existing alarm
+            selected_alarm = self.alarms[self.selected_index]
+            return ('ADD_ALARM', selected_alarm)  # Pass alarm to AddAlarmView

clock/ui/main_clock.py

@@ -0,0 +1,71 @@
+import curses
+from datetime import datetime
+from .utils import init_colors, draw_big_digit
+from .big_digits import BIG_DIGITS
+
+class MainClockView:
+    def __init__(self):
+        """Initialize the main clock view"""
+        self.digit_width = 14  # Width of each digit pattern in the big clock display
+        
+    def draw(self, stdscr):
+        """Draw the main clock screen"""
+        init_colors()
+        height, width = stdscr.getmaxyx()
+        current_time = datetime.now()
+        
+        self._draw_big_time(stdscr, current_time, height, width)
+        self._draw_date(stdscr, current_time, height, width)
+        self._draw_menu(stdscr, height, width)
+
+    def handle_input(self, key):
+        """Handle user input and return the next view name or None to stay"""
+        if key == ord('a'):
+            return 'ADD_ALARM'
+        elif key == ord('s'):
+            return 'LIST_ALARMS'
+        elif key == ord('q'):
+            return 'QUIT'
+        return None
+
+    def _draw_big_time(self, stdscr, current_time, height, width):
+        """Draw the big time display"""
+        time_str = current_time.strftime("%H:%M:%S")
+        total_width = self.digit_width * len(time_str)
+        start_x = self._center_x(width, total_width)
+        start_y = self._center_y(height, 7) - 4  # 7 is the height of digits
+
+        # Draw each digit in green
+        stdscr.attron(curses.color_pair(1))
+        for i, digit in enumerate(time_str):
+            self._draw_digit(stdscr, start_y, start_x + i * self.digit_width, digit)
+        stdscr.attroff(curses.color_pair(1))
+
+    def _draw_date(self, stdscr, current_time, height, width):
+        """Draw the current date"""
+        date_str = current_time.strftime("%Y-%m-%d")
+        date_x = self._center_x(width, len(date_str))
+        date_y = height // 2 + 4
+
+        stdscr.attron(curses.color_pair(2))
+        stdscr.addstr(date_y, date_x, date_str)
+        stdscr.attroff(curses.color_pair(2))
+
+    def _draw_menu(self, stdscr, height, width):
+        """Draw the menu options"""
+        menu_str = "A: Add Alarm  S: List Alarms  Q: Quit"
+        menu_x = self._center_x(width, len(menu_str))
+        stdscr.addstr(height - 2, menu_x, menu_str)
+
+    def _draw_digit(self, stdscr, y, x, digit):
+        """Draw a single big digit"""
+        # Delegate to the existing draw_big_digit utility function
+        draw_big_digit(stdscr, y, x, digit)
+
+    def _center_x(self, width, text_width):
+        """Calculate x coordinate to center text horizontally"""
+        return (width - text_width) // 2
+
+    def _center_y(self, height, text_height):
+        """Calculate y coordinate to center text vertically"""
+        return (height - text_height) // 2

clock/ui/ncurses_ui.py

@@ -0,0 +1,179 @@
+import curses
+import time
+import threading
+import logging
+import queue
+from datetime import datetime
+
+from .utils import init_colors, draw_error, ColorScheme
+from .active_alarm import ActiveAlarmView
+from .add_alarm import AddAlarmView
+from .list_alarms import ListAlarmsView
+from .main_clock import MainClockView
+
+class UI:
+    def __init__(self, alarm_system_manager, control_queue):
+        """Initialize the UI system"""
+        # System components
+        self.alarm_system = alarm_system_manager
+        self.stop_event = alarm_system_manager.stop_event
+        self.storage = alarm_system_manager.storage
+        self.control_queue = control_queue
+
+        # Logging
+        self.logger = logging.getLogger(__name__)
+
+        # Initialize views
+        self._init_views()
+
+        # UI State
+        self.current_view = 'CLOCK'
+        self.error_message = None
+        self.error_timestamp = None
+
+    def _init_views(self):
+        """Initialize all view classes"""
+        self.views = {
+            'CLOCK': MainClockView(),
+            'ADD_ALARM': AddAlarmView(self.storage, self.control_queue),
+            'LIST_ALARMS': ListAlarmsView(self.storage),
+            'ACTIVE_ALARMS': ActiveAlarmView(self.storage, self.control_queue)
+        }
+
+    def run(self):
+        """Start the ncurses UI in a separate thread"""
+        def ui_thread():
+            try:
+                # Start control queue monitor
+                monitor_thread = threading.Thread(
+                    target=self._monitor_control_queue,
+                    daemon=True
+                )
+                monitor_thread.start()
+
+                # Start UI
+                curses.wrapper(self._main_loop)
+            except Exception as e:
+                self.logger.error(f"UI Thread Error: {e}")
+            finally:
+                self.stop_event.set()
+
+        ui_thread_obj = threading.Thread(target=ui_thread, daemon=True)
+        ui_thread_obj.start()
+        return ui_thread_obj
+
+    def _monitor_control_queue(self):
+        """Monitor the control queue for alarm events"""
+        while not self.stop_event.is_set():
+            try:
+                # Non-blocking check of control queue
+                try:
+                    control_msg = self.control_queue.get(timeout=1)
+
+                    if control_msg['type'] == 'trigger':
+                        # Update active alarms view
+                        active_view = self.views['ACTIVE_ALARMS']
+                        alarm_id = control_msg['alarm_id']
+                        active_view.update_active_alarms({
+                            alarm_id: control_msg['info']
+                        })
+
+                        # Switch to active alarms view
+                        self.current_view = 'ACTIVE_ALARMS'
+
+                except queue.Empty:
+                    pass
+
+                time.sleep(0.1)
+            except Exception as e:
+                self.logger.error(f"Error monitoring control queue: {e}")
+                time.sleep(1)
+
+    def _show_error(self, message, duration=3):
+        """Display an error message"""
+        self.error_message = message
+        self.error_timestamp = time.time()
+
+    def _clear_error_if_expired(self):
+        """Clear error message if expired"""
+        if self.error_message and self.error_timestamp:
+            if time.time() - self.error_timestamp > 3:
+                self.error_message = None
+                self.error_timestamp = None
+
+    def _main_loop(self, stdscr):
+        """Main ncurses event loop"""
+        # Setup curses
+        curses.curs_set(0)  # Hide cursor
+        stdscr.keypad(1)    # Enable keypad
+        stdscr.timeout(100) # Non-blocking input
+        init_colors()       # Initialize color pairs
+
+        while not self.stop_event.is_set():
+            # Clear screen
+            stdscr.erase()
+
+            # Get current view
+            current_view = self.views.get(self.current_view)
+            if not current_view:
+                self.logger.error(f"Invalid view: {self.current_view}")
+                break
+
+            try:
+                # Draw current view
+                current_view.draw(stdscr)
+
+                # Handle any error messages
+                if self.error_message:
+                    draw_error(stdscr, self.error_message)
+                    self._clear_error_if_expired()
+
+                # Refresh screen
+                stdscr.refresh()
+
+                # Handle input
+                key = stdscr.getch()
+                if key != -1:
+                    # Handle quit key globally
+                    if key == ord('q'):
+                        if self.current_view == 'CLOCK':
+                            break  # Exit application from clock view
+                        else:
+                            self.current_view = 'CLOCK'  # Return to clock from other views
+                        continue
+
+                    # Let current view handle input
+                    result = current_view.handle_input(key)
+
+                    # Handle tuple result (view, data) or just a view change
+                    if isinstance(result, tuple):
+                        next_view, data = result
+                    else:
+                        next_view, data = result, None
+
+                    # Handle quitting
+                    if next_view == 'QUIT':
+                        break
+
+                    elif next_view:
+                        # Update list alarms view data when switching to it
+                        if next_view == 'LIST_ALARMS':
+                            self.views['LIST_ALARMS'].update_alarms(
+                                self.storage.get_saved_alerts()
+                            )
+
+                        # Handle editing an alarm by passing data to AddAlarmView
+                        elif next_view == 'ADD_ALARM' and data:
+                            self.views['ADD_ALARM'].set_alarm_data(data)
+
+                        self.current_view = next_view
+
+            except Exception as e:
+                self.logger.error(f"Error in main loop: {e}")
+                self._show_error(str(e))
+
+            time.sleep(0.1)  # Prevent CPU hogging
+
+    def stop(self):
+        """Stop the UI system"""
+        self.stop_event.set()

clock/ui/utils.py

@@ -0,0 +1,138 @@
+import curses
+from dataclasses import dataclass
+from typing import Optional
+from .big_digits import BIG_DIGITS
+
+@dataclass
+class ColorScheme:
+    """Color scheme configuration for the UI"""
+    PRIMARY = 1      # Green on black
+    HIGHLIGHT = 2    # Yellow on black
+    ERROR = 3        # Red on black
+
+class ViewUtils:
+    """Common utility functions for view classes"""
+    @staticmethod
+    def center_x(width: int, text_width: int) -> int:
+        """Calculate x coordinate to center text horizontally"""
+        return max(0, (width - text_width) // 2)
+
+    @staticmethod
+    def center_y(height: int, text_height: int) -> int:
+        """Calculate y coordinate to center text vertically"""
+        return max(0, (height - text_height) // 2)
+
+    @staticmethod
+    def draw_centered_text(stdscr, y: int, text: str, color_pair: Optional[int] = None, attrs: int = 0):
+        """Draw text centered horizontally on the screen with optional color and attributes"""
+        height, width = stdscr.getmaxyx()
+        x = ViewUtils.center_x(width, len(text))
+        
+        if color_pair is not None:
+            stdscr.attron(curses.color_pair(color_pair) | attrs)
+        
+        try:
+            stdscr.addstr(y, x, text)
+        except curses.error:
+            pass  # Ignore errors from writing at invalid positions
+        
+        if color_pair is not None:
+            stdscr.attroff(curses.color_pair(color_pair) | attrs)
+
+def init_colors():
+    """Initialize color pairs for the application"""
+    try:
+        curses.start_color()
+        curses.use_default_colors()
+        
+        # Primary color (green text on black background)
+        curses.init_pair(ColorScheme.PRIMARY, curses.COLOR_GREEN, curses.COLOR_BLACK)
+        
+        # Highlight color (yellow text on black background)
+        curses.init_pair(ColorScheme.HIGHLIGHT, curses.COLOR_YELLOW, curses.COLOR_BLACK)
+        
+        # Error color (red text on black background)
+        curses.init_pair(ColorScheme.ERROR, curses.COLOR_RED, curses.COLOR_BLACK)
+    except Exception as e:
+        # Log error or handle gracefully if color initialization fails
+        pass
+
+def draw_error(stdscr, error_message: str, duration_sec: int = 3):
+    """
+    Draw error message at the bottom of the screen
+    
+    Args:
+        stdscr: Curses window object
+        error_message: Message to display
+        duration_sec: How long the error should be displayed (for reference by caller)
+    """
+    height, width = stdscr.getmaxyx()
+    
+    # Truncate message if too long
+    max_width = width - 4
+    if len(error_message) > max_width:
+        error_message = error_message[:max_width-3] + "..."
+
+    # Position near bottom of screen
+    error_y = height - 4
+    
+    ViewUtils.draw_centered_text(
+        stdscr, 
+        error_y,
+        error_message,
+        ColorScheme.ERROR,
+        curses.A_BOLD
+    )
+
+def draw_big_digit(stdscr, y: int, x: int, digit: str):
+    """
+    Draw a large digit using the predefined patterns
+    
+    Args:
+        stdscr: Curses window object
+        y: Starting y coordinate
+        x: Starting x coordinate
+        digit: Character to draw ('0'-'9', ':', etc)
+    """
+    try:
+        patterns = BIG_DIGITS.get(digit, BIG_DIGITS['?'])
+        for i, line in enumerate(patterns):
+            try:
+                stdscr.addstr(y + i, x, line)
+            except curses.error:
+                continue  # Skip lines that would write outside the window
+    except (curses.error, IndexError):
+        pass  # Ignore any drawing errors
+
+def safe_addstr(stdscr, y: int, x: int, text: str, color_pair: Optional[int] = None, attrs: int = 0):
+    """
+    Safely add a string to the screen, handling boundary conditions
+    
+    Args:
+        stdscr: Curses window object
+        y: Y coordinate
+        x: X coordinate
+        text: Text to draw
+        color_pair: Optional color pair number
+        attrs: Additional curses attributes
+    """
+    height, width = stdscr.getmaxyx()
+    
+    # Check if the position is within bounds
+    if y < 0 or y >= height or x < 0 or x >= width:
+        return
+    
+    # Truncate text if it would extend beyond screen width
+    if x + len(text) > width:
+        text = text[:width - x]
+    
+    try:
+        if color_pair is not None:
+            stdscr.attron(curses.color_pair(color_pair) | attrs)
+        
+        stdscr.addstr(y, x, text)
+        
+        if color_pair is not None:
+            stdscr.attroff(curses.color_pair(color_pair) | attrs)
+    except curses.error:
+        pass  # Ignore any drawing errors