rss 1.0.go

package rss

import (
	"bytes"
	"encoding/xml"
	"fmt"
	"sort"
	"strings"
	"time"
)

func parseRSS1(data []byte, read *db) (*Feed, error) {
	feed := rss1_0Feed{}
	p := xml.NewDecoder(bytes.NewReader(data))
	p.CharsetReader = charsetReader
	err := p.Decode(&feed)
	if err != nil {
		return nil, err
	}
	if feed.Channel == nil {
		return nil, fmt.Errorf("Error: no channel found in %q.", string(data))
	}
	
	channel := feed.Channel
	
	out := new(Feed)
	out.Title = channel.Title
	out.Description = channel.Description
	out.Link = channel.Link
	out.Image = channel.Image.Image()
	if channel.MinsToLive != 0 {
		sort.Ints(channel.SkipHours)
		next := time.Now().Add(time.Duration(channel.MinsToLive) * time.Minute)
		for _, hour := range channel.SkipHours {
			if hour == next.Hour() {
				next.Add(time.Duration(60 - next.Minute()) * time.Minute)
			}
		}
		trying := true
		for trying {
			trying = false
			for _, day := range channel.SkipDays {
				if strings.Title(day) == next.Weekday().String() {
					next.Add(time.Duration(24 - next.Hour()) * time.Hour)
					trying = true
					break
				}
			}
		}
		
		out.Refresh = next
	}
	
	if out.Refresh.IsZero() {
		out.Refresh = time.Now().Add(10 * time.Minute)
	}
	
	if feed.Items == nil {
		return nil, fmt.Errorf("Error: no feeds found in %q.", string(data))
	}
	
	out.Items = make([]*Item, 0, len(feed.Items))
	out.ItemMap = make(map[string]struct{})
	
	// Process items.
	for _, item := range feed.Items {
		
		// Skip items already known.
		if read.req <- item.ID; <- read.res {
			continue
		}
		
		next := new(Item)
		next.Title = item.Title
		next.Content = item.Content
		next.Link = item.Link
		if item.Date != "" {
			next.Date, err = parseTime(item.Date)
			if err != nil {
				return nil, err
			}
		}
		next.ID = item.ID
		next.Read = false
		
		if next.ID == "" {
			if next.Link == "" {
				fmt.Printf("Warning: Item %q has no ID or link and will be ignored.\n", next.Title)
				continue
			}
			next.ID = next.Link
		}
		
		if _, ok := out.ItemMap[next.ID]; ok {
			fmt.Printf("Warning: Item %q has duplicate ID.\n", next.Title)
			continue
		}
		
		out.Items = append(out.Items, next)
		out.ItemMap[next.ID] = struct{}{}
		out.Unread++
	}
	
	return out, nil
}

type rss1_0Feed struct {
	XMLName  xml.Name       `xml:"RDF"`
	Channel  *rss1_0Channel `xml:"channel"`
	Items    []rss1_0Item   `xml:"item"`
}

type rss1_0Channel struct {
	XMLName     xml.Name     `xml:"channel"`
	Title       string       `xml:"title"`
	Description string       `xml:"description"`
	Link        string       `xml:"link"`
	Image       rss1_0Image  `xml:"image"`
	MinsToLive  int          `xml:"ttl"`
	SkipHours   []int        `xml:"skipHours>hour"`
	SkipDays    []string     `xml:"skipDays>day"`
}

type rss1_0Item struct {
	XMLName xml.Name `xml:"item"`
	Title   string   `xml:"title"`
	Content string   `xml:"description"`
	Link    string   `xml:"link"`
	Date    string   `xml:"pubDate"`
	ID      string   `xml:"guid"`
}

type rss1_0Image struct {
	XMLName xml.Name `xml:"image"`
	Title   string   `xml:"title"`
	Url     string   `xml:"url"`
	Height  int      `xml:"height"`
	Width   int      `xml:"width"`
}

func (i *rss1_0Image) Image() *Image {
	out := new(Image)
	out.Title = i.Title
	out.Url = i.Url
	out.Height = uint32(i.Height)
	out.Width = uint32(i.Width)
	return out
}