Начал работу над обработкой комментариев

src/main/java/org/sadtech/vkbot/core/distribution/impl/CommentSubscriber.java

@@ -1,13 +1,28 @@
 package org.sadtech.vkbot.core.distribution.impl;
 
+import com.google.gson.Gson;
+import com.google.gson.JsonObject;
+import com.vk.api.sdk.objects.wall.WallComment;
+import org.apache.log4j.Logger;
+import org.sadtech.vkbot.core.distribution.EventDistributable;
 import org.sadtech.vkbot.core.distribution.EventSubscribe;
-import org.sadtech.vkbot.core.entity.Comment;
+import org.sadtech.vkbot.core.service.distribution.CommentService;
 
-public class CommentSubscriber implements EventSubscribe<Comment> {
+public class CommentSubscriber implements EventSubscribe<JsonObject> {
 
+    public static final Logger log = Logger.getLogger(CommentSubscriber.class);
+
+    private CommentService commentService;
+
+    public CommentSubscriber(EventDistributable distributable, CommentService commentService) {
+        distributable.registerSubscriber("wall_reply_new", this);
+        this.commentService = commentService;
+    }
 
     @Override
-    public void update(Comment object) {
+    public void update(JsonObject object) {
-
+        Gson gson = new Gson();
+        WallComment wallComment = gson.fromJson(object, WallComment.class);
+        log.info(wallComment);
     }
 }

src/main/java/org/sadtech/vkbot/core/distribution/impl/MailChatSubscriber.java

@@ -3,7 +3,7 @@ package org.sadtech.vkbot.core.distribution.impl;
 import com.vk.api.sdk.objects.messages.Message;
 import org.sadtech.vkbot.core.distribution.EventDistributable;
 import org.sadtech.vkbot.core.distribution.EventSubscribe;
-import org.sadtech.vkbot.core.service.handlers.MailService;
+import org.sadtech.vkbot.core.service.distribution.MailService;
 
 public class MailChatSubscriber implements EventSubscribe<Message> {
 

src/main/java/org/sadtech/vkbot/core/distribution/impl/MailSubscriber.java

@@ -6,7 +6,7 @@ import com.vk.api.sdk.objects.messages.Message;
 import org.apache.log4j.Logger;
 import org.sadtech.vkbot.core.distribution.EventDistributable;
 import org.sadtech.vkbot.core.distribution.EventSubscribe;
-import org.sadtech.vkbot.core.service.handlers.MailService;
+import org.sadtech.vkbot.core.service.distribution.MailService;
 
 import java.util.HashMap;
 import java.util.HashSet;

src/main/java/org/sadtech/vkbot/core/distribution/impl/TerminalSubscriber.java

@@ -3,7 +3,7 @@ package org.sadtech.vkbot.core.distribution.impl;
 import com.vk.api.sdk.objects.messages.Message;
 import org.apache.log4j.Logger;
 import org.sadtech.vkbot.core.distribution.EventSubscribe;
-import org.sadtech.vkbot.core.service.handlers.MailService;
+import org.sadtech.vkbot.core.service.distribution.MailService;
 
 public class TerminalSubscriber implements EventSubscribe<Message> {
 

src/main/java/org/sadtech/vkbot/core/entity/Comment.java

@@ -1,4 +1,10 @@
 package org.sadtech.vkbot.core.entity;
 
 public class Comment {
+
+    private Integer postId;
+    private Integer fromId;
+    private String text;
+    private Integer data;
+
 }

src/main/java/org/sadtech/vkbot/core/repository/CommentRepository.java

@@ -0,0 +1,9 @@
+package org.sadtech.vkbot.core.repository;
+
+import org.sadtech.vkbot.core.entity.Comment;
+
+public interface CommentRepository {
+
+    void add(Comment comment);
+
+}

src/main/java/org/sadtech/vkbot/core/repository/impl/CommentRepositoryList.java

@@ -0,0 +1,17 @@
+package org.sadtech.vkbot.core.repository.impl;
+
+import org.sadtech.vkbot.core.entity.Comment;
+import org.sadtech.vkbot.core.repository.CommentRepository;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class CommentRepositoryList implements CommentRepository {
+
+    private List<Comment> comments = new ArrayList<>();
+
+    @Override
+    public void add(Comment comment) {
+        comments.add(comment);
+    }
+}

src/main/java/org/sadtech/vkbot/core/service/distribution/CommentService.java

@@ -0,0 +1,10 @@
+package org.sadtech.vkbot.core.service.distribution;
+
+import org.sadtech.vkbot.core.entity.Comment;
+import org.sadtech.vkbot.core.service.distribution.impl.EventService;
+
+public interface CommentService extends EventService<Comment> {
+
+
+
+}

src/main/java/org/sadtech/vkbot/core/service/distribution/MailService.java

@@ -0,0 +1,11 @@
+package org.sadtech.vkbot.core.service.distribution;
+
+import com.vk.api.sdk.objects.messages.Message;
+import org.sadtech.vkbot.core.entity.Mail;
+import org.sadtech.vkbot.core.service.distribution.impl.EventService;
+
+public interface MailService extends EventService<Mail>, SortEventService<Mail> {
+
+    void add(Message message);
+
+}

src/main/java/org/sadtech/vkbot/core/service/distribution/SortEventService.java

@@ -1,4 +1,4 @@
-package org.sadtech.vkbot.core.service.handlers;
+package org.sadtech.vkbot.core.service.distribution;
 
 import java.util.List;
 

src/main/java/org/sadtech/vkbot/core/service/distribution/impl/CommentServiceImpl.java

@@ -0,0 +1,19 @@
+package org.sadtech.vkbot.core.service.distribution.impl;
+
+import org.sadtech.vkbot.core.entity.Comment;
+import org.sadtech.vkbot.core.repository.CommentRepository;
+import org.sadtech.vkbot.core.service.distribution.CommentService;
+
+public class CommentServiceImpl implements CommentService {
+
+    private CommentRepository commentRepository;
+
+    public CommentServiceImpl(CommentRepository commentRepository) {
+        this.commentRepository = commentRepository;
+    }
+
+    @Override
+    public void add(Comment comment) {
+        commentRepository.add(comment);
+    }
+}

src/main/java/org/sadtech/vkbot/core/service/distribution/impl/EventService.java

@@ -0,0 +1,7 @@
+package org.sadtech.vkbot.core.service.distribution.impl;
+
+public interface EventService<T> {
+
+    void add(T event);
+
+}

src/main/java/org/sadtech/vkbot/core/service/distribution/impl/MailServiceImpl.java

@@ -1,4 +1,4 @@
-package org.sadtech.vkbot.core.service.handlers.impl;
+package org.sadtech.vkbot.core.service.distribution.impl;
 
 import com.vk.api.sdk.objects.messages.Message;
 import org.apache.log4j.Logger;
@@ -7,7 +7,7 @@ import org.sadtech.vkbot.core.entity.Person;
 import org.sadtech.vkbot.core.repository.MailRepository;
 import org.sadtech.vkbot.core.repository.impl.MailRepositoryList;
 import org.sadtech.vkbot.core.service.PersonService;
-import org.sadtech.vkbot.core.service.handlers.MailService;
+import org.sadtech.vkbot.core.service.distribution.MailService;
 
 import java.util.ArrayList;
 import java.util.HashSet;

src/main/java/org/sadtech/vkbot/core/service/handlers/MailService.java

@@ -1,12 +0,0 @@
-package org.sadtech.vkbot.core.service.handlers;
-
-import com.vk.api.sdk.objects.messages.Message;
-import org.sadtech.vkbot.core.entity.Mail;
-
-public interface MailService extends SortEventService<Mail> {
-
-    void add(Mail mail);
-
-    void add(Message message);
-
-}