Compare commits
13
Commits
2a6d470a9a
..
v1.2.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
320696c57c | ||
|
|
e26c53456f | ||
|
|
1eeb8ad148 | ||
|
|
1d641288e5 | ||
|
|
e58a58e766 | ||
|
|
e0bcda6e7c | ||
|
|
f4419f6a72 | ||
|
|
6de91fa6a9 | ||
|
|
a1a914ee4d | ||
|
|
824358f846 | ||
|
|
cb20abfb85 | ||
|
|
ca1e74154f | ||
|
|
4dd10240ce |
@@ -0,0 +1,43 @@
|
|||||||
|
name: Refresh Showcase Data
|
||||||
|
|
||||||
|
on:
|
||||||
|
schedule:
|
||||||
|
# Run daily at 3 AM UTC
|
||||||
|
- cron: "0 3 * * *"
|
||||||
|
workflow_dispatch: # Allow manual triggering
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
refresh-data:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: Checkout code
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
|
- name: Set up Python
|
||||||
|
uses: actions/setup-python@v5
|
||||||
|
with:
|
||||||
|
python-version: ${{ vars.PYTHON_VERSION }}
|
||||||
|
|
||||||
|
- name: Install uv
|
||||||
|
run: curl -LsSf https://astral.sh/uv/install.sh | sh
|
||||||
|
|
||||||
|
- name: Install dependencies
|
||||||
|
run: |
|
||||||
|
uv sync --no-dev --all-extras
|
||||||
|
|
||||||
|
- name: Run showcase data seeding script
|
||||||
|
env:
|
||||||
|
ADMIN_USERNAME: ${{ secrets.ADMIN_USERNAME }}
|
||||||
|
ADMIN_PASSWORD: ${{ secrets.ADMIN_PASSWORD }}
|
||||||
|
POSTGRES_URI: ${{ secrets.POSTGRES_URI }}
|
||||||
|
run: |
|
||||||
|
uv run python scripts/seed_showcase_data.py
|
||||||
|
|
||||||
|
- name: Notify on success
|
||||||
|
if: success()
|
||||||
|
run: echo "✅ Showcase data refreshed successfully"
|
||||||
|
|
||||||
|
- name: Notify on failure
|
||||||
|
if: failure()
|
||||||
|
run: echo "❌ Failed to refresh showcase data"
|
||||||
@@ -71,3 +71,7 @@ markers = [
|
|||||||
[[tool.mypy.overrides]]
|
[[tool.mypy.overrides]]
|
||||||
module = "redis.*"
|
module = "redis.*"
|
||||||
ignore_missing_imports = true
|
ignore_missing_imports = true
|
||||||
|
|
||||||
|
[[tool.mypy.overrides]]
|
||||||
|
module = "showcase_data_definitions.*"
|
||||||
|
ignore_missing_imports = true
|
||||||
|
|||||||
@@ -0,0 +1,185 @@
|
|||||||
|
"""Seed test data into the database for demo purposes."""
|
||||||
|
|
||||||
|
import sys
|
||||||
|
from pathlib import Path
|
||||||
|
from datetime import datetime
|
||||||
|
|
||||||
|
# Add parent directory to path to import baby_monitor modules
|
||||||
|
sys.path.insert(0, str(Path(__file__).parent.parent / "src"))
|
||||||
|
|
||||||
|
# Import after path is set up
|
||||||
|
from baby_monitor.repositories.dependencies.get_database import ( # noqa: E402
|
||||||
|
get_database,
|
||||||
|
init_db,
|
||||||
|
)
|
||||||
|
from baby_monitor.repositories.user.sqlite_user import ( # noqa: E402
|
||||||
|
DatabaseUserRepository,
|
||||||
|
)
|
||||||
|
from baby_monitor.repositories.child.sqlite_child import ( # noqa: E402
|
||||||
|
DatabaseChildRepository,
|
||||||
|
)
|
||||||
|
from baby_monitor.repositories.feeding.sqlite_feeding import ( # noqa: E402
|
||||||
|
DatabaseFeedingRepository,
|
||||||
|
)
|
||||||
|
from baby_monitor.repositories.diaper_change.sqlite_diaper_change import ( # noqa: E402, E501
|
||||||
|
DatabaseDiaperChangeRepository,
|
||||||
|
)
|
||||||
|
from baby_monitor.repositories.sleep.sqlite_sleep import ( # noqa: E402
|
||||||
|
DatabaseSleepRepository,
|
||||||
|
)
|
||||||
|
from baby_monitor.routers.auth import hash_password # noqa: E402
|
||||||
|
from showcase_data_definitions import generate_showcase_data # noqa: E402
|
||||||
|
|
||||||
|
|
||||||
|
def seed_database(reference_time: datetime | None = None) -> None:
|
||||||
|
"""
|
||||||
|
Seed the database with test data.
|
||||||
|
|
||||||
|
This function is idempotent - it will check if test users exist
|
||||||
|
and either create them or update timestamps of existing data.
|
||||||
|
|
||||||
|
Args:
|
||||||
|
reference_time: The "now" time to use for generating timestamps.
|
||||||
|
Defaults to current time.
|
||||||
|
"""
|
||||||
|
# Initialize database
|
||||||
|
init_db()
|
||||||
|
db = next(get_database())
|
||||||
|
|
||||||
|
try:
|
||||||
|
# Initialize repositories
|
||||||
|
user_repo = DatabaseUserRepository(db)
|
||||||
|
child_repo = DatabaseChildRepository(db)
|
||||||
|
feeding_repo = DatabaseFeedingRepository(db)
|
||||||
|
diaper_repo = DatabaseDiaperChangeRepository(db)
|
||||||
|
sleep_repo = DatabaseSleepRepository(db)
|
||||||
|
|
||||||
|
# Generate showcase data
|
||||||
|
test_data = generate_showcase_data(reference_time)
|
||||||
|
|
||||||
|
print("Starting database seeding...")
|
||||||
|
print(f"Reference time: {test_data['reference_time']}")
|
||||||
|
|
||||||
|
# Create or get showcase users
|
||||||
|
user_ids = []
|
||||||
|
for user_data in test_data["users"]:
|
||||||
|
# Check if user exists
|
||||||
|
existing_user = user_repo.get_by_username(user_data["username"])
|
||||||
|
|
||||||
|
if existing_user:
|
||||||
|
print(f"✓ User '{user_data['username']}' already exists")
|
||||||
|
user_ids.append(existing_user["id"])
|
||||||
|
else:
|
||||||
|
# Create new user
|
||||||
|
hashed_pw = hash_password(user_data["password"])
|
||||||
|
user_id = user_repo.create(
|
||||||
|
username=user_data["username"],
|
||||||
|
hashed_password=hashed_pw,
|
||||||
|
)
|
||||||
|
user_ids.append(user_id["id"])
|
||||||
|
print(f"✓ Created user '{user_data['username']}'")
|
||||||
|
|
||||||
|
# Create or get shared child
|
||||||
|
child_data = test_data["child"]
|
||||||
|
|
||||||
|
# Check if child exists for first user
|
||||||
|
existing_children = child_repo.get_by_user_id(user_ids[0])
|
||||||
|
child_id: int | None = None
|
||||||
|
|
||||||
|
# Look for existing child with matching name
|
||||||
|
for child in existing_children:
|
||||||
|
if child["name"] == child_data["name"]:
|
||||||
|
child_id = child["id"]
|
||||||
|
print(f"✓ Child '{child_data['name']}' already exists")
|
||||||
|
break
|
||||||
|
|
||||||
|
if child_id is None:
|
||||||
|
# Create new child
|
||||||
|
created_child = child_repo.create(
|
||||||
|
name=child_data["name"],
|
||||||
|
birth_time=child_data["birth_time"],
|
||||||
|
birth_weight=child_data["birth_weight"],
|
||||||
|
user_id=user_ids[0],
|
||||||
|
)
|
||||||
|
child_id = created_child["id"]
|
||||||
|
print(f"✓ Created child '{child_data['name']}'")
|
||||||
|
|
||||||
|
# Ensure child_id is set
|
||||||
|
assert child_id is not None, "Child ID must be set at this point"
|
||||||
|
|
||||||
|
# Share child with second user if not already shared
|
||||||
|
parent_ids = child_repo.get_parent_ids(child_id)
|
||||||
|
if user_ids[1] not in parent_ids:
|
||||||
|
child_repo.add_parent(child_id, user_ids[1])
|
||||||
|
msg = f"✓ Shared child with '{test_data['users'][1]['username']}'"
|
||||||
|
print(msg)
|
||||||
|
|
||||||
|
# Clear existing logs to avoid duplicates
|
||||||
|
print("Clearing existing logs...")
|
||||||
|
|
||||||
|
# Get all logs for this child
|
||||||
|
existing_feedings = feeding_repo.get_by_child_id(child_id)
|
||||||
|
for feeding in existing_feedings:
|
||||||
|
feeding_repo.delete(feeding["id"])
|
||||||
|
|
||||||
|
existing_diapers = diaper_repo.get_by_child_id(child_id)
|
||||||
|
for diaper in existing_diapers:
|
||||||
|
diaper_repo.delete(diaper["id"])
|
||||||
|
|
||||||
|
existing_sleep = sleep_repo.get_by_child_id(child_id)
|
||||||
|
for sleep in existing_sleep:
|
||||||
|
sleep_repo.delete(sleep["id"])
|
||||||
|
|
||||||
|
print("✓ Cleared existing logs")
|
||||||
|
|
||||||
|
# Add feeding logs
|
||||||
|
print(f"Adding {len(test_data['feedings'])} feeding logs...")
|
||||||
|
for feeding in test_data["feedings"]:
|
||||||
|
feeding_repo.create(
|
||||||
|
child_id=child_id,
|
||||||
|
start_time=feeding["start_time"],
|
||||||
|
end_time=feeding["end_time"],
|
||||||
|
feeding_type=feeding["feeding_type"],
|
||||||
|
)
|
||||||
|
print(f"✓ Added {len(test_data['feedings'])} feedings")
|
||||||
|
|
||||||
|
# Add diaper changes
|
||||||
|
print(f"Adding {len(test_data['diapers'])} diaper changes...")
|
||||||
|
for diaper in test_data["diapers"]:
|
||||||
|
diaper_repo.create(
|
||||||
|
child_id=child_id,
|
||||||
|
change_time=diaper["time"],
|
||||||
|
poop_color=diaper.get("poop_color"),
|
||||||
|
poop_amount=diaper.get("poop_amount"),
|
||||||
|
pee_color=diaper.get("pee_color"),
|
||||||
|
pee_amount=diaper.get("pee_amount"),
|
||||||
|
)
|
||||||
|
print(f"✓ Added {len(test_data['diapers'])} diaper changes")
|
||||||
|
|
||||||
|
# Add sleep sessions
|
||||||
|
print(f"Adding {len(test_data['sleep'])} sleep sessions...")
|
||||||
|
for sleep in test_data["sleep"]:
|
||||||
|
sleep_repo.create(
|
||||||
|
child_id=child_id,
|
||||||
|
start_time=sleep["start_time"],
|
||||||
|
end_time=sleep["end_time"],
|
||||||
|
)
|
||||||
|
print(f"✓ Added {len(test_data['sleep'])} sleep sessions")
|
||||||
|
|
||||||
|
db.commit()
|
||||||
|
print("\n✅ Database seeding completed successfully!")
|
||||||
|
print("\nTest user credentials:")
|
||||||
|
print(f" Username: {test_data['users'][0]['username']}")
|
||||||
|
print(f" Password: {test_data['users'][0]['password']}")
|
||||||
|
print(" (Both users share the same password)")
|
||||||
|
|
||||||
|
except Exception as e:
|
||||||
|
db.rollback()
|
||||||
|
print(f"\n❌ Error seeding database: {e}")
|
||||||
|
raise
|
||||||
|
finally:
|
||||||
|
db.close()
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
seed_database()
|
||||||
@@ -0,0 +1,278 @@
|
|||||||
|
"""Definition of showcase data to be used for presenting the app."""
|
||||||
|
|
||||||
|
from datetime import datetime, timedelta
|
||||||
|
import random
|
||||||
|
|
||||||
|
# User credentials
|
||||||
|
SHOWCASE_USERS = [
|
||||||
|
{
|
||||||
|
"username": "user",
|
||||||
|
"password": "demo123", # Will be hashed when inserted
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"username": "user2",
|
||||||
|
"password": "demo123", # Will be hashed when inserted
|
||||||
|
},
|
||||||
|
]
|
||||||
|
|
||||||
|
# Shared child (14 days old)
|
||||||
|
CHILD_AGE_DAYS = 14
|
||||||
|
|
||||||
|
|
||||||
|
def get_child_data(reference_time: datetime) -> dict:
|
||||||
|
"""Get child data with birth time relative to reference time."""
|
||||||
|
birth_time = reference_time - timedelta(days=CHILD_AGE_DAYS)
|
||||||
|
return {
|
||||||
|
"name": "Emma Rose",
|
||||||
|
"birth_time": birth_time,
|
||||||
|
"birth_weight": 3420, # grams (7.5 lbs)
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
def get_feeding_schedule(reference_time: datetime) -> list[dict]:
|
||||||
|
"""
|
||||||
|
Generate realistic feeding schedule for the last 14 days.
|
||||||
|
|
||||||
|
Newborns feed every 2-3 hours initially, gradually spacing out
|
||||||
|
to 3-4 hours.
|
||||||
|
"""
|
||||||
|
feedings: list[dict] = []
|
||||||
|
current_time = reference_time - timedelta(days=CHILD_AGE_DAYS)
|
||||||
|
end_time = reference_time
|
||||||
|
|
||||||
|
feeding_types = ["left_breast", "right_breast", "bottle"]
|
||||||
|
|
||||||
|
# Day-by-day feeding patterns
|
||||||
|
day_number = 0
|
||||||
|
while current_time < end_time:
|
||||||
|
age_in_days = day_number
|
||||||
|
|
||||||
|
# Newborns feed more frequently
|
||||||
|
if age_in_days < 3:
|
||||||
|
interval_hours = random.uniform(2, 2.5)
|
||||||
|
duration_minutes = random.randint(15, 25)
|
||||||
|
elif age_in_days < 7:
|
||||||
|
interval_hours = random.uniform(2.5, 3)
|
||||||
|
duration_minutes = random.randint(20, 30)
|
||||||
|
else:
|
||||||
|
interval_hours = random.uniform(3, 3.5)
|
||||||
|
duration_minutes = random.randint(20, 35)
|
||||||
|
|
||||||
|
# Alternate between breasts and occasional bottle
|
||||||
|
if random.random() < 0.2: # 20% bottle feeding
|
||||||
|
feeding_type = "bottle"
|
||||||
|
else:
|
||||||
|
# Alternate breasts
|
||||||
|
feeding_type = feeding_types[len(feedings) % 2]
|
||||||
|
|
||||||
|
start_time = current_time
|
||||||
|
end_time_feeding = start_time + timedelta(minutes=duration_minutes)
|
||||||
|
|
||||||
|
feedings.append(
|
||||||
|
{
|
||||||
|
"start_time": start_time,
|
||||||
|
"end_time": end_time_feeding,
|
||||||
|
"feeding_type": feeding_type,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
current_time += timedelta(hours=interval_hours)
|
||||||
|
|
||||||
|
# Move to next day
|
||||||
|
prev_date = (current_time - timedelta(hours=interval_hours)).date()
|
||||||
|
if current_time.date() != prev_date:
|
||||||
|
day_number += 1
|
||||||
|
|
||||||
|
return feedings
|
||||||
|
|
||||||
|
|
||||||
|
def get_diaper_changes(reference_time: datetime) -> list[dict]:
|
||||||
|
"""
|
||||||
|
Generate realistic diaper changes for the last 14 days.
|
||||||
|
|
||||||
|
- First 2-3 days: Black/dark (meconium), minimal pee
|
||||||
|
- Days 3-5: Transition to yellow, more frequent
|
||||||
|
- Days 5+: Regular yellow stools, normal pee patterns
|
||||||
|
- 8-10 diaper changes per day initially, settling to 6-8
|
||||||
|
"""
|
||||||
|
diapers = []
|
||||||
|
current_time = reference_time - timedelta(days=CHILD_AGE_DAYS)
|
||||||
|
end_time = reference_time
|
||||||
|
|
||||||
|
day_number = 0
|
||||||
|
|
||||||
|
while current_time < end_time:
|
||||||
|
age_in_days = day_number
|
||||||
|
|
||||||
|
# Determine number of diaper changes per day based on age
|
||||||
|
if age_in_days < 3:
|
||||||
|
changes_per_day = random.randint(8, 10)
|
||||||
|
elif age_in_days < 7:
|
||||||
|
changes_per_day = random.randint(7, 9)
|
||||||
|
else:
|
||||||
|
changes_per_day = random.randint(6, 8)
|
||||||
|
|
||||||
|
# Distribute changes throughout the day
|
||||||
|
day_start = current_time.replace(hour=0, minute=0, second=0, microsecond=0)
|
||||||
|
day_end = day_start + timedelta(days=1)
|
||||||
|
|
||||||
|
for _ in range(changes_per_day):
|
||||||
|
# Random time during the day
|
||||||
|
random_seconds = random.randint(0, 86400)
|
||||||
|
change_time = day_start + timedelta(seconds=random_seconds)
|
||||||
|
|
||||||
|
if change_time >= end_time:
|
||||||
|
break
|
||||||
|
|
||||||
|
# Determine diaper contents
|
||||||
|
has_poop = random.random() < 0.4 # 40% have poop
|
||||||
|
# 90% have pee, or always if no poop
|
||||||
|
has_pee = random.random() < 0.9 or not has_poop
|
||||||
|
|
||||||
|
diaper = {
|
||||||
|
"time": change_time,
|
||||||
|
"has_poop": has_poop,
|
||||||
|
"has_pee": has_pee,
|
||||||
|
}
|
||||||
|
|
||||||
|
# Poop characteristics based on age
|
||||||
|
if has_poop:
|
||||||
|
if age_in_days < 2:
|
||||||
|
# Meconium phase
|
||||||
|
diaper["poop_color"] = "black"
|
||||||
|
diaper["poop_amount"] = "light"
|
||||||
|
elif age_in_days < 4:
|
||||||
|
# Transition phase
|
||||||
|
colors = ["black", "green", "yellow"]
|
||||||
|
diaper["poop_color"] = random.choice(colors)
|
||||||
|
amounts = ["light", "medium"]
|
||||||
|
diaper["poop_amount"] = random.choice(amounts)
|
||||||
|
else:
|
||||||
|
# Normal phase
|
||||||
|
colors = ["yellow", "yellow", "yellow", "green"]
|
||||||
|
diaper["poop_color"] = random.choice(colors)
|
||||||
|
# Amount increases with age
|
||||||
|
if age_in_days < 7:
|
||||||
|
amounts = ["light", "medium"]
|
||||||
|
diaper["poop_amount"] = random.choice(amounts)
|
||||||
|
else:
|
||||||
|
amounts = ["medium", "heavy"]
|
||||||
|
diaper["poop_amount"] = random.choice(amounts)
|
||||||
|
|
||||||
|
# Pee characteristics based on age
|
||||||
|
if has_pee:
|
||||||
|
if age_in_days < 2:
|
||||||
|
# Very light pee initially
|
||||||
|
diaper["pee_amount"] = "light"
|
||||||
|
diaper["pee_color"] = random.choice(["clear", "yellow"])
|
||||||
|
elif age_in_days < 5:
|
||||||
|
# Increasing output
|
||||||
|
diaper["pee_amount"] = random.choice(["light", "medium"])
|
||||||
|
diaper["pee_color"] = random.choice(["clear", "yellow"])
|
||||||
|
else:
|
||||||
|
# Normal output
|
||||||
|
if age_in_days < 10:
|
||||||
|
amounts = ["medium", "medium", "heavy"]
|
||||||
|
diaper["pee_amount"] = random.choice(amounts)
|
||||||
|
else:
|
||||||
|
amounts = ["medium", "heavy", "heavy"]
|
||||||
|
diaper["pee_amount"] = random.choice(amounts)
|
||||||
|
colors = ["clear", "yellow", "yellow"]
|
||||||
|
diaper["pee_color"] = random.choice(colors)
|
||||||
|
|
||||||
|
diapers.append(diaper)
|
||||||
|
|
||||||
|
day_number += 1
|
||||||
|
current_time = day_end
|
||||||
|
|
||||||
|
# Sort by time (type: ignore for mypy - we know time is datetime)
|
||||||
|
diapers.sort(
|
||||||
|
key=lambda x: x["time"] # type: ignore[arg-type,return-value]
|
||||||
|
)
|
||||||
|
return diapers
|
||||||
|
|
||||||
|
|
||||||
|
def get_sleep_sessions(reference_time: datetime) -> list[dict]:
|
||||||
|
"""
|
||||||
|
Generate realistic sleep patterns for the last 14 days.
|
||||||
|
|
||||||
|
Newborns sleep 16-18 hours per day in short bursts (30min - 4 hours).
|
||||||
|
Sleep gradually consolidates over time.
|
||||||
|
"""
|
||||||
|
sleep_sessions = []
|
||||||
|
current_time = reference_time - timedelta(days=CHILD_AGE_DAYS)
|
||||||
|
end_time = reference_time
|
||||||
|
|
||||||
|
day_number = 0
|
||||||
|
|
||||||
|
while current_time < end_time:
|
||||||
|
age_in_days = day_number
|
||||||
|
|
||||||
|
# Sleep patterns evolve with age
|
||||||
|
if age_in_days < 3:
|
||||||
|
# Very short, frequent naps
|
||||||
|
avg_wake_time = 1.5 # hours
|
||||||
|
sleep_duration_range = (30, 120) # minutes
|
||||||
|
elif age_in_days < 7:
|
||||||
|
# Slightly longer sleep periods
|
||||||
|
avg_wake_time = 2
|
||||||
|
sleep_duration_range = (45, 180)
|
||||||
|
else:
|
||||||
|
# More consolidated sleep
|
||||||
|
avg_wake_time = 2.5
|
||||||
|
sleep_duration_range = (60, 240)
|
||||||
|
|
||||||
|
# Random wake time with variation
|
||||||
|
wake_minutes = random.randint(int(avg_wake_time * 45), int(avg_wake_time * 75))
|
||||||
|
|
||||||
|
# Sleep start time
|
||||||
|
start_time = current_time + timedelta(minutes=wake_minutes)
|
||||||
|
|
||||||
|
if start_time >= end_time:
|
||||||
|
break
|
||||||
|
|
||||||
|
# Sleep duration
|
||||||
|
duration_minutes = random.randint(*sleep_duration_range)
|
||||||
|
|
||||||
|
# Longer sleep at night
|
||||||
|
if 20 <= start_time.hour or start_time.hour < 6:
|
||||||
|
duration_minutes = int(duration_minutes * 1.3)
|
||||||
|
|
||||||
|
end_time_sleep = start_time + timedelta(minutes=duration_minutes)
|
||||||
|
|
||||||
|
sleep_sessions.append(
|
||||||
|
{
|
||||||
|
"start_time": start_time,
|
||||||
|
"end_time": end_time_sleep,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
|
||||||
|
current_time = end_time_sleep
|
||||||
|
birth_time = reference_time - timedelta(days=CHILD_AGE_DAYS)
|
||||||
|
day_number = (current_time - birth_time).days
|
||||||
|
|
||||||
|
return sleep_sessions
|
||||||
|
|
||||||
|
|
||||||
|
def generate_showcase_data(reference_time: datetime | None = None) -> dict:
|
||||||
|
"""
|
||||||
|
Generate all test data with timestamps relative to reference time.
|
||||||
|
|
||||||
|
Args:
|
||||||
|
reference_time: The "now" time to use as reference.
|
||||||
|
Defaults to current time.
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
Dictionary containing all test data
|
||||||
|
"""
|
||||||
|
if reference_time is None:
|
||||||
|
reference_time = datetime.now()
|
||||||
|
|
||||||
|
return {
|
||||||
|
"users": SHOWCASE_USERS,
|
||||||
|
"child": get_child_data(reference_time),
|
||||||
|
"feedings": get_feeding_schedule(reference_time),
|
||||||
|
"diapers": get_diaper_changes(reference_time),
|
||||||
|
"sleep": get_sleep_sessions(reference_time),
|
||||||
|
"reference_time": reference_time,
|
||||||
|
}
|
||||||
@@ -6,7 +6,7 @@ import logging
|
|||||||
from baby_monitor.repositories.interfaces import (
|
from baby_monitor.repositories.interfaces import (
|
||||||
TokenRepositoryInterface,
|
TokenRepositoryInterface,
|
||||||
)
|
)
|
||||||
from baby_monitor.repositories.token.memory_token import (
|
from baby_monitor.repositories.token import (
|
||||||
InMemoryTokenRepository,
|
InMemoryTokenRepository,
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -43,7 +43,7 @@ def _initialize_token_repository() -> TokenRepositoryInterface:
|
|||||||
) from e
|
) from e
|
||||||
|
|
||||||
try:
|
try:
|
||||||
from baby_monitor.repositories.token.redis_token import (
|
from baby_monitor.repositories.token import (
|
||||||
RedisTokenRepository,
|
RedisTokenRepository,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,11 @@
|
|||||||
|
"""Token repository implementations and configurations."""
|
||||||
|
|
||||||
|
from .default_ttl import DEFAULT_TTL
|
||||||
|
from .memory_token import InMemoryTokenRepository
|
||||||
|
from .redis_token import RedisTokenRepository
|
||||||
|
|
||||||
|
__all__ = [
|
||||||
|
"DEFAULT_TTL",
|
||||||
|
"InMemoryTokenRepository",
|
||||||
|
"RedisTokenRepository",
|
||||||
|
]
|
||||||
@@ -0,0 +1,3 @@
|
|||||||
|
"""Definition of Token default TTL."""
|
||||||
|
|
||||||
|
DEFAULT_TTL = 28800 # seconds -> 8 hours
|
||||||
@@ -3,6 +3,7 @@
|
|||||||
from datetime import datetime, timedelta, UTC
|
from datetime import datetime, timedelta, UTC
|
||||||
|
|
||||||
from baby_monitor.repositories.interfaces import TokenRepositoryInterface
|
from baby_monitor.repositories.interfaces import TokenRepositoryInterface
|
||||||
|
from baby_monitor.repositories.token import DEFAULT_TTL
|
||||||
|
|
||||||
|
|
||||||
class InMemoryTokenRepository(TokenRepositoryInterface):
|
class InMemoryTokenRepository(TokenRepositoryInterface):
|
||||||
@@ -16,9 +17,8 @@ class InMemoryTokenRepository(TokenRepositoryInterface):
|
|||||||
def __init__(self) -> None:
|
def __init__(self) -> None:
|
||||||
# token -> (user_id, expiry_time)
|
# token -> (user_id, expiry_time)
|
||||||
self._tokens: dict[str, tuple[int, datetime]] = {}
|
self._tokens: dict[str, tuple[int, datetime]] = {}
|
||||||
self._default_ttl = 3600 # Store default TTL for sliding expiration
|
|
||||||
|
|
||||||
def store(self, token: str, user_id: int, ttl: int = 3600) -> None:
|
def store(self, token: str, user_id: int, ttl: int = DEFAULT_TTL) -> None:
|
||||||
"""Store a token with TTL (time to live in seconds)."""
|
"""Store a token with TTL (time to live in seconds)."""
|
||||||
expiry = datetime.now(UTC) + timedelta(seconds=ttl)
|
expiry = datetime.now(UTC) + timedelta(seconds=ttl)
|
||||||
self._tokens[token] = (user_id, expiry)
|
self._tokens[token] = (user_id, expiry)
|
||||||
@@ -39,7 +39,7 @@ class InMemoryTokenRepository(TokenRepositoryInterface):
|
|||||||
return None
|
return None
|
||||||
|
|
||||||
# Sliding expiration: extend the token lifetime
|
# Sliding expiration: extend the token lifetime
|
||||||
new_expiry = datetime.now(UTC) + timedelta(seconds=self._default_ttl)
|
new_expiry = datetime.now(UTC) + timedelta(seconds=DEFAULT_TTL)
|
||||||
self._tokens[token] = (user_id, new_expiry)
|
self._tokens[token] = (user_id, new_expiry)
|
||||||
|
|
||||||
return user_id
|
return user_id
|
||||||
|
|||||||
@@ -3,14 +3,14 @@
|
|||||||
from typing import Any
|
from typing import Any
|
||||||
|
|
||||||
from baby_monitor.repositories.interfaces import TokenRepositoryInterface
|
from baby_monitor.repositories.interfaces import TokenRepositoryInterface
|
||||||
|
from baby_monitor.repositories.token import DEFAULT_TTL
|
||||||
|
|
||||||
|
|
||||||
class RedisTokenRepository(TokenRepositoryInterface):
|
class RedisTokenRepository(TokenRepositoryInterface):
|
||||||
"""
|
"""
|
||||||
Redis-based token storage.
|
Redis-based token storage.
|
||||||
|
|
||||||
Requires redis package: pip install redis
|
This implementation uses Redis to store tokens with TTL. Implements sliding expiration.
|
||||||
Set REDIS_URI environment variable (e.g., redis://localhost:6379/0)
|
|
||||||
"""
|
"""
|
||||||
|
|
||||||
def __init__(self, redis_client: Any) -> None:
|
def __init__(self, redis_client: Any) -> None:
|
||||||
@@ -21,9 +21,8 @@ class RedisTokenRepository(TokenRepositoryInterface):
|
|||||||
redis_client: Redis client instance from redis.from_url()
|
redis_client: Redis client instance from redis.from_url()
|
||||||
"""
|
"""
|
||||||
self.redis = redis_client
|
self.redis = redis_client
|
||||||
self.default_ttl = 3600 # Store default TTL for sliding expiration
|
|
||||||
|
|
||||||
def store(self, token: str, user_id: int, ttl: int = 3600) -> None:
|
def store(self, token: str, user_id: int, ttl: int = DEFAULT_TTL) -> None:
|
||||||
"""Store a token with TTL (time to live in seconds)."""
|
"""Store a token with TTL (time to live in seconds)."""
|
||||||
key = f"token:{token}"
|
key = f"token:{token}"
|
||||||
self.redis.setex(key, ttl, str(user_id))
|
self.redis.setex(key, ttl, str(user_id))
|
||||||
@@ -37,7 +36,7 @@ class RedisTokenRepository(TokenRepositoryInterface):
|
|||||||
user_id_str = self.redis.get(key)
|
user_id_str = self.redis.get(key)
|
||||||
if user_id_str:
|
if user_id_str:
|
||||||
# Sliding expiration: extend the token lifetime
|
# Sliding expiration: extend the token lifetime
|
||||||
self.redis.expire(key, self.default_ttl)
|
self.redis.expire(key, DEFAULT_TTL)
|
||||||
return int(user_id_str)
|
return int(user_id_str)
|
||||||
return None
|
return None
|
||||||
|
|
||||||
|
|||||||
@@ -338,7 +338,8 @@
|
|||||||
}
|
}
|
||||||
|
|
||||||
function goBack() {
|
function goBack() {
|
||||||
window.location.href = "/";
|
// Redirect to settings page if editing, otherwise home page
|
||||||
|
window.location.href = isEditMode ? "/settings.html" : "/";
|
||||||
}
|
}
|
||||||
|
|
||||||
function skipToHome() {
|
function skipToHome() {
|
||||||
|
|||||||
@@ -281,6 +281,9 @@
|
|||||||
let currentDaysRange =
|
let currentDaysRange =
|
||||||
parseInt(localStorage.getItem("lastDiaperTimeRange")) || 7;
|
parseInt(localStorage.getItem("lastDiaperTimeRange")) || 7;
|
||||||
let selectedChildId = null; // null means show first/only child
|
let selectedChildId = null; // null means show first/only child
|
||||||
|
let barChartInstance = null; // Track chart instance for proper cleanup
|
||||||
|
let poopPieChartInstance = null;
|
||||||
|
let peePieChartInstance = null;
|
||||||
|
|
||||||
// Restore last selected child from localStorage
|
// Restore last selected child from localStorage
|
||||||
const lastChildId = localStorage.getItem("lastDiaperChildFilter");
|
const lastChildId = localStorage.getItem("lastDiaperChildFilter");
|
||||||
@@ -782,7 +785,12 @@
|
|||||||
function renderBarChart(chartData) {
|
function renderBarChart(chartData) {
|
||||||
const ctx = document.getElementById("diaperChart").getContext("2d");
|
const ctx = document.getElementById("diaperChart").getContext("2d");
|
||||||
|
|
||||||
new Chart(ctx, {
|
// Destroy existing chart instance if it exists
|
||||||
|
if (barChartInstance) {
|
||||||
|
barChartInstance.destroy();
|
||||||
|
}
|
||||||
|
|
||||||
|
barChartInstance = new Chart(ctx, {
|
||||||
type: "bar",
|
type: "bar",
|
||||||
data: {
|
data: {
|
||||||
labels: chartData.labels,
|
labels: chartData.labels,
|
||||||
@@ -875,6 +883,11 @@
|
|||||||
function renderPoopPieChart(chartData) {
|
function renderPoopPieChart(chartData) {
|
||||||
const ctx = document.getElementById("poopPieChart").getContext("2d");
|
const ctx = document.getElementById("poopPieChart").getContext("2d");
|
||||||
|
|
||||||
|
// Destroy existing chart instance if it exists
|
||||||
|
if (poopPieChartInstance) {
|
||||||
|
poopPieChartInstance.destroy();
|
||||||
|
}
|
||||||
|
|
||||||
const colors = {
|
const colors = {
|
||||||
Light: {
|
Light: {
|
||||||
bg: "rgba(139, 69, 19, 0.5)",
|
bg: "rgba(139, 69, 19, 0.5)",
|
||||||
@@ -901,7 +914,7 @@
|
|||||||
(label) => colors[label]?.border || "rgba(200, 200, 200, 1)",
|
(label) => colors[label]?.border || "rgba(200, 200, 200, 1)",
|
||||||
);
|
);
|
||||||
|
|
||||||
new Chart(ctx, {
|
poopPieChartInstance = new Chart(ctx, {
|
||||||
type: "pie",
|
type: "pie",
|
||||||
data: {
|
data: {
|
||||||
labels: chartData.labels,
|
labels: chartData.labels,
|
||||||
@@ -957,6 +970,11 @@
|
|||||||
function renderPeePieChart(chartData) {
|
function renderPeePieChart(chartData) {
|
||||||
const ctx = document.getElementById("peePieChart").getContext("2d");
|
const ctx = document.getElementById("peePieChart").getContext("2d");
|
||||||
|
|
||||||
|
// Destroy existing chart instance if it exists
|
||||||
|
if (peePieChartInstance) {
|
||||||
|
peePieChartInstance.destroy();
|
||||||
|
}
|
||||||
|
|
||||||
const colors = {
|
const colors = {
|
||||||
Light: {
|
Light: {
|
||||||
bg: "rgba(255, 215, 0, 0.5)",
|
bg: "rgba(255, 215, 0, 0.5)",
|
||||||
@@ -983,7 +1001,7 @@
|
|||||||
(label) => colors[label]?.border || "rgba(200, 200, 200, 1)",
|
(label) => colors[label]?.border || "rgba(200, 200, 200, 1)",
|
||||||
);
|
);
|
||||||
|
|
||||||
new Chart(ctx, {
|
peePieChartInstance = new Chart(ctx, {
|
||||||
type: "pie",
|
type: "pie",
|
||||||
data: {
|
data: {
|
||||||
labels: chartData.labels,
|
labels: chartData.labels,
|
||||||
|
|||||||
@@ -319,6 +319,8 @@
|
|||||||
parseInt(localStorage.getItem("lastFeedingTimeRange")) || 7;
|
parseInt(localStorage.getItem("lastFeedingTimeRange")) || 7;
|
||||||
let selectedChildId = null; // null means show first/only child
|
let selectedChildId = null; // null means show first/only child
|
||||||
let barChartInstance = null;
|
let barChartInstance = null;
|
||||||
|
let pieChartInstance = null;
|
||||||
|
let durationChartInstance = null;
|
||||||
|
|
||||||
// Restore last selected child from localStorage
|
// Restore last selected child from localStorage
|
||||||
const lastChildId = localStorage.getItem("lastFeedingChildFilter");
|
const lastChildId = localStorage.getItem("lastFeedingChildFilter");
|
||||||
@@ -979,6 +981,11 @@
|
|||||||
function renderPieChart(chartData) {
|
function renderPieChart(chartData) {
|
||||||
const ctx = document.getElementById("pieChart").getContext("2d");
|
const ctx = document.getElementById("pieChart").getContext("2d");
|
||||||
|
|
||||||
|
// Destroy existing chart instance if it exists
|
||||||
|
if (pieChartInstance) {
|
||||||
|
pieChartInstance.destroy();
|
||||||
|
}
|
||||||
|
|
||||||
// Color mapping for each type
|
// Color mapping for each type
|
||||||
const colorMap = {
|
const colorMap = {
|
||||||
"Left Breast": {
|
"Left Breast": {
|
||||||
@@ -1003,7 +1010,7 @@
|
|||||||
(label) => colorMap[label]?.border || "rgba(200, 200, 200, 1)",
|
(label) => colorMap[label]?.border || "rgba(200, 200, 200, 1)",
|
||||||
);
|
);
|
||||||
|
|
||||||
new Chart(ctx, {
|
pieChartInstance = new Chart(ctx, {
|
||||||
type: "pie",
|
type: "pie",
|
||||||
data: {
|
data: {
|
||||||
labels: chartData.labels,
|
labels: chartData.labels,
|
||||||
@@ -1059,7 +1066,12 @@
|
|||||||
function renderDurationChart(chartData) {
|
function renderDurationChart(chartData) {
|
||||||
const ctx = document.getElementById("durationChart").getContext("2d");
|
const ctx = document.getElementById("durationChart").getContext("2d");
|
||||||
|
|
||||||
new Chart(ctx, {
|
// Destroy existing chart instance if it exists
|
||||||
|
if (durationChartInstance) {
|
||||||
|
durationChartInstance.destroy();
|
||||||
|
}
|
||||||
|
|
||||||
|
durationChartInstance = new Chart(ctx, {
|
||||||
type: "bar",
|
type: "bar",
|
||||||
data: {
|
data: {
|
||||||
labels: chartData.labels,
|
labels: chartData.labels,
|
||||||
|
|||||||
@@ -167,6 +167,52 @@
|
|||||||
margin-top: 0.5rem;
|
margin-top: 0.5rem;
|
||||||
opacity: 0.9;
|
opacity: 0.9;
|
||||||
}
|
}
|
||||||
|
.recent-activity {
|
||||||
|
margin-top: 2rem;
|
||||||
|
padding: 1.5rem;
|
||||||
|
background: #f8f9fa;
|
||||||
|
border-radius: 8px;
|
||||||
|
}
|
||||||
|
.recent-activity h3 {
|
||||||
|
margin-top: 0;
|
||||||
|
margin-bottom: 1rem;
|
||||||
|
color: #333;
|
||||||
|
font-size: 1.1rem;
|
||||||
|
}
|
||||||
|
.activity-grid {
|
||||||
|
display: grid;
|
||||||
|
grid-template-columns: repeat(auto-fit, minmax(200px, 1fr));
|
||||||
|
gap: 1rem;
|
||||||
|
}
|
||||||
|
.activity-card {
|
||||||
|
background: white;
|
||||||
|
padding: 1rem;
|
||||||
|
border-radius: 6px;
|
||||||
|
box-shadow: 0 1px 3px rgba(0, 0, 0, 0.1);
|
||||||
|
}
|
||||||
|
.activity-card .icon {
|
||||||
|
font-size: 1.5rem;
|
||||||
|
margin-bottom: 0.5rem;
|
||||||
|
}
|
||||||
|
.activity-card .type {
|
||||||
|
font-weight: 600;
|
||||||
|
color: #333;
|
||||||
|
margin-bottom: 0.25rem;
|
||||||
|
}
|
||||||
|
.activity-card .time {
|
||||||
|
font-size: 0.85rem;
|
||||||
|
color: #666;
|
||||||
|
}
|
||||||
|
.activity-card .details {
|
||||||
|
font-size: 0.85rem;
|
||||||
|
color: #888;
|
||||||
|
margin-top: 0.5rem;
|
||||||
|
}
|
||||||
|
.activity-card.empty {
|
||||||
|
opacity: 0.5;
|
||||||
|
font-style: italic;
|
||||||
|
color: #999;
|
||||||
|
}
|
||||||
</style>
|
</style>
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
@@ -321,6 +367,7 @@
|
|||||||
let activeSleep = null;
|
let activeSleep = null;
|
||||||
let lastSleep = null;
|
let lastSleep = null;
|
||||||
let sleepUpdateTimerInterval = null;
|
let sleepUpdateTimerInterval = null;
|
||||||
|
let lastDiaperChange = null;
|
||||||
|
|
||||||
async function loadFeedingStatus(children) {
|
async function loadFeedingStatus(children) {
|
||||||
userChildren = children;
|
userChildren = children;
|
||||||
@@ -376,6 +423,20 @@
|
|||||||
lastSleep = sleeps[0];
|
lastSleep = sleeps[0];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Fetch all diaper changes to get the last one
|
||||||
|
const diaperResponse = await fetch("/api/diaper-changes", {
|
||||||
|
headers: {
|
||||||
|
Authorization: `Bearer ${token}`,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if (diaperResponse.ok) {
|
||||||
|
const diapers = await diaperResponse.json();
|
||||||
|
if (diapers.length > 0) {
|
||||||
|
lastDiaperChange = diapers[0];
|
||||||
|
}
|
||||||
|
}
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error("Error loading feeding status:", error);
|
console.error("Error loading feeding status:", error);
|
||||||
}
|
}
|
||||||
@@ -478,9 +539,98 @@
|
|||||||
</button>
|
</button>
|
||||||
${feedingButtonHtml}
|
${feedingButtonHtml}
|
||||||
${sleepButtonHtml}
|
${sleepButtonHtml}
|
||||||
|
${buildRecentActivitySection()}
|
||||||
`;
|
`;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function buildRecentActivitySection() {
|
||||||
|
// Build diaper card
|
||||||
|
const diaperCard = lastDiaperChange
|
||||||
|
? `
|
||||||
|
<div class="activity-card">
|
||||||
|
<div class="icon">🧷</div>
|
||||||
|
<div class="type">Last Diaper</div>
|
||||||
|
<div class="time">${formatTime(lastDiaperChange.change_time)}</div>
|
||||||
|
<div class="details">
|
||||||
|
${lastDiaperChange.poop_amount ? `💩 ${lastDiaperChange.poop_amount}` : ""}
|
||||||
|
${lastDiaperChange.poop_amount && lastDiaperChange.pee_amount ? " • " : ""}
|
||||||
|
${lastDiaperChange.pee_amount ? `💧 ${lastDiaperChange.pee_amount}` : ""}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
`
|
||||||
|
: `
|
||||||
|
<div class="activity-card empty">
|
||||||
|
<div class="icon">🧷</div>
|
||||||
|
<div class="type">No diaper changes yet</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
|
||||||
|
// Build feeding card
|
||||||
|
const feedingCard = lastFeeding
|
||||||
|
? `
|
||||||
|
<div class="activity-card">
|
||||||
|
<div class="icon">🍼</div>
|
||||||
|
<div class="type">Last Feeding</div>
|
||||||
|
<div class="time">${formatTime(lastFeeding.start_time)}</div>
|
||||||
|
<div class="details">
|
||||||
|
${formatFeedingType(lastFeeding.feeding_type)}
|
||||||
|
${lastFeeding.end_time ? ` • ${calculateDuration(lastFeeding.start_time, lastFeeding.end_time)}` : " (ongoing)"}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
`
|
||||||
|
: `
|
||||||
|
<div class="activity-card empty">
|
||||||
|
<div class="icon">🍼</div>
|
||||||
|
<div class="type">No feedings yet</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
|
||||||
|
// Build sleep card
|
||||||
|
const sleepCard = lastSleep
|
||||||
|
? `
|
||||||
|
<div class="activity-card">
|
||||||
|
<div class="icon">😴</div>
|
||||||
|
<div class="type">Last Sleep</div>
|
||||||
|
<div class="time">${formatTime(lastSleep.start_time)}</div>
|
||||||
|
<div class="details">
|
||||||
|
${lastSleep.end_time ? calculateDuration(lastSleep.start_time, lastSleep.end_time) : "ongoing"}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
`
|
||||||
|
: `
|
||||||
|
<div class="activity-card empty">
|
||||||
|
<div class="icon">😴</div>
|
||||||
|
<div class="type">No sleep sessions yet</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
|
||||||
|
return `
|
||||||
|
<div class="recent-activity">
|
||||||
|
<h3>📊 Recent Activity</h3>
|
||||||
|
<div class="activity-grid">
|
||||||
|
${diaperCard}
|
||||||
|
${feedingCard}
|
||||||
|
${sleepCard}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
`;
|
||||||
|
}
|
||||||
|
|
||||||
|
function calculateDuration(startTime, endTime) {
|
||||||
|
const start = new Date(startTime);
|
||||||
|
const end = new Date(endTime);
|
||||||
|
const diffMs = end - start;
|
||||||
|
const diffMins = Math.floor(diffMs / 60000);
|
||||||
|
|
||||||
|
if (diffMins < 60) {
|
||||||
|
return `${diffMins} min`;
|
||||||
|
}
|
||||||
|
|
||||||
|
const hours = Math.floor(diffMins / 60);
|
||||||
|
const mins = diffMins % 60;
|
||||||
|
return `${hours}h ${mins}m`;
|
||||||
|
}
|
||||||
|
|
||||||
function formatFeedingType(type) {
|
function formatFeedingType(type) {
|
||||||
const types = {
|
const types = {
|
||||||
left_breast: "Left Breast",
|
left_breast: "Left Breast",
|
||||||
|
|||||||
@@ -345,13 +345,16 @@
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
document
|
function attachTimeRangeListener() {
|
||||||
.getElementById("timeRangeFilter")
|
const timeRangeFilter = document.getElementById("timeRangeFilter");
|
||||||
.addEventListener("change", function () {
|
if (timeRangeFilter) {
|
||||||
|
timeRangeFilter.addEventListener("change", function () {
|
||||||
// Save selection to localStorage
|
// Save selection to localStorage
|
||||||
localStorage.setItem("lastSleepTimeRange", this.value);
|
localStorage.setItem("lastSleepTimeRange", this.value);
|
||||||
loadData();
|
renderCharts();
|
||||||
});
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async function loadData() {
|
async function loadData() {
|
||||||
try {
|
try {
|
||||||
@@ -443,6 +446,9 @@
|
|||||||
attachChildFilterListener();
|
attachChildFilterListener();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Always attach time range listener after recreating the controls
|
||||||
|
attachTimeRangeListener();
|
||||||
|
|
||||||
renderCharts();
|
renderCharts();
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
console.error("Error loading data:", error);
|
console.error("Error loading data:", error);
|
||||||
|
|||||||
Reference in New Issue
Block a user