ward/ripnews
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: ward:master
Branches Tags
ward:master
ward:ripnews-20200312
ward:ripnews-20200311
..
compare: ward:ripnews-20200312
Branches Tags
ward:master
ward:ripnews-20200312
ward:ripnews-20200311

No commits in common. "master" and "ripnews-20200312" have entirely different histories.
master ... ripnews-20

3 changed files with 38 additions and 63 deletions
Download patch file Download diff file Expand all files Collapse all files

3
encode/uuencode.rb
View file

@ -90,8 +90,7 @@ def _uudecode_file(file, outfile)
next if line =~ /[a-z]/ next if line =~ /[a-z]/
next if line == nil next if line == nil
next unless ((((line[0].ord - 32) & 077) + 2) / 3).to_i == (line.length/4).to_i next unless ((((line[0].ord - 32) & 077) + 2) / 3).to_i == (line.length/4).to_i
#line.unpack("u").each{|x| outfile.print x} line.unpack("u").each{|x| outfile.print x}
line.unpack("u").each{|x| outfile.write x}
end end
puts "No \"end\" found!!!" puts "No \"end\" found!!!"

51
news/article.rb
View file

@ -1,3 +1,6 @@
# $Dwarf: article.rb,v 1.114 2005/05/12 07:39:53 ward Exp $
# $Source$
# #
# Copyright (c) 2002, 2003, 2004, 2005, 2006, 2007, 2008 Ward Wouts <ward@wouts.nl> # Copyright (c) 2002, 2003, 2004, 2005, 2006, 2007, 2008 Ward Wouts <ward@wouts.nl>
# #
@ -20,7 +23,7 @@ require Pathname.new(__FILE__).dirname + '../news/newsrc'
require 'tempfile' require 'tempfile'
require 'timeout' require 'timeout'
#require 'yaml' #require 'yaml'
#require 'profiler' # removed from ruby? require 'profiler'
class ArticleError < RuntimeError; end class ArticleError < RuntimeError; end
class TempError < ArticleError; end class TempError < ArticleError; end
@ -111,10 +114,6 @@ def initialize(nntpservers, groupname, newsrc="~/.newsrc", maxage=0)
@serverlist = [] @serverlist = []
@serverpasses = {} @serverpasses = {}
@maxage = maxage.to_i @maxage = maxage.to_i
@oldestallowed = 0
if @maxage != 0
@oldestallowed = (DateTime.now - @maxage).strftime('%Y%m%d').to_i
end
tmplist = nntpservers.split('|') tmplist = nntpservers.split('|')
tmplist.each{ |server| tmplist.each{ |server|
@ -149,7 +148,7 @@ def initialize(nntpservers, groupname, newsrc="~/.newsrc", maxage=0)
# p server # p server
# p Time.now # p Time.now
begin begin
Timeout.timeout(60) do timeout(60) do
#p "connecting" #p "connecting"
@connections[server]["nntp"] = Net::KANNTP.new(server, 119, @serverpasses[server]['user'], @serverpasses[server]['pass']) @connections[server]["nntp"] = Net::KANNTP.new(server, 119, @serverpasses[server]['user'], @serverpasses[server]['pass'])
end end
@ -177,7 +176,7 @@ def reconnect(server)
retries = 0 retries = 0
begin begin
puts "Trying to kill old connection #{Time.now}" puts "Trying to kill old connection #{Time.now}"
Timeout.timeout(10) do timeout(10) do
@connections[server]["nntp"].quit @connections[server]["nntp"].quit
end end
puts "Killed old connection #{Time.now}" puts "Killed old connection #{Time.now}"
@ -189,7 +188,7 @@ def reconnect(server)
puts "Trying to reconnect #{Time.now}" puts "Trying to reconnect #{Time.now}"
sleep 3 sleep 3
#timeout(180) do #timeout(180) do
Timeout.timeout(60) do timeout(60) do
@connections[server]["nntp"] = Net::KANNTP.new(server, 119, @serverpasses[server]['user'], @serverpasses[server]['pass']) @connections[server]["nntp"] = Net::KANNTP.new(server, 119, @serverpasses[server]['user'], @serverpasses[server]['pass'])
end end
resp = @connections[server]["nntp"].mode_reader resp = @connections[server]["nntp"].mode_reader
@ -332,8 +331,7 @@ def get_articles(cachedir=false)
art[id] = {} unless art.has_key?(id) art[id] = {} unless art.has_key?(id)
begin begin
lastdate = DateTime.parse(date) lastdate = art[id]["date"] = DateTime.parse(date).strftime('%Y%m%d')
art[id]["date"] = DateTime.parse(date).strftime('%Y%m%d')
rescue rescue
puts $!.message puts $!.message
puts id puts id
@ -356,16 +354,14 @@ def get_articles(cachedir=false)
# dit wellicht alleen doen indien preselector hem uitkiest # dit wellicht alleen doen indien preselector hem uitkiest
# en anders een leuk regeltje aan de cache toevoegen, # en anders een leuk regeltje aan de cache toevoegen,
# maar niet in het geheugen houden # maar niet in het geheugen houden
if art[id]["date"].to_i >= @oldestallowed && preselect(art[id]["subject"]) if preselect(art[id]["subject"])
add(id.to_i, art[id]["messid"], art[id]["date"], art[id]["from"], art[id]["subject"], server) add(id.to_i, art[id]["messid"], art[id]["date"], art[id]["from"], art[id]["subject"], server)
end end
if art[id]["date"].to_i >= @oldestallowed cache_add(cachedir, id, art[id]["messid"], art[id]["date"], art[id]["from"], art[id]["subject"], server)
cache_add(cachedir, id, art[id]["messid"], art[id]["date"], art[id]["from"], art[id]["subject"], server)
end
end end
} }
if @maxage and @maxage > 0 if @maxage and @maxage > 0
if lastdate < ( DateTime.now - @maxage ) if DateTime.parse(lastdate) < ( DateTime.now - @maxage )
puts "Skipping articles older than #{DateTime.now - @maxage}" puts "Skipping articles older than #{DateTime.now - @maxage}"
break break
end end
@ -388,7 +384,7 @@ def get_group_info(server)
first = "" first = ""
last = "" last = ""
begin begin
Timeout.timeout(30) do timeout(30) do
begin begin
resp, count, first, last, name = @connections[server]["nntp"].group(@group) resp, count, first, last, name = @connections[server]["nntp"].group(@group)
rescue Net::NNTPReplyError rescue Net::NNTPReplyError
@ -422,7 +418,7 @@ def get_xhdr(server, range, header)
resp = "" resp = ""
lines = [] lines = []
begin begin
Timeout.timeout(180) do timeout(180) do
begin begin
p Time.now if Debuglevel > 1 p Time.now if Debuglevel > 1
puts "getting headers: #{header}, #{range}" if Debuglevel > 1 puts "getting headers: #{header}, #{range}" if Debuglevel > 1
@ -478,7 +474,7 @@ def get_xover(server, range)
ed = start ed = start
end end
begin begin
Timeout.timeout(180) do timeout(180) do
begin begin
p Time.now if Debuglevel > 1 p Time.now if Debuglevel > 1
puts "getting headers: #{range}" if Debuglevel > 1 puts "getting headers: #{range}" if Debuglevel > 1
@ -536,7 +532,7 @@ def get_body(server, message)
messid = "" messid = ""
list = [] list = []
begin begin
Timeout.timeout(180) do timeout(180) do
begin begin
list = [] list = []
resp, id, messid, list = @connections[server]["nntp"].body(message) resp, id, messid, list = @connections[server]["nntp"].body(message)
@ -829,7 +825,6 @@ def save_newsrc()
end end
def cache_add(cachedir, id, messid, date, from, subject, server) def cache_add(cachedir, id, messid, date, from, subject, server)
# also add to skip stuff
if @cache_buf.has_key?(server) if @cache_buf.has_key?(server)
@cache_buf[server].push("#{id}|#{messid}|#{date}|#{from}|#{subject}\n") @cache_buf[server].push("#{id}|#{messid}|#{date}|#{from}|#{subject}\n")
else else
@ -854,7 +849,7 @@ puts "#{Time.now} Reading & scrubbing caches"
@connections.keys.each{|server| @connections.keys.each{|server|
first = @connections[server]["first"] first = @connections[server]["first"]
last = @connections[server]["last"] last = @connections[server]["last"]
cache_scrub(cachedir, server) #cache_scrub(cachedir, server)
puts " #{Time.now} Reading cache for #{server}" puts " #{Time.now} Reading cache for #{server}"
excludes[server] = {} excludes[server] = {}
@connections[server]["skip_ids"].elements.collect!{|x| excludes[server][x]=true} @connections[server]["skip_ids"].elements.collect!{|x| excludes[server][x]=true}
@ -881,13 +876,11 @@ puts " #{Time.now} Reading cache for #{server}"
if first <= id_i and id_i <= last if first <= id_i and id_i <= last
if ! excludes[server].has_key?(id_i) if ! excludes[server].has_key?(id_i)
outfile.puts(line) outfile.puts(line)
if date.to_i >= @oldestallowed && preselect(subject) if preselect(subject)
add(id_i, messid, date, from, subject, server) add(id_i, messid, date, from, subject, server)
end end
# XXX alle traagheid van de cache_read zit in deze regel: # XXX alle traagheid van de cache_read zit in deze regel:
if date.to_i < @oldestallowed @connections[server]["skip_ids"].insert!(id_i)
@connections[server]["skip_ids"].insert!(id_i)
end
end end
end end
end end
@ -942,19 +935,11 @@ p Time.now
outfile = File.new("#{filename}.#{server}.new", "w") or puts "Couldn't open cachefile for writing" outfile = File.new("#{filename}.#{server}.new", "w") or puts "Couldn't open cachefile for writing"
infile.each{ |line| infile.each{ |line|
id, messid, date, subject = line.split("|", 3) id, messid, date, subject = line.split("|", 3)
#puts "#{date.to_i} #{@oldestallowed}"
# XXX maybe also add to skipids ??
next if date.to_i < @oldestallowed
if id.to_i >= @connections[server]["first"] and if id.to_i >= @connections[server]["first"] and
id.to_i <= @connections[server]["last"] id.to_i <= @connections[server]["last"]
outfile.puts(line) outfile.puts(line)
end end
} }
if ( FileUtils.move("#{filename}.#{server}.new", "#{filename}.#{server}") )
puts " #{Time.now} Cache scrubbed for #{server}"
else
puts "Couldn't scrub #{server} cache"
end
end end
p Time.now p Time.now
end end

47
ripnews.rb
View file

@ -50,20 +50,20 @@ def aprofile_mem(group)
groups = {} groups = {}
ObjectSpace.each_object { |x| ObjectSpace.each_object { |x|
if not [Array,Hash].include? x.class if not [Array,Hash].include? x.class
e = nil e = nil
begin begin
e = MEntry.new( x.class, Marshal::dump(x).size ) e = MEntry.new( x.class, Marshal::dump(x).size )
rescue TypeError # undumpable rescue TypeError # undumpable
e = MEntry.new( x.class, 0 ) e = MEntry.new( x.class, 0 )
end
if groups.has_key? e.c
groups[e.c].mem += e.mem
groups[e.c].total += 1
else
groups[e.c] = GroupEntry.new( e.c, e.mem, 1 )
end
end end
} if groups.has_key? e.c
groups[e.c].mem += e.mem
groups[e.c].total += 1
else
groups[e.c] = GroupEntry.new( e.c, e.mem, 1 )
end
end
}
File.open( "mem_log", "a+" ) { |file| File.open( "mem_log", "a+" ) { |file|
file << "Group #{group}\n" file << "Group #{group}\n"
total = 0 total = 0
@ -547,17 +547,11 @@ def get_multi(subj, group)
# puts "inside thread post pass\n" # puts "inside thread post pass\n"
if UUEncode.is_uuencoded(tbody) if UUEncode.is_uuencoded(tbody)
puts " UUDecoding..." puts " UUDecoding..."
begin if tfile
if tfile tmode, tfilename, tbody = UUEncode.uudecode(tfile, tfileout)
tmode, tfilename, tbody = UUEncode.uudecode(tfile, tfileout) else
else tmode, tfilename, tbody = UUEncode.uudecode(tbody)
tmode, tfilename, tbody = UUEncode.uudecode(tbody) end
end
rescue Encoding::UndefinedConversionError
puts "#{$!}"
puts " Skipping article..."
Thread.current.exit
end
elsif YEnc.is_yencoded(tbody) elsif YEnc.is_yencoded(tbody)
puts " YDecoding..." puts " YDecoding..."
begin begin
@ -689,7 +683,7 @@ def get_max_file_length(tempdir=".")
name = "a"*500 name = "a"*500
name = "#$$#{name}" name = "#$$#{name}"
begin begin
File.new("#{tempdir}/#{name}", "w", 0644).close file = File.new("#{tempdir}/#{name}", "w", 0644).close
FileUtils.rm("#{tempdir}/#{name}") FileUtils.rm("#{tempdir}/#{name}")
rescue Errno::ENAMETOOLONG rescue Errno::ENAMETOOLONG
name = name[0...-1] name = name[0...-1]
@ -780,9 +774,6 @@ def main
@decode_file_lock = Mutex.new @decode_file_lock = Mutex.new
profile_mem("#{group} start") profile_mem("#{group} start")
puts "\nGetting articles for #{group}" puts "\nGetting articles for #{group}"
puts "nntpserver #{@config[group]["NNTPSERVER"]}"
puts "newsrcname #{@config[group]["NEWSRCNAME"]}"
puts "maxage #{@config[group]["MAXAGE"]}"
@articles = Article.new(@config[group]["NNTPSERVER"], group, @config[group]["NEWSRCNAME"], @config[group]["MAXAGE"]) @articles = Article.new(@config[group]["NNTPSERVER"], group, @config[group]["NEWSRCNAME"], @config[group]["MAXAGE"])
fill_preselector(group) fill_preselector(group)
puts "initialized" puts "initialized"