From 97842fabddaea2eb387308f973ed44b987c2ba2d Mon Sep 17 00:00:00 2001
From: Stefano Mazzocchi <stefano@apache.org>
Date: Sun, 30 May 2010 18:48:14 +0000
Subject: [PATCH] starting GAE support

git-svn-id: http://google-refine.googlecode.com/svn/trunk@918 7d457c2a-affb-35e4-300a-418c747d4874
---
 appengine/.classpath                          |  10 +
 ...ngine.eclipse.core.projectValidator.launch |   7 +
 ...eclipse.core.webAppProjectValidator.launch |   7 +
 appengine/.project                            |  43 ++++
 .../com.google.appengine.eclipse.core.prefs   |   3 +
 .../com.google.gdt.eclipse.core.prefs         |   5 +
 appengine/lib/slf4j-jdk14-1.5.6.jar           | Bin 0 -> 8815 bytes
 .../appengine/AppEngineClientConnection.java  | 243 ++++++++++++++++++
 .../AppEngineClientConnectionManager.java     |  83 ++++++
 9 files changed, 401 insertions(+)
 create mode 100644 appengine/.classpath
 create mode 100644 appengine/.externalToolBuilders/com.google.appengine.eclipse.core.projectValidator.launch
 create mode 100644 appengine/.externalToolBuilders/com.google.gdt.eclipse.core.webAppProjectValidator.launch
 create mode 100644 appengine/.project
 create mode 100644 appengine/.settings/com.google.appengine.eclipse.core.prefs
 create mode 100644 appengine/.settings/com.google.gdt.eclipse.core.prefs
 create mode 100644 appengine/lib/slf4j-jdk14-1.5.6.jar
 create mode 100644 appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnection.java
 create mode 100644 appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnectionManager.java

