summaryrefslogtreecommitdiff
path: root/internal
diff options
context:
space:
mode:
Diffstat (limited to 'internal')
-rw-r--r--internal/store/calendar.go85
-rw-r--r--internal/store/google_tasks.go117
-rw-r--r--internal/store/sqlite.go189
3 files changed, 202 insertions, 189 deletions
diff --git a/internal/store/calendar.go b/internal/store/calendar.go
new file mode 100644
index 0000000..44ffe0e
--- /dev/null
+++ b/internal/store/calendar.go
@@ -0,0 +1,85 @@
+package store
+
+import (
+ "time"
+
+ "task-dashboard/internal/models"
+)
+
+func (s *Store) SaveCalendarEvents(events []models.CalendarEvent) error {
+ tx, err := s.db.Begin()
+ if err != nil {
+ return err
+ }
+ defer func() { _ = tx.Rollback() }()
+
+ _, err = tx.Exec(`DELETE FROM calendar_events`)
+ if err != nil {
+ return err
+ }
+
+ stmt, err := tx.Prepare(`
+ INSERT INTO calendar_events (id, summary, description, start_time, end_time, html_link, recurring_event_id)
+ VALUES (?, ?, ?, ?, ?, ?, ?)
+ `)
+ if err != nil {
+ return err
+ }
+ defer func() { _ = stmt.Close() }()
+
+ for _, e := range events {
+ _, err = stmt.Exec(e.ID, e.Summary, e.Description, e.Start, e.End, e.HTMLLink, e.RecurringEventID)
+ if err != nil {
+ return err
+ }
+ }
+
+ return tx.Commit()
+}
+
+// GetCalendarEvents retrieves all cached calendar events
+func (s *Store) GetCalendarEvents() ([]models.CalendarEvent, error) {
+ rows, err := s.db.Query(`
+ SELECT id, summary, description, start_time, end_time, html_link
+ FROM calendar_events
+ ORDER BY start_time ASC
+ `)
+ if err != nil {
+ return nil, err
+ }
+ defer func() { _ = rows.Close() }()
+
+ var events []models.CalendarEvent
+ for rows.Next() {
+ var e models.CalendarEvent
+ if err := rows.Scan(&e.ID, &e.Summary, &e.Description, &e.Start, &e.End, &e.HTMLLink); err != nil {
+ return nil, err
+ }
+ events = append(events, e)
+ }
+ return events, rows.Err()
+}
+
+// GetCalendarEventsByDateRange retrieves cached calendar events within a date range
+func (s *Store) GetCalendarEventsByDateRange(start, end time.Time) ([]models.CalendarEvent, error) {
+ rows, err := s.db.Query(`
+ SELECT id, summary, description, start_time, end_time, html_link, recurring_event_id
+ FROM calendar_events
+ WHERE start_time >= ? AND start_time <= ?
+ ORDER BY start_time ASC
+ `, start, end)
+ if err != nil {
+ return nil, err
+ }
+ defer func() { _ = rows.Close() }()
+
+ var events []models.CalendarEvent
+ for rows.Next() {
+ var e models.CalendarEvent
+ if err := rows.Scan(&e.ID, &e.Summary, &e.Description, &e.Start, &e.End, &e.HTMLLink, &e.RecurringEventID); err != nil {
+ return nil, err
+ }
+ events = append(events, e)
+ }
+ return events, rows.Err()
+}
diff --git a/internal/store/google_tasks.go b/internal/store/google_tasks.go
new file mode 100644
index 0000000..9d03bf4
--- /dev/null
+++ b/internal/store/google_tasks.go
@@ -0,0 +1,117 @@
+package store
+
+import (
+ "database/sql"
+ "time"
+
+ "task-dashboard/internal/models"
+)
+
+// SaveGoogleTasks replaces all cached Google Tasks
+func (s *Store) SaveGoogleTasks(tasks []models.GoogleTask) error {
+ tx, err := s.db.Begin()
+ if err != nil {
+ return err
+ }
+ defer func() { _ = tx.Rollback() }()
+
+ if _, err := tx.Exec(`DELETE FROM google_tasks`); err != nil {
+ return err
+ }
+
+ stmt, err := tx.Prepare(`
+ INSERT INTO google_tasks (id, title, notes, status, completed, due_date, updated_at, list_id, url)
+ VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
+ `)
+ if err != nil {
+ return err
+ }
+ defer func() { _ = stmt.Close() }()
+
+ for _, t := range tasks {
+ _, err = stmt.Exec(t.ID, t.Title, t.Notes, t.Status, t.Completed, t.DueDate, t.UpdatedAt, t.ListID, t.URL)
+ if err != nil {
+ return err
+ }
+ }
+
+ return tx.Commit()
+}
+
+// parseGoogleTaskTime parses a TEXT-column timestamp written by mattn/go-sqlite3's
+// default time.Time binding. The google_tasks.due_date/updated_at columns are declared
+// TEXT (not DATETIME), so the driver never auto-converts them back to time.Time on read.
+func parseGoogleTaskTime(s string) (time.Time, bool) {
+ for _, layout := range []string{
+ "2006-01-02 15:04:05.999999999-07:00",
+ time.RFC3339Nano,
+ time.RFC3339,
+ "2006-01-02 15:04:05",
+ "2006-01-02",
+ } {
+ if parsed, err := time.Parse(layout, s); err == nil {
+ return parsed, true
+ }
+ }
+ return time.Time{}, false
+}
+
+func scanGoogleTasks(rows *sql.Rows) ([]models.GoogleTask, error) {
+ var tasks []models.GoogleTask
+ for rows.Next() {
+ var t models.GoogleTask
+ var dueDate, updatedAt sql.NullString
+
+ err := rows.Scan(&t.ID, &t.Title, &t.Notes, &t.Status, &t.Completed, &dueDate, &updatedAt, &t.ListID, &t.URL)
+ if err != nil {
+ return nil, err
+ }
+
+ if dueDate.Valid {
+ if parsed, ok := parseGoogleTaskTime(dueDate.String); ok {
+ t.DueDate = &parsed
+ }
+ }
+ if updatedAt.Valid {
+ if parsed, ok := parseGoogleTaskTime(updatedAt.String); ok {
+ t.UpdatedAt = parsed
+ }
+ }
+
+ tasks = append(tasks, t)
+ }
+
+ return tasks, rows.Err()
+}
+
+// GetGoogleTasks retrieves all cached Google Tasks
+func (s *Store) GetGoogleTasks() ([]models.GoogleTask, error) {
+ rows, err := s.db.Query(`
+ SELECT id, title, notes, status, completed, due_date, updated_at, list_id, url
+ FROM google_tasks
+ ORDER BY completed ASC, CASE WHEN due_date IS NULL THEN 1 ELSE 0 END, due_date ASC
+ `)
+ if err != nil {
+ return nil, err
+ }
+ defer func() { _ = rows.Close() }()
+
+ return scanGoogleTasks(rows)
+}
+
+// GetGoogleTasksByDateRange retrieves cached Google Tasks due before end, including overdue
+// tasks (due before start) so they keep appearing until completed.
+func (s *Store) GetGoogleTasksByDateRange(start, end time.Time) ([]models.GoogleTask, error) {
+ rows, err := s.db.Query(`
+ SELECT id, title, notes, status, completed, due_date, updated_at, list_id, url
+ FROM google_tasks
+ WHERE due_date IS NULL OR due_date < ?
+ ORDER BY completed ASC, CASE WHEN due_date IS NULL THEN 1 ELSE 0 END, due_date ASC
+ `, end)
+ if err != nil {
+ return nil, err
+ }
+ defer func() { _ = rows.Close() }()
+
+ return scanGoogleTasks(rows)
+}
diff --git a/internal/store/sqlite.go b/internal/store/sqlite.go
index 1662c6a..d26dd3e 100644
--- a/internal/store/sqlite.go
+++ b/internal/store/sqlite.go
@@ -432,195 +432,6 @@ func (s *Store) GetCardsByDateRange(start, end time.Time) ([]models.Card, error)
// Calendar event operations
// SaveCalendarEvents replaces all cached calendar events
-func (s *Store) SaveCalendarEvents(events []models.CalendarEvent) error {
- tx, err := s.db.Begin()
- if err != nil {
- return err
- }
- defer func() { _ = tx.Rollback() }()
-
- _, err = tx.Exec(`DELETE FROM calendar_events`)
- if err != nil {
- return err
- }
-
- stmt, err := tx.Prepare(`
- INSERT INTO calendar_events (id, summary, description, start_time, end_time, html_link, recurring_event_id)
- VALUES (?, ?, ?, ?, ?, ?, ?)
- `)
- if err != nil {
- return err
- }
- defer func() { _ = stmt.Close() }()
-
- for _, e := range events {
- _, err = stmt.Exec(e.ID, e.Summary, e.Description, e.Start, e.End, e.HTMLLink, e.RecurringEventID)
- if err != nil {
- return err
- }
- }
-
- return tx.Commit()
-}
-
-// GetCalendarEvents retrieves all cached calendar events
-func (s *Store) GetCalendarEvents() ([]models.CalendarEvent, error) {
- rows, err := s.db.Query(`
- SELECT id, summary, description, start_time, end_time, html_link
- FROM calendar_events
- ORDER BY start_time ASC
- `)
- if err != nil {
- return nil, err
- }
- defer func() { _ = rows.Close() }()
-
- var events []models.CalendarEvent
- for rows.Next() {
- var e models.CalendarEvent
- if err := rows.Scan(&e.ID, &e.Summary, &e.Description, &e.Start, &e.End, &e.HTMLLink); err != nil {
- return nil, err
- }
- events = append(events, e)
- }
- return events, rows.Err()
-}
-
-// GetCalendarEventsByDateRange retrieves cached calendar events within a date range
-func (s *Store) GetCalendarEventsByDateRange(start, end time.Time) ([]models.CalendarEvent, error) {
- rows, err := s.db.Query(`
- SELECT id, summary, description, start_time, end_time, html_link, recurring_event_id
- FROM calendar_events
- WHERE start_time >= ? AND start_time <= ?
- ORDER BY start_time ASC
- `, start, end)
- if err != nil {
- return nil, err
- }
- defer func() { _ = rows.Close() }()
-
- var events []models.CalendarEvent
- for rows.Next() {
- var e models.CalendarEvent
- if err := rows.Scan(&e.ID, &e.Summary, &e.Description, &e.Start, &e.End, &e.HTMLLink, &e.RecurringEventID); err != nil {
- return nil, err
- }
- events = append(events, e)
- }
- return events, rows.Err()
-}
-
-// Google Tasks operations
-
-// SaveGoogleTasks replaces all cached Google Tasks
-func (s *Store) SaveGoogleTasks(tasks []models.GoogleTask) error {
- tx, err := s.db.Begin()
- if err != nil {
- return err
- }
- defer func() { _ = tx.Rollback() }()
-
- if _, err := tx.Exec(`DELETE FROM google_tasks`); err != nil {
- return err
- }
-
- stmt, err := tx.Prepare(`
- INSERT INTO google_tasks (id, title, notes, status, completed, due_date, updated_at, list_id, url)
- VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
- `)
- if err != nil {
- return err
- }
- defer func() { _ = stmt.Close() }()
-
- for _, t := range tasks {
- _, err = stmt.Exec(t.ID, t.Title, t.Notes, t.Status, t.Completed, t.DueDate, t.UpdatedAt, t.ListID, t.URL)
- if err != nil {
- return err
- }
- }
-
- return tx.Commit()
-}
-
-// parseGoogleTaskTime parses a TEXT-column timestamp written by mattn/go-sqlite3's
-// default time.Time binding. The google_tasks.due_date/updated_at columns are declared
-// TEXT (not DATETIME), so the driver never auto-converts them back to time.Time on read.
-func parseGoogleTaskTime(s string) (time.Time, bool) {
- for _, layout := range []string{
- "2006-01-02 15:04:05.999999999-07:00",
- time.RFC3339Nano,
- time.RFC3339,
- "2006-01-02 15:04:05",
- "2006-01-02",
- } {
- if parsed, err := time.Parse(layout, s); err == nil {
- return parsed, true
- }
- }
- return time.Time{}, false
-}
-
-func scanGoogleTasks(rows *sql.Rows) ([]models.GoogleTask, error) {
- var tasks []models.GoogleTask
- for rows.Next() {
- var t models.GoogleTask
- var dueDate, updatedAt sql.NullString
-
- err := rows.Scan(&t.ID, &t.Title, &t.Notes, &t.Status, &t.Completed, &dueDate, &updatedAt, &t.ListID, &t.URL)
- if err != nil {
- return nil, err
- }
-
- if dueDate.Valid {
- if parsed, ok := parseGoogleTaskTime(dueDate.String); ok {
- t.DueDate = &parsed
- }
- }
- if updatedAt.Valid {
- if parsed, ok := parseGoogleTaskTime(updatedAt.String); ok {
- t.UpdatedAt = parsed
- }
- }
-
- tasks = append(tasks, t)
- }
-
- return tasks, rows.Err()
-}
-
-// GetGoogleTasks retrieves all cached Google Tasks
-func (s *Store) GetGoogleTasks() ([]models.GoogleTask, error) {
- rows, err := s.db.Query(`
- SELECT id, title, notes, status, completed, due_date, updated_at, list_id, url
- FROM google_tasks
- ORDER BY completed ASC, CASE WHEN due_date IS NULL THEN 1 ELSE 0 END, due_date ASC
- `)
- if err != nil {
- return nil, err
- }
- defer func() { _ = rows.Close() }()
-
- return scanGoogleTasks(rows)
-}
-
-// GetGoogleTasksByDateRange retrieves cached Google Tasks due before end, including overdue
-// tasks (due before start) so they keep appearing until completed.
-func (s *Store) GetGoogleTasksByDateRange(start, end time.Time) ([]models.GoogleTask, error) {
- rows, err := s.db.Query(`
- SELECT id, title, notes, status, completed, due_date, updated_at, list_id, url
- FROM google_tasks
- WHERE due_date IS NULL OR due_date < ?
- ORDER BY completed ASC, CASE WHEN due_date IS NULL THEN 1 ELSE 0 END, due_date ASC
- `, end)
- if err != nil {
- return nil, err
- }
- defer func() { _ = rows.Close() }()
-
- return scanGoogleTasks(rows)
-}
-
// Agent operations
// CreateAgentSession creates a new pending agent session
generated by cgit v1.2.3 (git 2.39.1) at 2026-09-14 12:07:36 +0000