+Show TOC
×Hide TOC

AirLoggerLayout

Kind of class:	public class
Package:	com.bourre.utils
Inherits from:	none
Implements:	LogListener
Author:	Cédric Néhémie
Classpath:	com.bourre.utils.AirLoggerLayout
File last modified:	Monday, 24 November 2008, 11:36:51

► View source

▼ Hide source

/*
 * Copyright the original author or authors.
 * 
 * Licensed under the MOZILLA PUBLIC LICENSE, Version 1.1 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 *      http://www.mozilla.org/MPL/MPL-1.1.html
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.bourre.utils 
{
    import com.bourre.log.LogEvent;
    import com.bourre.log.LogListener;
    import com.bourre.log.PixlibStringifier;
    
    import flash.events.SecurityErrorEvent;
    import flash.events.StatusEvent;
    import flash.net.LocalConnection;
    import flash.utils.clearInterval;
    import flash.utils.getQualifiedClassName;
    import flash.utils.setInterval;    

    /**
     * @author    C√©dric N√©h√©mie
     */
    public class AirLoggerLayout 
        implements LogListener
    {
        /*---------------------------------------------------------------
                STATIC MEMBERS
        ----------------------------------------------------------------*/
        
        private static var _oI : AirLoggerLayout = null;
        
        protected static const LOCALCONNECTION_ID     : String = "_AIRLOGGER_CONSOLE";
        protected static const OUT_SUFFIX             : String = "_IN";
        protected static const IN_SUFFIX             : String = "_OUT";
        
        static protected var ALTERNATE_ID_IN : String = "";
        
        public static function getInstance () : AirLoggerLayout
        {
            if( _oI == null )
                _oI = new AirLoggerLayout ( new ConstructorAccess() );
                
            return _oI;
        }
        public static function release () : void
        {
            _oI.close();
            _oI = null;
        }
        
        /*---------------------------------------------------------------
                INSTANCE MEMBERS
        ----------------------------------------------------------------*/
        
        protected var _lcOut : LocalConnection;
        protected var _lcIn : LocalConnection;
        protected var _sID : String;
        
        protected var _bIdentified : Boolean;
        protected var _bRequesting : Boolean;
        
        protected var _aLogStack : Array;
        protected var _nPingRequest : Number;
        
        protected var _sName : String;
        
        public function AirLoggerLayout ( access : ConstructorAccess )
        {
            try
            {
                _lcOut = new LocalConnection();
                _lcOut.addEventListener( StatusEvent.STATUS, onStatus, false, 0, true);
                _lcOut.addEventListener( SecurityErrorEvent.SECURITY_ERROR, onSecurityError, false, 0, true);
                
                _lcIn = new LocalConnection();
                _lcIn.client = this;
                _lcIn.allowDomain( "*" );
                
                connect();
                
                _aLogStack = new Array();
                
                _bIdentified = false;
                _bRequesting = false;

            } catch ( e : Error )
            {
                // TODO Notifier le AirLogger que le channel de requete est d√©ja occup√©
                // se reconnecter sur un autre
            }
        }
        
        protected function connect () : void
        {
            var b : Boolean = true;
            
            while( b )
            {
                try
                {
                   _lcIn.connect( _getInConnectionName( ALTERNATE_ID_IN ) );
                   
                   b = false;
                   break;
                }
                catch ( e : Error )
                {
                    _lcOut.send( _getOutConnectionName(), "mainConnectionAlreadyUsed", ALTERNATE_ID_IN );
                    
                    ALTERNATE_ID_IN += "_";
                }
            }
        }
        
        public function close() : void
        {
            _lcIn.close();
        }
        
        public function focus() : void
        {
            _send ( new AirLoggerEvent ( "focus" ) );
        }
        
        public function clear() : void
        {
            _send ( new AirLoggerEvent ( "clear" ) );
        }
        
        public function setName ( s : String ) : void
        {
            _sName = s;
            
            if( _bIdentified )
            {
                _lcOut.send( _getOutConnectionName( _sID ), "setTabName", _sName  );
            }
        }
        
        public function setID ( id : String ) : void
        {
            try
            {
                clearInterval( _nPingRequest );
                _sID = id;
                
                _lcIn.close();
                _lcIn.connect( _getInConnectionName( _sID ) );
                
                _lcOut.send( _getOutConnectionName() , "confirmID", id, _sName  );
                
                _bIdentified = true;
                _bRequesting = false;
                
                var l : Number = _aLogStack.length;
                if( l != 0 )
                {
                    for(var i : Number = 0; i < l; i++ )
                    {
                        _send( _aLogStack.shift() as AirLoggerEvent );
                    }
                }
            }
            catch ( e : Error )
            {
                _lcIn.connect( _getInConnectionName( ALTERNATE_ID_IN ) );
                
                _lcOut.send( _getOutConnectionName() , "idAlreadyUsed", id );
            } 
        }
        
        public function pingRequest () : void
        {
            _lcOut.send( _getOutConnectionName() , "requestID", ALTERNATE_ID_IN  );
        }
        
        public function isRequesting () : Boolean
        {
            return _bRequesting;
        }
        
        public function isIdentified () : Boolean
        {
            return _bIdentified;
        }
        
        protected function _send ( evt : AirLoggerEvent ) : void
        {
            if( _bIdentified )
            {
                _lcOut.send( _getOutConnectionName( _sID ), evt.type, evt );
            }
            else
            {
                _aLogStack.push( evt );
                
                if( !_bRequesting )
                {                    
                    pingRequest();
                    _nPingRequest = setInterval( pingRequest, 1000 );
                    _bRequesting = true;
                }
            }
        }        
        protected function _getInConnectionName ( id : String = "" ) : String
        {
            return LOCALCONNECTION_ID + id + IN_SUFFIX;
        }
        protected function _getOutConnectionName ( id : String = "" ) : String
        {
            return LOCALCONNECTION_ID + id + OUT_SUFFIX;
        }
        
        /*---------------------------------------------------------------
                EVENT HANDLING
        ----------------------------------------------------------------*/
        
        public function onLog( e : LogEvent ) : void
        {
            if( !e ) return;
            
            var evt : AirLoggerEvent = new AirLoggerEvent ( "log", 
                                                            e.message,
                                                            e.level.getLevel(),
                                                            new Date(),
                                                            getQualifiedClassName( e.message ) ); 
            
            _send( evt );
        }
        
        private function onStatus( event : StatusEvent ) : void 
        {
             // trace( "onStatus( " + event + ")" );
        }

        private function onSecurityError( event : SecurityErrorEvent ) : void 
        {
            // trace( "onSecurityError(" + event + ")" );
        }
        
        public function toString () : String
        {
            return PixlibStringifier.stringify( this );
        }
    }
}