diff --git a/appengine/.classpath b/appengine/.classpath
new file mode 100644
index 000000000..cc1ca7b80
--- /dev/null
+++ b/appengine/.classpath
@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" path="src"/>
+	<classpathentry kind="con" path="com.google.appengine.eclipse.core.GAE_CONTAINER"/>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+	<classpathentry combineaccessrules="false" kind="src" path="/gridworks"/>
+	<classpathentry kind="lib" path="/gridworks/webapp/WEB-INF/lib/httpcore-4.0.1.jar" sourcepath="/gridworks/webapp/WEB-INF/lib-src/httpcore-4.0.1-sources.jar"/>
+	<classpathentry kind="lib" path="/gridworks/webapp/WEB-INF/lib/httpclient-4.0.1.jar" sourcepath="/gridworks/webapp/WEB-INF/lib-src/httpclient-4.0.1-sources.jar"/>
+	<classpathentry kind="output" path="classes"/>
+</classpath>
diff --git a/appengine/.externalToolBuilders/com.google.appengine.eclipse.core.projectValidator.launch b/appengine/.externalToolBuilders/com.google.appengine.eclipse.core.projectValidator.launch
new file mode 100644
index 000000000..3a3b1b194
--- /dev/null
+++ b/appengine/.externalToolBuilders/com.google.appengine.eclipse.core.projectValidator.launch
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<launchConfiguration type="org.eclipse.ui.externaltools.ProgramBuilderLaunchConfigurationType">
+<booleanAttribute key="org.eclipse.ui.externaltools.ATTR_BUILDER_ENABLED" value="false"/>
+<stringAttribute key="org.eclipse.ui.externaltools.ATTR_DISABLED_BUILDER" value="com.google.appengine.eclipse.core.projectValidator"/>
+<mapAttribute key="org.eclipse.ui.externaltools.ATTR_TOOL_ARGUMENTS"/>
+<booleanAttribute key="org.eclipse.ui.externaltools.ATTR_TRIGGERS_CONFIGURED" value="true"/>
+</launchConfiguration>
diff --git a/appengine/.externalToolBuilders/com.google.gdt.eclipse.core.webAppProjectValidator.launch b/appengine/.externalToolBuilders/com.google.gdt.eclipse.core.webAppProjectValidator.launch
new file mode 100644
index 000000000..eb4252719
--- /dev/null
+++ b/appengine/.externalToolBuilders/com.google.gdt.eclipse.core.webAppProjectValidator.launch
@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<launchConfiguration type="org.eclipse.ui.externaltools.ProgramBuilderLaunchConfigurationType">
+<booleanAttribute key="org.eclipse.ui.externaltools.ATTR_BUILDER_ENABLED" value="false"/>
+<stringAttribute key="org.eclipse.ui.externaltools.ATTR_DISABLED_BUILDER" value="com.google.gdt.eclipse.core.webAppProjectValidator"/>
+<mapAttribute key="org.eclipse.ui.externaltools.ATTR_TOOL_ARGUMENTS"/>
+<booleanAttribute key="org.eclipse.ui.externaltools.ATTR_TRIGGERS_CONFIGURED" value="true"/>
+</launchConfiguration>
diff --git a/appengine/.project b/appengine/.project
new file mode 100644
index 000000000..c7fc93149
--- /dev/null
+++ b/appengine/.project
@@ -0,0 +1,43 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>gridworks appengine</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.ui.externaltools.ExternalToolBuilder</name>
+			<triggers>full,incremental,</triggers>
+			<arguments>
+				<dictionary>
+					<key>LaunchConfigHandle</key>
+					<value>&lt;project&gt;/.externalToolBuilders/com.google.gdt.eclipse.core.webAppProjectValidator.launch</value>
+				</dictionary>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>com.google.appengine.eclipse.core.enhancerbuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.ui.externaltools.ExternalToolBuilder</name>
+			<triggers>full,incremental,</triggers>
+			<arguments>
+				<dictionary>
+					<key>LaunchConfigHandle</key>
+					<value>&lt;project&gt;/.externalToolBuilders/com.google.appengine.eclipse.core.projectValidator.launch</value>
+				</dictionary>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>com.google.appengine.eclipse.core.gaeNature</nature>
+	</natures>
+</projectDescription>
diff --git a/appengine/.settings/com.google.appengine.eclipse.core.prefs b/appengine/.settings/com.google.appengine.eclipse.core.prefs
new file mode 100644
index 000000000..b727dd4d9
--- /dev/null
+++ b/appengine/.settings/com.google.appengine.eclipse.core.prefs
@@ -0,0 +1,3 @@
+#Wed May 26 15:13:15 PDT 2010
+eclipse.preferences.version=1
+validationExclusions=src/com/metaweb/gridworks/appengine/*ClientConnection*.java
diff --git a/appengine/.settings/com.google.gdt.eclipse.core.prefs b/appengine/.settings/com.google.gdt.eclipse.core.prefs
new file mode 100644
index 000000000..a060470b7
--- /dev/null
+++ b/appengine/.settings/com.google.gdt.eclipse.core.prefs
@@ -0,0 +1,5 @@
+#Wed May 26 15:11:38 PDT 2010
+eclipse.preferences.version=1
+jarsExcludedFromWebInfLib=
+warSrcDir=
+warSrcDirIsOutput=true
diff --git a/appengine/lib/slf4j-jdk14-1.5.6.jar b/appengine/lib/slf4j-jdk14-1.5.6.jar
new file mode 100644
index 0000000000000000000000000000000000000000..1ce0a28e7d1ddcc2564ab6d2d87f6ca266ce5dbc
GIT binary patch
literal 8815
zcmb7p1zeQb_dYd*fOL0vr=-MC14v4D2}n0c3P?9dH;i<rgme!`2olm#BHajoSl9Kt
zy1Sp>|4zI!@0{nkbMu^YA0-eh+ykilLg?o5=#LM7z9HRR6@Y4DEV7DHY)XHcAwm({
znfWBvL~%evL8-z(L1F)|nSz+2tQ1gHja5M^D7M2ffE_(}FJ+nJ5K2Lc*)x0M<<sXN
z>zy~Nby)E@R1{<A_}*6mYLZ|sVe|Hd+gmp-6Kz|H22)hp*F~pQAg_mn1a0v&$smvN
zC8f1<6yjr3KP`0A7sm(mCNB`&d*#L+65^?RRLziJPHP~~39&w)*!4bvcTq+Ln8G~b
z<E){JRxgMxDQoCkUK=^tm$IU8ndEije7HF#Rv}wR4sD|)d`qS;Tk_5hrC-0heEPwt
zPsJGHu}-ZJZJL_wO-I}jdn@VJ7^06n&teJ5*cQS1GNO2+EL!i}C{RO|pjzHc0GbnM
zr(CqjUVSrrtn0a#y%bZ>8~13HBb@Q|q-5;?dC5BIAno3&*>d~a3Zgv$P7hkUoR<PG
z5Ex7L%O)l(-$3N_$LBLgJFB;ANRDBDbTJeZg6rQ$0`9Jh?Hn!s8ie01?nm(6!s)p=
zx7B~xq5aLy(#HPzU&e@kR9hQ1p5=-R1w~B;1x5F}v797`gInIt!oti^%+$!<+02pE
z<hhZPQ-LOum)aD8&)x|006R2iymD|Q945CHxp)E)z51OYJ~#Ap6f4^}!FZ(j6n-u-
zC8pdrYSs&5jG8u6ayo94euXY2Wo4j+=DDdL@NIUTh~6isulxjDXL0C<LT8!Zu09?4
z>^)kXZ@E~+Gk~eY@6&5Uy2>~Y#^QS$^Gc_CCykZ4iv^$=rlWU`Yl~Gkhis4V6?^2Z
z<dI)^#aq2bghkv6ubv$dj`eJJ63mLLo*h9&p``#cw6KeY&{?;h9k1Mrn99>itmsB|
zY5vTYdvEvYAHLm(y;kDCh)ups-t^L)%(P#TrOR|&MwyR`1_Li5+(`!dYI0vdf`IP&
z%)|qI%FD~iGZ}%m;v)La#*?9Bf(KXtu6R$%Twudis3|q+9O1L4+0WIKX0W4aRJEDw
z6v7|woX(93-@H@GKL-G!o(U0uz<OZbfci|Z?s8d;TAS^XvdZ2&jaaAX-G}$%ABx|Z
z42N0~@5s>b2br8kmEqOaGV#~&71PA8A4oO|5umb=&_|;@1P<}>X0@9Z8Clq5@g`uF
zhgA=AhXQL=#;OF9wx?BN^#SUuEGIkfDQw@oh)<fyp@Ui0)IHY+)413gs#D|2mOW)}
z==4NLoNIhl=uWmV`YgQrcxm4-I&&uXMAD_I#GQ>`qMvAPOHrp-G)_(FgB11&Ca`tp
ziT76@L?2J;CYqd+Z5EEI#wTL>!1W$eS{ebIb4EuGtdK+ac%wse&eW-zCX2^=3Ii7p
zAscW{#Sgl(lX3wp7&lg$;}bZ{SqWNB(!8m9#@MJ280DE=QrLz!!s<c;>vjC6O&>^j
z8LR1BVjVESy&6yLB)OEArdc2H9JS|{Xli}JU34tNiH_XE^{pOJr}~PL1%qg(Er7+c
zkR~>Su6KAdSJu3U9H7Ip?4xdWsVLlhNbUMLcPZC1_oTCsTu-XU5#R$Fif|X-i=+#&
zD{tzbTd!QA!48#5%Rez^DPVY(yoSrk3)cqY0rPT}e5yq99Iju6v%umSTxQuSh_Wnw
zA|^}=lRm0t2^ii<HMA8|i4KOT67j~9MeKQHGQapatQ5;4-3`kamae1DL`ge#<3)=Z
z03s%wGTAw=b@R@?b|fUQtI-denNzTdw&8Vic%Rwwxxb;%6r<}@b%_R<+<`z67v98F
z@uz2(A6677j>j;_6py#dFdR<OGrjsIk%kmo)_R9#^0J*NrKx?N%dxZ4@$68T#GyA5
zvCM4rGPzGhs`F2WPS2k+=)0|2Xs&jTF1W)A&YuH(wtB5f9jGFF=sr2;!P<pR&)K%T
zG-x^~Pd>?XZ)MXbGkg^ghZO>9{5BS8U{XWW-eI>8Lctnw8+8^Wdp&<He6!R|ws4ME
zA$UN?cN5Xx=#csNSi@-54(4#NN~`0#Y8^UEv=ms>n2_1iZ@Eg<WXq3@*-W3H%oaJ2
zuC(3TcP`l?LQ^;{Q_YS0Br$9PFA7*bd9^)%F3)d+@palbBLJYLo^ki=M|Wv@@3czz
z#UW2?n3XIo17hW3u4U5^XxYb}m>JKjF6v*jrj)NwEhyHnt?%clBXBW_Pe-4LT!_DV
zjfYskYuVNLR3Yesqoy(6LW{<97Hx;2%f|s|_LX84KoXw^)|n3#$}jUb1oh#PX3D5&
z@*JKLPZ&TS;^HuP<RDq}0>&6si>Xi32h2>lCW*kQE+Y{N6WzesRLF@r(gHJTS{y^8
zF$QA&VJSbG_8ch++;n_bRFVzLE^$#!;mCCZ$VlZ0L6v+-pbdd%W~~-3<8rl1IGLqZ
z6F6oNe+buDc3m<we+{nd!94d2chabN)FPVY7#rD#+yRI7$u{bQ>H~YXUYraw8K{MP
z@a3wv)LdFh!otp2aIkaiM=RQXnvbvJW>kSoaCsL+jqhL5T*GU^10wAWc_F=zO4&B>
zV#08e8NRxHIO?Hc9XcAPv15f;!<d#lDp7}k0cFoCEXp!m)sixc^X%2sMbRwOPY@5Y
zq&v9A``|g?i59KTMbH4Xx{}t=r|IUU-BRgnEMC-vH_4BQcnfyfR*8ewYl}CQgkYu-
z3xzW|zQjln6>v0gu-M3pp{GsI)_1UyjF56UkeREI_@_l$t<yi~%U0arBd-Jm%{&lg
z9SnFR2<yblx@3;Mwc1%5jqM$xkYs+fuRcxOb!<4Rx~m~fkbgX(3a5`^D3Uv_gLBn7
zuOR4+$Xr0sUNBr@y~YX(wJ)Kj?Oz~3JjL|SFw^1<(3;|@>ti<wVu|dq<ASYvMP9zH
z@mZg_`vkLFCH1hXK~E}Dii>=ZlYCHS^r@@@L0hkOX5hpl3JR_#GX2n=t!Z%c65?Nl
zk;GZ0G*V-BE#Vd<V=M?x3F9k8<rkybzeLNm7xZqYSBB5hG^%;N9hL(FX$8E;)xZl+
z1y}~*bxn&WOyI6zpraMDCv2HAaM!nM`?;Cz-cQV-bP1viy;U8vY)DiLA9mI@EuV-+
zTEW^rRNX#4XV|KpyQ69n;GtW~I=*DX+<%00Vf;W~w|;!9u`+E_%^_RKp|b*8UK^a6
zs3_bdpdKdgGHX(x`h?doIz=%N6DCvQ-4X4WW%M7vo+JkWi}Jvp?uk9g72NV-VBx0%
zC&^orCdH}+LFC%Ysvk^pF!^aRPBphC<4aVX#93*RSTU<J0(Aud_cxt&XGWX_9xn>w
zpLWRZ)K1HR^|3O(a!*-iB`UUl^lL2?Xif4v!`wf?+N>Rw1Ao%Z@KosP<OZ{kFvvR%
z4&*nnxy)J=s8*yXwtg1yjvyxmD`sUYW(nNYsI@hjc3-1DMUsYWzcuyR3Bw;8tDUxm
z6K9)O-of9xWOvjW#x1Kt6-7CxEc@laJs<tT6<jU}pvmZ#eC4wzV(xm-$wm7)VbbW<
z)*{Lf9?Fn!;rH7k&f3q5Rb6NwOi`Yzq2U(yfb;(}w~`BK4$*}8X$WH-O${<^a+?-R
zI2iH0FKUixBU;uNP03eOKQL&jZMX^@@2ED%ZiA%G=JDGEE!b5Mc5G24uQy!TQ0;4|
zU+qex3i(_i%Jp84;#yCgBp2E~t|ELK+8kTOPd2qp8){Z(B>1u*n2ZNLiO^^EON{cH
z*z-eEg{7JUcIGANQF4#{klP~ynM5N9WTR9fFL}ZP+ew<8?G5kjA>pow*DeSxr~ZS5
z9e&3(&cpVXS*ZmG91DB=0f5p^2(L#!Jrj%w@OE9_zZFqx>NVf7bv`HFN_^NfzU4;9
z<n05lIwaQ+Alx-BkSIO=IEA20DO6@Zc}}9s9S~Hl!W(eNVLYomY(*Ek)#>aaXkPT%
z(BG3Gspz#)(`=;r7aj0v4shyydGJ_4FowoetQytKKwHU_m@c@t(x8>t?F|yKnrhq_
zg{&gd5Kn%62-(4FDzV(=ac@OTo8w27S;sUC&oBZcQqYM91D9f`wF-LXI3hAoI-KXj
zm>NIyqFva`(6BIJ4}En;B%E<|T=#E^metXF@rC^cva-5T6Nh%jddt8b9lfvJ0e)$q
z!9@J(eYZhHuI_*VLatDFLj`?Fk*#u4q_Oe_J;X3%^jIw-JI=rSkexY^D*N2pAc@nt
zUzMXZZ1T!RJVWc1F^_p=GZAR2r2k}U?UJxm{VZE+A>7ZCWOmZKQK=PLXEJT9=xd+r
ziTR;7T~iyfTag<mlMnxDxY89$V})^G7J49y(Hhp2{>g`OMFW0>{J>pJMcXz-e?j_>
z*5?#ugI&18*Q#sy3E(-Y*gn14M!u_|@p^?%=UR`%7t)&sNLu8|*KLaWnKlG2_LA9d
zQJsWO3!<G~)uN?)!@1ZQ27_<#aot41o4b~j-w<`gS@iIXlLtdMg9+D^UJ`5XN63p2
znbNCowMn-63G>M~+FgtO$QZtd?%eIV2a$IP+00$K@ZX`kl#z+EoukM1&^=O3=gEX2
zzE4|OX=%a)_9J?j0RHBxfT)*#h%oUTyqFaDEm!z;2?;K)8KI&*21{kMjFh2-P3#Aq
zS*9=MASgyu`d<WF7LVFSk4T%d+C_b#*@J;dW%!s5I^s|gMzw~G7;e;(9OH-uNF3e3
z2sxR@I2^P&NUP-s<sn{_ag?<9orMKEsTu3Q;19#lz5`R$CdrHh<^<wSQXTf62?E~7
z+Q1tP%ueX0D~~y@cj=9MT6s&WMM=OkI$~o>^tII(JKa04n?1SexgJZ(Xgor(gC_S>
z-TKLaX>XpwL5s=9iV%iU>nJ-D{HRNDdHt~|g+AT~mtXo*=tUrj7EgsdA@puGYsx?*
zfX}973wnYW^DQby5s=(Q+f1;c0EI6L65ferD?^}RpP19iXq5Q+w8)Qh7K7r3j)+Ky
zlGaS#C>5IW>rgUuke%QY24h7jG*WhyNw(P)QZ|9q-Eqi}dq@!IJx+n-Qw3j>v&Tb%
zD0=D*&fc{K%$$~NgY(P<Cjn;GpcYA*tv6Fe7APaPD43CGE@!$1-l&t)$h70?6=^7;
zsWlF=XI^<H1`8<<afhgFnuBX^F~gxRx3$Hla>(X`CkV5-M&QawoV^0G&ps3q`!moX
zej%nfhwc<a^N9R_D-MN)&MsS3I3~;Y@k|V_*^(@~s8K)kEPRY&)`_{~%UW9>B`O()
zXQYzkF#R4ychr0QcYJ|02V|S!-T~ZH>DiWG9sYpy6Z8WUZiEBp<6~4|-iS<Bz88`0
zG%OV3&El~dF{iEudI2|lkDYMeQBowyEOVNrh>Mb%AeJaq22+2i@?+-g_t?f61XAn~
zZ5CizmaQ#k+U7=cBB9r39XeXO46PDg|CIxOpV3vVvh1|5P*8&K|2U&nosFC=O}=NN
z;+D3iKa$Z%wK<guC2T!}*}}+JaUi-R919FUTj?>jWD_>MX_%5>Fdc1zQfFYG?910|
zhdABHR9u&v5oGI)ZrWRs1S4G^2R>Qv4hhh0Oz+t(LZe6|a)faptzu>lzUhNw8x>dD
z*OlU;rIsH=G!76}ZE1;NXNk{1T%qx8UooQ%(Q<`2)O#SwA|b=%$TPOSq2+rz0fVMK
zH$Zdv`DW9olV5-ri$KFEveatBv6;(S)2o?_!QM-_sXk@+IrWB{xjxvnK5i!kyM}5z
z=Tr)moSI0LYohrGK8@5vY^b^Z$Okfc=n;lAU%HQ6`#MpvXq`iDJk3l$0bLmlWBqgP
z&=C_=o|Rc@VKr%salFv7*O2g-B|0<>_$|Tq@TA@x=H}MUZAGlN(`hCv`cqWUlPu!h
zZAfsvbsQbLnP#vci_+qBdk^M}*2w%g@yjk?#HcX)AxxxNbMahM*ddR}Vv%{mnl<fb
z9xH?g;s=Ix%Qx1wMP7WA``H39^$UQj?paXV&~{(Bkq)V&COLm1PdMxl!BzLbHZpwl
zjCP53x|5uyT4f-Gf4OfW`X;m3cs)Yu^cgaFUlj>J`IuhDNJ|V^8_-<hT7D`--x&T7
zu=}h8IPJ>3L>3y|(}y!JmKNZ($y~WY$^<Drcj1BO$TtMQ*7g)2J#|AnDb-Qt^?gpw
z_{MiAxTF>%=G2C+j3l<2BFRfpaA4xf@S@O`nEzBq#1Q97`%nc_KqMV*;dp}Y<qhy$
z7I{31H4z<6wmxHug2<?-AKt^Z^Amz7beIc976j4TC1$<v48vcw+S$k*|5Pz2>I@u`
zUT_uK8d+5lWBeM?))%<RwZ?Tg<xvVR4pp*mglbf}is8)wc<9;s5O6tWF#MW)h{N{_
z*4jh~b<o|2ncm_&3ihXbq))9n$5-4mXQpcqOSDEpgY7h7x}%vn1L!XD4E0Ry=GzC{
zkO89>B@#GUJqUFA@v>VSDqND>X5yR3t<kA8RLa~h{QW`n30I#V!NdkT1&Zb#&~?TZ
zB1_hfzCVYCK77$p<}}a$cDyZnh2E4}wuk0W<P`qJA;RCCN3QVgXy={tZ~*+rQd2N;
zv^I16-=!9$x~Ph&jD5ojgWMPvSCp*v05`izCG~;|Bu`|4PG+Be;LwBfAxY0%OYSyT
zp9hqYUesrPnU@M_MJMMU=xR-OYTFZR|9W$C^bNs}ARpE}I3Et!DG#M5bFk_G^-V_B
z9m6j$fvh!oy)PY&4c2+o3BrVgJdeH%L;_(Z5nMNoe7PFFgt#VA#8rI>P~muJ5slrd
z#+#6yC*bJ=suO+Ys?CSS?G>5>rv8G;v!{8A)Fp##?Nq`ewIumTi7AnuA{PdO#Y#%6
zhUtB+_62xeX?v8oh)lglX(XV!*8|kjhBd)pr3U}fO^eUPA}EImchStgLJNUVf;}%y
zyIy;C`U{E6BKZ?~lXZ0yjXD?G=?q)&8x8!+2dNWDuH3k{2FP8zD9YN9DgyYBkIX5$
z&06Ha4Ij9>OiQ_l+Y4l;9m0%qg=6Z{QA?~yOUX9ss`GRTA4B$UY-P7~AVenzaE?!>
zAl5_zdtPsxLS+?S?`!uypd}z(OnhxriZq}NbF3&>>i>MM+ALzpKZ4JF2;C;Cy3M-4
zX`1t^iBd0muytTQIrUE9noS@*tyw8$C%exEQ=$VJZ0(Nu)ZCS{_NS(fvILiPsVKtN
zq-t|Q`1uk;kYbwD!mMa_g|ercx6V7RZejH&q3yLq$hMxcfuAt&I{3YPzh(1`zasja
zIPSL4halb%JsN0iw4a5*Dxy^_Js^jb>F|67^HVoZek<s_t;1JJ1dnw5BM8wD+IE;K
z1Q-!ZGtKW#eK=On;H&T?C#_E?v|>MtSF)wEX;%D{yB{lLa=<$9bJac`oDT*5c3VJ;
zThu!X_W>vWOxKPP+zxxavAza5de-EEIiMT81Hd)4NeZuSBeU6W1H9DO!!3Y=Ft9<h
zK<CcbLeY(m_lTU6n(!zb(L4K!ur;4VNP014vzXzL^hN^xi_2e*Klh@l65{Tb!Qx#E
zMg9Bn=XZ~zASv<pHDLW@LJ8mJVMHAh(2z0=&yd}8wc7FM0Y@x!uW1q*74-{dy^nHo
zZ)-DF*bbRwU?efWJzI(9Y}=^KaYEmHm6>@aH0qRjHg3?~?u}6C#{&Qk%OoeVgR_Z_
zuGLl8{XCFTVUUgpj*Y~6bH#TsU$KESmx&w><vX2%<xg5~%B!1d%D5slgxbpikdDC|
zb21*1GD5-}8=o2aiaFbnLk)sLg+9apq2)uE*LIqU6NfLan=ugA=2G9Iuw)rkIzD^B
z&E03eqn#4}^ujD_q0%UpR>E_{b$1_C!Y!w9D2CCCCp@R!_-)cBf!T&@5|hOonfjHK
z;2P_5-o?HSwV6s-_#)e&YsKKcAmg-)Y)k7<yykO#ln9tkMIP#S2}#g%m44S9xF^zD
zoboufq<D6+r91AiM!83i&pKHu)<5t@E0hq-W-`Sf3xRc56Q||rSVL7#wA(CgJ_=3e
zM6o9DYjh&xu*K#Te%n(Ceh-)H1ygH8B1yh@_5!D?v0?>BpKC3SvNvN&K%iuWHJH*+
z77D~s=?u#sl^&)Z5&O~?Eh$XQlmH$xYwqe*62Z8Tv#GSO=>CfZ{@hMe_qstTrtH0@
zQ>k6<7kgM_3GJSVl6f7=l>P6c*&pAk;z>0kT*i6$WXD4LdTs_5OI#t;>J%m(Yz_m)
z!5pYc&j7J1lAbaKR&bqE6f#|*bXD&#DK1i804(=l4hQO_w7aF}&JTHfu}wJIiI1e)
zD37qdX{}?ndRg?p5KE=pP!a^t&B93=i>2@dE9okM6VpZ^x&aw#<zou<Dm5FM7Zm&q
z%Km9#UD%-buW+<L?r@>PXOYFUt6MH3v_T?cUO^(`ZBD^As<G;nDFtV>?E2?_MNz+N
zI``-Qe`z{4My_VIe=UIDjR}4?zS9_3f7KX%)s1NW3-$+?#mdy0gZr<V5ur@oogcNb
zht~PsEj=p)C@ALtD}}wC4XeA&^Ex$!=vj7jVT90I!yJ7q36R%g%X~d(Or4phFlC-P
z9we~lSbfzbB5J$727RvLn7Ff`M`oW#ghr>S)+pyNN*_1CzT;3xzWy}F*dvWz`0R<M
zAAhF~rl~Qk?>F6dMq_A~txm_A^p=SZ{KNrWcvx3Wi)8N>!!K0m!2Mu(#%^|pl(?vT
z=+6XFVdh`RNCDH75nYRDSy!XqmgraYCwH9%_4{MV<t@98IwSiXMZ&2_$ofr%=YuMp
z35bz^(}+wqL^BNo6s6F>btw1cOvEBk6nw|@k`5xM#vL<rk$IRqT=sCyenJwFNJM9I
zcZJn@uBYOqQ3>}PyAP0PkoWz=(A=bP=EuP*m@FF;%dqbFxA-U>!e&+Q63@_wV#2A5
zcgKY^hWP^lDw5rj#$rv5Bwi&f(6qx<ZJJNHBFvw2h-5&J!jZZX`YGGL3N#^EFOGyZ
zCWlv%E9yub$Ybz$rd^9>Imd2y%jSouwP^)$FjclBKk-dJhuQEbF^ES_;&)P`s9h{a
zn%U0%T-n6~d7Vyci!C&8!lT(;^895T_DZ)|;^*<y086=EMsy1XFcL=FNaIWpq=P_b
zLV;DuMKnmmyy>0fjx1T-6)QzhcQ8G2lbtj`bZMN=;MDn}v2~yC4u;=Q!JNp6l&Ec$
zoaJly$C0RZTbbPHvl*09)1G};g@FsC&#pVK(tD5&vTV~8nbrt<8Vd)x6ckD<iX9~0
zu{3K9V#RIy3Qnw#43-Dhn?u>5<)pq>Bh%U?a9S2iV#+Mxz?n@9ogmVcf9iJg#o+;-
zTXfBqY10GTi6gAwyefS6rj*mjEvjNukG9%oh73&5l#3u?m5bEg&sYlaPP&^M$lABQ
zo58ksFRuTenQZT9XK&`{Y-#4C>iT2^#3IKmtDr1XthTSf3>sNoS8-(;RNEh7Q)TB=
zW9P2otg7VXR<?IVRc7a8uUuMZ1hFtehDU37Cb_1#R@dd&2H9Bl<*P>6<ffS*vRnfz
z>vGJD1M(nwR_L$*pmU8%HL8Mp6O<AN8U`Eo-zDI?2HX{Ns9mx9>tCD4PuM?8!uQ7a
zCEx%4EaETN{|LlC8GhF@?-kGQ<-X#uJE{4*{`vE-{;H9FZ@@j~9#Q%y;>TX~@3{LN
z@q4+)P5uq{r#|`v{Lc#M4|u*m^xf|DQ-u8k{BL^c&$j>b+09SV7S#VD{o6^-ucW`G
z&p%0{(0?QSw`BTP(q9vWpQIO9|3dnE+VCssuVL3uQYgHCBmH|2_LK2<KlaNI-?_EF
zrsEG6_+yBF2j4rv@8y1eKokB3{$H2)?=<&L@h1)cf6@HiMgE}tXD9iCG~eIr|4R9%
w%lz44h*1BuY5imdlKe-T|M$<{GymMelt6&HV;d+aw7ZAq-Fk*5z5n+A0AbhFYXATM

literal 0
HcmV?d00001

diff --git a/appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnection.java b/appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnection.java
new file mode 100644
index 000000000..9f0effa08
--- /dev/null
+++ b/appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnection.java
@@ -0,0 +1,243 @@
+package com.metaweb.gridworks.appengine;
+
+import static com.google.appengine.api.urlfetch.FetchOptions.Builder.allowTruncate;
+
+import java.io.ByteArrayOutputStream;
+import java.net.InetAddress;
+import java.net.URL;
+import java.util.concurrent.TimeUnit;
+
+import javax.net.ssl.SSLSession;
+
+import org.apache.http.Header;
+import org.apache.http.HttpConnectionMetrics;
+import org.apache.http.HttpHost;
+import org.apache.http.HttpResponse;
+import org.apache.http.ProtocolVersion;
+import org.apache.http.conn.ManagedClientConnection;
+import org.apache.http.conn.routing.HttpRoute;
+import org.apache.http.entity.ByteArrayEntity;
+import org.apache.http.message.BasicHttpResponse;
+import org.apache.http.params.HttpParams;
+import org.apache.http.protocol.HttpContext;
+
+import com.google.appengine.api.urlfetch.HTTPHeader;
+import com.google.appengine.api.urlfetch.HTTPMethod;
+import com.google.appengine.api.urlfetch.HTTPRequest;
+import com.google.appengine.api.urlfetch.HTTPResponse;
+import com.google.appengine.api.urlfetch.URLFetchService;
+import com.google.appengine.api.urlfetch.URLFetchServiceFactory;
+
+class AppEngineClientConnection implements ManagedClientConnection {
+    // Managed is the composition of ConnectionReleaseTrigger,
+    //     HttpClientConnection, HttpConnection, HttpInetConnection
+
+    private HttpRoute _route;
+    private Object _state;
+    private boolean _reuseable;
+
+    public AppEngineClientConnection(HttpRoute route, Object state) {
+        _route = route;
+        _state = state;
+    }
+
+    // ManagedClientConnection methods
+
+    public HttpRoute getRoute() {
+        return _route;
+    }
+
+    public Object getState() {
+        return _state;
+    }
+
+    public SSLSession getSSLSession() {
+        return null;
+    }
+
+    public boolean isSecure() {
+        // XXX maybe parse the url to see if it's https?
+        return false;
+    }
+
+    public boolean isMarkedReusable() {
+        return _reuseable;
+    }
+
+    public void markReusable() {
+        _reuseable = true;
+    }
+
+    public void layerProtocol(HttpContext context, HttpParams params) {
+        return;
+    }
+
+    public void open(HttpRoute route, HttpContext context, HttpParams params) {
+        return;
+    }
+
+    public void setIdleDuration(long duration, TimeUnit unit) {
+        return;
+    }
+
+    public void setState(Object state) {
+        _state = state;
+    }
+
+    public void tunnelProxy(HttpHost next, boolean secure, HttpParams params) {
+        return;
+    }
+
+    public void tunnelTarget(boolean secure, HttpParams params) {
+        return;
+    }
+
+    public void unmarkReusable() {
+        _reuseable = false;
+    }
+
+
+    // ConnectionReleaseTrigger methods
+
+    public void releaseConnection() {
+        return;
+    }
+
+    public void abortConnection() {
+        return;
+    }
+
+    // HttpClientConnection methods
+
+    private HTTPRequest _appengine_hrequest;
+    private HTTPResponse _appengine_hresponse;
+
+    public void flush() {
+        return;
+    }
+
+    public boolean isResponseAvailable(int timeout) {
+        // XXX possibly use Async fetcher
+        return true;
+    }
+
+    public void receiveResponseEntity(org.apache.http.HttpResponse apache_response) {
+        byte[] data = _appengine_hresponse.getContent();
+
+        if (data != null) {
+            apache_response.setEntity(new ByteArrayEntity(data));
+        }
+    }
+
+    public HttpResponse receiveResponseHeader() {
+        URLFetchService ufs = URLFetchServiceFactory.getURLFetchService();
+        try {
+            _appengine_hresponse = ufs.fetch(_appengine_hrequest);
+        } catch (java.io.IOException e) {
+            throw new RuntimeException(e);
+        }
+
+        org.apache.http.HttpResponse apache_response =
+            new BasicHttpResponse(new ProtocolVersion("HTTP", 1, 0),
+                                  _appengine_hresponse.getResponseCode(),
+                                  null);
+
+        for (HTTPHeader h : _appengine_hresponse.getHeaders()) {
+            apache_response.addHeader(h.getName(), h.getValue());
+        }
+
+        return apache_response;
+    }
+
+    public void sendRequestEntity(org.apache.http.HttpEntityEnclosingRequest request) {
+        ByteArrayOutputStream os = new ByteArrayOutputStream();
+
+        org.apache.http.HttpEntity ent = request.getEntity();
+        if (ent != null) {
+            try {
+                ent.writeTo(os);
+            } catch (java.io.IOException e) {
+                throw new RuntimeException(e);
+            }
+        }
+
+        _appengine_hrequest.setPayload(os.toByteArray());
+    }
+
+    public void sendRequestHeader(org.apache.http.HttpRequest apache_request) {
+        URL request_url;
+
+        HttpHost host = _route.getTargetHost();
+
+        String protocol = host.getSchemeName();
+        String addr = host.getHostName();
+        int port = host.getPort();
+
+        String path = apache_request.getRequestLine().getUri();
+
+        try {
+            request_url = new URL(protocol, addr, port, path);
+        } catch (java.net.MalformedURLException e) {
+            throw new RuntimeException(e);
+        }
+
+        HTTPMethod method = HTTPMethod.valueOf(apache_request.getRequestLine().getMethod());
+        _appengine_hrequest = new HTTPRequest(request_url, method, allowTruncate()
+                                              .doNotFollowRedirects());
+
+        Header[] apache_headers = apache_request.getAllHeaders();
+        for (int i = 0; i < apache_headers.length; i++) {
+            Header h = apache_headers[i];
+            _appengine_hrequest
+                .setHeader(new HTTPHeader(h.getName(), h.getValue()));
+        }
+    }
+
+    // HttpConnection methods
+
+    public void close() {
+        return;
+    }
+
+    public HttpConnectionMetrics getMetrics() {
+        return null;
+    }
+
+    public int getSocketTimeout()  {
+        return -1;
+    }
+
+    public boolean isOpen() {
+        return true;
+    }
+
+    public boolean isStale() {
+        return false;
+    }
+
+    public void setSocketTimeout(int timeout) {
+        return;
+    }
+
+    public void shutdown() {
+        return;
+    }
+
+    // HttpInetConnection methods
+
+    public InetAddress getLocalAddress() {
+        return null;
+    }
+           
+    public int getLocalPort() {
+        return -1;
+    }
+           
+    public InetAddress getRemoteAddress() {
+        return null;
+    }
+           
+    public int getRemotePort() {
+        return -1;
+    }
+}
\ No newline at end of file
diff --git a/appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnectionManager.java b/appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnectionManager.java
new file mode 100644
index 000000000..9bbc1e9f4
--- /dev/null
+++ b/appengine/src/com/metaweb/gridworks/appengine/AppEngineClientConnectionManager.java
@@ -0,0 +1,83 @@
+package com.metaweb.gridworks.appengine;
+
+import java.net.InetAddress;
+import java.net.Socket;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.http.conn.ClientConnectionManager;
+import org.apache.http.conn.ClientConnectionRequest;
+import org.apache.http.conn.ManagedClientConnection;
+import org.apache.http.conn.routing.HttpRoute;
+import org.apache.http.conn.scheme.Scheme;
+import org.apache.http.conn.scheme.SchemeRegistry;
+import org.apache.http.conn.scheme.SocketFactory;
+import org.apache.http.params.HttpParams;
+
+public class AppEngineClientConnectionManager implements ClientConnectionManager {
+    private SchemeRegistry schemes;
+
+    class NoopSocketFactory implements SocketFactory {
+        public Socket connectSocket(Socket sock, String host, int port,
+                                   InetAddress addr, int lport,
+                                   HttpParams params) {
+            return null;
+        }
+
+        public Socket createSocket() {
+            return null;
+        }
+
+        public boolean isSecure(Socket sock) {
+            return false;
+        }
+    }
+
+    public AppEngineClientConnectionManager() {
+        SocketFactory noop_sf = new NoopSocketFactory();
+
+        schemes = new SchemeRegistry();
+        schemes.register(new Scheme("http",  noop_sf, 80));
+        schemes.register(new Scheme("https", noop_sf, 443));
+    }
+
+    public void closeExpiredConnections() {
+        return;
+    }
+
+    public void closeIdleConnections(long idletime, TimeUnit tunit) {
+        return;
+    }
+
+    public ManagedClientConnection getConnection(HttpRoute route, Object state) {
+        return new AppEngineClientConnection(route, state);
+    }
+
+    public SchemeRegistry getSchemeRegistry() {
+        return schemes;
+    }
+
+    public void releaseConnection(ManagedClientConnection conn,
+                                  long valid, TimeUnit tuint) {
+        return;
+    }
+
+    public ClientConnectionRequest requestConnection(final HttpRoute route,
+                                                     final Object state) {
+        return new ClientConnectionRequest() {
+            public void abortRequest() {
+                return;
+            }
+
+            public ManagedClientConnection getConnection(long idletime,
+                                                         TimeUnit tunit) {
+
+                return AppEngineClientConnectionManager.this.getConnection(route, state);
+            }
+        };
+    }
+
+    public void shutdown() {
+        return;
+    }
+}
+