36 lines
745 B
Go
36 lines
745 B
Go
package model
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
)
|
|
|
|
func (m *Model) GetItems() ([]*Item, error) {
|
|
rows, err := m.db.Queryx("SELECT * FROM items")
|
|
if err != nil {
|
|
return nil, fmt.Errorf("couldn't query db: %v", err)
|
|
}
|
|
|
|
items := []*Item{}
|
|
for rows.Next() {
|
|
item := &Item{}
|
|
if err := rows.StructScan(&item); err != nil {
|
|
continue
|
|
}
|
|
items = append(items, item)
|
|
}
|
|
|
|
return items, nil
|
|
}
|
|
|
|
func (m *Model) UpdateRefreshedAt(itemId int64, refreshedAt time.Time) error {
|
|
if _, err := m.db.NamedExec("UPDATE items SET refreshed_at = :refreshed_at WHERE id = :item_id", map[string]any{
|
|
"refreshed_at": refreshedAt,
|
|
"item_id": itemId,
|
|
}); err != nil {
|
|
return fmt.Errorf("failed to update refreshed_at field: %v", err)
|
|
}
|
|
|
|
return nil
|
|
}
|