@@ -0,0 +1,139 @@
+			/* {  "answer": {    
+			             "data": ["a" ],    
+			             "event":"success",    
+			             "id":"2204d4b2-de94-4946-965c-e7aaf12a1a8b",    
+			             "more":true,    
+			             "projection": ["X" ],    
+			             "time":2.2752000000000015e-5  
+			      },  
+		        "event":"create",  
+		        "id":"2204d4b2-de94-4946-965c-e7aaf12a1a8b",  
+		        "slave_limit":3
+		        }
+		        
+		        if no first solution job.add("ask", "member(X, [])");
+		        {
+		          "answer":{
+		             "data":{
+		                   "event":"failure",
+		                   "id":"c7e9e0c5-84b6-4faa-bbcb-1e1139df1206",
+		                   "time":0.000019857999999999985
+		                   },
+		             "event":"destroy",
+		             "id":"c7e9e0c5-84b6-4faa-bbcb-1e1139df1206"
+		         },
+		         "event":"create",
+		         "id":"c7e9e0c5-84b6-4faa-bbcb-1e1139df1206",
+		         "slave_limit":3
+		         }
+		         
+		         What happens if job.add("ask", "member(X, ][])");  (syntax invalid)?
+		         it returns 500
+		         (doucment that it also 500's if it throws an uncaught exception)
+		         
+		         what if we don't use template?
+		         {  
+		             "answer": {    
+		                  "data": [ {"X":"a"} ],    
+		                  "event":"success",    
+		                  "id":"4f856b3a-a2a5-493c-8241-baf1a5a5ed28",    
+		                  "more":true,    
+		                  "projection": ["X" ],    
+		                  "time":1.5222999999999973e-5  
+		             },  
+		             "event":"create",  
+		             "id":"4f856b3a-a2a5-493c-8241-baf1a5a5ed28",  
+		             "slave_limit":3}
+		             
+		             with more than one variable a couple fields change
+		             	job.add("ask", "member((X,Y), [(a,3),(b,4),(c,5)])");
+		              // job.add("template", "X");
+		              "data": [ {"X":"a", "Y":3} ],    
+                     "projection": ["X", "Y" ],  
+
+
+		             non atom response
+		             job.add("ask", "member(X, [(a,3),(b,4),(c,5)])");
+		             job.add("template", "X");
+		             {  "answer": {    
+		                    "data": [ {"args": ["a", 3 ], "functor":","} ],   
+		                     "event":"success",   
+		                      "id":"514e0608-5925-4774-a408-4d5d03344c5f",    
+		                      "more":true,    
+		                      "projection": ["X" ],   
+		                       "time":1.6837000000000015e-5  },  
+		                       "event":"create",  
+		                       "id":"514e0608-5925-4774-a408-4d5d03344c5f", 
+					"slave_limit":3}
+					
+					now I'll set the type to json-s in the create
+					and it just 500's
+					
+					Try it with chunking set to 2
+					   job.add("ask", "member((X,Y), [(a,3),(b,4),(c,5)])");
+		            
+		            {  
+		                 "answer": {    
+			                 "data": [ {"X":"a", "Y":3},  {"X":"b", "Y":4} ],    
+			                 "event":"success",    
+			                 "id":"b648885b-cf65-49f4-a028-756bb2579d2b",    
+			                 "more":true,    
+			                 "projection": ["X", "Y" ],    
+			                 "time":1.6732999999999896e-5  
+			            },  
+			            "event":"create",  
+			            "id":"b648885b-cf65-49f4-a028-756bb2579d2b",  
+			            "slave_limit":3
+		            }
+		            
+		            what if the value bound is compound? I changed a in the example to a(taco)
+		            "data": [      {"X": {"args": ["taco" ], "functor":"a"}, "Y":3},      {"X":"b", "Y":4}    ],  
+		        */
+			
+/*
+ * This project has involved a lot of experimenting, as hte protocol is poorly documented. As such,
+ * I'm retaining my notes here
+ */
+// <domain>/<path>/pengine/create
+// application/json
+// see server_url/4, line 1529 of pengines.pl
+/*
+* HTTP/1.1 200 OK
+Server: nginx/1.4.6 (Ubuntu)
+Date: Wed, 20 Apr 2016 20:53:39 GMT
+Content-Type: text/x-prolog; charset=UTF-8
+Content-Length: 65
+Connection: close
+
+http://www.oracle.com/technetwork/articles/java/json-1973242.html
+
+Asks response looks like
+success('8eb2ec31-fd63-43a2-a80b-4552b6d505d7',
+	[q(b)],
+	1.1307000000002065e-5,
+	true)
+	
+	the last item is whether there are more
+	
+then when you get the last one, and it does a destroy (I guess?)
+
+destroy('8eb2ec31-fd63-43a2-a80b-4552b6d505d7',
+	success('8eb2ec31-fd63-43a2-a80b-4552b6d505d7',
+		[q(c)],
+		2.1917999999999244e-5,
+		false))
+		
+		
+	from pengines.pl http_pengine_create/1
+	
+	%   HTTP POST handler  for  =/pengine/create=.   This  API  accepts  the
+%   pengine  creation  parameters  both  as  =application/json=  and  as
+%   =www-form-encoded=.
+
+Looks like event_to_json we want the lang to be json-s maybe? certainly need to look into it.
+For the moment, just json
+
+
+
+
+*/
@@ -28,6 +28,7 @@ of this software and associated documentation files (the "Software"), to deal
  * 
  */
 import java.net.URL;
