Method encodeToFrames

src/main/java/core/packetproxy/http2/Grpc.java:138–197

(byte[] data, HpackEncoder encoder)

	}

	private byte[] encodeToFrames(byte[] data, HpackEncoder encoder) throws Exception {
		ByteArrayOutputStream out = new ByteArrayOutputStream();
		Http http = Http.create(data);
		int flags = Integer.valueOf(http.getFirstHeader("X-PacketProxy-HTTP2-Flags"));
		HttpFields.Mutable GRPC2ndHeaderHttpFields = HttpFields.build();

		List<String> unusedHeaders = new ArrayList<>();
		for (HeaderField field : http.getHeader().getFields()) {

			if (field.getName().startsWith("x-trailer-")) {

				unusedHeaders.add(field.getName());
				GRPC2ndHeaderHttpFields.add(field.getName().substring(10), field.getValue());
			}
		}

		for (String name : unusedHeaders) {

			http.removeHeader(name);
		}
		boolean has_second_frame = (http.getBody() != null && http.getBody().length > 0)
				|| GRPC2ndHeaderHttpFields.size() > 0;

		int first_flags = flags & 0xff | HeadersFrame.FLAG_END_STREAM;
		if (has_second_frame) {

			first_flags = flags & 0xff & ~HeadersFrame.FLAG_END_STREAM;
		}
		http.updateHeader("X-PacketProxy-HTTP2-Flags", String.valueOf(first_flags));

		HeadersFrame headersFrame = new HeadersFrame(http);
		out.write(headersFrame.toByteArrayWithoutExtra(encoder));

		if (http.getBody() != null && http.getBody().length > 0) {

			DataFrame dataFrame = new DataFrame(http);
			if (GRPC2ndHeaderHttpFields.size() > 0) {

				dataFrame.setFlags(dataFrame.getFlags() & 0xff & ~DataFrame.FLAG_END_STREAM);
			}
			out.write(dataFrame.toByteArrayWithoutExtra());
		}

		if (GRPC2ndHeaderHttpFields.size() > 0) {

			Http althttp = http;
			althttp.setBody(new byte[0]);
			althttp.removeMatches("^(?!X-PacketProxy-HTTP2).*$");

			for (HttpField headerField : GRPC2ndHeaderHttpFields) {

				althttp.updateHeader(headerField.getName(), headerField.getValue());
			}
			althttp.updateHeader("X-PacketProxy-HTTP2-Flags",
					String.valueOf(flags & 0xff | HeadersFrame.FLAG_END_STREAM));
			HeadersFrame headers2ndFrame = new HeadersFrame(althttp);
			out.write(headers2ndFrame.toByteArrayWithoutExtra(encoder));
		}