Skip to content

Commit ff3efb2

Browse files
ashuklafispanashuklafispan
committed
Repository setup
0 parents  commit ff3efb2

File tree

9 files changed

+1682
-0
lines changed

9 files changed

+1682
-0
lines changed

‎.editorconfig

Lines changed: 1162 additions & 0 deletions
Large diffs are not rendered by default.

‎.gitignore

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
.idea
2+
*.iml
3+
target

‎aws/iam_access_policy.json

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
{
2+
"Version": "2012-10-17",
3+
"Statement": [
4+
{
5+
"Sid": "VisualEditor0",
6+
"Effect": "Allow",
7+
"Action": [
8+
"sqs:GetQueueUrl",
9+
"sqs:SendMessage",
10+
"sqs:CreateQueue"
11+
],
12+
"Resource": "arn:aws:sqs:us-east-1:717292077848:aal_api_invocation_queue"
13+
}
14+
]
15+
}

‎pom.xml

Lines changed: 114 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,114 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
3+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<modelVersion>4.0.0</modelVersion>
6+
7+
<groupId>com.actigence</groupId>
8+
<artifactId>api-access-logger-client</artifactId>
9+
<version>0.0.1-SNAPSHOT</version>
10+
11+
<build>
12+
<plugins>
13+
<plugin>
14+
<groupId>org.apache.maven.plugins</groupId>
15+
<artifactId>maven-compiler-plugin</artifactId>
16+
<configuration>
17+
<source>8</source>
18+
<target>8</target>
19+
</configuration>
20+
</plugin>
21+
</plugins>
22+
</build>
23+
24+
<name>api-access-logger-client</name>
25+
<url>http://www.example.com</url>
26+
27+
<properties>
28+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
29+
<maven.compiler.source>1.7</maven.compiler.source>
30+
<maven.compiler.target>1.7</maven.compiler.target>
31+
<spring.version>5.2.6.RELEASE</spring.version>
32+
<log4j.version>2.13.2</log4j.version>
33+
<gson.version>2.8.6</gson.version>
34+
</properties>
35+
36+
<dependencyManagement>
37+
<dependencies>
38+
<dependency>
39+
<groupId>com.amazonaws</groupId>
40+
<artifactId>aws-java-sdk-bom</artifactId>
41+
<version>1.11.771</version>
42+
<type>pom</type>
43+
<scope>import</scope>
44+
</dependency>
45+
</dependencies>
46+
</dependencyManagement>
47+
48+
<dependencies>
49+
<!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
50+
<dependency>
51+
<groupId>org.projectlombok</groupId>
52+
<artifactId>lombok</artifactId>
53+
<version>1.18.12</version>
54+
<scope>provided</scope>
55+
</dependency>
56+
57+
<!-- https://mvnrepository.com/artifact/javax.servlet/javax.servlet-api -->
58+
<dependency>
59+
<groupId>javax.servlet</groupId>
60+
<artifactId>javax.servlet-api</artifactId>
61+
<version>4.0.1</version>
62+
<scope>provided</scope>
63+
</dependency>
64+
65+
<!-- https://mvnrepository.com/artifact/org.springframework/spring-core -->
66+
<dependency>
67+
<groupId>org.springframework</groupId>
68+
<artifactId>spring-core</artifactId>
69+
<version>${spring.version}</version>
70+
</dependency>
71+
72+
<!-- https://mvnrepository.com/artifact/org.springframework/spring-context -->
73+
<dependency>
74+
<groupId>org.springframework</groupId>
75+
<artifactId>spring-context</artifactId>
76+
<version>${spring.version}</version>
77+
</dependency>
78+
79+
<dependency>
80+
<groupId>org.apache.logging.log4j</groupId>
81+
<artifactId>log4j-api</artifactId>
82+
<version>${log4j.version}</version>
83+
</dependency>
84+
<dependency>
85+
<groupId>org.apache.logging.log4j</groupId>
86+
<artifactId>log4j-core</artifactId>
87+
<version>${log4j.version}</version>
88+
</dependency>
89+
<dependency>
90+
<groupId>org.apache.logging.log4j</groupId>
91+
<artifactId>log4j-slf4j-impl</artifactId>
92+
<version>${log4j.version}</version>
93+
</dependency>
94+
95+
<!-- https://mvnrepository.com/artifact/com.google.code.gson/gson -->
96+
<dependency>
97+
<groupId>com.google.code.gson</groupId>
98+
<artifactId>gson</artifactId>
99+
<version>${gson.version}</version>
100+
</dependency>
101+
102+
<dependency>
103+
<groupId>com.amazonaws</groupId>
104+
<artifactId>aws-java-sdk-sqs</artifactId>
105+
</dependency>
106+
107+
<dependency>
108+
<groupId>junit</groupId>
109+
<artifactId>junit</artifactId>
110+
<version>4.11</version>
111+
<scope>test</scope>
112+
</dependency>
113+
</dependencies>
114+
</project>

‎src/main/java/com/actigence/aal/ApiAccessLoggingFilter.java

