flash on 2011-11-17

/**
 * Copyright tepe ( http://wonderfl.net/user/tepe )
 * MIT License ( http://www.opensource.org/licenses/mit-license.php )
 * Downloaded from: http://wonderfl.net/c/tMAD
 */

package {
     import flash.display.*;
    import flash.events.*;
    import flash.net.*
    import flash.text.*;
    import flash.media.*;
    
    public class Main extends Sprite {
        private var txt1:TextField = new TextField(); 
        private var txt2:TextField = new TextField();
        
        private var ar:Array;
        private var logar:Array;
        private var gs:GroupSpecifier;//接続グループ機能制限
        private var nc:NetConnection;
        private var group:NetGroup;
        private var reqflg:Boolean;
        private var groupName:String;
        private var cnt1:int = 1;
        private var memberInfo:Object;
        private var memberList:Array = new Array();
        
        private var NETCANVAS_CMD_1LINE:String = "1line";//通信コマンド
        private var CMD_1:String = "create";
        private var s:Sprite = new Sprite();

        public function Main() {
            
     
            txt1.text = "aaa";
            
            // グループ機能制限
            groupName = new String();
            groupName = "net.wonderfl.ozmap.test41"
            gs = new GroupSpecifier(groupName);//接続グループ名
            gs.postingEnabled = true;//ポスティング許可
            gs.ipMulticastMemberUpdatesEnabled = true;//IP情報のマルチキャスト許可
            gs.multicastEnabled = true;//NetStreamによるストリーミング許可
            gs.objectReplicationEnabled = true;//オブジェクトの複製許可
            gs.routingEnabled = true;//NetGroupでの転送メソッド許可
            gs.serverChannelEnabled = true;//メンバーへサーバーチャンネルを開く権限を付与
            
            // RTMFPコネクション
            nc = new NetConnection();
            //イベント NET_STATUS
            nc.addEventListener(NetStatusEvent.NET_STATUS, procNetStatus);
            //接続
            nc.connect("rtmfp://p2p.rtmfp.net/3ea2ccfc17227d122a776d41-31e9e4d71a17/");
            logar = new Array();
            reqflg = false;
            

        }
        
        private function initCanvas():void {
            addChild(s);
            addChild(txt1);
            addChild(txt2);
            //txt1.text = group.estimatedMemberCount.toString();
            txt1.width = 400;
            txt1.y = 400;
            txt1.textColor = 0x0000ff;
            
            txt2.width = 400;
            txt2.height = 400;
            txt2.type = "input";
            txt2.border = true;
            
            
            //txt1.text = nc.nearID.toString();
            //txt1.appendText("\n"+nc.nearNonce.toString());
            
        }
//--------------------------------------------------------------------------        
        //送信用ストリームの宣言
        private var _sendStream:NetStream;
        // パブリッシュするストリームの名前
        private var _streamName:String = "directstream";
        
        
 
        // NetConnection.Connect.Success の時に呼ばれる 
        private function onConnect():void {
            // NetStream インスタンス生成
            _sendStream = new NetStream(nc, NetStream.DIRECT_CONNECTIONS);
            // イベントハンドラーの登録
            _sendStream.addEventListener(NetStatusEvent.NET_STATUS, procNetStatus);
            // マイクとカメラを設定
            //_sendStream.attachAudio(Microphone.getMicrophone())
            _sendStream.attachCamera(Camera.getCamera());
            
            var microphone:Microphone = Microphone.getMicrophone();
            microphone.codec = SoundCodec.SPEEX;
            _sendStream.attachAudio(microphone);
            // パブリッシュ開始
            _sendStream.publish(_streamName);
        }
//^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
        // 受信用ストリームの宣言
        private var _recvStream:NetStream;
        // パプリッシュしているノードの ID
        private var _publisherID:String = "xxxxxxxxxxxxxxxxxxxxxxxxxxxx";
        // 受信するストリームの名前
 
        // NetConnection.Connect.Success の時に呼ばれる 
        private function onConnect2():void {
            // NetStream インスタンス生成
            _recvStream = new NetStream(nc, _publisherID);
            // イベントハンドラーの登録
            _recvStream.addEventListener(NetStatusEvent.NET_STATUS, procNetStatus);
            // 受信開始 - 引数は送信側 publish() の引数に対応
            _recvStream.play(_streamName);
        }
        
        
//-----------------------------------------------------------------------------        
        
        
        
        
        
        private function connectNode():void{
            group.post({cmd: CMD_1});
        }

        //通信イベント
        private function procNetStatus(e:NetStatusEvent):void {
            
           
            var i:int;
            var j:int;
            var now:Date = new Date();
            txt2.appendText("[ "+now.toLocaleDateString()+" ] ");//タイムスタンプ
            txt2.appendText(now.toLocaleTimeString()+"    ");
            txt2.appendText(e.info.code);
            
            switch (e.info.code) {
                case "NetConnection.Connect.Success"://接続確立
                    group = new NetGroup(nc, gs.groupspecWithAuthorizations());
                    group.addEventListener(NetStatusEvent.NET_STATUS, procNetStatus);
                    txt1.text = nc.nearID +"\n"+nc.farID;
                    txt2.appendText("\n"+nc.nearID);
                    break;
                case "NetGroup.Connect.Success"://グループ接続確立
                    initCanvas();//開始
                    break;
                case "NetGroup.Neighbor.Connect"://メンバー接続  
                    if (logar.length == 0) {
                        reqflg = true;
                        group.addWantObjects(0, 0);//同期
                     }
                     cnt1++;
                     txt2.appendText(" "+cnt1.toString());
                     //txt2.appendText(" "+Math.round(group.estimatedMemberCount).toString());
                     txt2.appendText("\nPeerID:"+e.info.peerID);
                     txt2.appendText("\nネイバー："+e.info.neighbor+"\n");
                     memberInfo[cnt1].peerID = e.info.peerID;
                     txt1.text = "> ";
                     for(var s:String in memberInfo){
                         txt1.appendText(s+" ");
                         //txt1.text = "sssssssssss";
                     }

                     
                    break;
                case "NetGroup.Neighbor.Disconnect"://メンバー切断
                    cnt1--;
                    txt2.appendText(" "+cnt1.toString());
                    //txt2.appendText(" "+Math.round(group.estimatedMemberCount).toString());
                    txt2.appendText("\nPeerID:"+e.info.peerID);
                    txt2.appendText("\nネイバー："+e.info.neighbor+"\n");
                    
                    txt1.text = "< ";
                     for(var s2:String in memberInfo){
                         txt1.appendText(s2+" ");
                     }
                    break;
//ポスト受信------------------------
                case "NetGroup.Posting.Notify"://メンバーからのポスト受信
                    txt2.appendText(" "+e.info.message.cmd);
                    var obj:Object = e.info.message;//メッセージオブジェクト
                    var cmd:String = obj.cmd;//コマンド
                    logar.push(ar1);//メッセージをログに追記
                    group.addHaveObjects(0, 0);//同期
                    //コマンド-----------------------------------------
                    if (cmd == NETCANVAS_CMD_1LINE) {
                        var ar1:Array = obj.msg;//メッセージ
                        var shape:Shape = new Shape();
                        shape.graphics.lineStyle(2, 0x000000);
                        shape.graphics.moveTo(ar1[0], ar1[1]);//ライン開始点
                        for (j = 2; j < ar1.length; j += 2) {
                            shape.graphics.lineTo(ar1[j], ar1[j+1]);
                        }
                        addChild(shape);
                        txt1.text = cnt1.toString();
                    }
                    if(cmd == CMD_1){
                        cnt1++;
                        txt1.text = "cnt1 = "+cnt1.toString();
                    }

                    break;
                case "NetGroup.Replication.Request"://隣接ノードからの同期要求
                    txt2.appendText("\nrequestID:"+e.info.requestID+"\n");
                    if (e.info.index == 0) {
                        group.writeRequestedObject(e.info.requestID, {log: logar});
                    }
                    break;
                case "NetGroup.Replication.Fetch.Result"://隣接ノードが同期要求を満たした
                    if (e.info.index == 0) {
                        reqflg = false;
                        logar = e.info.object.log;
                        group.addHaveObjects(0, 0);
                        for (i = 0; i < logar.length; ++i) {
                            var ar:Array = logar[i];
                        }

                    }
                    break;
            }
            txt2.appendText("\n");
            txt2.scrollV = txt2.maxScrollV;
        }
    }
}