Method decodeFromFrames

src/main/java/core/packetproxy/http2/Grpc.java:88–126

(byte[] frames)

	}

	private byte[] decodeFromFrames(byte[] frames) throws Exception {
		ByteArrayOutputStream outHeader = new ByteArrayOutputStream();
		ByteArrayOutputStream outData = new ByteArrayOutputStream();
		Http httpHeaderSums = null;

		for (Frame frame : FrameUtils.parseFrames(frames)) {

			if (frame instanceof HeadersFrame) {

				HeadersFrame headersFrame = (HeadersFrame) frame;
				Http http = Http.create(headersFrame.getHttp());
				if (null == httpHeaderSums) { // Main Header Frame

					httpHeaderSums = http;
				} else { // Trailer Header Frame

					for (HeaderField field : http.getHeader().getFields()) {

						httpHeaderSums.updateHeader("x-trailer-" + field.getName(), field.getValue());
					}
				}
			} else if (frame instanceof DataFrame) {

				DataFrame dataFrame = (DataFrame) frame;
				outData.write(dataFrame.getPayload());
			}
		}
		outHeader.write(httpHeaderSums.toByteArray());
		// 順序をHeader, Dataにする。本当はStreamIDで管理してencode時に元の順番に戻せるようにしたい。
		// 暫定でgRPC over HTTP2のレスポンスの2つめのヘッダは"x-trailer-"から始まるヘッダに従って元の順番に戻す。
		outData.writeTo(outHeader);
		Http http = Http.create(outHeader.toByteArray());
		int flags = Integer.valueOf(http.getFirstHeader("X-PacketProxy-HTTP2-Flags"));
		if (http.getBody() == null || http.getBody().length == 0) {

			http.updateHeader("X-PacketProxy-HTTP2-Flags", String.valueOf(flags & 0xff | HeadersFrame.FLAG_END_STREAM));
		}
		return http.toByteArray();
	}

	@Override
	protected byte[] encodeClientRequestToFrames(byte[] http) throws Exception {