Skip to content

Commit 24f47d7

Browse files
author
Thomas
committed
Add exception handler to event publisher
1 parent 1713475 commit 24f47d7

File tree

1 file changed

+4
-1
lines changed
  • server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/framework/filter

1 file changed

+4
-1
lines changed

server/api-service/lowcoder-server/src/main/java/org/lowcoder/api/framework/filter/ApiEventFilter.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import reactor.core.scheduler.Schedulers;
2020

2121
import java.nio.charset.StandardCharsets;
22+
import java.util.Optional;
2223

2324
import static org.lowcoder.sdk.constants.GlobalContext.CURRENT_ORG_MEMBER;
2425
import static org.lowcoder.sdk.constants.GlobalContext.VISITOR_TOKEN;
@@ -53,7 +54,9 @@ public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
5354
private void emitEvent(ServerHttpRequest request, String token, OrgMember orgMember) {
5455
MultiValueMap<String, String> headers = writableHttpHeaders(request.getHeaders());
5556
headers.remove("Cookie");
56-
String ipAddress = headers.remove("X-Real-IP").stream().findFirst().get();
57+
String ipAddress = "n/a";
58+
Optional<String> optionalIpAddress = headers.remove("X-Real-IP").stream().findFirst();
59+
if(optionalIpAddress.isPresent()) ipAddress = optionalIpAddress.get();
5760

5861
APICallEvent event = APICallEvent.builder()
5962
.userId(orgMember.getUserId())

0 commit comments

Comments
 (0)