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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
# rss-recent.rb: RSS recent plugin
#
# rss_recnet: show recnet list from RSS
# parameters (default):
# url: URL of RSS
# max: max of list itmes(5)
# cache_time: cache time(second) of RSS(60*60)
#
#
# Copyright (c) 2003 Kouhei Sutou <kou@cozmixng.org>
# Distributed under the GPL
#
require "rss/rss"
RSS_RECENT_FIELD_SEPARATOR = "\0"
RSS_RECENT_VERSION = "0.0.2"
RSS_RECENT_CONTENT_TYPE = {
"User-Agent" => "tDiary RSS recent plugin version #{RSS_RECENT_VERSION}. " <<
"Using RSS parser version is #{::RSS::VERSION}."
}
def rss_recent(url, max=5, cache_time=3600)
cache_file = "#{@cache_path}/rss-recent.#{CGI.escape(url)}"
rss_recent_cache_rss(url, cache_file, cache_time.to_i)
return '' unless test(?r, cache_file)
rv = "<ul>\n"
File.open(cache_file) do |f|
max.to_i.times do
title = f.gets(RSS_RECENT_FIELD_SEPARATOR)
break if title.nil?
rv << '<li>'
link = f.gets(RSS_RECENT_FIELD_SEPARATOR)
unless link.nil?
rv << %Q!<a href="#{CGI.escapeHTML(link.chomp(RSS_RECENT_FIELD_SEPARATOR))}">!
end
rv << CGI::escapeHTML(title.chomp(RSS_RECENT_FIELD_SEPARATOR))
rv << '</a>' unless link.nil?
rv << "</li>\n"
end
end
rv << "</ul>\n"
rv
end
class InvalidResourceError < StandardError; end
def rss_recent_cache_rss(url, cache_file, cache_time)
begin
raise if Time.now > File.mtime(cache_file) + cache_time
rescue
require 'net/http'
require 'uri/generic'
require 'rss/parser'
require 'rss/1.0'
require 'rss/2.0'
begin
ur = URI.parse(url)
raise URI::InvalidURIError if ur.scheme != "http"
rss_source = rss_recent_fetch_rss(ur)
# parse RSS
rss = ::RSS::Parser.parse(rss_source, false)
raise ::RSS::Error if rss.nil?
# pre processing
begin
rss.output_encoding = charset
rescue ::RSS::UnknownConversionMethodError
end
tlary = rss.items.collect{|item| [item.title, item.link]}
rss_recent_write_to_cache(cache_file, tlary)
rescue URI::InvalidURIError
rss_recent_write_to_cache(cache_file, [['Invalid URI', url]])
rescue InvalidResourceError, ::RSS::Error
rss_recent_write_to_cache(cache_file, [['Invalid Resource', url]])
end
end
end
def rss_recent_fetch_rss(uri)
rss = ''
begin
Net::HTTP.start(uri.host, uri.port || 80) do |http|
path = uri.path
path << "?#{uri.query}" if uri.query
req = http.request_get(path)
raise InvalidResourceError unless req.code == "200"
rss << req.body
end
rescue TimeoutError, SocketError
raise InvalidResourceError
end
rss
end
def rss_recent_write_to_cache(cache_file, array_of_titles_and_links)
File.open(cache_file, 'w') do |f|
f.flock(File::LOCK_EX)
array_of_titles_and_links.each do |title, link|
f << "#{title}#{RSS_RECENT_FIELD_SEPARATOR}"
f << "#{link}#{RSS_RECENT_FIELD_SEPARATOR}"
end
f.flock(File::LOCK_UN)
end
end
|
