Protei/PromucFlow_constructor
2
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

chore: Add data points for debugging event log (#18404)

Browse Source
This commit is contained in:
Anagh Hegde 2022-11-23 23:06:37 +05:30 committed by GitHub
parent 30023b7a9c
commit bae241461c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/AnalyticsServiceCEImpl.java
View File

@ -17,6 +17,7 @@ import com.segment.analytics.messages.TrackMessage;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers;
@ -24,6 +25,7 @@ import reactor.core.scheduler.Schedulers;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@Slf4j
public class AnalyticsServiceCEImpl implements AnalyticsServiceCE {
@ -127,6 +129,12 @@ public class AnalyticsServiceCEImpl implements AnalyticsServiceCE {
// at java.base/java.util.ImmutableCollections$AbstractImmutableMap.put(ImmutableCollections.java)
Map<String, Object> analyticsProperties = properties == null ? new HashMap<>() : new HashMap<>(properties);
// To debug the issue with userId empty error from segment
// TODO remove the code block once the issue is fixed
if (StringUtils.isEmpty(userId)) {
log.error(" UserId is null or empty. event Name is {}, analyticProperties is {}, hashUserId is {}", String.valueOf(userId), event, convertWithStream(properties), hashUserId);
}
// Hash usernames at all places for self-hosted instance
if (userId != null
&& hashUserId
@ -260,4 +268,11 @@ public class AnalyticsServiceCEImpl implements AnalyticsServiceCE {
public <T extends BaseDomain> Mono<T> sendDeleteEvent(T object) {
return sendDeleteEvent(object, null);
}
public String convertWithStream(Map<String, ?> map) {
String mapAsString = map.keySet().stream()
.map(key -> key + "=" + map.get(key))
.collect(Collectors.joining(", ", "{", "}"));
return mapAsString;
}
}