package handlers import ( "context" "fmt" "html/template" "log" "net/http" "path/filepath" "sort" "strings" "sync" "time" "task-dashboard/internal/api" "task-dashboard/internal/auth" "task-dashboard/internal/config" "task-dashboard/internal/models" "task-dashboard/internal/store" ) // Handler holds dependencies for HTTP handlers type Handler struct { store *store.Store todoistClient api.TodoistAPI trelloClient api.TrelloAPI planToEatClient api.PlanToEatAPI googleCalendarClient api.GoogleCalendarAPI googleTasksClient api.GoogleTasksAPI config *config.Config renderer Renderer BuildVersion string WebAuthnEnabled bool } // New creates a new Handler instance func New(s *store.Store, todoist api.TodoistAPI, trello api.TrelloAPI, planToEat api.PlanToEatAPI, googleCalendar api.GoogleCalendarAPI, googleTasks api.GoogleTasksAPI, cfg *config.Config, buildVersion string, webAuthnEnabled bool) *Handler { // Template functions funcMap := template.FuncMap{ "subtract": func(a, b int) int { return a - b }, } // Parse templates including partials tmpl, err := template.New("").Funcs(funcMap).ParseGlob(filepath.Join(cfg.TemplateDir, "*.html")) if err != nil { log.Printf("Warning: failed to parse templates: %v", err) } // Also parse partials tmpl, err = tmpl.ParseGlob(filepath.Join(cfg.TemplateDir, "partials", "*.html")) if err != nil { log.Printf("Warning: failed to parse partial templates: %v", err) } return &Handler{ store: s, todoistClient: todoist, trelloClient: trello, planToEatClient: planToEat, googleCalendarClient: googleCalendar, googleTasksClient: googleTasks, config: cfg, renderer: NewTemplateRenderer(tmpl), BuildVersion: buildVersion, WebAuthnEnabled: webAuthnEnabled, } } // HandleDashboard renders the main dashboard view func (h *Handler) HandleDashboard(w http.ResponseWriter, r *http.Request) { ctx := r.Context() // Extract tab query parameter for state persistence tab := r.URL.Query().Get("tab") if tab == "" { tab = "timeline" } // Aggregate data from all sources dashboardData, err := h.aggregateData(ctx, false) if err != nil { http.Error(w, "Failed to load dashboard data", http.StatusInternalServerError) log.Printf("Error aggregating data: %v", err) return } // Render template if h.renderer == nil { http.Error(w, "Renderer not configured", http.StatusInternalServerError) return } // Generate random background URL (Lorem Picsum - CORS-friendly) // Add random seed to get different image each load backgroundURL := fmt.Sprintf("https://picsum.photos/1920/1080?random=%d", time.Now().UnixNano()) // Wrap dashboard data with active tab for template data := struct { *models.DashboardData ActiveTab string CSRFToken string BackgroundURL string BuildVersion string }{ DashboardData: dashboardData, ActiveTab: tab, CSRFToken: auth.GetCSRFTokenFromContext(ctx), BackgroundURL: backgroundURL, BuildVersion: h.BuildVersion, } if err := h.renderer.Render(w, "index.html", data); err != nil { http.Error(w, "Failed to render template", http.StatusInternalServerError) log.Printf("Error rendering template: %v", err) } } // HandleRefresh forces a refresh of all data func (h *Handler) HandleRefresh(w http.ResponseWriter, r *http.Request) { data, err := h.aggregateData(r.Context(), true) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to refresh data", err) return } JSONResponse(w, data) } // HandleGetTasks returns tasks as JSON func (h *Handler) HandleGetTasks(w http.ResponseWriter, r *http.Request) { tasks, err := h.store.GetTasks() if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to get tasks", err) return } JSONResponse(w, tasks) } // HandleGetMeals returns meals as JSON func (h *Handler) HandleGetMeals(w http.ResponseWriter, r *http.Request) { startDate := config.Now() endDate := startDate.AddDate(0, 0, 7) meals, err := h.store.GetMeals(startDate, endDate) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to get meals", err) return } JSONResponse(w, meals) } // HandleGetBoards returns Trello boards with cards as JSON func (h *Handler) HandleGetBoards(w http.ResponseWriter, r *http.Request) { boards, err := h.store.GetBoards() if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to get boards", err) return } JSONResponse(w, boards) } // HandleGetShoppingList returns PlanToEat shopping list as JSON func (h *Handler) HandleGetShoppingList(w http.ResponseWriter, r *http.Request) { if h.planToEatClient == nil { JSONError(w, http.StatusServiceUnavailable, "PlanToEat not configured", nil) return } items, err := h.planToEatClient.GetShoppingList(r.Context()) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to get shopping list", err) return } JSONResponse(w, items) } // HandleTasksTab renders the tasks tab content (Trello + Todoist + PlanToEat) func (h *Handler) HandleTasksTab(w http.ResponseWriter, r *http.Request) { data, err := h.aggregateData(r.Context(), false) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to load tasks", err) return } HTMLResponse(w, h.renderer, "tasks-tab", data) } // HandleRefreshTab refreshes and re-renders the specified tab func (h *Handler) HandleRefreshTab(w http.ResponseWriter, r *http.Request) { data, err := h.aggregateData(r.Context(), true) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to refresh", err) return } HTMLResponse(w, h.renderer, "tasks-tab", data) } // aggregateData fetches and caches data from all sources concurrently func (h *Handler) aggregateData(ctx context.Context, forceRefresh bool) (*models.DashboardData, error) { data := &models.DashboardData{ LastUpdated: config.Now(), Errors: make([]string, 0), } var wg sync.WaitGroup var mu sync.Mutex // Helper to run fetch in goroutine with error collection fetch := func(name string, fn func() error) { wg.Add(1) go func() { defer wg.Done() select { case <-ctx.Done(): return default: } if err := fn(); err != nil { log.Printf("ERROR [%s]: %v", name, err) mu.Lock() data.Errors = append(data.Errors, name+": "+err.Error()) mu.Unlock() } }() } fetch("Trello", func() error { boards, err := h.fetchBoards(ctx, forceRefresh) if err == nil { mu.Lock() data.Boards = boards mu.Unlock() } return err }) fetch("Todoist", func() error { tasks, err := h.fetchTasks(ctx, forceRefresh) if err == nil { sortTasksByUrgency(tasks) mu.Lock() data.Tasks = tasks mu.Unlock() } return err }) fetch("Projects", func() error { projects, err := h.todoistClient.GetProjects(ctx) if err == nil { mu.Lock() data.Projects = projects mu.Unlock() } return err }) if h.planToEatClient != nil { fetch("PlanToEat", func() error { meals, err := h.fetchMeals(ctx, forceRefresh) if err == nil { mu.Lock() data.Meals = meals mu.Unlock() } return err }) } if h.googleCalendarClient != nil { fetch("Google Calendar", func() error { events, err := h.fetchCalendarEvents(ctx, false) if err == nil { mu.Lock() data.Events = events mu.Unlock() } return err }) } wg.Wait() // Extract and sort Trello tasks data.TrelloTasks = filterAndSortTrelloTasks(data.Boards) return data, nil } // sortTasksByUrgency sorts tasks by due date then priority func sortTasksByUrgency(tasks []models.Task) { sort.Slice(tasks, func(i, j int) bool { if tasks[i].DueDate == nil && tasks[j].DueDate != nil { return false } if tasks[i].DueDate != nil && tasks[j].DueDate == nil { return true } if tasks[i].DueDate != nil && tasks[j].DueDate != nil { if !tasks[i].DueDate.Equal(*tasks[j].DueDate) { return tasks[i].DueDate.Before(*tasks[j].DueDate) } } return tasks[i].Priority > tasks[j].Priority }) } // filterAndSortTrelloTasks extracts task-like cards from boards func filterAndSortTrelloTasks(boards []models.Board) []models.Card { var tasks []models.Card for _, board := range boards { for _, card := range board.Cards { if card.DueDate != nil || isActionableList(card.ListName) { tasks = append(tasks, card) } } } sort.Slice(tasks, func(i, j int) bool { if tasks[i].DueDate != nil && tasks[j].DueDate != nil { if !tasks[i].DueDate.Equal(*tasks[j].DueDate) { return tasks[i].DueDate.Before(*tasks[j].DueDate) } } if tasks[i].DueDate != nil && tasks[j].DueDate == nil { return true } if tasks[i].DueDate == nil && tasks[j].DueDate != nil { return false } return tasks[i].BoardName < tasks[j].BoardName }) return tasks } // fetchTasks fetches tasks from cache or API using incremental sync func (h *Handler) fetchTasks(ctx context.Context, forceRefresh bool) ([]models.Task, error) { cacheKey := store.CacheKeyTodoistTasks syncService := "todoist" // Check cache validity if !forceRefresh { valid, err := h.store.IsCacheValid(cacheKey) if err == nil && valid { return h.store.GetTasks() } } // Get stored sync token (empty string means full sync) syncToken, err := h.store.GetSyncToken(syncService) if err != nil { log.Printf("Failed to get sync token, will do full sync: %v", err) syncToken = "" } // Force full sync if requested if forceRefresh { syncToken = "" } // Fetch using Sync API syncResp, err := h.todoistClient.Sync(ctx, syncToken) if err != nil { // Try to return cached data even if stale cachedTasks, cacheErr := h.store.GetTasks() if cacheErr == nil && len(cachedTasks) > 0 { return cachedTasks, nil } return nil, err } // Build project map from sync response projectMap := api.BuildProjectMapFromSync(syncResp.Projects) // Process sync response if syncResp.FullSync { // Full sync: replace all tasks tasks := api.ConvertSyncItemsToTasks(syncResp.Items, projectMap) if err := h.store.SaveTasks(tasks); err != nil { log.Printf("Failed to save tasks to cache: %v", err) } } else { // Incremental sync: merge changes var deletedIDs []string for _, item := range syncResp.Items { if item.IsDeleted || item.IsCompleted { deletedIDs = append(deletedIDs, item.ID) } else { // Upsert active task task := h.convertSyncItemToTask(item, projectMap) if err := h.store.UpsertTask(task); err != nil { log.Printf("Failed to upsert task %s: %v", item.ID, err) } } } // Delete removed tasks if len(deletedIDs) > 0 { if err := h.store.DeleteTasksByIDs(deletedIDs); err != nil { log.Printf("Failed to delete tasks: %v", err) } } } // Store the new sync token if err := h.store.SetSyncToken(syncService, syncResp.SyncToken); err != nil { log.Printf("Failed to save sync token: %v", err) } // Update cache metadata if err := h.store.UpdateCacheMetadata(cacheKey, h.config.CacheTTLMinutes); err != nil { log.Printf("Failed to update cache metadata: %v", err) } return h.store.GetTasks() } // convertSyncItemToTask converts a sync item to a Task model func (h *Handler) convertSyncItemToTask(item api.SyncItemResponse, projectMap map[string]string) models.Task { // Use the ConvertSyncItemsToTasks helper for single item conversion items := api.ConvertSyncItemsToTasks([]api.SyncItemResponse{item}, projectMap) if len(items) > 0 { return items[0] } // Fallback for completed/deleted items (shouldn't happen in practice) return models.Task{ ID: item.ID, Content: item.Content, Description: item.Description, ProjectID: item.ProjectID, ProjectName: projectMap[item.ProjectID], Priority: item.Priority, Completed: item.IsCompleted, Labels: item.Labels, URL: fmt.Sprintf("https://todoist.com/app/task/%s", item.ID), } } // fetchMeals fetches meals from cache or API func (h *Handler) fetchMeals(ctx context.Context, forceRefresh bool) ([]models.Meal, error) { startDate := config.Now() endDate := startDate.AddDate(0, 0, 7) fetcher := &CacheFetcher[models.Meal]{ Store: h.store, CacheKey: store.CacheKeyPlanToEatMeals, TTLMinutes: h.config.CacheTTLMinutes, Fetch: func(ctx context.Context) ([]models.Meal, error) { return h.planToEatClient.GetUpcomingMeals(ctx, 7) }, GetFromCache: func() ([]models.Meal, error) { return h.store.GetMeals(startDate, endDate) }, SaveToCache: h.store.SaveMeals, } return fetcher.FetchWithCache(ctx, forceRefresh) } // fetchCalendarEvents fetches Google Calendar events from cache or API func (h *Handler) fetchCalendarEvents(ctx context.Context, forceRefresh bool) ([]models.CalendarEvent, error) { if h.googleCalendarClient == nil { return nil, nil } fetcher := &CacheFetcher[models.CalendarEvent]{ Store: h.store, CacheKey: store.CacheKeyGoogleCalendar, TTLMinutes: h.config.CacheTTLMinutes, Fetch: func(ctx context.Context) ([]models.CalendarEvent, error) { return h.googleCalendarClient.GetUpcomingEvents(ctx, 50) }, GetFromCache: h.store.GetCalendarEvents, SaveToCache: h.store.SaveCalendarEvents, } return fetcher.FetchWithCache(ctx, forceRefresh) } // fetchBoards fetches Trello boards from cache or API func (h *Handler) fetchBoards(ctx context.Context, forceRefresh bool) ([]models.Board, error) { fetcher := &CacheFetcher[models.Board]{ Store: h.store, CacheKey: store.CacheKeyTrelloBoards, TTLMinutes: h.config.CacheTTLMinutes, Fetch: func(ctx context.Context) ([]models.Board, error) { boards, err := h.trelloClient.GetBoardsWithCards(ctx) if err == nil { // Debug logging totalCards := 0 for _, b := range boards { totalCards += len(b.Cards) if len(b.Cards) > 0 { log.Printf("Trello API: Board %q has %d cards", b.Name, len(b.Cards)) } } log.Printf("Trello API: Fetched %d boards with %d total cards", len(boards), totalCards) } return boards, err }, GetFromCache: h.store.GetBoards, SaveToCache: h.store.SaveBoards, } return fetcher.FetchWithCache(ctx, forceRefresh) } // HandleCreateCard creates a new Trello card func (h *Handler) HandleCreateCard(w http.ResponseWriter, r *http.Request) { ctx := r.Context() if err := r.ParseForm(); err != nil { JSONError(w, http.StatusBadRequest, "Failed to parse form", err) return } boardID := r.FormValue("board_id") listID := r.FormValue("list_id") name := r.FormValue("name") if boardID == "" || listID == "" || name == "" { JSONError(w, http.StatusBadRequest, "Missing required fields", nil) return } if _, err := h.trelloClient.CreateCard(ctx, listID, name, "", nil); err != nil { JSONError(w, http.StatusInternalServerError, "Failed to create card", err) return } data, err := h.aggregateData(ctx, true) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to refresh data", err) return } var targetBoard *models.Board for i := range data.Boards { if data.Boards[i].ID == boardID { targetBoard = &data.Boards[i] break } } if targetBoard == nil { JSONError(w, http.StatusNotFound, "Board not found", nil) return } HTMLResponse(w, h.renderer, "trello-board", targetBoard) } // HandleCompleteCard marks a Trello card as complete func (h *Handler) HandleCompleteCard(w http.ResponseWriter, r *http.Request) { if !parseFormOr400(w, r) { return } cardID := r.FormValue("card_id") if cardID == "" { JSONError(w, http.StatusBadRequest, "Missing card_id", nil) return } if err := h.trelloClient.UpdateCard(r.Context(), cardID, map[string]interface{}{"closed": true}); err != nil { JSONError(w, http.StatusInternalServerError, "Failed to complete card", err) return } w.WriteHeader(http.StatusOK) } // HandleCreateTask creates a new Todoist task func (h *Handler) HandleCreateTask(w http.ResponseWriter, r *http.Request) { ctx := r.Context() if err := r.ParseForm(); err != nil { JSONError(w, http.StatusBadRequest, "Failed to parse form", err) return } content := r.FormValue("content") projectID := r.FormValue("project_id") if content == "" { JSONError(w, http.StatusBadRequest, "Missing content", nil) return } if _, err := h.todoistClient.CreateTask(ctx, content, projectID, nil, 0); err != nil { JSONError(w, http.StatusInternalServerError, "Failed to create task", err) return } tasks, err := h.fetchTasks(ctx, true) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to refresh tasks", err) return } projects, _ := h.todoistClient.GetProjects(ctx) data := struct { Tasks []models.Task Projects []models.Project }{Tasks: tasks, Projects: projects} HTMLResponse(w, h.renderer, "todoist-tasks", data) } // HandleCompleteTask marks a Todoist task as complete func (h *Handler) HandleCompleteTask(w http.ResponseWriter, r *http.Request) { if err := r.ParseForm(); err != nil { JSONError(w, http.StatusBadRequest, "Failed to parse form", err) return } taskID := r.FormValue("task_id") if taskID == "" { JSONError(w, http.StatusBadRequest, "Missing task_id", nil) return } if err := h.todoistClient.CompleteTask(r.Context(), taskID); err != nil { JSONError(w, http.StatusInternalServerError, "Failed to complete task", err) return } w.WriteHeader(http.StatusOK) } // HandleCompleteAtom handles completion of a unified task (Atom) func (h *Handler) HandleCompleteAtom(w http.ResponseWriter, r *http.Request) { h.handleAtomToggle(w, r, true) } // HandleUncompleteAtom handles reopening a completed task func (h *Handler) HandleUncompleteAtom(w http.ResponseWriter, r *http.Request) { h.handleAtomToggle(w, r, false) } // handleAtomToggle handles both complete and uncomplete operations func (h *Handler) handleAtomToggle(w http.ResponseWriter, r *http.Request, complete bool) { ctx := r.Context() if err := r.ParseForm(); err != nil { JSONError(w, http.StatusBadRequest, "Failed to parse form", err) return } id := r.FormValue("id") source := r.FormValue("source") if id == "" || source == "" { JSONError(w, http.StatusBadRequest, "Missing id or source", nil) return } var err error switch source { case "todoist": if complete { err = h.todoistClient.CompleteTask(ctx, id) } else { err = h.todoistClient.ReopenTask(ctx, id) } case "trello": err = h.trelloClient.UpdateCard(ctx, id, map[string]interface{}{"closed": complete}) case "bug": // Bug IDs are prefixed with "bug-", extract the numeric ID var bugID int64 if _, parseErr := fmt.Sscanf(id, "bug-%d", &bugID); parseErr != nil { JSONError(w, http.StatusBadRequest, "Invalid bug ID format", parseErr) return } if complete { err = h.store.ResolveBug(bugID) } else { err = h.store.UnresolveBug(bugID) } case "gtasks": // Google Tasks - need list ID from form or use default listID := r.FormValue("listId") if listID == "" { listID = "@default" } if h.googleTasksClient != nil { if complete { err = h.googleTasksClient.CompleteTask(ctx, listID, id) } else { err = h.googleTasksClient.UncompleteTask(ctx, listID, id) } } else { JSONError(w, http.StatusServiceUnavailable, "Google Tasks not configured", nil) return } default: JSONError(w, http.StatusBadRequest, "Unknown source: "+source, nil) return } if err != nil { action := "complete" if !complete { action = "reopen" } JSONError(w, http.StatusInternalServerError, "Failed to "+action+" task", err) return } if complete { // Get task details before removing from cache title, dueDate := h.getAtomDetails(id, source) // Log to completed tasks _ = h.store.SaveCompletedTask(source, id, title, dueDate) // Remove from local cache switch source { case "todoist": _ = h.store.DeleteTask(id) case "trello": _ = h.store.DeleteCard(id) } // Return completed task HTML with uncomplete option data := struct { ID string Source string Title string }{id, source, title} HTMLResponse(w, h.renderer, "completed-atom", data) } else { // Invalidate cache to force refresh switch source { case "todoist": _ = h.store.InvalidateCache(store.CacheKeyTodoistTasks) case "trello": _ = h.store.InvalidateCache(store.CacheKeyTrelloBoards) } // Don't swap empty response - just trigger refresh w.Header().Set("HX-Reswap", "none") w.Header().Set("HX-Trigger", "refresh-tasks") w.WriteHeader(http.StatusOK) } } // getAtomDetails retrieves title and due date for a task/card/bug from the store func (h *Handler) getAtomDetails(id, source string) (string, *time.Time) { switch source { case "todoist": if tasks, err := h.store.GetTasks(); err == nil { for _, t := range tasks { if t.ID == id { return t.Content, t.DueDate } } } case "trello": if boards, err := h.store.GetBoards(); err == nil { for _, b := range boards { for _, c := range b.Cards { if c.ID == id { return c.Name, c.DueDate } } } } case "bug": if bugs, err := h.store.GetBugs(); err == nil { var bugID int64 if _, err := fmt.Sscanf(id, "bug-%d", &bugID); err == nil { for _, b := range bugs { if b.ID == bugID { return b.Description, nil } } } } case "gtasks": // Google Tasks don't have local cache, return generic title return "Google Task", nil } return "Task", nil } // getAtomTitle retrieves the title for a task/card/bug from the store (legacy) func (h *Handler) getAtomTitle(id, source string) string { title, _ := h.getAtomDetails(id, source) return title } // HandleUnifiedAdd creates a task in Todoist or a card in Trello from the Quick Add form func (h *Handler) HandleUnifiedAdd(w http.ResponseWriter, r *http.Request) { ctx := r.Context() if err := r.ParseForm(); err != nil { JSONError(w, http.StatusBadRequest, "Failed to parse form", err) return } title := r.FormValue("title") source := r.FormValue("source") dueDateStr := r.FormValue("due_date") if title == "" { JSONError(w, http.StatusBadRequest, "Title is required", nil) return } var dueDate *time.Time if dueDateStr != "" { if parsed, err := config.ParseDateInDisplayTZ(dueDateStr); err == nil { dueDate = &parsed } } switch source { case "todoist": if _, err := h.todoistClient.CreateTask(ctx, title, "", dueDate, 1); err != nil { JSONError(w, http.StatusInternalServerError, "Failed to create Todoist task", err) return } _ = h.store.InvalidateCache(store.CacheKeyTodoistTasks) case "trello": listID := r.FormValue("list_id") if listID == "" { JSONError(w, http.StatusBadRequest, "List is required for Trello", nil) return } if _, err := h.trelloClient.CreateCard(ctx, listID, title, "", dueDate); err != nil { JSONError(w, http.StatusInternalServerError, "Failed to create Trello card", err) return } _ = h.store.InvalidateCache(store.CacheKeyTrelloBoards) default: JSONError(w, http.StatusBadRequest, "Invalid source", nil) return } w.Header().Set("HX-Trigger", "refresh-tasks") w.WriteHeader(http.StatusOK) } // HandleGetListsOptions returns HTML options for lists in a given board func (h *Handler) HandleGetListsOptions(w http.ResponseWriter, r *http.Request) { boardID := r.URL.Query().Get("board_id") if boardID == "" { JSONError(w, http.StatusBadRequest, "board_id is required", nil) return } lists, err := h.trelloClient.GetLists(r.Context(), boardID) if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to fetch lists", err) return } w.Header().Set("Content-Type", "text/html") for _, list := range lists { _, _ = fmt.Fprintf(w, ``, template.HTMLEscapeString(list.ID), template.HTMLEscapeString(list.Name)) } } // HandleGetBugs returns the list of reported bugs func (h *Handler) HandleGetBugs(w http.ResponseWriter, r *http.Request) { bugs, err := h.store.GetBugs() if err != nil { JSONError(w, http.StatusInternalServerError, "Failed to fetch bugs", err) return } w.Header().Set("Content-Type", "text/html") if len(bugs) == 0 { _, _ = fmt.Fprint(w, `
No bugs reported yet.
`) return } for _, bug := range bugs { _, _ = fmt.Fprintf(w, `%s
%s