Method onChunkReceived

src/main/java/core/packetproxy/ProxyHttp.java:66–177

(byte[] data)

					}

					@Override
					public byte[] onChunkReceived(byte[] data) throws Exception {
						byte[] result = new byte[]{};
						synchronized (client_loopback) {

							Http http = Http.create(data);
							// System.out.println(String.format("%s: %s:%s", http.getMethod(),
							// http.getServerName(), http.getServerPort()));

							if (http.getMethod().equals("CONNECT")) {

								// HTTP2対応の都合上、ALPNを早期に確定する必要がある。
								// そのため、早めに「connection established」を返すことで、早めにSSLハンドシェイクを実施できるよう準備する。
								client_loopback
										.sendWithoutRecording("HTTP/1.0 200 Connection Established\r\n\r\n".getBytes());

								String serverName = http.getServerName();
								if (serverName.matches("\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}\\.\\d{1,3}")) {

									serverName = Https.getCommonName(http.getServerAddr());
									log("Overwrite CN: %s --> %s", http.getServerName(), serverName);
								}

								if (SSLPassThroughs.getInstance().includes(serverName, listen_info.getPort())) {

									SocketEndpoint server_e = new SocketEndpoint(http.getServerAddr());
									SocketEndpoint client_e = new SocketEndpoint(client);
									DuplexAsync d = new DuplexAsync(client_e, server_e);
									d.start();

								} else {

									SSLSocketEndpoint clientE;
									SSLSocketEndpoint serverE;
									if (listen_info.getServer() != null) { // upstream proxyに接続する時

										SSLSocketEndpoint[] es = EndpointFactory.createBothSideSSLEndpoints(client,
												null, http.getServerAddr(), listen_info.getServer().getAddress(),
												http.getServerName(), listen_info.getCA().get());
										clientE = es[0];
										serverE = es[1];
									} else { // 直接サーバに接続する時

										SSLSocketEndpoint[] es = EndpointFactory.createBothSideSSLEndpoints(client,
												null, http.getServerAddr(), null, http.getServerName(),
												listen_info.getCA().get());
										clientE = es[0];
										serverE = es[1];
									}
									String ALPN = clientE.getApplicationProtocol();
									if (ALPN == null || ALPN.length() == 0) {

										/* The client does not support ALPN. It seems to be an old HTTP client */
										ALPN = "http/1.1";
									}
									Server serverSetting = Servers.getInstance().queryByAddress(http.getServerAddr());
									String encoderName = (serverSetting != null) ? serverSetting.getEncoder() : "HTTP";
									DuplexAsync d = DuplexFactory.createDuplexAsync(clientE, serverE, encoderName,