in proxy/kms/src/main/java/com/amazon/aws/pix/kms/proxy/service/Logger.java [35:55]
public void log(APIGatewayProxyRequestEvent request, APIGatewayProxyResponseEvent response) {
AuditLog auditLog = new AuditLog();
auditLog.setRequestMethod(request.getHttpMethod());
auditLog.setRequestPath(request.getPath());
auditLog.setRequestBody(request.getBody());
auditLog.setRequestHeader(flatList(request.getMultiValueHeaders()));
auditLog.setResponseStatusCode(response.getStatusCode());
auditLog.setResponseSignatureValid(isSignatureValid(response));
auditLog.setResponseBody(response.getBody());
auditLog.setResponseHeader(response.getHeaders());
PutRecordRequest putRecordRequest = PutRecordRequest.builder()
.deliveryStreamName(streamName)
.record(builder -> builder.data(SdkBytes.fromUtf8String(auditLog.toJson())))
.build();
firehoseClient.putRecord(putRecordRequest);
}