mirror of
https://github.com/sstent/foodplanner.git
synced 2026-04-04 20:13:52 +00:00
adding fitbit data capture
This commit is contained in:
55
alembic/versions/e1c2d8d5c1a8_add_fitbit_tables.py
Normal file
55
alembic/versions/e1c2d8d5c1a8_add_fitbit_tables.py
Normal file
@@ -0,0 +1,55 @@
|
|||||||
|
"""add fitbit tables
|
||||||
|
|
||||||
|
Revision ID: e1c2d8d5c1a8
|
||||||
|
Revises: 4522e2de4143
|
||||||
|
Create Date: 2026-01-12 12:00:00.000000
|
||||||
|
|
||||||
|
"""
|
||||||
|
from typing import Sequence, Union
|
||||||
|
|
||||||
|
from alembic import op
|
||||||
|
import sqlalchemy as sa
|
||||||
|
|
||||||
|
|
||||||
|
# revision identifiers, used by Alembic.
|
||||||
|
revision: str = 'e1c2d8d5c1a8'
|
||||||
|
down_revision: Union[str, None] = '31fdce040eea'
|
||||||
|
branch_labels: Union[str, Sequence[str], None] = None
|
||||||
|
depends_on: Union[str, Sequence[str], None] = None
|
||||||
|
|
||||||
|
|
||||||
|
def upgrade() -> None:
|
||||||
|
# Create fitbit_config table
|
||||||
|
op.create_table('fitbit_config',
|
||||||
|
sa.Column('id', sa.Integer(), nullable=False),
|
||||||
|
sa.Column('client_id', sa.String(), nullable=True),
|
||||||
|
sa.Column('client_secret', sa.String(), nullable=True),
|
||||||
|
sa.Column('redirect_uri', sa.String(), nullable=True),
|
||||||
|
sa.Column('access_token', sa.String(), nullable=True),
|
||||||
|
sa.Column('refresh_token', sa.String(), nullable=True),
|
||||||
|
sa.Column('expires_at', sa.Float(), nullable=True),
|
||||||
|
sa.PrimaryKeyConstraint('id')
|
||||||
|
)
|
||||||
|
op.create_index(op.f('ix_fitbit_config_id'), 'fitbit_config', ['id'], unique=False)
|
||||||
|
|
||||||
|
# Create weight_logs table
|
||||||
|
op.create_table('weight_logs',
|
||||||
|
sa.Column('id', sa.Integer(), nullable=False),
|
||||||
|
sa.Column('date', sa.Date(), nullable=True),
|
||||||
|
sa.Column('weight', sa.Float(), nullable=True),
|
||||||
|
sa.Column('source', sa.String(), nullable=True),
|
||||||
|
sa.Column('fitbit_log_id', sa.String(), nullable=True),
|
||||||
|
sa.PrimaryKeyConstraint('id')
|
||||||
|
)
|
||||||
|
op.create_index(op.f('ix_weight_logs_date'), 'weight_logs', ['date'], unique=False)
|
||||||
|
op.create_index(op.f('ix_weight_logs_fitbit_log_id'), 'weight_logs', ['fitbit_log_id'], unique=True)
|
||||||
|
op.create_index(op.f('ix_weight_logs_id'), 'weight_logs', ['id'], unique=False)
|
||||||
|
|
||||||
|
|
||||||
|
def downgrade() -> None:
|
||||||
|
op.drop_index(op.f('ix_weight_logs_id'), table_name='weight_logs')
|
||||||
|
op.drop_index(op.f('ix_weight_logs_fitbit_log_id'), table_name='weight_logs')
|
||||||
|
op.drop_index(op.f('ix_weight_logs_date'), table_name='weight_logs')
|
||||||
|
op.drop_table('weight_logs')
|
||||||
|
op.drop_index(op.f('ix_fitbit_config_id'), table_name='fitbit_config')
|
||||||
|
op.drop_table('fitbit_config')
|
||||||
@@ -11,6 +11,7 @@ from app.api.routes import (
|
|||||||
templates,
|
templates,
|
||||||
tracker,
|
tracker,
|
||||||
weekly_menu,
|
weekly_menu,
|
||||||
|
fitbit,
|
||||||
)
|
)
|
||||||
|
|
||||||
api_router = APIRouter()
|
api_router = APIRouter()
|
||||||
@@ -20,6 +21,7 @@ api_router.include_router(meals.router, tags=["meals"])
|
|||||||
api_router.include_router(templates.router, tags=["templates"])
|
api_router.include_router(templates.router, tags=["templates"])
|
||||||
api_router.include_router(charts.router, tags=["charts"])
|
api_router.include_router(charts.router, tags=["charts"])
|
||||||
api_router.include_router(admin.router, tags=["admin"])
|
api_router.include_router(admin.router, tags=["admin"])
|
||||||
|
api_router.include_router(fitbit.router, tags=["fitbit"])
|
||||||
api_router.include_router(weekly_menu.router, tags=["weekly_menu"])
|
api_router.include_router(weekly_menu.router, tags=["weekly_menu"])
|
||||||
api_router.include_router(plans.router, tags=["plans"])
|
api_router.include_router(plans.router, tags=["plans"])
|
||||||
api_router.include_router(export.router, tags=["export"])
|
api_router.include_router(export.router, tags=["export"])
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ from starlette.responses import HTMLResponse
|
|||||||
from sqlalchemy.orm import Session
|
from sqlalchemy.orm import Session
|
||||||
from datetime import date, timedelta
|
from datetime import date, timedelta
|
||||||
from typing import List
|
from typing import List
|
||||||
from app.database import get_db, TrackedDay, TrackedMeal, calculate_day_nutrition_tracked
|
from app.database import get_db, TrackedDay, TrackedMeal, calculate_day_nutrition_tracked, WeightLog
|
||||||
|
|
||||||
router = APIRouter(tags=["charts"])
|
router = APIRouter(tags=["charts"])
|
||||||
|
|
||||||
@@ -37,17 +37,101 @@ async def get_charts_data(
|
|||||||
).order_by(TrackedDay.date.desc()).all()
|
).order_by(TrackedDay.date.desc()).all()
|
||||||
|
|
||||||
chart_data = []
|
chart_data = []
|
||||||
for tracked_day in tracked_days:
|
# Fetch all tracked days and weight logs for the period
|
||||||
tracked_meals = db.query(TrackedMeal).filter(
|
tracked_days_map = {
|
||||||
TrackedMeal.tracked_day_id == tracked_day.id
|
d.date: d for d in db.query(TrackedDay).filter(
|
||||||
|
TrackedDay.person == person,
|
||||||
|
TrackedDay.date >= start_date,
|
||||||
|
TrackedDay.date <= end_date
|
||||||
).all()
|
).all()
|
||||||
day_totals = calculate_day_nutrition_tracked(tracked_meals, db)
|
}
|
||||||
|
|
||||||
|
# Sort logs desc
|
||||||
|
weight_logs_map = {
|
||||||
|
w.date: w for w in db.query(WeightLog).filter(
|
||||||
|
WeightLog.date >= start_date,
|
||||||
|
WeightLog.date <= end_date
|
||||||
|
).order_by(WeightLog.date.desc()).all()
|
||||||
|
}
|
||||||
|
|
||||||
|
# Get last weight BEFORE start_date (for initial carry forward)
|
||||||
|
last_historical_weight_log = db.query(WeightLog).filter(
|
||||||
|
WeightLog.date < start_date
|
||||||
|
).order_by(WeightLog.date.desc()).first()
|
||||||
|
|
||||||
|
last_historical_weight_val = last_historical_weight_log.weight * 2.20462 if last_historical_weight_log else None
|
||||||
|
|
||||||
|
# Find the most recent weight available (either in range or history)
|
||||||
|
# This is for "Today" (end_date)
|
||||||
|
latest_weight_val = last_historical_weight_val
|
||||||
|
|
||||||
|
# Check if we have newer weights in the map
|
||||||
|
# Values in weight_logs_map are WeightLog objects.
|
||||||
|
# Find the one with max date <= end_date. Since map key is date, we can check.
|
||||||
|
# But filtering the map is tedious. Let's just iterate.
|
||||||
|
# Actually, we already have `weight_logs_map` (in range).
|
||||||
|
# If the range has weights, the newest one is the "latest" known weight relevant to the end of chart.
|
||||||
|
if weight_logs_map:
|
||||||
|
# Get max date
|
||||||
|
max_date = max(weight_logs_map.keys())
|
||||||
|
latest_weight_val = weight_logs_map[max_date].weight * 2.20462
|
||||||
|
|
||||||
|
chart_data = []
|
||||||
|
|
||||||
|
# Iterate dates. Note: i=0 is end_date (Today), i=days-1 is start_date (Oldest)
|
||||||
|
for i in range(days):
|
||||||
|
current_date = end_date - timedelta(days=i)
|
||||||
|
|
||||||
|
tracked_day = tracked_days_map.get(current_date)
|
||||||
|
weight_log = weight_logs_map.get(current_date)
|
||||||
|
|
||||||
|
calories = 0
|
||||||
|
protein = 0
|
||||||
|
fat = 0
|
||||||
|
net_carbs = 0
|
||||||
|
|
||||||
|
# Calculate nutrition
|
||||||
|
if tracked_day:
|
||||||
|
tracked_meals = db.query(TrackedMeal).filter(
|
||||||
|
TrackedMeal.tracked_day_id == tracked_day.id
|
||||||
|
).all()
|
||||||
|
day_totals = calculate_day_nutrition_tracked(tracked_meals, db)
|
||||||
|
calories = round(day_totals.get("calories", 0), 2)
|
||||||
|
protein = round(day_totals.get("protein", 0), 2)
|
||||||
|
fat = round(day_totals.get("fat", 0), 2)
|
||||||
|
net_carbs = round(day_totals.get("net_carbs", 0), 2)
|
||||||
|
|
||||||
|
weight_lbs = None
|
||||||
|
is_real = False
|
||||||
|
|
||||||
|
if weight_log:
|
||||||
|
weight_lbs = round(weight_log.weight * 2.20462, 2)
|
||||||
|
is_real = True
|
||||||
|
|
||||||
|
# Logic for Start and End Points (to ensure line connects across view)
|
||||||
|
|
||||||
|
# If this is the Oldest date in view (start_date) and no real weight
|
||||||
|
if i == days - 1 and weight_lbs is None:
|
||||||
|
# Use historical weight if available (to start the line)
|
||||||
|
if last_historical_weight_val is not None:
|
||||||
|
weight_lbs = round(last_historical_weight_val, 2)
|
||||||
|
# is_real remains False (inferred)
|
||||||
|
|
||||||
|
# If this is the Newest date in view (end_date/Today) and no real weight
|
||||||
|
if i == 0 and weight_lbs is None:
|
||||||
|
# Use latest known weight (to end the line)
|
||||||
|
if latest_weight_val is not None:
|
||||||
|
weight_lbs = round(latest_weight_val, 2)
|
||||||
|
# is_real remains False (inferred)
|
||||||
|
|
||||||
chart_data.append({
|
chart_data.append({
|
||||||
"date": tracked_day.date.isoformat(),
|
"date": current_date.isoformat(),
|
||||||
"calories": round(day_totals.get("calories", 0), 2),
|
"calories": calories,
|
||||||
"protein": round(day_totals.get("protein", 0), 2),
|
"protein": protein,
|
||||||
"fat": round(day_totals.get("fat", 0), 2),
|
"fat": fat,
|
||||||
"net_carbs": round(day_totals.get("net_carbs", 0), 2)
|
"net_carbs": net_carbs,
|
||||||
|
"weight_lbs": weight_lbs,
|
||||||
|
"weight_is_real": is_real
|
||||||
})
|
})
|
||||||
|
|
||||||
return chart_data
|
return chart_data
|
||||||
283
app/api/routes/fitbit.py
Normal file
283
app/api/routes/fitbit.py
Normal file
@@ -0,0 +1,283 @@
|
|||||||
|
from fastapi import APIRouter, Depends, HTTPException, Request, Form
|
||||||
|
from fastapi.responses import HTMLResponse, RedirectResponse, JSONResponse
|
||||||
|
from sqlalchemy.orm import Session
|
||||||
|
import requests
|
||||||
|
import base64
|
||||||
|
import json
|
||||||
|
import datetime
|
||||||
|
from datetime import date
|
||||||
|
from typing import Optional
|
||||||
|
|
||||||
|
from app.database import get_db, FitbitConfig, WeightLog
|
||||||
|
from main import templates
|
||||||
|
|
||||||
|
from urllib.parse import quote
|
||||||
|
|
||||||
|
router = APIRouter()
|
||||||
|
|
||||||
|
# --- Helpers ---
|
||||||
|
|
||||||
|
def get_config(db: Session) -> FitbitConfig:
|
||||||
|
config = db.query(FitbitConfig).first()
|
||||||
|
if not config:
|
||||||
|
config = FitbitConfig()
|
||||||
|
db.add(config)
|
||||||
|
db.commit()
|
||||||
|
db.refresh(config)
|
||||||
|
return config
|
||||||
|
|
||||||
|
def refresh_tokens(db: Session, config: FitbitConfig):
|
||||||
|
if not config.refresh_token:
|
||||||
|
return None
|
||||||
|
|
||||||
|
token_url = "https://api.fitbit.com/oauth2/token"
|
||||||
|
auth_str = f"{config.client_id}:{config.client_secret}"
|
||||||
|
b64_auth = base64.b64encode(auth_str.encode()).decode()
|
||||||
|
|
||||||
|
headers = {
|
||||||
|
"Authorization": f"Basic {b64_auth}",
|
||||||
|
"Content-Type": "application/x-www-form-urlencoded"
|
||||||
|
}
|
||||||
|
|
||||||
|
data = {
|
||||||
|
"grant_type": "refresh_token",
|
||||||
|
"refresh_token": config.refresh_token
|
||||||
|
}
|
||||||
|
|
||||||
|
try:
|
||||||
|
response = requests.post(token_url, headers=headers, data=data)
|
||||||
|
if response.status_code == 200:
|
||||||
|
tokens = response.json()
|
||||||
|
config.access_token = tokens['access_token']
|
||||||
|
config.refresh_token = tokens['refresh_token']
|
||||||
|
# config.expires_at = datetime.datetime.now().timestamp() + tokens['expires_in'] # Optional
|
||||||
|
db.commit()
|
||||||
|
return config.access_token
|
||||||
|
else:
|
||||||
|
print(f"Failed to refresh token: {response.text}")
|
||||||
|
return None
|
||||||
|
except Exception as e:
|
||||||
|
print(f"Error refreshing token: {e}")
|
||||||
|
return None
|
||||||
|
|
||||||
|
def get_valid_access_token(db: Session, config: FitbitConfig):
|
||||||
|
# Simply try to refresh if we suspect it's old (or just always return current and handle 401 caller side)
|
||||||
|
# For now, return current, caller handles 401 by calling refresh
|
||||||
|
return config.access_token
|
||||||
|
|
||||||
|
|
||||||
|
# --- Routes ---
|
||||||
|
|
||||||
|
@router.get("/admin/fitbit", response_class=HTMLResponse)
|
||||||
|
async def fitbit_page(request: Request, db: Session = Depends(get_db)):
|
||||||
|
config = get_config(db)
|
||||||
|
# Mask secret
|
||||||
|
masked_secret = "*" * 8 if config.client_secret else ""
|
||||||
|
is_connected = bool(config.access_token)
|
||||||
|
|
||||||
|
# Get recent logs
|
||||||
|
logs = db.query(WeightLog).order_by(WeightLog.date.desc()).limit(30).all()
|
||||||
|
|
||||||
|
return templates.TemplateResponse("admin/fitbit.html", {
|
||||||
|
"request": request,
|
||||||
|
"config": config,
|
||||||
|
"masked_secret": masked_secret,
|
||||||
|
"is_connected": is_connected,
|
||||||
|
"logs": logs
|
||||||
|
})
|
||||||
|
|
||||||
|
@router.post("/admin/fitbit/config")
|
||||||
|
async def update_config(
|
||||||
|
request: Request,
|
||||||
|
client_id: str = Form(...),
|
||||||
|
client_secret: str = Form(...),
|
||||||
|
redirect_uri: str = Form(...),
|
||||||
|
db: Session = Depends(get_db)
|
||||||
|
):
|
||||||
|
config = get_config(db)
|
||||||
|
config.client_id = client_id
|
||||||
|
config.client_secret = client_secret
|
||||||
|
config.redirect_uri = redirect_uri
|
||||||
|
db.commit()
|
||||||
|
return RedirectResponse(url="/admin/fitbit", status_code=303)
|
||||||
|
|
||||||
|
@router.get("/admin/fitbit/auth_url")
|
||||||
|
async def get_auth_url(db: Session = Depends(get_db)):
|
||||||
|
config = get_config(db)
|
||||||
|
if not config.client_id or not config.redirect_uri:
|
||||||
|
return {"status": "error", "message": "Client ID and Redirect URI must be configured first."}
|
||||||
|
|
||||||
|
encoded_redirect_uri = quote(config.redirect_uri, safe='')
|
||||||
|
auth_url = (
|
||||||
|
"https://www.fitbit.com/oauth2/authorize"
|
||||||
|
f"?response_type=code&client_id={config.client_id}"
|
||||||
|
f"&redirect_uri={encoded_redirect_uri}"
|
||||||
|
"&scope=weight"
|
||||||
|
"&expires_in=604800"
|
||||||
|
)
|
||||||
|
return {"status": "success", "url": auth_url}
|
||||||
|
|
||||||
|
@router.post("/admin/fitbit/auth/exchange")
|
||||||
|
async def exchange_code(
|
||||||
|
request: Request,
|
||||||
|
code_input: str = Form(...),
|
||||||
|
db: Session = Depends(get_db)
|
||||||
|
):
|
||||||
|
config = get_config(db)
|
||||||
|
|
||||||
|
# Parse code from URL if provided
|
||||||
|
code = code_input.strip()
|
||||||
|
if "?" in code and "code=" in code:
|
||||||
|
from urllib.parse import urlparse, parse_qs
|
||||||
|
try:
|
||||||
|
query = parse_qs(urlparse(code).query)
|
||||||
|
if 'code' in query:
|
||||||
|
code = query['code'][0]
|
||||||
|
except:
|
||||||
|
pass
|
||||||
|
|
||||||
|
if code.endswith('#_=_'):
|
||||||
|
code = code[:-4]
|
||||||
|
|
||||||
|
# Exchange
|
||||||
|
token_url = "https://api.fitbit.com/oauth2/token"
|
||||||
|
auth_str = f"{config.client_id}:{config.client_secret}"
|
||||||
|
b64_auth = base64.b64encode(auth_str.encode()).decode()
|
||||||
|
|
||||||
|
headers = {
|
||||||
|
"Authorization": f"Basic {b64_auth}",
|
||||||
|
"Content-Type": "application/x-www-form-urlencoded"
|
||||||
|
}
|
||||||
|
|
||||||
|
data = {
|
||||||
|
"clientId": config.client_id,
|
||||||
|
"grant_type": "authorization_code",
|
||||||
|
"redirect_uri": config.redirect_uri,
|
||||||
|
"code": code
|
||||||
|
}
|
||||||
|
|
||||||
|
try:
|
||||||
|
response = requests.post(token_url, headers=headers, data=data)
|
||||||
|
if response.status_code == 200:
|
||||||
|
tokens = response.json()
|
||||||
|
config.access_token = tokens['access_token']
|
||||||
|
config.refresh_token = tokens['refresh_token']
|
||||||
|
db.commit()
|
||||||
|
return RedirectResponse(url="/admin/fitbit", status_code=303)
|
||||||
|
else:
|
||||||
|
return templates.TemplateResponse("error.html", {
|
||||||
|
"request": request,
|
||||||
|
"error_title": "Auth Failed",
|
||||||
|
"error_message": f"Fitbit Error: {response.text}",
|
||||||
|
"error_details": ""
|
||||||
|
})
|
||||||
|
except Exception as e:
|
||||||
|
return templates.TemplateResponse("error.html", {
|
||||||
|
"request": request,
|
||||||
|
"error_title": "Auth Error",
|
||||||
|
"error_message": str(e),
|
||||||
|
"error_details": ""
|
||||||
|
})
|
||||||
|
|
||||||
|
@router.post("/admin/fitbit/sync")
|
||||||
|
async def sync_data(
|
||||||
|
request: Request,
|
||||||
|
scope: str = Form("30d"),
|
||||||
|
db: Session = Depends(get_db)
|
||||||
|
):
|
||||||
|
config = get_config(db)
|
||||||
|
if not config.access_token:
|
||||||
|
return JSONResponse({"status": "error", "message": "Not connected"}, status_code=400)
|
||||||
|
|
||||||
|
# Helper to fetch with token refresh support
|
||||||
|
def fetch_weights_range(start_date: date, end_date: date, token: str):
|
||||||
|
url = f"https://api.fitbit.com/1/user/-/body/log/weight/date/{start_date}/{end_date}.json"
|
||||||
|
headers = {
|
||||||
|
"Authorization": f"Bearer {token}",
|
||||||
|
"Accept": "application/json"
|
||||||
|
}
|
||||||
|
return requests.get(url, headers=headers)
|
||||||
|
|
||||||
|
# Determine ranges
|
||||||
|
ranges = []
|
||||||
|
today = datetime.date.today()
|
||||||
|
|
||||||
|
if scope == "all":
|
||||||
|
# Start from a reasonable past date, e.g., 2015-01-01
|
||||||
|
current_start = datetime.date(2015, 1, 1)
|
||||||
|
while current_start <= today:
|
||||||
|
current_end = current_start + datetime.timedelta(days=30)
|
||||||
|
if current_end > today:
|
||||||
|
current_end = today
|
||||||
|
ranges.append((current_start, current_end))
|
||||||
|
current_start = current_end + datetime.timedelta(days=1)
|
||||||
|
else:
|
||||||
|
# Default 30 days
|
||||||
|
start = today - datetime.timedelta(days=30)
|
||||||
|
ranges.append((start, today))
|
||||||
|
|
||||||
|
total_new = 0
|
||||||
|
errors = []
|
||||||
|
|
||||||
|
# Iterate ranges
|
||||||
|
# We need to manage token state outside the loop to avoid re-refreshing constantly if it fails
|
||||||
|
current_token = config.access_token
|
||||||
|
|
||||||
|
print(f"DEBUG: Starting sync for scope={scope} with {len(ranges)} ranges.")
|
||||||
|
|
||||||
|
for start, end in ranges:
|
||||||
|
print(f"DEBUG: Fetching range {start} to {end}...")
|
||||||
|
resp = fetch_weights_range(start, end, current_token)
|
||||||
|
|
||||||
|
print(f"DEBUG: Response status: {resp.status_code}")
|
||||||
|
|
||||||
|
# Handle 401 (Refresh)
|
||||||
|
if resp.status_code == 401:
|
||||||
|
print(f"Token expired during sync of {start}-{end}, refreshing...")
|
||||||
|
new_token = refresh_tokens(db, config)
|
||||||
|
if new_token:
|
||||||
|
current_token = new_token
|
||||||
|
resp = fetch_weights_range(start, end, current_token)
|
||||||
|
print(f"DEBUG: Retried request status: {resp.status_code}")
|
||||||
|
else:
|
||||||
|
errors.append("Token expired and refresh failed.")
|
||||||
|
break
|
||||||
|
|
||||||
|
# Handle 429 (Rate Limit) - Basic handling: stop
|
||||||
|
if resp.status_code == 429:
|
||||||
|
errors.append("Rate limit exceeded.")
|
||||||
|
print("DEBUG: Rate limit exceeded.")
|
||||||
|
break
|
||||||
|
|
||||||
|
if resp.status_code == 200:
|
||||||
|
data = resp.json()
|
||||||
|
weights = data.get('weight', [])
|
||||||
|
print(f"DEBUG: Found {len(weights)} weights in this range.")
|
||||||
|
for w in weights:
|
||||||
|
log_id = str(w.get('logId'))
|
||||||
|
weight_val = float(w.get('weight'))
|
||||||
|
date_str = w.get('date')
|
||||||
|
|
||||||
|
existing = db.query(WeightLog).filter(WeightLog.fitbit_log_id == log_id).first()
|
||||||
|
if not existing:
|
||||||
|
log = WeightLog(
|
||||||
|
date=datetime.date.fromisoformat(date_str),
|
||||||
|
weight=weight_val,
|
||||||
|
fitbit_log_id=log_id,
|
||||||
|
source='fitbit'
|
||||||
|
)
|
||||||
|
db.add(log)
|
||||||
|
total_new += 1
|
||||||
|
else:
|
||||||
|
existing.weight = weight_val
|
||||||
|
db.commit()
|
||||||
|
else:
|
||||||
|
print(f"DEBUG: Error response: {resp.text}")
|
||||||
|
errors.append(f"Error {resp.status_code} for range {start}-{end}: {resp.text}")
|
||||||
|
|
||||||
|
print(f"DEBUG: Sync complete. Total new: {total_new}. Errors: {errors}")
|
||||||
|
|
||||||
|
if errors:
|
||||||
|
return JSONResponse({"status": "warning", "message": f"Synced {total_new} records, but encountered errors: {', '.join(errors[:3])}..."})
|
||||||
|
else:
|
||||||
|
return JSONResponse({"status": "success", "message": f"Synced {total_new} new records (" + ("All History" if scope == 'all' else "30d") + ")"})
|
||||||
@@ -170,6 +170,26 @@ class TrackedMealFood(Base):
|
|||||||
tracked_meal = relationship("TrackedMeal", back_populates="tracked_foods")
|
tracked_meal = relationship("TrackedMeal", back_populates="tracked_foods")
|
||||||
food = relationship("Food")
|
food = relationship("Food")
|
||||||
|
|
||||||
|
class FitbitConfig(Base):
|
||||||
|
__tablename__ = "fitbit_config"
|
||||||
|
|
||||||
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
|
client_id = Column(String)
|
||||||
|
client_secret = Column(String)
|
||||||
|
redirect_uri = Column(String, default="http://localhost:8080/fitbit-callback")
|
||||||
|
access_token = Column(String, nullable=True)
|
||||||
|
refresh_token = Column(String, nullable=True)
|
||||||
|
expires_at = Column(Float, nullable=True) # Timestamp
|
||||||
|
|
||||||
|
class WeightLog(Base):
|
||||||
|
__tablename__ = "weight_logs"
|
||||||
|
|
||||||
|
id = Column(Integer, primary_key=True, index=True)
|
||||||
|
date = Column(Date, index=True)
|
||||||
|
weight = Column(Float)
|
||||||
|
source = Column(String, default="fitbit")
|
||||||
|
fitbit_log_id = Column(String, unique=True, index=True) # To prevent duplicates
|
||||||
|
|
||||||
# Pydantic models
|
# Pydantic models
|
||||||
class FoodCreate(BaseModel):
|
class FoodCreate(BaseModel):
|
||||||
name: str
|
name: str
|
||||||
|
|||||||
179
templates/admin/fitbit.html
Normal file
179
templates/admin/fitbit.html
Normal file
@@ -0,0 +1,179 @@
|
|||||||
|
{% extends "admin/index.html" %}
|
||||||
|
|
||||||
|
{% block admin_content %}
|
||||||
|
<div class="card mb-4">
|
||||||
|
<div class="card-header d-flex justify-content-between align-items-center">
|
||||||
|
<h5 class="mb-0">Fitbit Connection</h5>
|
||||||
|
{% if is_connected %}
|
||||||
|
<span class="badge bg-success">Connected</span>
|
||||||
|
{% else %}
|
||||||
|
<span class="badge bg-secondary">Disconnected</span>
|
||||||
|
{% endif %}
|
||||||
|
</div>
|
||||||
|
<div class="card-body">
|
||||||
|
|
||||||
|
<!-- Configuration Form -->
|
||||||
|
<form action="/admin/fitbit/config" method="post" class="mb-4">
|
||||||
|
<div class="row">
|
||||||
|
<div class="col-md-4 mb-3">
|
||||||
|
<label class="form-label">Client ID</label>
|
||||||
|
<input type="text" class="form-control" name="client_id" value="{{ config.client_id or '' }}"
|
||||||
|
required>
|
||||||
|
</div>
|
||||||
|
<div class="col-md-4 mb-3">
|
||||||
|
<label class="form-label">Client Secret</label>
|
||||||
|
<input type="text" class="form-control" name="client_secret"
|
||||||
|
value="{{ config.client_secret or '' }}" required>
|
||||||
|
</div>
|
||||||
|
<div class="col-md-4 mb-3">
|
||||||
|
<label class="form-label">Redirect URI</label>
|
||||||
|
<input type="text" class="form-control" name="redirect_uri"
|
||||||
|
value="{{ config.redirect_uri or 'http://localhost:8080/fitbit-callback' }}" required>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
<button type="submit" class="btn btn-outline-primary btn-sm">Update Configuration</button>
|
||||||
|
</form>
|
||||||
|
|
||||||
|
<hr>
|
||||||
|
|
||||||
|
{% if not is_connected %}
|
||||||
|
<div class="alert alert-info">
|
||||||
|
<strong>Connect to Fitbit:</strong>
|
||||||
|
<ol>
|
||||||
|
<li>Click "Get Authorization URL" below.</li>
|
||||||
|
<li>Visit the URL in your browser and authorize the app.</li>
|
||||||
|
<li>You will be redirected to a URL (likely failing to load). Copy the entire URL.</li>
|
||||||
|
<li>Paste it in the box below and click "Complete Connection".</li>
|
||||||
|
</ol>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="mb-3">
|
||||||
|
<button id="get-auth-url-btn" class="btn btn-primary">Get Authorization URL</button>
|
||||||
|
<div id="auth-url-container" class="mt-2" style="display:none;">
|
||||||
|
<textarea class="form-control" rows="2" readonly id="auth-url-display"></textarea>
|
||||||
|
<a href="#" target="_blank" id="auth-link" class="btn btn-sm btn-link">Open Link</a>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<form action="/admin/fitbit/auth/exchange" method="post">
|
||||||
|
<div class="input-group">
|
||||||
|
<input type="text" class="form-control" name="code_input"
|
||||||
|
placeholder="Paste full redirected URL or code here..." required>
|
||||||
|
<button class="btn btn-success" type="submit">Complete Connection</button>
|
||||||
|
</div>
|
||||||
|
</form>
|
||||||
|
|
||||||
|
{% else %}
|
||||||
|
|
||||||
|
<div class="d-flex align-items-center gap-3">
|
||||||
|
<button class="btn btn-primary sync-btn" data-scope="30d">
|
||||||
|
<i class="bi bi-arrow-repeat"></i> Sync Last 30 Days
|
||||||
|
</button>
|
||||||
|
<button class="btn btn-secondary sync-btn" data-scope="all">
|
||||||
|
<i class="bi bi-clock-history"></i> Sync All History
|
||||||
|
</button>
|
||||||
|
<span id="sync-status" class="text-muted"></span>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{% endif %}
|
||||||
|
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="card">
|
||||||
|
<div class="card-header">
|
||||||
|
<h5 class="mb-0">Recent Weight Logs</h5>
|
||||||
|
</div>
|
||||||
|
<div class="card-body">
|
||||||
|
<table class="table table-sm table-striped">
|
||||||
|
<thead>
|
||||||
|
<tr>
|
||||||
|
<th>Date</th>
|
||||||
|
<th>Weight (kg)</th>
|
||||||
|
<th>Source</th>
|
||||||
|
</tr>
|
||||||
|
</thead>
|
||||||
|
<tbody>
|
||||||
|
{% for log in logs %}
|
||||||
|
<tr>
|
||||||
|
<td>{{ log.date }}</td>
|
||||||
|
<td>{{ log.weight }}</td>
|
||||||
|
<td>{{ log.source }}</td>
|
||||||
|
</tr>
|
||||||
|
{% else %}
|
||||||
|
<tr>
|
||||||
|
<td colspan="3" class="text-center text-muted">No logs found. Sync to import data.</td>
|
||||||
|
</tr>
|
||||||
|
{% endfor %}
|
||||||
|
</tbody>
|
||||||
|
</table>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<script>
|
||||||
|
document.addEventListener('DOMContentLoaded', function () {
|
||||||
|
// Auth URL handler
|
||||||
|
const authBtn = document.getElementById('get-auth-url-btn');
|
||||||
|
if (authBtn) {
|
||||||
|
authBtn.addEventListener('click', async () => {
|
||||||
|
try {
|
||||||
|
const response = await fetch('/admin/fitbit/auth_url');
|
||||||
|
const data = await response.json();
|
||||||
|
if (data.status === 'success') {
|
||||||
|
const container = document.getElementById('auth-url-container');
|
||||||
|
const display = document.getElementById('auth-url-display');
|
||||||
|
const link = document.getElementById('auth-link');
|
||||||
|
|
||||||
|
display.value = data.url;
|
||||||
|
link.href = data.url;
|
||||||
|
container.style.display = 'block';
|
||||||
|
} else {
|
||||||
|
alert('Error: ' + data.message);
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
alert('Request failed: ' + e);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
// Sync handler
|
||||||
|
const syncBtns = document.querySelectorAll('.sync-btn');
|
||||||
|
syncBtns.forEach(btn => {
|
||||||
|
btn.addEventListener('click', async () => {
|
||||||
|
const scope = btn.dataset.scope;
|
||||||
|
const statusFn = document.getElementById('sync-status');
|
||||||
|
|
||||||
|
// Disable all sync buttons
|
||||||
|
syncBtns.forEach(b => b.disabled = true);
|
||||||
|
|
||||||
|
statusFn.textContent = scope === 'all' ? 'Syncing history (this may take a while)...' : 'Syncing...';
|
||||||
|
statusFn.className = 'text-muted';
|
||||||
|
|
||||||
|
try {
|
||||||
|
const formData = new FormData();
|
||||||
|
formData.append('scope', scope);
|
||||||
|
|
||||||
|
const response = await fetch('/admin/fitbit/sync', {
|
||||||
|
method: 'POST',
|
||||||
|
body: formData
|
||||||
|
});
|
||||||
|
const data = await response.json();
|
||||||
|
if (data.status === 'success' || data.status === 'warning') {
|
||||||
|
statusFn.textContent = data.message;
|
||||||
|
statusFn.className = data.status === 'warning' ? 'text-warning' : 'text-success';
|
||||||
|
setTimeout(() => location.reload(), 2000); // Reload to show data
|
||||||
|
} else {
|
||||||
|
statusFn.textContent = 'Error: ' + data.message;
|
||||||
|
statusFn.className = 'text-danger';
|
||||||
|
}
|
||||||
|
} catch (e) {
|
||||||
|
statusFn.textContent = 'Failed: ' + e;
|
||||||
|
statusFn.className = 'text-danger';
|
||||||
|
} finally {
|
||||||
|
syncBtns.forEach(b => b.disabled = false);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
});
|
||||||
|
</script>
|
||||||
|
{% endblock %}
|
||||||
@@ -13,6 +13,9 @@
|
|||||||
<li class="nav-item" role="presentation">
|
<li class="nav-item" role="presentation">
|
||||||
<a class="nav-link" id="llm-config-tab" href="/admin/llm_config">LLM Config</a>
|
<a class="nav-link" id="llm-config-tab" href="/admin/llm_config">LLM Config</a>
|
||||||
</li>
|
</li>
|
||||||
|
<li class="nav-item" role="presentation">
|
||||||
|
<a class="nav-link" id="fitbit-tab" href="/admin/fitbit">Fitbit</a>
|
||||||
|
</li>
|
||||||
</ul>
|
</ul>
|
||||||
|
|
||||||
<div class="tab-content mt-3">
|
<div class="tab-content mt-3">
|
||||||
|
|||||||
@@ -100,30 +100,82 @@
|
|||||||
resizeChart();
|
resizeChart();
|
||||||
|
|
||||||
chart = new Chart(ctx, {
|
chart = new Chart(ctx, {
|
||||||
type: 'bar', // Switch to bar chart
|
type: 'bar',
|
||||||
data: {
|
data: {
|
||||||
labels: labels,
|
labels: labels,
|
||||||
datasets: [
|
datasets: [
|
||||||
|
{
|
||||||
|
type: 'line',
|
||||||
|
label: 'Weight (lbs)',
|
||||||
|
data: data.map(item => item.weight_lbs),
|
||||||
|
borderColor: '#0d6efd', // Bootstrap primary (Blue)
|
||||||
|
backgroundColor: '#0d6efd',
|
||||||
|
borderWidth: 2,
|
||||||
|
pointRadius: function (context) {
|
||||||
|
const index = context.dataIndex;
|
||||||
|
const item = data[index]; // Access data array from outer scope
|
||||||
|
|
||||||
|
// Show dot if it's a real weight measurement
|
||||||
|
if (item.weight_is_real) return 4;
|
||||||
|
|
||||||
|
// "Or the first point if no datapoints in the view"
|
||||||
|
// Check if ANY point in the view is real
|
||||||
|
const anyReal = data.some(d => d.weight_is_real);
|
||||||
|
if (!anyReal) {
|
||||||
|
// Make sure we only show ONE dot (the first one / oldest date)
|
||||||
|
// Data is sorted by date ascending in frontend (index 0 is oldest)
|
||||||
|
if (index === 0 && item.weight_lbs !== null) return 4;
|
||||||
|
}
|
||||||
|
|
||||||
|
return 0; // Hide dot for inferred points
|
||||||
|
},
|
||||||
|
yAxisID: 'y1',
|
||||||
|
datalabels: {
|
||||||
|
display: true,
|
||||||
|
align: 'top',
|
||||||
|
formatter: function (value, context) {
|
||||||
|
// Only show label if radius > 0
|
||||||
|
const index = context.dataIndex;
|
||||||
|
const item = data[index];
|
||||||
|
|
||||||
|
// Same logic as pointRadius
|
||||||
|
let show = false;
|
||||||
|
if (item.weight_is_real) show = true;
|
||||||
|
else {
|
||||||
|
const anyReal = data.some(d => d.weight_is_real);
|
||||||
|
if (!anyReal && index === 0 && item.weight_lbs !== null) show = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
return show ? (value ? value + ' lbs' : '') : '';
|
||||||
|
},
|
||||||
|
color: '#0d6efd',
|
||||||
|
font: { weight: 'bold' }
|
||||||
|
},
|
||||||
|
spanGaps: true
|
||||||
|
},
|
||||||
{
|
{
|
||||||
label: 'Net Carbs',
|
label: 'Net Carbs',
|
||||||
data: netCarbsCals,
|
data: netCarbsCals,
|
||||||
backgroundColor: 'rgba(255, 193, 7, 0.8)', // Bootstrap warning (Yellow)
|
backgroundColor: 'rgba(255, 193, 7, 0.8)', // Bootstrap warning (Yellow)
|
||||||
borderColor: '#ffc107',
|
borderColor: '#ffc107',
|
||||||
borderWidth: 1
|
borderWidth: 1,
|
||||||
|
yAxisID: 'y'
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
label: 'Fat',
|
label: 'Fat',
|
||||||
data: fatCals,
|
data: fatCals,
|
||||||
backgroundColor: 'rgba(220, 53, 69, 0.8)', // Bootstrap danger (Red)
|
backgroundColor: 'rgba(220, 53, 69, 0.8)', // Bootstrap danger (Red)
|
||||||
borderColor: '#dc3545',
|
borderColor: '#dc3545',
|
||||||
borderWidth: 1
|
borderWidth: 1,
|
||||||
|
yAxisID: 'y'
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
label: 'Protein',
|
label: 'Protein',
|
||||||
data: proteinCals,
|
data: proteinCals,
|
||||||
backgroundColor: 'rgba(25, 135, 84, 0.8)', // Bootstrap success (Green)
|
backgroundColor: 'rgba(25, 135, 84, 0.8)', // Bootstrap success (Green)
|
||||||
borderColor: '#198754',
|
borderColor: '#198754',
|
||||||
borderWidth: 1
|
borderWidth: 1,
|
||||||
|
yAxisID: 'y'
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
@@ -133,14 +185,26 @@
|
|||||||
scales: {
|
scales: {
|
||||||
y: {
|
y: {
|
||||||
beginAtZero: true,
|
beginAtZero: true,
|
||||||
stacked: true, // Enable stacking for Y axis
|
stacked: true,
|
||||||
title: {
|
title: {
|
||||||
display: true,
|
display: true,
|
||||||
text: 'Calories'
|
text: 'Calories'
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
y1: {
|
||||||
|
type: 'linear',
|
||||||
|
display: true,
|
||||||
|
position: 'right',
|
||||||
|
title: {
|
||||||
|
display: true,
|
||||||
|
text: 'Weight (lbs)'
|
||||||
|
},
|
||||||
|
grid: {
|
||||||
|
drawOnChartArea: false // only want the grid lines for one axis to show up
|
||||||
|
}
|
||||||
|
},
|
||||||
x: {
|
x: {
|
||||||
stacked: true, // Enable stacking for X axis
|
stacked: true,
|
||||||
title: {
|
title: {
|
||||||
display: true,
|
display: true,
|
||||||
text: 'Date'
|
text: 'Date'
|
||||||
@@ -156,8 +220,11 @@
|
|||||||
label += ': ';
|
label += ': ';
|
||||||
}
|
}
|
||||||
if (context.parsed.y !== null) {
|
if (context.parsed.y !== null) {
|
||||||
|
if (context.dataset.type === 'line') {
|
||||||
|
return label + context.parsed.y + ' lbs';
|
||||||
|
}
|
||||||
const dayData = data[context.dataIndex];
|
const dayData = data[context.dataIndex];
|
||||||
const macroKey = MACRO_KEYS[context.datasetIndex];
|
const macroKey = MACRO_KEYS[context.datasetIndex - 1]; // Offset by 1 due to weight dataset
|
||||||
const grams = dayData[macroKey];
|
const grams = dayData[macroKey];
|
||||||
label += Math.round(context.parsed.y) + ' cals (' + Math.round(grams) + 'g)';
|
label += Math.round(context.parsed.y) + ' cals (' + Math.round(grams) + 'g)';
|
||||||
}
|
}
|
||||||
@@ -172,6 +239,8 @@
|
|||||||
size: 11
|
size: 11
|
||||||
},
|
},
|
||||||
display: function (context) {
|
display: function (context) {
|
||||||
|
if (context.dataset.type === 'line') return false; // Handled separately
|
||||||
|
|
||||||
const dayData = data[context.dataIndex];
|
const dayData = data[context.dataIndex];
|
||||||
const pC = dayData.protein * 4;
|
const pC = dayData.protein * 4;
|
||||||
const fC = dayData.fat * 9;
|
const fC = dayData.fat * 9;
|
||||||
@@ -182,6 +251,8 @@
|
|||||||
return calcTotal > 0 && (value / calcTotal) > 0.05;
|
return calcTotal > 0 && (value / calcTotal) > 0.05;
|
||||||
},
|
},
|
||||||
formatter: function (value, context) {
|
formatter: function (value, context) {
|
||||||
|
if (context.dataset.type === 'line') return '';
|
||||||
|
|
||||||
const dayData = data[context.dataIndex];
|
const dayData = data[context.dataIndex];
|
||||||
const pC = dayData.protein * 4;
|
const pC = dayData.protein * 4;
|
||||||
const fC = dayData.fat * 9;
|
const fC = dayData.fat * 9;
|
||||||
@@ -190,7 +261,7 @@
|
|||||||
|
|
||||||
const totalCals = calcTotal || 1;
|
const totalCals = calcTotal || 1;
|
||||||
const percent = Math.round((value / totalCals) * 100);
|
const percent = Math.round((value / totalCals) * 100);
|
||||||
const macroKey = MACRO_KEYS[context.datasetIndex];
|
const macroKey = MACRO_KEYS[context.datasetIndex - 1]; // Offset by 1
|
||||||
const grams = Math.round(dayData[macroKey]);
|
const grams = Math.round(dayData[macroKey]);
|
||||||
|
|
||||||
return grams + 'g\n' + percent + '%';
|
return grams + 'g\n' + percent + '%';
|
||||||
|
|||||||
Reference in New Issue
Block a user