summaryrefslogtreecommitdiff
path: root/internal/store/sqlite.go
diff options
context:
space:
mode:
authorPeter Stone <thepeterstone@gmail.com>2026-07-15 09:44:47 +0000
committerPeter Stone <thepeterstone@gmail.com>2026-07-16 02:53:12 +0000
commit3d69922b0a9904be7e2261d4376ea051bb29afd4 (patch)
treeec825c39a14c0f99adfc6e781529377fef9254f9 /internal/store/sqlite.go
parentb27b7e681952df44f05c60eea7218798b31d1fb4 (diff)
refactor(store): extract calendar and Google Tasks methods from sqlite.go
Pure move: SaveCalendarEvents/GetCalendarEvents/GetCalendarEventsByDateRange into calendar.go, SaveGoogleTasks/GetGoogleTasks/GetGoogleTasksByDateRange into google_tasks.go. Neither cluster had dedicated tests in sqlite_test.go to move. No behavior change. Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01VTUSAEKfsPc6WGDq45yPHD
Diffstat (limited to 'internal/store/sqlite.go')
-rw-r--r--internal/store/sqlite.go189
1 files changed, 0 insertions, 189 deletions
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