rss.go 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243
  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. Comments string `xml:"comments"`
  41. Description string `xml:"description"`
  42. Content string `xml:"http://purl.org/rss/1.0/modules/content/ encoded"`
  43. PubDate string `xml:"pubDate"`
  44. Date string `xml:"http://purl.org/dc/elements/1.1/ date"`
  45. Authors []rssAuthor `xml:"author"`
  46. Creator string `xml:"http://purl.org/dc/elements/1.1/ creator"`
  47. Enclosures []rssEnclosure `xml:"enclosure"`
  48. OrigEnclosureLink string `xml:"http://rssnamespace.org/feedburner/ext/1.0 origEnclosureLink"`
  49. }
  50. type rssAuthor struct {
  51. XMLName xml.Name
  52. Data string `xml:",chardata"`
  53. Name string `xml:"name"`
  54. Inner string `xml:",innerxml"`
  55. }
  56. type rssEnclosure struct {
  57. URL string `xml:"url,attr"`
  58. Type string `xml:"type,attr"`
  59. Length string `xml:"length,attr"`
  60. }
  61. func (r *rssFeed) GetSiteURL() string {
  62. for _, element := range r.Links {
  63. if element.XMLName.Space == "" {
  64. return strings.TrimSpace(element.Data)
  65. }
  66. }
  67. return ""
  68. }
  69. func (r *rssFeed) GetFeedURL() string {
  70. for _, element := range r.Links {
  71. if element.XMLName.Space == "http://www.w3.org/2005/Atom" {
  72. return strings.TrimSpace(element.Href)
  73. }
  74. }
  75. return ""
  76. }
  77. func (r *rssFeed) Transform() *model.Feed {
  78. feed := new(model.Feed)
  79. feed.SiteURL = r.GetSiteURL()
  80. feed.FeedURL = r.GetFeedURL()
  81. feed.Title = strings.TrimSpace(r.Title)
  82. if feed.Title == "" {
  83. feed.Title = feed.SiteURL
  84. }
  85. for _, item := range r.Items {
  86. entry := item.Transform()
  87. if entry.Author == "" && r.ItunesAuthor != "" {
  88. entry.Author = r.ItunesAuthor
  89. }
  90. entry.Author = strings.TrimSpace(sanitizer.StripTags(entry.Author))
  91. if entry.URL == "" {
  92. entry.URL = feed.SiteURL
  93. } else {
  94. entryURL, err := url.AbsoluteURL(feed.SiteURL, entry.URL)
  95. if err == nil {
  96. entry.URL = entryURL
  97. }
  98. }
  99. if entry.Title == "" {
  100. entry.Title = entry.URL
  101. }
  102. feed.Entries = append(feed.Entries, entry)
  103. }
  104. return feed
  105. }
  106. func (r *rssItem) GetDate() time.Time {
  107. value := r.PubDate
  108. if r.Date != "" {
  109. value = r.Date
  110. }
  111. if value != "" {
  112. result, err := date.Parse(value)
  113. if err != nil {
  114. logger.Error("rss: %v", err)
  115. return time.Now()
  116. }
  117. return result
  118. }
  119. return time.Now()
  120. }
  121. func (r *rssItem) GetAuthor() string {
  122. for _, element := range r.Authors {
  123. if element.Name != "" {
  124. return element.Name
  125. }
  126. if element.Inner != "" {
  127. return element.Inner
  128. }
  129. }
  130. return r.Creator
  131. }
  132. func (r *rssItem) GetHash() string {
  133. for _, value := range []string{r.GUID, r.GetURL()} {
  134. if value != "" {
  135. return crypto.Hash(value)
  136. }
  137. }
  138. return ""
  139. }
  140. func (r *rssItem) GetContent() string {
  141. if r.Content != "" {
  142. return r.Content
  143. }
  144. return r.Description
  145. }
  146. func (r *rssItem) GetURL() string {
  147. if r.OriginalLink != "" {
  148. return r.OriginalLink
  149. }
  150. for _, link := range r.Links {
  151. if link.XMLName.Space == "http://www.w3.org/2005/Atom" && link.Href != "" && isValidLinkRelation(link.Rel) {
  152. return strings.TrimSpace(link.Href)
  153. }
  154. if link.Data != "" {
  155. return strings.TrimSpace(link.Data)
  156. }
  157. }
  158. return ""
  159. }
  160. func (r *rssItem) GetEnclosures() model.EnclosureList {
  161. enclosures := make(model.EnclosureList, 0)
  162. for _, enclosure := range r.Enclosures {
  163. length, _ := strconv.ParseInt(enclosure.Length, 10, 0)
  164. enclosureURL := enclosure.URL
  165. if r.OrigEnclosureLink != "" {
  166. filename := path.Base(r.OrigEnclosureLink)
  167. if strings.Contains(enclosureURL, filename) {
  168. enclosureURL = r.OrigEnclosureLink
  169. }
  170. }
  171. enclosures = append(enclosures, &model.Enclosure{
  172. URL: enclosureURL,
  173. MimeType: enclosure.Type,
  174. Size: length,
  175. })
  176. }
  177. return enclosures
  178. }
  179. func (r *rssItem) Transform() *model.Entry {
  180. entry := new(model.Entry)
  181. entry.URL = r.GetURL()
  182. entry.CommentsURL = r.Comments
  183. entry.Date = r.GetDate()
  184. entry.Author = r.GetAuthor()
  185. entry.Hash = r.GetHash()
  186. entry.Content = r.GetContent()
  187. entry.Title = strings.TrimSpace(r.Title)
  188. entry.Enclosures = r.GetEnclosures()
  189. return entry
  190. }
  191. func isValidLinkRelation(rel string) bool {
  192. switch rel {
  193. case "", "alternate", "enclosure", "related", "self", "via":
  194. return true
  195. default:
  196. if strings.HasPrefix(rel, "http") {
  197. return true
  198. }
  199. return false
  200. }
  201. }