Tadashi Okoshi
slash****@users*****
2005年 12月 19日 (月) 14:55:24 JST
Index: affelio/lib/Affelio/Managing/NewsAggregator.pm
diff -u affelio/lib/Affelio/Managing/NewsAggregator.pm:1.13 affelio/lib/Affelio/Managing/NewsAggregator.pm:1.14
--- affelio/lib/Affelio/Managing/NewsAggregator.pm:1.13 Sat Dec 17 04:50:00 2005
+++ affelio/lib/Affelio/Managing/NewsAggregator.pm Mon Dec 19 14:55:24 2005
@@ -14,7 +14,7 @@
# along with this program; if not, write to the Free Software
# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
#
-# $Id: NewsAggregator.pm,v 1.13 2005/12/16 19:50:00 slash5234 Exp $
+# $Id: NewsAggregator.pm,v 1.14 2005/12/19 05:55:24 slash5234 Exp $
package Affelio::Managing::NewsAggregator;
{
@@ -109,10 +109,12 @@
#########################################################
#Get a friend whose last_news_in is smallet (oldest).
- my $threshold = Affelio::misc::Time::get_timestamp() - 1000; #-10m
+ my $threshold = Affelio::misc::Time::get_timestamp(); #- 1000; #-10m
my $result = $af->getFM->get_all_friend_list(where => "last_news_in < $threshold",
sort => "last_news_in",
order => "desc");
+ debug_print("NewsAggregator::get_one: FM access done.");
+
my @row = $result->fetchrow_array;
if(!@row){ return; }
@@ -121,18 +123,21 @@
my $af_id = $row[1];
my $nickname = $row[2];
my $password = $row[4];
+ debug_print("NewsAggregator::get_one: [$uid, $af_id, $nickname, $password]");
#########################################################
#generate X-WSSE message
my $xwsse_mesg = Affelio::misc::WSSE::make_XWSSE($af->{site__web_root},
$password);
-
+ debug_print("NewsAggregator::get_one: [$xwsse_mesg]");
+
#########################################################
#update AFuser_CORE_friends
my $curtime = Affelio::misc::Time::get_timestamp();
my $result = $af->getFM->set_attribute_by_id($uid,
"last_news_in",
$curtime);
+ debug_print("NewsAggregator::get_one: updated_last_news_in");
#########################################################
#Invoke SNS/Handshaker_c
@@ -140,28 +145,27 @@
try{
require Affelio::SNS::Handshaker_c;
- $ret = get_news(dest_uri => "$af_id/bin/xml-rpc-serv.cgi",
- xwsse_mesg => $xwsse_mesg);
+ $ret = Affelio::SNS::Handshaker_c::get_news(
+ dest_uri => "$af_id/bin/xml-rpc-serv.cgi",
+ xwsse_mesg => $xwsse_mesg);
}catch Error with{
my $e = shift;
+ debug_print("NewsAggregator::get_one: ERR[$e]");
return;
};
- if(!defined($ret)){
- return;
- }
- if($ret eq ""){
- return;
- }
-
- if(!defined($ret->{flerror})){
- return;
- }
- if($ret->{flerror} != 0 ){
+ if( (!defined($ret))
+ || ($ret eq "")
+ || !(defined($ret->{flerror}))
+ || ($ret->{flerror} != 0 )
+ || !(defined($ret->{message}))
+ ){
+ debug_print("NewsAggregator::get_one: XML-RPC error.");
return;
}
- if( (!defined($ret->{message})) || ($ret->{message} eq "")){
+ if($ret->{message} eq ""){
+ debug_print("NewsAggregator::get_one: No News.");
return;
}