X-Git-Url: http://git.osdn.jp/view?a=blobdiff_plain;ds=sidebyside;f=0.6.x%2Fjs%2F06_net%2F00_XNet.js;h=fdc66aaf10bb5c74d0edc4b042a3e63afbf4f02d;hb=0a4e04fb0af6e1b2e452d1a8c0822e723d32a0ee;hp=8e1e63da0e572e50be941ac30106dbebd9ea7e8e;hpb=eedd028ba64be2ea0828cf686f1d0ec3bb4010d5;p=pettanr%2FclientJs.git

diff --git a/0.6.x/js/06_net/00_XNet.js b/0.6.x/js/06_net/00_XNet.js
index 8e1e63d..fdc66aa 100644
--- a/0.6.x/js/06_net/00_XNet.js
+++ b/0.6.x/js/06_net/00_XNet.js
@@ -3,64 +3,184 @@
 
 // http://bugs.jquery.com/ticket/2709
 // <head><base> ãããå ´åã<script>ã®è¿½å ã«å¤±æãã
-X[ 'Net' ] = {
-
-	'xhrGet' : function( url, obj ){
-		if( X_Type_isString( url ) ){
-			if( obj ){
-				obj[ 'url' ] = url;
-			} else {
-				obj = { 'url' : url };
-			};
-		} else {
-			obj = url;
-		};
-		obj[ 'method' ] = 'GET';
-		return new X_NET_Queue( X_NET_TYPE_XHR, obj );
-	},
-	
-	'xhrPost' : function( url, postbody, obj ){
-		if( X_Type_isString( url ) ){
-			if( obj ){
-				obj[ 'url' ] = url;
-			} else {
-				obj = { 'url' : url };
-			};
-		} else {
-			obj = url;
-		};
-		obj[ 'method' ] = 'POST';
-		obj[ 'postbody' ] = postbody;
-		return new X_NET_Queue( X_NET_TYPE_XHR, obj );
-	},
-	
-	'formGet' : function(){
-		
-	},
-	
-	'formPost' : function(){
-		
-	},
-	
-	// TODO chashe
-	// TODO iframe useful or not. TODO dynamicIframe
-	// TODO file: ã§ã¯ãhttp: ã¯ä½¿ããªã
-	'jsonp' : function( url, useIframe ){
-		return new X_NET_Queue( X_NET_TYPE_JSONP, url );
-	},
-	
-	'image' : function( url, needSize, delay, timeout ){
-		return new X_NET_Queue( X_NET_TYPE_IMAGE, { url : url, needSize : needSize } );
-	},
-	
-	// <script>, <link>
-	
-	'amountQueue' : function(){
-		return X_NET_QUEUE_LIST.length;
-	}
 
-};
 
