From 9662947a2c9b4ff7b592e5ecb15e6a4e135165ff Mon Sep 17 00:00:00 2001
From: joshua bauer <josh@wurrly.com>
Date: Thu, 2 Aug 2018 01:06:35 -0700
Subject: [PATCH] Cleanup error handling for byte handling.

---
 .../proteus/server/ServerRequest.java         | 82 ++-----------------
 1 file changed, 6 insertions(+), 76 deletions(-)

diff --git a/src/main/java/io/sinistral/proteus/server/ServerRequest.java b/src/main/java/io/sinistral/proteus/server/ServerRequest.java
index 2bfe032..b4091d8 100644
--- a/src/main/java/io/sinistral/proteus/server/ServerRequest.java
+++ b/src/main/java/io/sinistral/proteus/server/ServerRequest.java
@@ -18,6 +18,7 @@
 import io.sinistral.proteus.server.predicates.ServerPredicates;
 import io.undertow.io.Receiver;
 import io.undertow.security.api.SecurityContext;
+import io.undertow.server.DefaultResponseListener;
 import io.undertow.server.HttpServerExchange;
 import io.undertow.server.handlers.form.FormData;
 import io.undertow.server.handlers.form.FormDataParser;
@@ -34,19 +35,17 @@
  */
 public class ServerRequest
 {    
-    private static final LinkedBlockingDeque<IOException> EXCEPTIONS = new LinkedBlockingDeque<>();
-
-	 public static final Receiver.ErrorCallback ERROR_CALLBACK = new Receiver.ErrorCallback() {
+	 protected static final Receiver.ErrorCallback ERROR_CALLBACK = new Receiver.ErrorCallback() {
 	        @Override
 	        public void error(HttpServerExchange exchange, IOException e) {
-	            EXCEPTIONS.add(e);
+	            
+				exchange.putAttachment(DefaultResponseListener.EXCEPTION, e);
+
 	            exchange.endExchange();
 	        }
 	    };
 	    
     public static final AttachmentKey<ByteBuffer> BYTE_BUFFER_KEY = AttachmentKey.create(ByteBuffer.class);
- 
-    private static Logger log = LoggerFactory.getLogger(ServerRequest.class.getCanonicalName());
 
 	protected static final String CHARSET = "UTF-8";
 	protected static final String TMP_DIR = System.getProperty("java.io.tmpdir");
@@ -157,10 +156,7 @@ public SecurityContext getSecurityContext()
 	
 	private void extractBytes() throws IOException
 	{  
-		 log.debug("start extracting bytes!");
-		 
-			//this.exchange.startBlocking();
-			
+
 			this.exchange.getRequestReceiver().receiveFullBytes(new Receiver.FullBytesCallback() {
                 @Override
                 public void handle(HttpServerExchange exchange, byte[] message) {
@@ -172,72 +168,6 @@ public void handle(HttpServerExchange exchange, byte[] message) {
                 }
             }, ERROR_CALLBACK);
 			
-			
-//			long contentLength;
-//		    final ByteArrayOutputStream sb;
-//		        
-//	        String contentLengthString = exchange.getRequestHeaders().getFirst(Headers.CONTENT_LENGTH);
-//
-//	        if (contentLengthString != null) {
-//	            contentLength = Long.parseLong(contentLengthString);
-//	            sb = new ByteArrayOutputStream((int) contentLength);
-//	        }
-//	        else {
-//	            contentLength = -1;
-//	            sb = new ByteArrayOutputStream();
-//	        }
-//	        
-//	        int s;
-//	        
-//            final InputStream is = this.exchange.getInputStream();
-//
-//	        try (PooledByteBuffer pooled = exchange.getConnection().getByteBufferPool().getArrayBackedPool().allocate()) {
-//	            while ((s = is.read(pooled.getBuffer().array(), pooled.getBuffer().arrayOffset(), pooled.getBuffer().remaining())) > 0) {
-//	                sb.write(pooled.getBuffer().array(), pooled.getBuffer().arrayOffset(), s);
-//	            }
-//	        }
-//	        
-//	        ByteBuffer buffer = ByteBuffer.wrap(sb.toByteArray());
-//	        
-//	        exchange.putAttachment(BYTE_BUFFER_KEY, buffer);
-	        
-//			 try (PooledByteBuffer pooled = exchange.getConnection().getByteBufferPool().getArrayBackedPool().allocate()){
-//	                ByteBuffer buf = pooled.getBuffer();
-//	                 
-//	                log.debug("buf: " + buf);
-//	                
-//                    final StreamSourceChannel channel = this.exchange.getRequestChannel(); 
-//                  
-//	                while (true) {
-//	                	 
-//	                	buf.clear();
-//	                	
-// 	                    int c = channel.read(buf); 
-// 	                      
-//	                    if (c == -1) {
-//	                      
-//	                    	int pos = buf.limit();
-//	                    	
-//	 	                    ByteBuffer buffer = ByteBuffer.allocate(pos);
-//
-//	                    	System.arraycopy(buf.array(), 0, buffer.array(), 0, pos);
-//	                    	
-//	                    	buffer.rewind();
-//	                    	
-//	                    	log.debug("buffer " + buffer + "\n" + new String(buffer.array()));
-//	                    	
-//	    	                exchange.putAttachment(BYTE_BUFFER_KEY, buffer);
-//	    	                
-//	    	                break;
-//	    	                
-//	                    } else if (c != 0) {
-//	                        buf.limit(c);
-//	                    }
-//	                }
-// 	            } catch (MalformedMessageException e) {
-//	                throw new IOException(e);
-//	            } 
- 		
 	}
 
 	private void parseMultipartForm() throws IOException