import com.bourre.events.BasicEvent;

internal class AirLoggerEvent 
    extends BasicEvent
{
    public var message : *;
    public var level : uint;
    public var date : Date;
    public var messageType : String;
    
    public function AirLoggerEvent( sType : String, message : * = null, level : uint = 0, date : Date = null, messageType : String = null ) 
    {
        super( sType, null );
        
        this.message = message;
        this.level = level;
        this.date = date;
        this.messageType = messageType;
    }
}

internal class ConstructorAccess {}

Summary

Constructor

AirLoggerLayout (access:ConstructorAccess)

Class methods

getInstance : AirLoggerLayout
release : void

Instance methods

close : void
focus : void
clear : void
setName (s:String) : void
setID (id:String) : void
pingRequest : void
isRequesting : Boolean
isIdentified : Boolean
toString : String

Event handlers

onLog (e:LogEvent) : void

Constructor

AirLoggerLayout

public function AirLoggerLayout (

access:ConstructorAccess)

Class methods

getInstance

public static function getInstance (

) : AirLoggerLayout

release

public static function release (

) : void

Instance methods

clear

public function clear (

) : void

close

public function close (

) : void

focus

public function focus (

) : void

isIdentified

public function isIdentified (

) : Boolean

isRequesting

public function isRequesting (

) : Boolean

pingRequest

public function pingRequest (

) : void

setID

public function setID (

id:String) : void

setName

public function setName (

s:String) : void

toString

public function toString (

) : String

Event handlers

onLog

public function onLog (

e:LogEvent) : void

Specified by:

LogListener.onLog