+
+/**
+ * <p>busy() ã¡ã½ããã ããæã¤ãéä¿¡ç¨ã®ãã­ããã£ã¯ X.Pair ã«ãã£ã¦é è½ãããã
+ * <h4>éä¿¡ã®ã­ã£ã³ã»ã«</h4>
+ * <p>kill() ã§éä¿¡å¾ã¡ä¸­ã¯ã­ã£ã³ã»ã«&ç ´æ£ãéä¿¡ä¸­ã®å ´åã¯éä¿¡ã®ä¸­æ­&ç ´æ£ãè¡ããSUCCESS, ERROR, TIMEOUT ã¤ãã³ãä»¥éã¯ kill() ã¯ç¡è¦ãããã
+ * <h4>ã¤ãã³ã</h4>
+ * <dl>
+ * <dt>X.Event.PROGRESS<dd>éä¿¡é²è¡ç¶æ³
+ * <dt>X.Event.SUCCESS<dd>éä¿¡æå
+ * <dt>X.Event.ERROR<dd>éä¿¡ã¨ã©ã¼
+ * <dt>X.Event.TIMEOUT<dd>éä¿¡ã¿ã¤ã ã¢ã¦ã
+ * <dt>X.Event.CANCELED<dd>éä¿¡ã®ã¦ã¼ã¶ã¼ããã­ã°ã©ã ã«ããã­ã£ã³ã»ã«
+ * <dt>X.Event.COMPLETE<dd>éä¿¡å®äºãSUCCESS, ERROR, TIMEOUT, CANCELED å¾ã«çºçã
+ * </dl>
+ * <p>X.Net ã¤ã³ã¹ã¿ã³ã¹ã¯ COMPLETE å¾ã«èªåã§ç ´æ£ãããã
+ * <h4>å¿é ãã­ããã£</h4>
+ * <dl>
+ * <dt>url<dd>URL
+ * <dt>type<dd>'xhr', 'jsonp', 'image', 'img'
+ * <dt>xhr<dd>URL { url : 'hoge', type : 'xhr' } ã®çç¥å½¢
+ * <dt>jsonp<dd>URL { url : 'hoge', type : 'jsonp' } ã®çç¥å½¢
+ * <dt>image, img<dd>URL { url : 'hoge', type : 'image' } ã®çç¥å½¢
+ * </dl>
+ * <h4>XHR ç¨ãã­ããã£</h4>
+ * <dl>
+ * <dt>method<dd>'GET', 'POST' æªæå®ãã¤ postdata ãè¨­å®ãã¦ããå ´åã'POST' ã«ãªãã
+ * <dt>params<dd>url ãã©ã¡ã¼ã¿ã object ã§æ¸¡ããã¨ãåºæ¥ãã
+ * <dt>postdata<dd>string, object ã®å ´åã¯ X.String.serialize ãããã
+ * <dt>async<dd>boolean
+ * <dt>username<dd>BASIC èªè¨¼
+ * <dt>password<dd>BASIC èªè¨¼
+ * <dt>headers<dd>object xhr.setRequestHeader ããå¤
+ * <dt>timeout<dd>ã¿ã¤ã ã¢ã¦ã ms
+ * <dt>cache<dd>headers[ 'Pragma' ] = 'no-cache' ç­ãè¨­å®ããã?
+ * <dt>dataType<dd>'text', 'json', 'xml', 'blob', 'arraybuffer' ç­ãxhr.responseType ã«æå®ããå¤
+ * <dt>mimeType<dd>'text/xml', 'audio/mpeg' ç­ãxhr.overrideMimeType ããå¤
+ * <dt>auth<dd>X.OAuth2 ã¤ã³ã¹ã¿ã³ã¹(OAuth2 ãµã¼ãã¹ã®å®ç¾©)
+ * <dt>getFullHeaders<dd>getAllResponseHeaders() ããã¼ã¹ããããã·ã¥ãè¿ããå¤ã¯éåã«ãªã£ã¦ãããXDR ã¯ Content-Type ããåå¾ã§ããªãã
+ * <dt>canUse<dd>æªå®è£ãgadget proxy, YQL, YPipes ç­ã®ããã·ã¥ã¢ããã®è¨±å¯ãç¾å¨ã¯ test : 'gadget' ã¨ãã¦ãã
+ * </dl>
+ * 
+ * <h4>JSONP ç¨ãã­ããã£</h4>
+ * <dl>
+ * <dt>params<dd>url ãã©ã¡ã¼ã¿ã object ã§æ¸¡ããã¨ãåºæ¥ãã
+ * <dt>callbackName<dd>callback(json) ã³ã¼ã«ããã¯åãåºå®ããã¦ããéã«æå®ãã¾ãã¯ &callback=hoge ä»¥å¤ã®ååã§ã³ã¼ã«ããã¯ãæå®ããå ´åã« params ã¨ callbackName ã«æ¸ãã¦ãããurl ãã©ã¡ã¼ã¿ã« callback ãç¡ããcallbackName ããªãå ´åããã¬ã¼ã ã¯ã¼ã¯åã§èªåã§è¨­å®ããã
+ * <dt>charset<dd>ãã¼ã¸ã¨ç°ãªãjsonpãèª­ã¿è¾¼ãå ´åã«æå® 'EUC-JP', 'Shift-JIS' ç­ script ã¿ã°ã® charset ã«å¥ããhttps://code.google.com/p/ajaxzip3/issues/detail?id=5
+ * <dt>useFireWall<dd>ç°ãªããã¡ã¤ã³ã« jsonp ãèª­ã¿è¾¼ãã å¾ãxdomain iframe éä¿¡ãä½¿ã£ã¦ãã¼ã¿ãåãåããä¸æ­£ãªã³ã¼ãã®å®è¡ãé²ããã¨ãåºæ¥ããæªå®è£
+ * </dl>
+ * 
+ * @alias X.Net
+ * @class åç¨®ãããã¯ã¼ã¯æ©è½ãã©ãããã¤ã³ã¿ã¼ãã§ã¤ã¹ãå±éåããã
+ * @constructs Net
+ * @extends {EventDispatcher}
+ * @example // XHR - GET
+ * var net = X.Net( { xhr : urlString } )
+ * 		.listen( X.Event.PROGRESS )
+ * 		.listenOnce( [ X.Event.SUCCESS, X.Event.ERROR, X.Event.TIMEOUT, X.Event.CANCELED ] );
+ * 
+ * // XHR - GET 
+ * var net = X.Net( urlString );
+ * 
+ * // XHR - POST 
+ * var net = X.Net( { xhr : urlString, postdata : myData } );
+ * 
+ * // JSONP
+ * var net = X.Net( { jsonp : urlString, params : params, callbackName : callbackName, charset : charset, useFireWall : false } );
+ * 
+ * // Form
+ * var net = X.Net( { form : urlString, method : 'POST', target : '_self', params : {} } ); // _self, _parent, _top ã®å ´åããã¼ã¸ããé¢è±ãã
+ * 
+ * // Image preload & getSize
+ * var net = X.Net( { image : src, sizeDetection : true } );
+ * 
+ * // load &lt;script&gt;, &lt;link&gt;
+ */
+X[ 'Net' ] = X_EventDispatcher[ 'inherits' ](
+		'X.Net',
+		X_Class.NONE,
+		{
+			'netType'    : '',
+			'netName'    : '',
+			'netVersion' : 0,
+			
+			'Constructor' : function( urlOrObject, opt_options ){
+				var opt, url, type, auth;
+				
+				if( X_Type_isObject( opt = urlOrObject ) ){
+					if( X_Type_isString( url = opt[ 'xhr' ] ) ){
+						type = X_NET_TYPE_XHR;
+					} else
+					if( X_Type_isString( url = opt[ 'jsonp' ] ) ){
+						type = X_NET_TYPE_JSONP;
+					} else
+					if( X_Type_isString( url = opt[ 'img' ] || opt[ 'image' ] ) ){
+						type = X_NET_TYPE_IMAGE;
+					} else
+					if( X_Type_isString( url = opt[ 'form' ] ) ){
+						type = X_NET_TYPE_FORM;
+					//{+dev
+					} else
+					if( !( type = X_NET_NAME_TO_ID[ opt[ 'type' ] ] ) ){
+						alert( 'X.Net args error' );
+						return;
+					//}+dev
+					} else {
+						url = opt[ 'url' ];
+					};
+					//{+dev
+					if( !X_Type_isString( url ) ){
+						alert( 'X.Net args error' );
+						return;
+					};
+					//}+dev
+				} else
+				if( X_Type_isString( urlOrObject ) ){
+					url = urlOrObject;
+					
+					if( X_Type_isObject( opt = opt_options ) ){
+						type = opt[ 'type' ] || X_NET_TYPE_XHR;
+					} else {
+						type = X_NET_TYPE_XHR;
+						opt  = { 'url' : url, 'method' : 'GET' };
+					};
+				//{+dev	
+				} else {
+					alert( 'X.Net args error' );
+					return;
+				//}+dev
+				};
+				
+				// auth ã®éé¿
+				if( auth = opt[ 'auth' ] ){
+					delete opt[ 'auth' ];
+				};
+				opt = X_Object_deepCopy( opt );
+				if( auth ){
+					opt[ 'auth' ] = auth; // auth ã¯ deep copy ãããã¨ã¾ãã
+				};
+				
+				// params ã url ã«è¿½å 
+				if( opt[ 'params' ] ){
+					url = X_URL_create( url, opt[ 'params' ] );
+					delete opt[ 'params' ];
+				};				
+				
+				if( type === X_NET_TYPE_XHR ){
+					opt[ 'method' ] = opt[ 'method' ] || ( opt[ 'postdata' ] ? 'POST' : 'GET' );
+
+					// XDomain ä¸å¯ -> Flash, Gears, Silverlight, canUseGadget ãªã gadget ã«åæ¿?
+					// PUT DELETE UPDATE ä¸å¯ -> Flash, Gears, Silverlight, canUseGadget ãªã gadget ã«åæ¿?
+					// xãã­ãã³ã« ãª binary ã®ã­ã¼ã -> gadget åã§ proxyURL ã«ãã XHR
+					//  or X_EVENT_ERROR
+					
+					opt[ 'dataType' ] = opt[ 'dataType' ] || X_URL_getEXT( url );
+				};
+				
+				opt.netType   = type;
+				opt[ 'url'  ] = url;				
+				
+				X_Pair_create( this, opt );
+				
+				this[ 'listen' ]( [ X_EVENT_BEFORE_KILL_INSTANCE, X_EVENT_KILL_INSTANCE ], X_NET_proxyDispatch );
+				
+				X_NET_QUEUE_LIST[ X_NET_QUEUE_LIST.length ] = this;
+				!X_NET_currentQueue && X_NET_shiftQueue();
+			},
+			
+		/**
+		 * ç¾å¨éä¿¡ä¸­ãï¼èª¿ã¹ããfalse ã®å ´åãéä¿¡ã®é çªå¾ã¡ããéä¿¡ãçµäºãã¦ããã
+		 * @alias Net.prototype.busy
+		 */
+			'busy' : function(){
+				return this === X_NET_currentQueue && X_NET_currentWrapper._busy;
+			}
+		}
+	);
 /*
  * @interface
  */
