-
Notifications
You must be signed in to change notification settings - Fork 0
/
rdf.go
103 lines (88 loc) · 2.03 KB
/
rdf.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
package parser
import (
"encoding/xml"
"fmt"
"strings"
"time"
)
func parseRDF(data []byte, logger logger) (*Feed, error) {
feed := &rdfFeed{}
if err := xml.Unmarshal(data, feed); err != nil {
return nil, fmt.Errorf("unable to parse RDF feed: %w", err)
}
return feed.Convert(logger), nil
}
type rdfFeed struct {
XMLName xml.Name `xml:"RDF"`
Title string `xml:"channel>title"`
Link string `xml:"channel>link"`
Image *rdfImage `xml:"image"`
Items []*rdfItem `xml:"item"`
}
func (f *rdfFeed) Convert(logger logger) *Feed {
feed := &Feed{
Title: strings.TrimSpace(f.Title),
Link: strings.TrimSpace(f.Link),
Image: f.Image.Convert(),
}
for _, i := range f.Items {
item := i.Convert(logger)
if item.Link == "" {
item.Link = feed.Link
} else {
linkURL, err := absoluteURL(feed.Link, item.Link)
if err == nil {
item.Link = linkURL
}
}
feed.Items = append(feed.Items, item)
}
return feed
}
type rdfImage struct {
URL string `xml:"url"`
}
func (i *rdfImage) Convert() *Image {
if i == nil {
return nil
}
return &Image{
URL: i.URL,
}
}
type rdfItem struct {
Title string `xml:"title"`
Link string `xml:"link"`
Description string `xml:"description"`
DublinCoreDate string `xml:"http://purl.org/dc/elements/1.1/ date"`
DublinCoreContent string `xml:"http://purl.org/rss/1.0/modules/content/ encoded"`
}
func (i *rdfItem) Convert(logger logger) *Item {
return &Item{
Title: strings.TrimSpace(i.Title),
Link: strings.TrimSpace(i.Link),
Date: i.date(logger),
Content: i.content(),
}
}
func (i *rdfItem) content() *string {
switch {
case i.DublinCoreContent != "":
return &i.DublinCoreContent
case i.Description != "":
return &i.Description
default:
return nil
}
}
func (i *rdfItem) date(logger logger) *time.Time {
if i.DublinCoreDate != "" {
t, err := parseDateTime(i.DublinCoreDate)
if err != nil {
logger.Error("rdf: failed to parse date '%s': %s", i.DublinCoreDate, err)
return nil
}
return t
}
return nil
}