rsstootalizer/cronjob.pl

103 lines
2.6 KiB
Perl
Raw Normal View History

2017-04-23 18:49:07 +00:00
#!/usr/bin/perl -w -I.
use strict;
use Data::Dumper;
use URI::Escape;
use JSON;
2017-04-23 18:51:48 +00:00
use RSSTootalizer::Feed;
2017-04-24 06:17:30 +00:00
use RSSTootalizer::Filter;
2017-04-23 18:51:48 +00:00
use RSSTootalizer::User;
use RSSTootalizer::Entry;
2017-04-26 07:51:03 +00:00
use RSSTootalizer::DB;
2017-04-23 18:49:07 +00:00
our $config = "";
2017-04-23 18:51:48 +00:00
open CONFIG, "rsstootalizer.conf.json" or die "Cannot open rsstootalizer.conf.json";
2017-04-23 18:49:07 +00:00
{
2017-04-23 19:24:03 +00:00
local $/ = undef;
2017-04-23 18:49:07 +00:00
$config = <CONFIG>;
}
close CONFIG;
$config = decode_json($config);
sub Error {{{
my $errormessage = "\nStack Trace:\n";
my $i=0;
while ((my @call_details = (caller($i++))) ){
$errormessage .= $call_details[1].":".$call_details[2]." in function ".$call_details[3]."\n";
}
print STDERR $errormessage;
exit(1);
}}}
# Force Unicode output
binmode STDERR, ":utf8";
binmode STDOUT, ":utf8";
2017-04-23 18:51:48 +00:00
my @feeds = RSSTootalizer::Feed->all();
2017-04-23 18:49:07 +00:00
FEED: foreach my $feed (@feeds){
next FEED unless $feed->{data}->{enabled};
my $entries = $feed->fetch_entries();
ENTRY: foreach my $entry ($entries->items){
my @seen_entries = $feed->entry_by("entry_link", $entry->link());
next ENTRY if ((scalar @seen_entries) > 0);
my %entry;
$entry{title} = $entry->title();
$entry{link} = $entry->link();
$entry{content} = $entry->content()->body;
$entry{author} = $entry->author();
$entry{issued} = $entry->issued();
$entry{modified} = $entry->modified();
$entry{id} = $entry->id();
$entry{tags} = join(", ", $entry->tags());
2017-04-24 06:17:30 +00:00
my $do_post = 0;
my @filters = $feed->filters();
foreach my $filter (@filters){
if ($filter->apply($entry)){
if ($filter->{data}->{type} eq "white"){
$do_post = 1;
} else {
$do_post = 0;
}
}
}
if ($do_post){
my $user = $feed->user();
my $status = $feed->{data}->{format};
$status =~ s/{ID}/$entry{id}/g;
$status =~ s/{Title}/$entry{title}/g;
$status =~ s/{Link}/$entry{link}/g;
$status =~ s/{Content}/$entry{content}/g;
$status =~ s/{Author}/$entry{author}/g;
$status =~ s/{Issued}/$entry{issued}/g;
$status =~ s/{Modified}/$entry{modified}/g;
$status =~ s/{Tags}/$entry{tags}/g;
2017-04-23 18:49:07 +00:00
my %data;
if (length($status) > 500){
$status =~ s/^(.{497}).*$/\1.../g;
}
$data{status} = $status;
$ENV{status} = encode_json({%data});
2017-04-23 18:49:07 +00:00
open(DATA, "./post_status.bash '$user->{data}->{access_token}' '$user->{data}->{instance}' |");
2017-04-24 06:17:30 +00:00
my $reply = "";
{
local $/ = undef;
$reply = <DATA>;
}
2017-04-23 18:49:07 +00:00
}
my %ne;
$ne{feed_id} = $feed->{data}->{ID};
$ne{entry_link} = $entry{link};
2017-04-23 18:51:48 +00:00
RSSTootalizer::Entry->create(%ne);
2017-04-23 18:49:07 +00:00
}
}
2017-04-26 07:51:03 +00:00
RSSTootalizer::DB->doUPDATE("UPDATE `users` SET session_id = 'invalid' WHERE TIME_TO_SEC(NOW()) - TIME_TO_SEC(`valid_from`) > 60*60*4;"); # invalidate old sessions