Changeset 6214

Timestamp:

02/05/08 13:02:02 (5 years ago)

Author:

woremacx

Message:

lang/perl/WebService-Nowa: switch to nowa API (recent, update_nanishiteru)

Location:

lang/perl/WebService-Nowa/trunk

Files:

• config.yaml-dist (modified) (1 diff)
• lib/WebService/Nowa.pm (modified) (3 diffs)
• test.pl (modified) (1 diff)

lang/perl/WebService-Nowa/trunk/config.yaml-dist

@@ -2 +2 @@
 nowa_id: yourid
 password: yourpass
+api_pass: apipass
+# make your api_pass at http://my.nowa.jp/config/account/api_auth

lang/perl/WebService-Nowa/trunk/lib/WebService/Nowa.pm

@@ -7 +7 @@
 our $VERSION = '0.01';
 
-use base qw( Nowa::Nanishiteru );
-
 use Data::Dumper;
 use Encode ();
@@ -14 +12 @@
 use List::Util qw(first);
 use Web::Scraper;
+use Time::HiRes qw(time);
+use Carp;
+use URI;
+use JSON::Syck;
+use WWW::Mechanize;
+
+use constant NOWA_HOME => 'http://my.nowa.jp/home/';
+use constant NOWA_API_HOME => 'https://api.nowa.jp/';
 
 sub new {
     my $class = shift;
-    my $self  = $class->SUPER::new(@_);
+    croak "invalid argument" unless (ref($_[0]) eq 'HASH');
+    my $self = shift;
+    bless $self, $class;
+
+    my $mech = WWW::Mechanize->new;
+    $mech->credentials('api.nowa.jp:443', "nowa API", $self->{nowa_id}, $self->{api_pass});
+    $mech->agent_alias('Windows IE 6');
+    $self->{mech} = $mech;
     $self->{mech}->stack_depth(1);
 
     $self;
+}
+
+# copyed from Nowa::Nanishiteru
+sub _login {
+    my $self = shift;
+    $self->{mech}->get(NOWA_HOME);
+    $self->{_logged_in} = 1 if $self->{mech}->uri eq NOWA_HOME;
+    return if $self->{_logged_in};
+    my $uri = $self->{mech}->uri;
+    $self->{mech}->submit_form(
+        form_number => 1,
+        fields      => +{
+            nowa_id  => $self->{nowa_id},
+            password => $self->{password},
+        },
+    );
+    croak("login failed.") if $self->{mech}->uri eq $uri;
+    $self->{_logged_in} = 1;
 }
 
@@ -70 +101 @@
 }
 
+sub _api {
+    my $self = shift;
+    my $method = shift;
+
+    my $uri = URI->new_abs($method, NOWA_API_HOME);
+    $self->{mech}->get($uri->as_string);
+    my $res = JSON::Syck::Load($self->{mech}->content);
+    croak "fetch recent failed." if ref($res) eq 'HASH' and $res->{result} eq 'fail';
+    $res;
+}
+
 sub recent {
     my $self = shift;
-    $self->_login unless $self->{_logged_in};
 
-    my $s = scraper {
-        process '//div[@class="friendentry-box clearfix"]', 'entries[]' => scraper {
-            process '//div[@class="friendentrybody"]/a', 'userlink', '@href';
-            process 'span.time > a', 'permalink', '@href';
-
-            # message
-            process 'h2.statustitle', 'body', 'TEXT';
-
-            # entry
-            process '//h2[@class!="statustitle"]/a',
-                'entry', 'TEXT',
-                'entrylink', '@href';
-        };
-    };
-    my $res = $self->scrape($s, URI->new('http://my.nowa.jp/friend/'));
-
+    my $res = $self->_api('/status_message/friends_timeline.json');
     my @data;
-    for my $entry (@{ $res->{entries} }) {
-        my $user = ($entry->{userlink} =~ m!^http://([^\.]+)\.nowa\.jp/!)[0];
-        my $body;
-        if ($entry->{entry}) {
-            $body = $entry->{entry} . " " . $entry->{entrylink};
-            $entry->{permalink} = $entry->{entrylink};
-        } else {
-            $body = $entry->{body};
-        }
-
+    for my $entry (@$res) {
+        my $who = $entry->{user}->{nowa_id};
+        my $permalink = sprintf("http://%s.nowa.jp/status/%d", $who, (split(/_/, $entry->{id}))[1]);
         push(@data, +{
-            user      => $user,
-            permalink => $entry->{permalink},
-            body      => $body,
+            id        => $entry->{id},
+            user      => $entry->{user}->{nowa_id},
+            permalink => $permalink,
+            body      => $entry->{text},
         });
     }
 
     return wantarray ? @data : \@data;
+}
+
+sub update_nanishiteru {
+    my($self, $status) = @_;
+
+    my $uri = URI->new_abs('/status_message/update.json', NOWA_API_HOME);
+    $self->{mech}->post($uri->as_string, { status => $status });
+    my $res = JSON::Syck::Load($self->{mech}->content);
+    croak "fetch recent failed." unless $res->{id} =~ /^\d+_\d+$/;
+    $res;
 }
 

lang/perl/WebService-Nowa/trunk/test.pl

@@ -8 +8 @@
 my $config = YAML::LoadFile(shift(@ARGV) || "config.yaml");
 my $nowa = WebService::Nowa->new($config);
-# $nowa->update_nanishiteru('何もしてねえよ。');
-
+$nowa->update_nanishiteru('何もしてねえよ。');
 my $msgs = $nowa->recent;
 my $chans = $nowa->channels;