+import java.util.Iterator;
 
 import javax.json.Json;
 import javax.json.JsonBuilderFactory;
@@ -53,6 +54,11 @@ public final class Pengine {
 	private final PengineBuilder po;
 	@SuppressWarnings("unused")
 	private final String pengineID;
+	private JsonObject availableAnswer = null; // might have several
+	// set to true when the pengine is destroyed
+	// note that we might still have answers held
+	private boolean destroyed = false;
+	private Query currentQuery = null;
 
 	/**
 	 * Create a new pengine object from a set of {@link PengineBuilder}.
@@ -96,6 +102,9 @@ private String create(PengineBuilder po) throws CouldNotCreateException {
 			con.setRequestProperty("Content-type", "application/json");
 
 			String urlParameters = po.getRequestBodyCreate();
+			
+			// TODO think this out away from computer
+			this.currentQuery = po.getAskQuery();
 
 			// Send post request
 			con.setDoOutput(true);
@@ -116,7 +125,7 @@ private String create(PengineBuilder po) throws CouldNotCreateException {
 
 			int responseCode = con.getResponseCode();
 			if(responseCode < 200 || responseCode > 299) {
-				throw new CouldNotCreateException("bad response code" + Integer.toString(responseCode));
+				throw new CouldNotCreateException("bad response code (if 500, query was invalid? query threw Prolog exception?)" + Integer.toString(responseCode));
 			}
 
 			BufferedReader in = new BufferedReader(
@@ -142,72 +151,91 @@ private String create(PengineBuilder po) throws CouldNotCreateException {
 			JsonReader jr = jrf.createReader(new StringReader(response.toString()));
 			JsonObject respObject = jr.readObject();
 
+			// TODO handle answer here
+			if(respObject.containsKey("answer")) {
+				handleAnswer(respObject.getJsonObject("answer"));
+			}
+			
 			JsonString eventjson = (JsonString)respObject.get("event");
 			String evtstr = eventjson.getString();
 
-			if(!evtstr.equals("create")) {
-				throw new CouldNotCreateException("create request returned an event other than create");
+			// TODO store slave_limit and have accessor
+			if(evtstr.equals("destroy")) {
+				this.destroyed = true;
+			} else if(evtstr.equals("create")) {
+				;
+			} else {
+				throw new CouldNotCreateException("create request event was" + evtstr + " must be create or destroy");
 			}
 
 			String id = ((JsonString)respObject.get("id")).getString();
 			return id;
 
 		} catch (IOException e) {
 			throw new CouldNotCreateException(e.toString());
+		} catch(SyntaxErrorException e) {
+			throw new CouldNotCreateException(e.getMessage());
 		}
 	}
 
 	/**
-	 * 
+	 * @param jsonObject
+	 * @throws SyntaxErrorException 
 	 */
-	public void dumpStateDebug() {
-		System.err.println(this.pengineID);
+	private void handleAnswer(JsonObject answer) throws SyntaxErrorException {
+		if(answer.containsKey("event")) {
+			switch( ((JsonString)answer.get("event")).getString()) {
+			case	"success":
+				handleData(answer, true);
+				break;
+			case	"destroy":
+				this.destroyed = true;
+				handleData(answer, true);
+				break;
+			case	"failure":
+				handleData(answer, false);
+			default:
+				throw new SyntaxErrorException("Bad event in answer" + ((JsonString)answer.get("event")).getString());
+			}
+		}
+		/*
+		 * 
+		 * 		          "answer":{
+		             "data":{
+		                   "event":"failure",
+		                   "id":"c7e9e0c5-84b6-4faa-bbcb-1e1139df1206",
+		                   "time":0.000019857999999999985
+		                   },
+		             "event":"destroy",
+		             "id":"c7e9e0c5-84b6-4faa-bbcb-1e1139df1206"
+		         },
+		 */
+		
 	}
-}
-/*
- * This project has involved a lot of experimenting, as hte protocol is poorly documented. As such,
- * I'm retaining my notes here
- */
-// <domain>/<path>/pengine/create
-// application/json
-// see server_url/4, line 1529 of pengines.pl
-/*
-* HTTP/1.1 200 OK
-Server: nginx/1.4.6 (Ubuntu)
-Date: Wed, 20 Apr 2016 20:53:39 GMT
-Content-Type: text/x-prolog; charset=UTF-8
-Content-Length: 65
-Connection: close
-
-http://www.oracle.com/technetwork/articles/java/json-1973242.html
-
-Asks response looks like
-success('8eb2ec31-fd63-43a2-a80b-4552b6d505d7',
-	[q(b)],
-	1.1307000000002065e-5,
-	true)
-	
-	the last item is whether there are more
-	
-then when you get the last one, and it does a destroy (I guess?)
 
-destroy('8eb2ec31-fd63-43a2-a80b-4552b6d505d7',
-	success('8eb2ec31-fd63-43a2-a80b-4552b6d505d7',
-		[q(c)],
-		2.1917999999999244e-5,
-		false))
-		
+	/**
+	 * @param answer
+	 * @param b
+	 */
+	private void handleData(JsonObject answer, boolean b) {
+		// TODO Auto-generated method stub
 
-	from pengines.pl http_pengine_create/1
-	
-	%   HTTP POST handler  for  =/pengine/create=.   This  API  accepts  the
-%   pengine  creation  parameters  both  as  =application/json=  and  as
-%   =www-form-encoded=.
-
-Looks like event_to_json we want the lang to be json-s maybe? certainly need to look into it.
-For the moment, just json
-
-
+	}
 
+	/**
+	 * 
+	 */
+	public void dumpStateDebug() {
+		System.err.println(this.pengineID);
+	}
 
-*/
+	/**
+	 * @param string
+	 * @param string2
+	 * @return
+	 */
+	public Iterator<Proof> ask(String string, String string2) {
+		// TODO Auto-generated method stub
+		return null;
+	}
+}
@@ -4,14 +4,10 @@
 import java.net.URI;
 import java.net.URISyntaxException;
 import java.net.URL;
-import java.util.Map;
 
 import javax.json.Json;
 import javax.json.JsonBuilderFactory;
-import javax.json.JsonObject;
 import javax.json.JsonObjectBuilder;
-import javax.json.JsonValue;
-import javax.json.JsonValue.ValueType;
 
 /*
  * Copyright (c) 2016 Simularity Inc.
@@ -111,6 +107,10 @@ String getRequestBodyCreate() {
 			job.add("srcurl", this.srcurl.toString());
 		}
 
+		// test protocol
+		job.add("ask", "member((X,Y), [(a(taco),3),(b,4),(c,5)])");
+		// job.add("template", "X");
+		
 		// this will be a json object with fields for options
 		// sample, as a prolog dict
 		//_{ src_text:"\n            q(X) :- p(X).\n            p(a). p(b). p(c).\n        "}
 
@@ -0,0 +1,39 @@
+/**
+ * Copyright (c) 2016 Simularity Inc.
+ * 
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.
+ * 
+ */
+package com.simularity.os.javapengine;
+
+/**
+ * @author anniepoo
+ *
+ */
+public class Proof {
+
+	/**
+	 * 
+	 */
+	public Proof() {
+		// TODO Auto-generated constructor stub
+	}
+
+}