rss.go 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241
  1. // Copyright 2017 Frédéric Guillot. All rights reserved.
  2. // Use of this source code is governed by the Apache 2.0
  3. // license that can be found in the LICENSE file.
  4. package rss
  5. import (
  6. "encoding/xml"
  7. "path"
  8. "strconv"
  9. "strings"
  10. "time"
  11. "github.com/miniflux/miniflux/crypto"
  12. "github.com/miniflux/miniflux/logger"
  13. "github.com/miniflux/miniflux/model"
  14. "github.com/miniflux/miniflux/reader/date"
  15. "github.com/miniflux/miniflux/reader/sanitizer"
  16. "github.com/miniflux/miniflux/url"
  17. )
  18. type rssFeed struct {
  19. XMLName xml.Name `xml:"rss"`
  20. Version string `xml:"version,attr"`
  21. Title string `xml:"channel>title"`
  22. Links []rssLink `xml:"channel>link"`
  23. Language string `xml:"channel>language"`
  24. Description string `xml:"channel>description"`
  25. PubDate string `xml:"channel>pubDate"`
  26. ItunesAuthor string `xml:"http://www.itunes.com/dtds/podcast-1.0.dtd channel>author"`
  27. Items []rssItem `xml:"channel>item"`
  28. }
  29. type rssLink struct {
  30. XMLName xml.Name
  31. Data string `xml:",chardata"`
  32. Href string `xml:"href,attr"`
  33. Rel string `xml:"rel,attr"`
  34. }
  35. type rssItem struct {
  36. GUID string `xml:"guid"`
  37. Title string `xml:"title"`
  38. Links []rssLink `xml:"link"`
  39. OriginalLink string `xml:"http://rssnamespace.org/feedburner/ext/1.0 origLink"`
  40. Description string `xml:"description"`
  41. Content string `xml:"http://purl.org/rss/1.0/modules/content/ encoded"`
  42. PubDate string `xml:"pubDate"`
  43. Date string `xml:"http://purl.org/dc/elements/1.1/ date"`
  44. Authors []rssAuthor `xml:"author"`
  45. Creator string `xml:"http://purl.org/dc/elements/1.1/ creator"`
  46. Enclosures []rssEnclosure `xml:"enclosure"`
  47. OrigEnclosureLink string `xml:"http://rssnamespace.org/feedburner/ext/1.0 origEnclosureLink"`
  48. }
  49. type rssAuthor struct {
  50. XMLName xml.Name
  51. Data string `xml:",chardata"`
  52. Name string `xml:"name"`
  53. Inner string `xml:",innerxml"`
  54. }
  55. type rssEnclosure struct {
  56. URL string `xml:"url,attr"`
  57. Type string `xml:"type,attr"`
  58. Length string `xml:"length,attr"`
  59. }
  60. func (r *rssFeed) GetSiteURL() string {
  61. for _, element := range r.Links {
  62. if element.XMLName.Space == "" {
  63. return strings.TrimSpace(element.Data)
  64. }
  65. }
  66. return ""
  67. }
  68. func (r *rssFeed) GetFeedURL() string {
  69. for _, element := range r.Links {
  70. if element.XMLName.Space == "http://www.w3.org/2005/Atom" {
  71. return strings.TrimSpace(element.Href)
  72. }
  73. }
  74. return ""
  75. }
  76. func (r *rssFeed) Transform() *model.Feed {
  77. feed := new(model.Feed)
  78. feed.SiteURL = r.GetSiteURL()
  79. feed.FeedURL = r.GetFeedURL()
  80. feed.Title = strings.TrimSpace(r.Title)
  81. if feed.Title == "" {
  82. feed.Title = feed.SiteURL
  83. }
  84. for _, item := range r.Items {
  85. entry := item.Transform()
  86. if entry.Author == "" && r.ItunesAuthor != "" {
  87. entry.Author = r.ItunesAuthor
  88. }
  89. entry.Author = strings.TrimSpace(sanitizer.StripTags(entry.Author))
  90. if entry.URL == "" {
  91. entry.URL = feed.SiteURL
  92. } else {
  93. entryURL, err := url.AbsoluteURL(feed.SiteURL, entry.URL)
  94. if err == nil {
  95. entry.URL = entryURL
  96. }
  97. }
  98. if entry.Title == "" {
  99. entry.Title = entry.URL
  100. }
  101. feed.Entries = append(feed.Entries, entry)
  102. }
  103. return feed
  104. }
  105. func (r *rssItem) GetDate() time.Time {
  106. value := r.PubDate
  107. if r.Date != "" {
  108. value = r.Date
  109. }
  110. if value != "" {
  111. result, err := date.Parse(value)
  112. if err != nil {
  113. logger.Error("rss: %v", err)
  114. return time.Now()
  115. }
  116. return result
  117. }
  118. return time.Now()
  119. }
  120. func (r *rssItem) GetAuthor() string {
  121. for _, element := range r.Authors {
  122. if element.Name != "" {
  123. return element.Name
  124. }
  125. if element.Inner != "" {
  126. return element.Inner
  127. }
  128. }
  129. return r.Creator
  130. }
  131. func (r *rssItem) GetHash() string {
  132. for _, value := range []string{r.GUID, r.GetURL()} {
  133. if value != "" {
  134. return crypto.Hash(value)
  135. }
  136. }
  137. return ""
  138. }
  139. func (r *rssItem) GetContent() string {
  140. if r.Content != "" {
  141. return r.Content
  142. }
  143. return r.Description
  144. }
  145. func (r *rssItem) GetURL() string {
  146. if r.OriginalLink != "" {
  147. return r.OriginalLink
  148. }
  149. for _, link := range r.Links {
  150. if link.XMLName.Space == "http://www.w3.org/2005/Atom" && link.Href != "" && isValidLinkRelation(link.Rel) {
  151. return strings.TrimSpace(link.Href)
  152. }
  153. if link.Data != "" {
  154. return strings.TrimSpace(link.Data)
  155. }
  156. }
  157. return ""
  158. }
  159. func (r *rssItem) GetEnclosures() model.EnclosureList {
  160. enclosures := make(model.EnclosureList, 0)
  161. for _, enclosure := range r.Enclosures {
  162. length, _ := strconv.ParseInt(enclosure.Length, 10, 0)
  163. enclosureURL := enclosure.URL
  164. if r.OrigEnclosureLink != "" {
  165. filename := path.Base(r.OrigEnclosureLink)
  166. if strings.Contains(enclosureURL, filename) {
  167. enclosureURL = r.OrigEnclosureLink
  168. }
  169. }
  170. enclosures = append(enclosures, &model.Enclosure{
  171. URL: enclosureURL,
  172. MimeType: enclosure.Type,
  173. Size: length,
  174. })
  175. }
  176. return enclosures
  177. }
  178. func (r *rssItem) Transform() *model.Entry {
  179. entry := new(model.Entry)
  180. entry.URL = r.GetURL()
  181. entry.Date = r.GetDate()
  182. entry.Author = r.GetAuthor()
  183. entry.Hash = r.GetHash()
  184. entry.Content = r.GetContent()
  185. entry.Title = strings.TrimSpace(r.Title)
  186. entry.Enclosures = r.GetEnclosures()
  187. return entry
  188. }
  189. func isValidLinkRelation(rel string) bool {
  190. switch rel {
  191. case "", "alternate", "enclosure", "related", "self", "via":
  192. return true
  193. default:
  194. if strings.HasPrefix(rel, "http") {
  195. return true
  196. }
  197. return false
  198. }
  199. }