Added feat to increment the like metaData in community (#51) (#52)

* Added feat for like metaData * Added feat to increment the like metaData in community Co-authored-by: ruksana2808 <[email protected]>
KB-iGOT · Feb 28, 2025 · d733781 · d733781
1 parent 0d2c496
commit d733781
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/src/main/java/com/igot/cb/discussion/service/impl/DiscussionServiceImpl.java b/src/main/java/com/igot/cb/discussion/service/impl/DiscussionServiceImpl.java
@@ -85,6 +85,9 @@ public class DiscussionServiceImpl implements DiscussionService {
     @Value("${kafka.topic.community.discusion.post.count}")
     private String communityPostCount;
 
+    @Value("${kafka.topic.community.discusion.like.count}")
+    private String communityLikeCount;
+
     @PostConstruct
     public void init() {
         if (storageService == null) {
@@ -462,6 +465,12 @@ private ApiResponse vote(String discussionId, String token, String voteType) {
                 }
                 if (voteType.equals(Constants.UP)) {
                     discussionData.put(Constants.UP_VOTE_COUNT, existingUpVoteCount + 1);
+                    Map<String, String> communityObject = new HashMap<>();
+                    communityObject.put(Constants.COMMUNITY_ID,
+                         discussionDbData.getData().get(Constants.COMMUNITY_ID).asText());
+                    communityObject.put(Constants.STATUS, Constants.INCREMENT);
+                    communityObject.put(Constants.DISCUSSION_ID, discussionId);
+                    producer.push(communityLikeCount, communityObject);
                 } else {
                     discussionData.put(Constants.DOWN_VOTE_COUNT, existingDownVoteCount + 1);
                 }

diff --git a/src/main/resources/application.properties b/src/main/resources/application.properties
@@ -55,6 +55,8 @@ discussion.container.name=igot
 accesstoken.publickey.basepath=
 kafka.topic.community.discusion.post.count.group=dev.community.discusion.post.count.group
 kafka.topic.community.discusion.post.count=dev.community.discusion.post.count
+kafka.topic.community.discusion.like.count.group=dev.community.discusion.like.count.group
+kafka.topic.community.discusion.like.count=dev.community.discusion.like.count
 report.post.user.limit=5
 discussion.es.defaultPageSize=10
 discussion.feed.redis.ttl=3600