Changeset 6409 for lang/perl/WebService-Nowa

Timestamp:

02/09/08 06:57:27 (5 years ago)

Author:

woremacx

Message:

lang/perl/WebService-Nowa: channel_recent

Location:

lang/perl/WebService-Nowa/trunk

Files:

• lib/WebService/Nowa.pm (modified) (5 diffs)
• test.pl (modified) (1 diff)

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

@@ -39 +39 @@
 sub _login {
     my $self = shift;
+
     $self->{mech}->get(NOWA_HOME);
     $self->{_logged_in} = 1 if $self->{mech}->uri eq NOWA_HOME;
@@ -51 +52 @@
     );
     croak("login failed.") if $self->{mech}->uri eq $uri;
+
+    if ($self->{mech}->content =~ m!<script type="text/javascript">\s+\w+\.init\(\s*"([a-f0-9]+)"!s) {
+        $self->{rkey} = $1;
+    }
+
     $self->{_logged_in} = 1;
 }
@@ -101 +107 @@
 }
 
+sub channel_recent {
+    my $self = shift;
+    $self->_login unless $self->{_logged_in};
+
+#   <li>
+#     <a href="http://woremacx.nowa.jp/" title="woremacx">
+#       <img src="http://image.nowa.jp/icon/0000003bceb4da8eb19ca8ee838060c92294026b25fab89-s.png" width="16" height="16" alt="" />
+#     </a>
+#     <a href="http://woremacx.nowa.jp/" class="blue-cms">
+#       woremacx
+#     </a>
+#     <span class="body">
+#       ヴ
+#       <a href='http://nowa.jp/ch/vavava/' class='blue-cms'>#vavava</a>
+#     </span>
+#     <span class="time">(<a href="http://woremacx.nowa.jp/status/177736" class="blue-cms">36分前</a>)</span>
+#   </li>
+    my $s = scraper {
+        process 'ul#article-list > li', 'msgs[]' => scraper {
+            process_first 'a.blue-cms',
+                'user', 'TEXT',
+                'userlink', '@href';
+            process 'span.body',
+                'body', 'TEXT';
+            process 'span.body > a',
+                'channel', 'TEXT',
+                'channellink', '@href';
+            process 'span.time > a',
+                'permalink', '@href';
+        };
+    };
+    my $res = $self->scrape($s, URI->new('http://my.nowa.jp/channel/recent'));
+    my @data;
+    for my $msg (@{ $res->{msgs} }) {
+        next unless $msg->{permalink};
+
+        my $user = ($msg->{userlink} =~ m!^http://([^\.]+)\.nowa\.jp/!)[0];
+        my $body = $msg->{body};
+        $body =~ s/\s+#\w+$//;
+
+        push(@data, +{
+            body => Encode::encode('utf-8', $body),
+            user => $user,
+            permalink => $msg->{permalink}->as_string,
+            channel => $msg->{channel},
+        });
+    }
+    return wantarray ? @data : \@data;
+}
+
 sub _api {
     my $self = shift;
@@ -112 +168 @@
 }
 
+sub _internal_api {
+    my $self = shift;
+    my $method = shift;
+
+    my $uri = URI->new_abs($method, NOWA_HOME);
+
+    my($sec, $fsec) = time() =~ /^(\d+)(?:\.(\d+))?$/;
+    $fsec = substr($fsec, 0, 3);
+    $fsec .= '0' while length $fsec < 3;
+    my $uniqid = sprintf('%d%d', $sec, $fsec);
+
+    $uri->query_form(
+        rkey   => $self->{rkey},
+        uniqid => $uniqid,
+    );
+
+    $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;
@@ -118 +196 @@
     my @data;
     for my $entry (@$res) {
+        # skip channel messages
+        next if $entry->{text} =~ /^#\w+\s/;
+
         my $who = $entry->{user}->{nowa_id};
         my $permalink = sprintf("http://%s.nowa.jp/status/%d", $who, (split(/_/, $entry->{id}))[1]);

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;
+warn Dumper($msgs);
+
 my $chans = $nowa->channels;
+warn Dumper($chans);
+
 my $point = $nowa->point;
+print "$point nowa yen!\n";
+
+my $msgs = $nowa->channel_recent;
 warn Dumper($msgs);
-warn Dumper($chans);
-print "$point nowa yen!\n";