September 23, 2009

ニコ生のコメントを取得するperlプログラム

perlでニコ生のコメントを取得できるようにしてみたよ。

ソケットプログラミングとか、何か楽しい。
使い方:lv番号を渡して実行してください。

#!/usr/local/bin/perl

use LWP::UserAgent;
use HTTP::Cookies;
use URI::Escape;
use HTTP::Request;
use HTTP::Headers;
use IO::Socket;
use IO::Select;

# 初期設定
my $video_id = $ARGV[0] || die “lvから始まる生放送IDを入力してください”;

my $mail = メールアドレス;
my $password = パスワード;

# UserAgentの設定
my $ua = LWP::UserAgent->new;
$ua->cookie_jar( HTTP::Cookies->new(
file => ‘cookie.lwp’,
autosave => 1,
));

# ログイン
my $res=$ua->post( “https://secure.nicovideo.jp/secure/login”,
[
mail => $mail,
password => $password,
]);
print “Login : “,$res->status_line,”\n”;

$res = $ua->get( “http://live.nicovideo.jp/api/getplayerstatus?v=$video_id”);
$\=”\n”;
print “API connect : “,$res->status_line,”\n”;

my $content = uri_unescape($res->content);
die “放送してません” unless $content=~m!<ms><addr>(.*)</addr><port>(\d*)</port><thread>(\d*)</thread></ms>!;
my ($server,$port,$thread_id)=($1,$2,$3);
#save xml
my $post_data = “<thread res_from="-100" version="20061206" thread="” . $thread_id .”" />\0”;

my $selecter = IO::Select->new;             # select の前準備

print “$server:$port\n”;
my $sock = IO::Socket::INET->new(“$server:$port”);  # 各サーバのソケットを生成
$selecter->add($sock);                              # select の対象ソケットに追加
my $sock2host = “$server:$port”;                # メッセージ表示用
print $sock $post_data;                               # この書き込みするとコメントを送信してくれる
$sock->flush();                                     # バッファをフラッシュ

my $continue=1;

# 読み込みが完了していないソケットが残っていたら
while ( $continue ){
my ($readable_socks) = IO::Select->select($selecter, undef, undef, undef);

# 読み込み可能なソケットがあれば、以下の foreach ループが実行される
foreach my $sock (@$readable_socks){
my $len = sysread($sock, $buf, 4096);   # ソケットから 4096 バイト読み込む
print “read ${len}bytes from $sock2host\n $buf…”;
if ( $buf=~/\/disconnect/)
{
print “放送終了: $sock2host\n”;  # そのソケットからの読み込みは終了
$selecter->remove($sock);         # select の対象から外す
$sock->close();                   # ソケットをクローズ
$continue=0;
}
}
}

例:

$ perl nicolivecomment.pl lv4428803

出力

read 1448bytes from msg101.live.nicovideo.jp:2808
<thread last_res=”40” resultcode=”0” revision=”1” server_time=”1253706359” thread=”1005523015” ticket=”0x9e8e580”/><chat anonymity=”1” date=”1253705787” mail=”184” no=”1” premium=”1” thread=”1005523015” user_id=”uDy9TgWasnzEO2zbgo9xnWnqtVU” vpos=”2000”>こっそりと聞いて</chat><chat anonymity=”1” date=”1253705793” mail=”184” no=”2” premium=”1” thread=”1005523015” user_id=”X-UeIgE9Z8ujNsvYN-vKkK_25Gg” vpos=”2635”>そぉい</chat>

長いので以下省略。仕様変更したらうまくいかないかもしれません。

参考にしたサイト
http://x68000.q-e-d.net/~68user/net/http-parallel-1.html
http://d.hatena.ne.jp/dambiyori/20081227/1230393234