1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
/*
* ============LICENSE_START==========================================
* ONAP Portal SDK
* ===================================================================
* Copyright © 2017 AT&T Intellectual Property. All rights reserved.
* ===================================================================
*
* Unless otherwise specified, all software contained herein is licensed
* under the Apache License, Version 2.0 (the "License");
* you may not use this software except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* Unless otherwise specified, all documentation contained herein is licensed
* under the Creative Commons License, Attribution 4.0 Intl. (the "License");
* you may not use this documentation except in compliance with the License.
* You may obtain a copy of the License at
*
* https://creativecommons.org/licenses/by/4.0/
*
* Unless required by applicable law or agreed to in writing, documentation
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* ============LICENSE_END============================================
*
*
*/
package org.onap.portalsdk.core.logging.aspect;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.onap.portalsdk.core.util.SystemProperties.SecurityEventTypeEnum;
@Aspect
@org.springframework.context.annotation.Configuration
public class EELFLoggerAspect {
@Autowired
private EELFLoggerAdvice advice;
/*
* Point-cut expression to handle all INCOMING_REST_MESSAGES
*/
@Pointcut("execution(public * org.onap.portalsdk.core.controller.*.*(..))")
public void incomingAuditMessages() {
// Nothing is logged on incoming message
}
@Around("incomingAuditMessages() && @annotation(auditLog)")
public Object logAuditMethodAround(ProceedingJoinPoint joinPoint, AuditLog auditLog) throws Throwable {
return this.logAroundMethod(joinPoint, SecurityEventTypeEnum.INCOMING_REST_MESSAGE);
}
@Around("incomingAuditMessages() && @within(auditLog)")
public Object logAuditMethodClassAround(ProceedingJoinPoint joinPoint, AuditLog auditLog) throws Throwable {
return this.logAroundMethod(joinPoint, SecurityEventTypeEnum.INCOMING_REST_MESSAGE);
}
/*
* Point cut expression to capture metrics logging
*/
@Pointcut("execution(public * *(..))")
public void publicMethod() {
// By default do nothing
}
@Around("publicMethod() && @within(metricsLog)")
public Object logMetricsClassAround(ProceedingJoinPoint joinPoint, MetricsLog metricsLog) throws Throwable {
return this.logAroundMethod(joinPoint, null);
}
@Around("publicMethod() && @annotation(metricsLog)")
public Object logMetricsMethodAround(ProceedingJoinPoint joinPoint, MetricsLog metricsLog) throws Throwable {
return this.logAroundMethod(joinPoint, null);
}
private Object logAroundMethod(ProceedingJoinPoint joinPoint, SecurityEventTypeEnum securityEventType)
throws Throwable {
// Before
Object[] passOnArgs = new Object[] { joinPoint.getSignature().getDeclaringType().getName(),
joinPoint.getSignature().getName() };
Object[] returnArgs = advice.before(securityEventType, joinPoint.getArgs(), passOnArgs);
// Execute the actual method
Object result = null;
String restStatus = "COMPLETE";
try {
result = joinPoint.proceed();
} catch (Exception e) {
restStatus = "ERROR";
}
// After
advice.after(securityEventType, restStatus, joinPoint.getArgs(), returnArgs, passOnArgs);
return result;
}
//Metrics Logging
@Pointcut("execution(* *(..))")
public void performMetricsLogging() {}
@Around("performMetricsLogging() && @within(MetricsLog)")
public Object metricsLoggingAroundClass(ProceedingJoinPoint joinPoint, MetricsLog MetricsLog) throws Throwable {
return this.logAroundMethod(joinPoint, null);
}
@Around("performMetricsLogging() && @annotation(MetricsLog)")
public Object metricsLoggingAroundMethod(ProceedingJoinPoint joinPoint, MetricsLog MetricsLog) throws Throwable {
return this.logAroundMethod(joinPoint, null);
}
}
|
