/*
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
*/
|
package com.megatim.fdxcommons.core.impl.interceptor;
|
|
import com.megatim.fdxcommons.core.ifaces.interceptor.BeforeAction;
|
import com.megatim.fdxcommons.core.ifaces.interceptor.LoggingInterceptorBinding;
|
import java.io.BufferedReader;
|
import java.io.ByteArrayInputStream;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.lang.reflect.Method;
|
import java.util.stream.Collectors;
|
import javax.enterprise.context.Dependent;
|
import javax.ws.rs.container.ContainerRequestContext;
|
import javax.ws.rs.container.ResourceInfo;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Dependent
|
public class BeforeActionImpl implements BeforeAction {
|
|
@Override
|
public void filter(ContainerRequestContext crc, ResourceInfo resourceInfo) {
|
Method method = resourceInfo.getResourceMethod();
|
LoggingInterceptorBinding ann = method.getAnnotation(LoggingInterceptorBinding.class);
|
|
if (crc.hasEntity() && ann != null && ann.shouldCopyData()) {
|
InputStream inputStream = crc.getEntityStream();
|
String body = new BufferedReader(new InputStreamReader(inputStream))
|
.lines().collect(Collectors.joining("\n"));
|
|
crc.setProperty("entity", body);
|
|
// Replace the original input stream with a new one after reading it
|
crc.setEntityStream(new ByteArrayInputStream(body.getBytes()));
|
}
|
}
|
}
|