@@ -75,120 +195,151 @@ var X_NET_TYPE_XHR   = 1,
 	X_NET_TYPE_FORM  = 3,
 	X_NET_TYPE_IMAGE = 4,
 
+	X_NET_NAME_TO_ID = {
+		'xhr'   : X_NET_TYPE_XHR,
+		'jsonp' : X_NET_TYPE_JSONP,
+		'form'  : X_NET_TYPE_FORM,
+		'img'   : X_NET_TYPE_IMAGE,
+		'image' : X_NET_TYPE_IMAGE
+	},
+
 	X_NET_QUEUE_LIST = [],
 
 	X_NET_XHRWrapper,
 	X_NET_JSONPWrapper,
 	X_NET_FormWrapper,
 	X_NET_ImageWrapper,
+	X_NET_GIMRWrapper,
 
 	X_NET_currentWrapper,
-	X_NET_currentQueue;
-
-/**
- * ãã¬ã¼ã ã¯ã¼ã¯ã«ãã£ã¦ã©ããããããããã¯ã¼ã¯æ©è½ã«ã¢ã¯ã»ã¹ããããã®ã¯ã©ã¹ã
- *	
- * @alias X_NET_Queue
- * @class X_NET_Queue
- * @constructs X_NET_Queue
- * @extends {EventDispatcher}
- */
-var X_NET_Queue = X_EventDispatcher[ 'inherits' ](
-		'XNetQueue',
-		X_Class.POOL_OBJECT,
-		
-		/** @lends X_NET_Queue.prototype */
-		{
-			type : 0,
-			data : null,
-			
-			'Constructor' : function( type, data ){
-				this.type = type;
-				this.data = data;
-				
-				//this[ 'listenOnce' ]( X_EVENT_COMPLETE, X_NET_proxyDispatch );
-				X_EventDispatcher_systemListen( this, X_EVENT_COMPLETE, X_NET_proxyDispatch );
-				
-				X_NET_QUEUE_LIST[ X_NET_QUEUE_LIST.length ] = this;
-				!X_NET_currentQueue && X_NET_shiftQueue();
-			},
-			
-			'busy' : function(){
-				return this === X_NET_currentQueue && X_NET_currentWrapper._busy;
-			},
-			
-			'cancel' : function(){
-				var i = X_NET_QUEUE_LIST.indexOf( this );
-				if( i !== -1 ){
-					X_NET_QUEUE_LIST.splice( i, 1 );
-					this[ 'asyncDispatch' ]( X_EVENT_CANCELED );
-					this[ 'asyncDispatch' ]( 16, X_EVENT_COMPLETE );
-				} else
-				if( this === X_NET_currentQueue ){
-					X_NET_currentWrapper.cancel();
-				};
-			}
-		}
-	);
+	X_NET_currentQueue,
+	X_NET_currentData,
+	X_NET_completePhase;
 
 function X_NET_proxyDispatch( e ){
+	var i, flag, auth;
+	
 	switch( e.type ){
 		case X_EVENT_BEFORE_KILL_INSTANCE :
+			if( this === X_NET_currentQueue && X_NET_completePhase ) return X_Callback_PREVENT_DEFAULT;
 			break;
+		
 		case X_EVENT_KILL_INSTANCE :
+			i = X_NET_QUEUE_LIST.indexOf( this );
+			
+			if( i !== -1 ){
+				X_NET_QUEUE_LIST.splice( i, 1 );
+				flag = true;
+			} else
+			if( this === X_NET_currentQueue ){
+				X_NET_currentWrapper.cancel();
+				X_NET_shiftQueue();
+				flag = true;
+			};
+			
+			if( flag ){ // flag ãç«ã¤å ´åãããã¯ä¸­æ­
+				this[ 'dispatch' ]( X_EVENT_CANCELED );
+				this[ 'dispatch' ]( { type : X_EVENT_COMPLETE, 'lastEventType' : X_EVENT_CANCELED } );
+				X_Pair_release( this );
+			};
 			break;			
-		case X_EVENT_KILL_INSTANCE_CANCELED :
-			break;
 		case X_EVENT_PROGRESS :
 			this[ 'dispatch' ]( e );
 			break;
-		case X_EVENT_SUCCESS :
+		
 		case X_EVENT_ERROR :
+			if( e.status === 401 ){
+				if( auth = X_Pair_get( this )[ 'auth' ] ){
+					X_Pair_get( auth ).onAuthError( auth, e );
+				};
+			};
+			
+		case X_EVENT_SUCCESS :
 		case X_EVENT_TIMEOUT :
-		case X_EVENT_CANCELED :
-			this[ 'dispatch' ]( e );
-			this[ 'asyncDispatch' ]( X_EVENT_COMPLETE );
+			X_NET_completePhase = true;
+			this
+				[ 'listenOnce' ]( X_EVENT_COMPLETE, X_NET_proxyDispatch )
+				[ 'unlisten' ]( [ X_EVENT_BEFORE_KILL_INSTANCE, X_EVENT_KILL_INSTANCE ], X_NET_proxyDispatch )
+				[ 'asyncDispatch' ]( e );
+			this[ 'asyncDispatch' ]( 32, { type : X_EVENT_COMPLETE, 'lastEventType' : e.type } );
 			break;
 		case X_EVENT_COMPLETE :
-			this[ 'kill' ]();
+			X_Pair_release( this );
 			X_NET_shiftQueue();
+			X_NET_completePhase = false;
+			this[ 'kill' ]();
 			break;
 	};
 };
 
 function X_NET_shiftQueue(){
-	var queue;
-	
+	var auth, authSettings;
+
 	if( X_NET_currentQueue ){
-		console.log( 'X_NET_shiftQueue ' + X_NET_currentWrapper._busy );
 		if( X_NET_currentWrapper._busy ) return;
 		X_NET_currentWrapper
-			[ 'unlisten' ]( [ X_EVENT_PROGRESS, X_EVENT_SUCCESS, X_EVENT_ERROR, X_EVENT_TIMEOUT, X_EVENT_CANCELED ], X_NET_currentQueue, X_NET_proxyDispatch )
+			[ 'unlisten' ]( [ X_EVENT_PROGRESS, X_EVENT_SUCCESS, X_EVENT_ERROR, X_EVENT_TIMEOUT ], X_NET_currentQueue, X_NET_proxyDispatch )
 			.reset();
-		X_NET_currentQueue = X_NET_currentWrapper = null;
+		X_NET_currentQueue = X_NET_currentWrapper = X_NET_currentData = null;
 	};
 	
 	if( !X_NET_QUEUE_LIST.length ) return;
 
-	queue = X_NET_QUEUE_LIST.shift();
+	X_NET_currentQueue = X_NET_QUEUE_LIST.shift();
+	X_NET_currentData  = X_Pair_get( X_NET_currentQueue );
 	
-	switch( queue.type ){
+	switch( X_NET_currentData.netType ){
 		case X_NET_TYPE_XHR :
-			X_NET_currentWrapper = X_NET_XHRWrapper;
+			
+			// TODO (xProtocol |ãmethod='update' | !cors) & canUse -> gadget.io.makeRequset, flash
+			// force 'gadget', 'flash'
+			switch( X_NET_currentData[ 'test' ] ){
+				case 'gadget' :
+					X_NET_currentWrapper = X_NET_GIMRWrapper || X_TEMP.X_Net_GIMR_init();
+					break;
+				case 'flash'  :
+					break;
+				
+				default :
+					X_NET_currentWrapper = X_NET_XHRWrapper || X_TEMP.X_Net_XHR_init();
+			};
+			
+			
+			// OAuth2
+			if( auth = X_NET_currentData[ 'auth' ] ){
+				authSettings = X_Pair_get( auth );
+				switch( auth[ 'state' ]() ){
+					case 0 :
+					case 1 :
+					case 2 :
+						if( !( auth[ 'dispatch' ]( X_EVENT_NEED_AUTH ) & X_Callback_PREVENT_DEFAULT ) ){
+							authSettings.lazyReq = X_NET_currentQueue;
+						};
+						X_NET_currentQueue = null;
+						X_NET_shiftQueue();
+						break;
+					case 3 : // refresh token
+						X_NET_QUEUE_LIST.push( X_NET_currentQueue );
+						X_NET_currentQueue = null;
+						X_NET_shiftQueue();
+						return;
+				};
+				authSettings.updateRequest( auth, X_NET_currentData );
+			};
 			break;
 		case X_NET_TYPE_JSONP :
-			X_NET_currentWrapper = X_NET_JSONPWrapper;
+			X_NET_currentWrapper = X_NET_JSONPWrapper || X_TEMP.X_NET_JSONP_init();
 			break;
 		case X_NET_TYPE_FORM :
-			X_NET_currentWrapper = X_NET_FormWrapper;
+			X_NET_currentWrapper = X_NET_FormWrapper  || X_TEMP.X_NET_Form_init();
 			break;
 		case X_NET_TYPE_IMAGE :
-			X_NET_currentWrapper = X_NET_ImageWrapper;
+			X_NET_currentWrapper = X_NET_ImageWrapper || X_TEMP.X_NET_Image_init();
 			break;
 	};
 	
-	X_NET_currentWrapper[ 'listen' ]( [ X_EVENT_PROGRESS, X_EVENT_SUCCESS, X_EVENT_ERROR, X_EVENT_TIMEOUT, X_EVENT_CANCELED ], X_NET_currentQueue = queue, X_NET_proxyDispatch );
+	X_NET_currentWrapper[ 'listen' ]( [ X_EVENT_PROGRESS, X_EVENT_SUCCESS, X_EVENT_ERROR, X_EVENT_TIMEOUT ], X_NET_currentQueue, X_NET_proxyDispatch );
 	
-	X_NET_currentWrapper.load( queue.data );
+	X_NET_currentWrapper.load( X_NET_currentData );
 };
 
