Twitter Streaming APIを使って関連ＴＬをテレビにオーバーレイ表示するAIRアプリを作ってみた
一昨年の記事、テレビにTwitterの関連ＴＬをオーバーレイ表示するAIRアプリを作ってみた - Tosshi Note で紹介したアプリを Twitter Streaming API に対応してみました。 AIRアプリ自体の公開は反応をみることにして、Twitter Streaming API を ActionScript で実装する例があまり見つからなかったので、とりあえず載せときます。 ちなみに URLStream を使って実装していますが、URLStream の Progress イベントは HTTP chunk レスポンスの受信とは別に起こります。そのため、流れの速いＴＬでないと TweetReceived イベントにタイムラグが発生するかもしれません。 URLStreamから取得できるデータ本体は、[ツイートJSON][CRLF][ツイートJSON][CRLF][ツイートJSON][CRLF] となります。 ツイートがないときに、Keep-Aliveのためのパケットも[CRLF]となるため、バッファに文字列をためつつ、[CRLF]を探しては切り出して、文字列長0でなければJSONをパースしてツイート受信イベント発生という流れです。 以下、ソースをべた貼りしておきます。 TwitterStreamLoader.as コンストラクタ引数にBASIC認証のTwitterスクリーン名とパスワードを指定します。 package com.tilfin.tvtwlayer.twitter { import com.adobe.serialization.json.JSON; import flash.events.EventDispatcher; import flash.events.HTTPStatusEvent; import flash.events.IOErrorEvent; import flash.events.ProgressEvent; import flash.net.URLRequest; import flash.net.URLRequestHeader; import flash.net.URLRequestMethod; import flash.net.URLStream; import flash.net.URLVariables; import mx.utils.Base64Encoder; /** * Tweet Received イベント / [Event(name=“tweetReceived”, type=“com.tilfin.tvtwlayer.twitter.TwitterStreamEvent”)] /* * Twitter Stream API Loader / public class TwitterStreamLoader extends EventDispatcher { private static const ROOT_URL:String = “http://stream.twitter.com/1/statuses/"; private var _authHeader:URLRequestHeader; private var _stream:URLStream; private var _streamBuffer:String = “”; /* * コンストラクタ * * @param screenName スクリーン名 * @param password パスワード / public function TwitterStreamLoader(screenName:String , password:String) { super(); var encoder:Base64Encoder = new Base64Encoder(); encoder.encode(screenName + “:” + password); _authHeader = new URLRequestHeader(“Authorization”, “Basic " + encoder.flush()); } /* * 各種フィルタをかけたストリームの受信を開始します。 * * @param params クエリパラメータ / public function loadFilterStream(params:Object):void { var variables:URLVariables = new URLVariables(); for (var key:String in params) { variables[key] = params[key]; } var request:URLRequest = new URLRequest(ROOT_URL + “filter.json”); request.method = URLRequestMethod.POST; request.requestHeaders = [ _authHeader ]; request.data = variables; _stream = new URLStream(); _stream.addEventListener(IOErrorEvent.IO_ERROR, onIoError); _stream.addEventListener(HTTPStatusEvent.HTTP_RESPONSE_STATUS, onHttpResponseStatus); _stream.addEventListener(ProgressEvent.PROGRESS, onProgress); _stream.load(request); } /* * ストリームを閉じます。 */ public function close():void { _stream.removeEventListener(IOErrorEvent.IO_ERROR, onIoError); _stream.removeEventListener(ProgressEvent.PROGRESS, onProgress); _stream.close(); _stream = null; } private function onProgress(event:ProgressEvent):void { var buffer:String = _stream.readUTFBytes(_stream.bytesAvailable); _streamBuffer += buffer; var twstr:String; var splitpos:int = _streamBuffer.indexOf(”\r\n”); while (splitpos > -1) { twstr = _streamBuffer.substr(0, splitpos); if (twstr.length > 0) { receivedTweet(twstr); } _streamBuffer = _streamBuffer.substr(splitpos + 2); splitpos = _streamBuffer.indexOf("\r\n"); } } private function receivedTweet(str:String):void { var tweet:Object = JSON.decode(str); dispatchEvent(new TwitterStreamEvent(TwitterStreamEvent.TWEET_RECEIVED, tweet)); } private function onIoError(event:IOErrorEvent):void { trace(“IO Error.”); } } } ...