public void log()

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);
    }