1 files changed, 118 insertions, 0 deletions
diff --git a/models/item/item.go b/models/item/item.go
new file mode 100644
index 0000000..51166c4
--- /dev/null
+++ b/models/item/item.go
@@ -0,0 +1,118 @@
+package item
+
+import (
+	"fmt"
+	"log"
+	"neko/models"
+	//	"database/sql"
+	"github.com/microcosm-cc/bluemonday"
+)
+
+type Item struct {
+	Id          int64  `json:"_id,string,omitempty"`
+	Title       string `json:"title"`
+	Url         string `json:"url"`
+	Description string `json:"description"`
+	ReadState   bool   `json:"read"`
+	FeedId      int64
+	PublishDate string `json:"publish_date"`
+	FeedTitle   string `json:"feed_title"`
+	FeedUrl     string `json:"feed_url"`
+}
+
+func (i *Item) Print() {
+	fmt.Printf("id: %d\n", i.Id)
+	fmt.Printf("title: %s\n", i.Title)
+	fmt.Printf("ReadState: %d\n", i.ReadState)
+}
+
+func (i *Item) Create() error {
+	res, err := models.DB.Exec(`INSERT INTO 
+                                item(title, url, description, feed_id)
+                                VALUES(?, ?, ?, ?)`, i.Title, i.Url, i.Description, i.FeedId)
+	if err != nil {
+		return err
+	}
+
+	id, _ := res.LastInsertId()
+	i.Id = id
+
+	return nil
+}
+
+func (i *Item) Save() {
+	_, err := models.DB.Exec(`UPDATE item
+                              SET read_state=? 
+                              WHERE id=?`, i.ReadState, i.Id)
+	if err != nil {
+		log.Println(err)
+	}
+}
+
+func (i *Item) FullSave() {
+	_, err := models.DB.Exec(`UPDATE item
+                              SET title=?, url=?, description=?, feed_id=? 
+                              WHERE id=?`, i.Title, i.Url, i.Description, i.FeedId, i.Id)
+	if err != nil {
+		log.Println(err)
+	}
+}
+
+func Filter(max_id int64, feed_id int64, unread_only bool) ([]*Item, error) {
+
+	var args []interface{}
+
+	query := `SELECT item.id, item.title, item.url, item.description, 
+                     item.read_state, item.publish_date,
+                     feed.url, feed.title
+              FROM item,feed 
+              WHERE item.feed_id=feed.id  `
+
+	if max_id != 0 {
+		query = query + "AND item.id < ? "
+		args = append(args, max_id)
+	}
+
+	if feed_id != 0 {
+		query = query + " AND feed.id=? "
+		args = append(args, feed_id)
+	}
+
+	if unread_only {
+		query = query + " AND item.read_state=0 "
+	}
+
+	query = query + "ORDER BY item.id DESC LIMIT 15"
+	// log.Println(query)
+	// log.Println(args...)
+
+	rows, err := models.DB.Query(query, args...)
+	if err != nil {
+		log.Println(err)
+		return nil, err
+	}
+	defer rows.Close()
+
+	p := bluemonday.NewPolicy()
+	p.AllowElements("blockquote", "a", "img", "p", "h1", "h2", "h3", "h4", "b", "i", "em", "strong")
+	p.AllowAttrs("href").OnElements("a")
+	p.AllowAttrs("src", "alt").OnElements("img")
+
+	
+	items := make([]*Item, 0)
+	for rows.Next() {
+		i := new(Item)
+		err := rows.Scan(&i.Id, &i.Title, &i.Url, &i.Description, &i.ReadState, &i.PublishDate, &i.FeedUrl, &i.FeedTitle)
+		if err != nil {
+			log.Println(err)
+			return nil, err
+		}
+		i.Description = p.Sanitize(i.Description)
+		// TODO: sanitize other fields
+		items = append(items, i)
+	}
+	if err = rows.Err(); err != nil {
+		return nil, err
+	}
+	return items, nil
+}