Lines changed: 71 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,71 @@
1+
package com.actigence.aal;
2+
3+
import com.actigence.aal.aws.SQSClient;
4+
import com.actigence.aal.dto.ApiAccessLog;
5+
import lombok.extern.slf4j.Slf4j;
6+
7+
import javax.servlet.*;
8+
import javax.servlet.http.HttpServletRequest;
9+
import javax.servlet.http.HttpServletResponse;
10+
import java.io.IOException;
11+
12+
@Slf4j
13+
public class ApiAccessLoggingFilter implements Filter
14+
{
15+
private final SQSClient sqsClient;
16+
17+
public ApiAccessLoggingFilter()
18+
{
19+
sqsClient = new SQSClient();
20+
}
21+
22+
public ApiAccessLoggingFilter(SQSClient sqsClient)
23+
{
24+
this.sqsClient = sqsClient;
25+
}
26+
27+
@Override
28+
public void doFilter(ServletRequest request, ServletResponse response, FilterChain filterChain) throws IOException, ServletException
29+
{
30+
HttpRequestCachingWrapper requestWrapper = new HttpRequestCachingWrapper((HttpServletRequest) request);
31+
HttpResponseCachingWrapper responseWrapper = new HttpResponseCachingWrapper((HttpServletResponse) response);
32+
try
33+
{
34+
filterChain.doFilter(requestWrapper, responseWrapper);
35+
response.getOutputStream().write(responseWrapper.getBytes());
36+
}
37+
finally
38+
{
39+
generateEvent(requestWrapper, responseWrapper);
40+
}
41+
}
42+
43+
private void generateEvent(HttpRequestCachingWrapper requestCachingWrapper, HttpResponseCachingWrapper responseWrapper)
44+
{
45+
try
46+
{
47+
ApiAccessLog apiInvocationEvent = ApiAccessLog.builder()
48+
.requestBody(requestCachingWrapper.getBody())
49+
.responseBody(new String(responseWrapper.getBytes()))
50+
.responseHttpStatus(responseWrapper.getStatusCode())
51+
.build();
52+
sqsClient.publish(apiInvocationEvent);
53+
}
54+
catch (Exception e)
55+
{
56+
e.printStackTrace();
57+
}
58+
}
59+
60+
@Override
61+
public void init(FilterConfig filterConfig)
62+
{
63+
// Do nothing
64+
}
65+
66+
@Override
67+
public void destroy()
68+
{
69+
// Do nothing
70+
}
71+
}

‎src/main/java/com/actigence/aal/HttpRequestCachingWrapper.java

Lines changed: 99 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,99 @@
1+
package com.actigence.aal;
2+
3+
import lombok.extern.slf4j.Slf4j;
4+
5+
import javax.servlet.ReadListener;
6+
import javax.servlet.ServletInputStream;
7+
import javax.servlet.http.HttpServletRequest;
8+
import javax.servlet.http.HttpServletRequestWrapper;
9+
import java.io.BufferedReader;
10+
import java.io.ByteArrayInputStream;
11+
import java.io.IOException;
12+
import java.io.InputStream;
13+
import java.io.InputStreamReader;
14+
15+
@Slf4j
16+
public class HttpRequestCachingWrapper extends HttpServletRequestWrapper
17+
{
18+
private final String body;
19+
20+
public HttpRequestCachingWrapper(HttpServletRequest httpServletRequest) throws IOException
21+
{
22+
super(httpServletRequest);
23+
StringBuilder stringBuilder = new StringBuilder();
24+
BufferedReader bufferedReader = null;
25+
try
26+
{
27+
InputStream inputStream = httpServletRequest.getInputStream();
28+
if (inputStream != null)
29+
{
30+
bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
31+
char[] charBuffer = new char[128];
32+
int bytesRead = bufferedReader.read(charBuffer);
33+
while (bytesRead > 0)
34+
{
35+
stringBuilder.append(charBuffer, 0, bytesRead);
36+
bytesRead = bufferedReader.read(charBuffer);
37+
}
38+
}
39+
}
40+
finally
41+
{
42+
if (bufferedReader != null)
43+
{
44+
try
45+
{
46+
bufferedReader.close();
47+
}
48+
catch (IOException ignored)
49+
{
50+
}
51+
}
52+
}
53+
54+
body = stringBuilder.toString();
55+
}
56+
57+
@Override
58+
public BufferedReader getReader()
59+
{
60+
return new BufferedReader(new InputStreamReader(this.getInputStream()));
61+
}
62+
63+
public ServletInputStream getInputStream()
64+
{
65+
final ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(body.getBytes());
66+
67+
return new ServletInputStream()
68+
{
69+
@Override
70+
public boolean isFinished()
71+
{
72+
return false;
73+
}
74+
75+
@Override
76+
public boolean isReady()
77+
{
78+
return false;
79+
}
80+
81+
@Override
82+
public void setReadListener(ReadListener listener)
83+
{
84+
85+
}
86+
87+
@Override
88+
public int read()
89+
{
90+
return byteArrayInputStream.read();
91+
}
92+
};
93+
}
94+
95+
public String getBody()
96+
{
97+
return body;
98+
}
99+
}

0 commit comments

Comments
 (0)