1 files changed, 34 insertions, 0 deletions
diff --git a/internal/store/sqlite.go b/internal/store/sqlite.go
index c2f6e98..396ac54 100644
--- a/internal/store/sqlite.go
+++ b/internal/store/sqlite.go
@@ -701,6 +701,40 @@ func (s *Store) DeleteUserShoppingItem(id int64) error {
 	return err
 }
 
+// SetShoppingItemChecked sets the checked state for an external shopping item
+func (s *Store) SetShoppingItemChecked(source, itemID string, checked bool) error {
+	checkedInt := 0
+	if checked {
+		checkedInt = 1
+	}
+	_, err := s.db.Exec(`
+		INSERT INTO shopping_item_checks (source, item_id, checked, updated_at)
+		VALUES (?, ?, ?, CURRENT_TIMESTAMP)
+		ON CONFLICT(source, item_id) DO UPDATE SET checked = ?, updated_at = CURRENT_TIMESTAMP
+	`, source, itemID, checkedInt, checkedInt)
+	return err
+}
+
+// GetShoppingItemChecks returns a map of item_id -> checked for a given source
+func (s *Store) GetShoppingItemChecks(source string) (map[string]bool, error) {
+	rows, err := s.db.Query(`SELECT item_id, checked FROM shopping_item_checks WHERE source = ?`, source)
+	if err != nil {
+		return nil, err
+	}
+	defer func() { _ = rows.Close() }()
+
+	checks := make(map[string]bool)
+	for rows.Next() {
+		var itemID string
+		var checked int
+		if err := rows.Scan(&itemID, &checked); err != nil {
+			return nil, err
+		}
+		checks[itemID] = checked == 1
+	}
+	return checks, rows.Err()
+}
+
 // GetTasksByDateRange retrieves tasks due within a specific date range
 func (s *Store) GetTasksByDateRange(start, end time.Time) ([]models.Task, error) {
 	rows, err := s.db.Query(`