From 83d548ae8ac918d63651b4a919c9e06eb15c33ee Mon Sep 17 00:00:00 2001
From: djmcgrath <djmcgrath@c11ca15a-4712-0410-83d8-924469b57eb5>
Date: Tue, 30 Oct 2007 16:41:28 +0000
Subject: [PATCH] * Forgot to add the actual module ;)

git-svn-id: https://svn.code.sf.net/p/infobot/code/trunk@1599 c11ca15a-4712-0410-83d8-924469b57eb5
---
 src/Modules/RSSFeeds.pl | 162 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 162 insertions(+)
 create mode 100644 src/Modules/RSSFeeds.pl

diff --git a/src/Modules/RSSFeeds.pl b/src/Modules/RSSFeeds.pl
new file mode 100644
index 0000000..2697faf
--- /dev/null
+++ b/src/Modules/RSSFeeds.pl
@@ -0,0 +1,162 @@
+#
+#     RSSTest.pl: RSS Tractker hacked from Plug.pl/Rss.pl
+#     Author: Dan McGrath <djmcgrath@users.sourceforge.net>
+#  Licensing: Artistic License (as perl itself)
+#    Version: v0.1
+#
+
+package RSSFeeds;
+
+use strict;
+use XML::Feed;
+
+use vars qw(%channels %param $dbh $who $chan);
+
+sub getCacheEntry {
+	my ( $file, $url ) = @_;
+	my @entries;
+
+	&::DEBUG("rssFeed: Searching cache for $url");
+
+	open CACHE, "<$file" or return;
+	binmode( CACHE, ":utf8" );
+
+	while (<CACHE>) {
+		next unless /^$url:/;
+		chop;
+		s/^$url:(.*)/$1/;
+		push @entries, $_;
+	}
+	close CACHE;
+
+	return @entries;
+}
+
+sub saveCache {
+	my ( $file, $url, @entries ) = @_;
+
+	open IN,  "<$file"     or return;
+	open OUT, ">$file.tmp" or return;
+
+	binmode( IN,  ":utf8" );
+	binmode( OUT, ":utf8" );
+
+	# copy all but old ones
+	while (<IN>) {
+		next if /^$url:/;
+		print OUT $_;
+	}
+
+	# append new ones
+	foreach (@entries) {
+		print OUT "$url:$_\n";
+	}
+
+	close IN;
+	close OUT;
+
+	rename "$file.tmp", "$file";
+}
+
+sub createCache {
+	my $file = shift;
+
+	&::status("rssFeed: Creating cache in $file");
+
+	open CACHE, ">$file" or return;
+	close CACHE;
+}
+
+sub getFeed {
+	my ( $cacheFile, $chan, $rssFeedUrl ) = @_;
+
+	&::DEBUG("rssFeed: URL: $rssFeedUrl");
+
+	my $feed = XML::Feed->parse( URI->new($rssFeedUrl) )
+		or return XML::Feed->errstr;
+
+	my $curTitle = $feed->title;
+	&::DEBUG("rssFeed: TITLE: $curTitle");
+	my @curEntries;
+
+	for my $entry ( $feed->entries ) {
+		&::DEBUG( "rssFeed: ENTRY: " . $entry->title );
+		push @curEntries, $entry->title;
+	}
+
+	# Create the cache if it doesnt exist
+	&createCache($cacheFile)
+		if ( !-e $cacheFile );
+
+	my @oldEntries = &getCacheEntry( $cacheFile, $rssFeedUrl );
+	my @newEntries;
+	foreach (@curEntries) {
+		&::DEBUG("rssFeed: CACHE: $_");
+		last if ( $_ eq $oldEntries[0] );
+		push @newEntries, $_;
+	}
+
+	if ( scalar @newEntries == 0 ) {    # if there wasn't anything new
+		return "rssFeed: No new headlines for $curTitle.";
+	}
+
+	# save to hash again
+	&saveCache( $cacheFile, $rssFeedUrl, @curEntries )
+		or return "rssFeed: Could not save cache!";
+
+	my $reply = &::formListReply( 0, $curTitle, @newEntries );
+	&::msg( $chan, $reply );
+
+	#		"\002<<\002$curTitle\002>>\002 " . join( " \002::\002 ", @newEntries ) );
+
+	return;
+}
+
+sub RSS {
+	my ($command) = @_;
+	my $cacheFile = "$::param{tempDir}/rssFeed.cache";
+	my %feeds;
+
+	if ( not $command =~ /^(flush|update)?$/i ) {
+		&::status("rssFeed: Unknown command: $command");
+		return;
+	}
+
+	if ( $command =~ /^flush$/i ) {
+		if ( not &::IsFlag("o") ) {
+			&::status("rssFeed: User $::who tried to flush the cache, but isn't +o!");
+			return;
+		}
+		unlink $cacheFile if ( -e $cacheFile );
+		&::status("rssFeed: Flushing cache.");
+		&::performStrictReply("$::who: Flushed RSS Feed cache.");
+		return;
+	}
+
+	if ( $command =~ /^update$/i ) {
+		if ( not &::IsFlag("o") ) {
+			&::status("rssFeed: User $::who tried to manually update feeds, but isn't +o!");
+			return;
+		}
+		&::status("rssFeed: Manual update of feeds requested by $::who.");
+	}
+
+	foreach my $chan ( keys %::channels ) {
+		my $rssFeedUrl = &::getChanConf( 'rssFeedUrl', $chan );
+		my @urls = split / /, $rssFeedUrl;
+
+		# Store by url then chan to allow for same url's in multiple channels
+		foreach (@urls) { $feeds{$chan}{$_} = 1 }
+	}
+
+	foreach my $chans ( keys %feeds ) {
+		foreach ( keys %{ $feeds{$chans} } ) {
+			my $result = &getFeed( $cacheFile, $chans, $_ );
+			&::status($result) if $result;
+		}
+	}
+	return;
+}
+
+1;
+# vim: ts=2 sw=2
-- 
2.39.2